lib/PublicInbox/LeiXSearch.pm | 4 ++-- diff --git a/lib/PublicInbox/LeiXSearch.pm b/lib/PublicInbox/LeiXSearch.pm index 2958d3f910b0986baa2bccf138ee185ae35b8c7f..41e798562d424b097ec611ef5f283f2251d9563b 100644 --- a/lib/PublicInbox/LeiXSearch.pm +++ b/lib/PublicInbox/LeiXSearch.pm @@ -285,7 +285,7 @@ if ($self->{import_sto} && !$xoids) { my ($res, $kw) = $self->{import_sto}->wq_do('add_eml', $eml); if (ref($res) eq ref($smsg)) { # totally new message $smsg = $res; - $self->{-imported} = 1; + $self->{-sto_imported} = 1; } $smsg->{kw} = $kw; # short-circuit xsmsg_vmd } @@ -376,7 +376,7 @@ my $reap_curl = PublicInbox::AutoReap->new($pid); $fh = IO::Uncompress::Gunzip->new($fh, MultiStream => 1); PublicInbox::MboxReader->mboxrd($fh, \&each_remote_eml, $self, $lei, $each_smsg); - if ($self->{import_sto} && delete($self->{-imported})) { + if (delete($self->{-sto_imported})) { my $wait = $self->{import_sto}->wq_do('done'); } $reap_curl->join;