diff options
author | Eric Wong <e@yhbt.net> | 2020-08-22 19:51:36 +0000 |
---|---|---|
committer | Eric Wong <e@yhbt.net> | 2020-08-23 00:20:01 +0000 |
commit | 68dc097dc9fed5affe5ffadc6decc3a4b11392a8 (patch) | |
tree | ea1dc9b288f227dee04fed445592fae363e544ee | |
parent | a367ec1b15a2458e532245f5308565dd84f8ca63 (diff) | |
download | public-inbox-68dc097dc9fed5affe5ffadc6decc3a4b11392a8.tar.gz |
There's no reason we'd want Xapian to defer flushing once we've indexed everything belonging to a particular shard.
-rw-r--r-- | lib/PublicInbox/V2Writable.pm | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/lib/PublicInbox/V2Writable.pm b/lib/PublicInbox/V2Writable.pm index b0148dba..3d6f19cb 100644 --- a/lib/PublicInbox/V2Writable.pm +++ b/lib/PublicInbox/V2Writable.pm @@ -1264,8 +1264,11 @@ sub xapian_only { $sync->{art_end} = $art_end; if ($seq || !$self->{parallel}) { my $shard_end = $self->{shards} - 1; - for (0..$shard_end) { - index_xap_step($self, $sync, $art_beg + $_) + for my $i (0..$shard_end) { + index_xap_step($self, $sync, $art_beg + $i); + if ($i != $shard_end) { + reindex_checkpoint($self, $sync); + } } } else { # parallel (maybe) index_xap_step($self, $sync, $art_beg, 1); |