diff options
Diffstat (limited to 'lib/PublicInbox/LeiToMail.pm')
| -rw-r--r-- | lib/PublicInbox/LeiToMail.pm | 8 |
1 files changed, 1 insertions, 7 deletions
diff --git a/lib/PublicInbox/LeiToMail.pm b/lib/PublicInbox/LeiToMail.pm index 08a1570d..61b546b5 100644 --- a/lib/PublicInbox/LeiToMail.pm +++ b/lib/PublicInbox/LeiToMail.pm @@ -460,7 +460,7 @@ sub post_augment { # fast (spawn compressor or mkdir), runs in main daemon sub write_mail { # via ->wq_do my ($self, $git_dir, $smsg, $lei) = @_; - my $not_done = delete $self->{4}; # write end of {each_smsg_done} + my $not_done = delete $self->{$lei->{each_smsg_not_done}}; my $wcb = $self->{wcb} //= do { # first message my %sig = $lei->atfork_child_wq($self); @SIG{keys %sig} = values %sig; # not local @@ -471,12 +471,6 @@ sub write_mail { # via ->wq_do $git->cat_async($smsg->{blob}, \&git_to_mail, [$wcb, $smsg, $not_done]); } -sub ipc_atfork_prepare { - my ($self) = @_; - # FDs: (done_wr, stdout|mbox, stderr, 3: sock, 4: each_smsg_done_wr) - $self->SUPER::ipc_atfork_prepare; # PublicInbox::IPC -} - # We rely on OnDestroy to run this before ->DESTROY, since ->DESTROY # ordering is unstable at worker exit and may cause segfaults sub reap_gits { |