about summary refs log tree commit homepage
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2021-10-16 22:52:50 -1100
committerEric Wong <e@80x24.org>2021-10-17 19:04:49 +0000
commit1f07fa568f1c466b44bb69c89ad847a233437014 (patch)
treee8842eff8b0ba0df7e16fc0cdeee6e2b705ec85a
parent9406144c54215626e79ee65fc3c89ff350506317 (diff)
downloadpublic-inbox-1f07fa568f1c466b44bb69c89ad847a233437014.tar.gz
Check for graceful termination at every message since it's
a fairly inexpensive check.
-rw-r--r--lib/PublicInbox/ExtSearchIdx.pm4
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