diff options
author | Eric Wong <e@80x24.org> | 2021-10-16 22:52:50 -1100 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2021-10-17 19:04:49 +0000 |
commit | 1f07fa568f1c466b44bb69c89ad847a233437014 (patch) | |
tree | e8842eff8b0ba0df7e16fc0cdeee6e2b705ec85a | |
parent | 9406144c54215626e79ee65fc3c89ff350506317 (diff) | |
download | public-inbox-1f07fa568f1c466b44bb69c89ad847a233437014.tar.gz |
Check for graceful termination at every message since it's a fairly inexpensive check.
-rw-r--r-- | lib/PublicInbox/ExtSearchIdx.pm | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/PublicInbox/ExtSearchIdx.pm b/lib/PublicInbox/ExtSearchIdx.pm index cb5256a2..f479cf9e 100644 --- a/lib/PublicInbox/ExtSearchIdx.pm +++ b/lib/PublicInbox/ExtSearchIdx.pm @@ -908,10 +908,9 @@ ibx_id = ? AND xnum >= ? AND xnum <= ? for my $num (@$docids) { $self->{oidx}->eidxq_add($num); } - return if $sync->{quit}; } + return if $sync->{quit}; } - return if $sync->{quit}; next unless scalar keys %x3m; $self->git->async_wait_all; # wait for reindex_unseen @@ -936,6 +935,7 @@ BUG: (non-fatal) $ekey #$xnum $smsg->{blob} still matches (old exp: $exp) for my $i (@$docids) { _unref_doc($sync, $i, $ibx, $xnum, $bin); } + return if $sync->{quit}; } } defined($hi) and ($hi < $max) and |