diff options
| author | Eric Wong <e@80x24.org> | 2021-10-15 13:30:55 +0000 |
|---|---|---|
| committer | Eric Wong <e@80x24.org> | 2021-10-15 15:58:24 +0000 |
| commit | a1733d3406dfbde52d1468e671edd1d76893f546 (patch) | |
| tree | 118763410e5c6f32776671a435595792f0555ee4 /lib/PublicInbox/LeiConvert.pm | |
| parent | 2ca12a7fd78d7c9c27fec4f50fdcb58f9c838003 (diff) | |
| download | public-inbox-a1733d3406dfbde52d1468e671edd1d76893f546.tar.gz | |
Simplify our APIs and force dwaitpid() to work in async mode for all lei workers. This avoids having lingering zombies for parallel searches if one worker finishes soon before another. The old distinction between "old" and "new" workers was needlessly complex, error-prone, and embarrasingly bad. We also never handled v2:// writers properly before on Ctrl-C/Ctrl-Z (SIGINT/SIGTSTP), so add them to @WQ_KEYS to ensure they get handled by $lei when appropropriate.
Diffstat (limited to 'lib/PublicInbox/LeiConvert.pm')
| -rw-r--r-- | lib/PublicInbox/LeiConvert.pm | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/PublicInbox/LeiConvert.pm b/lib/PublicInbox/LeiConvert.pm index 9e98edc3..68fc7c0b 100644 --- a/lib/PublicInbox/LeiConvert.pm +++ b/lib/PublicInbox/LeiConvert.pm @@ -58,7 +58,7 @@ sub lei_convert { # the main "lei convert" method my ($op_c, $ops) = $lei->workers_start($self, 1); $lei->{wq1} = $self; $self->wq_io_do('process_inputs', []); - $self->wq_close(1); + $self->wq_close; $lei->wait_wq_events($op_c, $ops); } |