X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FExtSearchIdx.pm;h=503428021854d827f5970a1c73510790d3c62976;hb=5ed2573594258bd53c9ae8e1c1c517a0c8ba191f;hp=3e7f560486e38bf3b166d3277d1aeed28002074a;hpb=a381e4acc9070bad6490b83173687a4f0e142627;p=public-inbox.git diff --git a/lib/PublicInbox/ExtSearchIdx.pm b/lib/PublicInbox/ExtSearchIdx.pm index 3e7f5604..50342802 100644 --- a/lib/PublicInbox/ExtSearchIdx.pm +++ b/lib/PublicInbox/ExtSearchIdx.pm @@ -250,17 +250,22 @@ sub cur_ibx_xnum ($$) { sub index_oid { # git->cat_async callback for 'm' my ($bref, $oid, $type, $size, $req) = @_; + my $self = $req->{self}; + local $self->{current_info} = "$self->{current_info} $oid"; return if is_bad_blob($oid, $type, $size, $req->{oid}); my $new_smsg = $req->{new_smsg} = bless { blob => $oid, }, 'PublicInbox::Smsg'; $new_smsg->{bytes} = $size + crlf_adjust($$bref); defined($req->{xnum} = cur_ibx_xnum($req, $bref)) or return; + ++${$req->{nr}}; do_step($req); } sub unindex_oid { # git->cat_async callback for 'd' my ($bref, $oid, $type, $size, $req) = @_; + my $self = $req->{self}; + local $self->{current_info} = "$self->{current_info} $oid"; return if is_bad_blob($oid, $type, $size, $req->{oid}); return if defined(cur_ibx_xnum($req, $bref)); # was re-added do_step($req); @@ -286,6 +291,8 @@ sub _sync_inbox ($$$) { -opt => $opt, self => $self, ibx => $ibx, + nr => \(my $nr = 0), + -regen_fmt => "%u/?\n", }; my $v = $ibx->version; my $ekey = $ibx->eidx_key;