X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FLeiLsSearch.pm;h=0193e590b8b06c202d4034330e3eaf24e79e2344;hb=HEAD;hp=6cea6ae88089935d4f31a69bf9845ef8dad39dc4;hpb=528ef7a3988862763b6ca5b0123be0bf23a64213;p=public-inbox.git diff --git a/lib/PublicInbox/LeiLsSearch.pm b/lib/PublicInbox/LeiLsSearch.pm index 6cea6ae8..0193e590 100644 --- a/lib/PublicInbox/LeiLsSearch.pm +++ b/lib/PublicInbox/LeiLsSearch.pm @@ -71,12 +71,12 @@ sub do_ls_search_long { sub bg_worker ($$$) { my ($lei, $pfx, $json) = @_; - my $self = bless { -wq_nr_workers => 1, json => $json }, __PACKAGE__; + my $self = bless { json => $json }, __PACKAGE__; my ($op_c, $ops) = $lei->workers_start($self, 1); $lei->{wq1} = $self; $self->wq_io_do('do_ls_search_long', [], $pfx); - $self->wq_close(1); - $op_c->op_wait_event($ops); + $self->wq_close; + $lei->wait_wq_events($op_c, $ops); } sub lei_ls_search {