From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.6 (2021-04-09) on dcvr.yhbt.net X-Spam-Level: X-Spam-ASN: X-Spam-Status: No, score=-4.2 required=3.0 tests=ALL_TRUSTED,AWL,BAYES_00, DKIM_SIGNED,DKIM_VALID,DKIM_VALID_AU,DKIM_VALID_EF, T_SCC_BODY_TEXT_LINE shortcircuit=no autolearn=ham autolearn_force=no version=3.4.6 Received: from localhost (dcvr.yhbt.net [127.0.0.1]) by dcvr.yhbt.net (Postfix) with ESMTP id 989881F406 for ; Thu, 30 Nov 2023 21:43:28 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=80x24.org; s=selector1; t=1701380608; bh=paI595RovdnO1yd/CtMcvY28NS1ZvklJaF+21NYUYh0=; h=Date:From:To:Subject:References:In-Reply-To:From; b=zahKtyNZ3DdDyULNVxJBINyDsDB5nKFSRFKhXY3PDrj0ENe6gj2l+ki8ilhd8OrSr e1iR69flC95XO0tbdV6/wq8jauVrf1k4lU7wTyP/33N7iwL7hsJsYzxpjXQHDwaaZp VwaRibL6GlZS7k4lk6aeT3sD4ZJiYX5280L1Q874= Date: Thu, 30 Nov 2023 21:40:47 +0000 From: Eric Wong To: meta@public-inbox.org Subject: [PATCH v2] codesearch: use retry_reopen for WWW Message-ID: <20231130214048.M46988@dcvr> References: <20231130114109.2577708-1-e@80x24.org> <20231130114109.2577708-16-e@80x24.org> MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Disposition: inline In-Reply-To: <20231130114109.2577708-16-e@80x24.org> List-Id: As with mail search, a cindex may be updated while WWW is serving requests. Thus we must reopen the Xapian DB when the revision we're using becomes stale. --- v2: avoid reintroducing load_ct as noted in https://public-inbox.org/meta/20231130213641.M35664@dcvr/ lib/PublicInbox/CodeSearch.pm | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) diff --git a/lib/PublicInbox/CodeSearch.pm b/lib/PublicInbox/CodeSearch.pm index f4694686..3092718d 100644 --- a/lib/PublicInbox/CodeSearch.pm +++ b/lib/PublicInbox/CodeSearch.pm @@ -258,15 +258,11 @@ sub load_ct { # retry_reopen cb sub load_commit_times { # each_cindex callback my ($self, $todo) = @_; # todo = [ [ time, git ], [ time, git ] ...] - my (@pending, $rec, $dir, @ids, $doc); + my (@pending, $rec, $ct); while ($rec = shift @$todo) { - @ids = docids_of_git_dir $self, $rec->[1]->{git_dir}; - if (@ids) { - for (@ids) { - $doc = $self->get_doc($_) // next; - $rec->[0] = int_val($doc, CT); - last; - } + $ct = $self->retry_reopen(\&load_ct, $rec->[1]->{git_dir}); + if (defined $ct) { + $rec->[0] = $ct; } else { # may be in another cindex: push @pending, $rec; } @@ -295,7 +291,7 @@ EOM $git; }; } - my $jd = join_data($self) or return warn <retry_reopen(\&join_data, $self) or return warn <{topdir} has no usable join data for $cfg_f EOM my ($ekeys, $roots, $ibx2root) = @$jd{qw(ekeys roots ibx2root)}; @@ -366,7 +362,7 @@ sub repos_sorted { my @recs = map { [ 0, $_ ] } @_; # PublicInbox::Git objects my @todo = @recs; $pi_cfg->each_cindex(\&load_commit_times, \@todo); - @recs = sort { $b->[0] <=> $a->[0] } @recs; + @recs = sort { $b->[0] <=> $a->[0] } @recs; # sort by commit time } 1;