X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FV2Writable.pm;h=c926446c87ef0697057fdf1973228891ce2a8194;hb=71a27b7f45140194566e945ee7957e81abbc67bf;hp=b0148dba4985d3e9a4d9534a559b10a0b32db5df;hpb=a367ec1b15a2458e532245f5308565dd84f8ca63;p=public-inbox.git diff --git a/lib/PublicInbox/V2Writable.pm b/lib/PublicInbox/V2Writable.pm index b0148dba..c926446c 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); @@ -1343,7 +1346,7 @@ sub index_sync { my $s0 = PublicInbox::SearchIdx->new($self->{ibx}, 0, 0); if (my $xdb = $s0->idx_acquire) { my $n = $xdb->get_metadata('has_threadid'); - $xdb->set_metadata('has_threadid', 1) if $n ne '1'; + $xdb->set_metadata('has_threadid', '1') if $n ne '1'; } $s0->idx_release; $self->lock_release;