lib/PublicInbox/V2Writable.pm | 5 +++-- diff --git a/lib/PublicInbox/V2Writable.pm b/lib/PublicInbox/V2Writable.pm index 6b01171271475bdf6f082f25c12f7388d1f7f611..df8cfb45ad86f6042ae02c632fa941c25f295165 100644 --- a/lib/PublicInbox/V2Writable.pm +++ b/lib/PublicInbox/V2Writable.pm @@ -861,7 +861,7 @@ warn <<""; reindexing $git->{git_dir} starting at $range - $sync->{"unindex-range.$i"} = "$base..$cur"; + $sync->{unindex_range}->{$i} = "$base..$cur"; } $range; } @@ -993,6 +993,7 @@ $self->idx_init($opt); # acquire lock my $sync = { mm_tmp => $self->{mm}->tmp_clone, D => {}, # "$mid\0$cid" => $oid + unindex_range => {}, # EPOCH => oid_old..oid_new reindex => $opt->{reindex}, -opt => $opt }; @@ -1009,7 +1010,7 @@ die 'BUG: already reindexing!' if $self->{reindex_pipe}; -d $git_dir or next; # missing parts are fine fill_alternates($self, $i); my $git = PublicInbox::Git->new($git_dir); - my $unindex_range = delete $sync->{"unindex-range.$i"}; + my $unindex_range = delete $sync->{unindex_range}->{$i}; unindex($self, $sync, $git, $unindex_range) if $unindex_range; defined(my $range = $sync->{ranges}->[$i]) or next; $pr->("$i.git indexing $range\n") if $pr;