[backend] Checker: add read_packstatus method

This allows us to cache the packstatus in the future.
openSUSE · Mar 14, 2023 · 7679699 · 7679699
1 parent 054096e
commit 7679699
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 0 deletions.
diff --git a/src/backend/BSRepServer/Checker.pm b/src/backend/BSRepServer/Checker.pm
@@ -280,6 +280,11 @@ sub read_gbininfo {
   return BSRepServer::read_gbininfo("$reporoot/$prp/$arch");
 }
 
+sub read_packstatus {
+  my ($ctx, $prp, $arch) = @_;
+  return {};
+}
+
 sub writejob {
   my ($ctx, $job, $binfo, $reason) = @_;
   $ctx = $ctx->{'realctx'} if $ctx->{'realctx'};

diff --git a/src/backend/BSSched/Checker.pm b/src/backend/BSSched/Checker.pm
@@ -1499,7 +1499,9 @@ sub addrepo {
   my ($projid, $repoid) = split('/', $prp, 2);
   my $remoteprojs = $gctx->{'remoteprojs'};
   if ($remoteprojs->{$projid}) {
+    return 0 if ($ctx->{'addrepo_remote_inprogress'} || {})->{"$prp/$arch"};	
     $r = BSSched::Remote::addrepo_remote($ctx, $pool, $prp, $arch, $remoteprojs->{$projid});
+    $ctx->{'addrepo_remote_inprogress'}->{"$prp/$arch"} = 1 if !$r && defined($r);
   } elsif ($arch ne $gctx->{'arch'}) {
     my $alien_cache = $ctx->{'alien_repo_cache'};
     $alien_cache = $ctx->{'alien_repo_cache'} = {} unless $alien_cache;
@@ -1561,6 +1563,19 @@ sub rebuild_gbininfo {
   BSSched::BuildResult::rebuild_gbininfo($dir);
 }
 
+sub read_packstatus {
+  my ($ctx, $prp, $arch) = @_;
+  my $reporoot = $ctx->{'gctx'}->{'reporoot'};
+  return {} unless -e "$reporoot/$prp/$arch/:packstatus";
+  my $ps = BSUtil::retrieve("$reporoot/$prp/$arch/:packstatus", 1);
+  if (!$ps) {
+    # compat with very old obs versions
+    $ps = (readxml("$reporoot/$prp/$arch/:packstatus", $BSXML::packstatuslist, 1) || {})->{'packstatus'} || [];
+    return { map {$_->{'name'} => $_->{'status'}} @$ps };
+  }
+  return ($ps || {})->{'packstatus'} || {};
+}
+
 sub writejob {
   return BSSched::BuildJob::writejob(@_);
 }