From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.2 (2018-09-13) on dcvr.yhbt.net X-Spam-Level: X-Spam-Status: No, score=-4.0 required=3.0 tests=ALL_TRUSTED,AWL,BAYES_00 shortcircuit=no autolearn=ham autolearn_force=no version=3.4.2 Received: from localhost (dcvr.yhbt.net [127.0.0.1]) by dcvr.yhbt.net (Postfix) with ESMTP id CD57A1F918 for ; Fri, 24 Jul 2020 05:56:09 +0000 (UTC) From: Eric Wong To: meta@public-inbox.org Subject: [PATCH 14/20] searchidx: rename _xdb_{acquire,release} => idx_ Date: Fri, 24 Jul 2020 05:56:00 +0000 Message-Id: <20200724055606.27332-15-e@yhbt.net> In-Reply-To: <20200724055606.27332-1-e@yhbt.net> References: <20200724055606.27332-1-e@yhbt.net> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit List-Id: The "xdb" prefix was inaccurate since it's used by indexlevel=basic, which is Xapian-free. The '_' (underscore) prefix was also wrong for a method which is called across package boundaries. --- lib/PublicInbox/SearchIdx.pm | 12 ++++++------ lib/PublicInbox/SearchIdxShard.pm | 6 +++--- t/inbox_idle.t | 4 ++-- t/search.t | 4 ++-- 4 files changed, 13 insertions(+), 13 deletions(-) diff --git a/lib/PublicInbox/SearchIdx.pm b/lib/PublicInbox/SearchIdx.pm index 2d53b2d03..89c716793 100644 --- a/lib/PublicInbox/SearchIdx.pm +++ b/lib/PublicInbox/SearchIdx.pm @@ -77,7 +77,7 @@ sub new { sub need_xapian ($) { $_[0]->{indexlevel} =~ $xapianlevels } -sub _xdb_release { +sub idx_release { my ($self, $wake) = @_; if (need_xapian($self)) { my $xdb = delete $self->{xdb} or croak 'not acquired'; @@ -101,7 +101,7 @@ sub load_xapian_writable () { 1; } -sub _xdb_acquire { +sub idx_acquire { my ($self) = @_; my $flag; my $dir = $self->xdir; @@ -735,7 +735,7 @@ sub _index_sync { $git->cleanup; delete $self->{txn}; $xdb->cancel_transaction if $xdb; - $xdb = _xdb_release($self); + $xdb = idx_release($self); # ensure we leak no FDs to "git log" with Xapian <= 1.2 my $range = $lx eq '' ? $tip : "$lx..$tip"; @@ -766,7 +766,7 @@ sub _index_sync { $self->{over}->rethread_done($opts) if $newest; # all done $self->commit_txn_lazy; $git->cleanup; - $xdb = _xdb_release($self, $nr); + $xdb = idx_release($self, $nr); # let another process do some work... $pr->("indexed $nr/$self->{ntodo}\n") if $pr && $nr; if (!$newest) { # more to come @@ -805,7 +805,7 @@ sub remote_close { $? == 0 or die ref($self)." pid:$pid exited with: $?"; } else { die "transaction in progress $self\n" if $self->{txn}; - $self->_xdb_release if $self->{xdb}; + idx_release($self) if $self->{xdb}; } } @@ -821,7 +821,7 @@ sub remote_remove { sub _begin_txn { my ($self) = @_; - my $xdb = $self->{xdb} || $self->_xdb_acquire; + my $xdb = $self->{xdb} || idx_acquire($self); $self->{over}->begin_lazy if $self->{over}; $xdb->begin_transaction if $xdb; $self->{txn} = 1; diff --git a/lib/PublicInbox/SearchIdxShard.pm b/lib/PublicInbox/SearchIdxShard.pm index fd34e487b..cb79f3dc9 100644 --- a/lib/PublicInbox/SearchIdxShard.pm +++ b/lib/PublicInbox/SearchIdxShard.pm @@ -15,9 +15,9 @@ sub new { my $ibx = $v2w->{ibx}; my $self = $class->SUPER::new($ibx, 1, $shard); # create the DB before forking: - $self->_xdb_acquire; + $self->idx_acquire; $self->set_indexlevel; - $self->_xdb_release; + $self->idx_release; $self->spawn_worker($v2w, $shard) if $v2w->{parallel}; $self; } @@ -56,7 +56,7 @@ sub shard_worker_loop ($$$$$) { if ($line eq "commit\n") { $self->commit_txn_lazy; } elsif ($line eq "close\n") { - $self->_xdb_release; + $self->idx_release; } elsif ($line eq "barrier\n") { $self->commit_txn_lazy; # no need to lock < 512 bytes is atomic under POSIX diff --git a/t/inbox_idle.t b/t/inbox_idle.t index f754e0fcc..61287200d 100644 --- a/t/inbox_idle.t +++ b/t/inbox_idle.t @@ -28,9 +28,9 @@ for my $V (1, 2) { my $im = $ibx->importer(0); if ($V == 1) { my $sidx = PublicInbox::SearchIdx->new($ibx, 1); - $sidx->_xdb_acquire; + $sidx->idx_acquire; $sidx->set_indexlevel; - $sidx->_xdb_release; # allow watching on lockfile + $sidx->idx_release; # allow watching on lockfile } my $pi_config = PublicInbox::Config->new(\<new($ibx, 1); $ibx->with_umask(sub { - $rw->_xdb_acquire; - $rw->_xdb_release; + $rw->idx_acquire; + $rw->idx_release; }); $rw = undef; my $ro = PublicInbox::Search->new($ibx);