X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FLeiImport.pm;h=21af28a3a79c647df2cf0b6dafa07d7e401e7efb;hb=5be0cb101bab44167a78af7a2d167f254c95bdb3;hp=9ad2ff12cd396380442aae9e24ab4358e8ca30c0;hpb=e7d13d7bc4a7b1e990602e796b7c2acbddb99a7b;p=public-inbox.git diff --git a/lib/PublicInbox/LeiImport.pm b/lib/PublicInbox/LeiImport.pm index 9ad2ff12..21af28a3 100644 --- a/lib/PublicInbox/LeiImport.pm +++ b/lib/PublicInbox/LeiImport.pm @@ -78,16 +78,6 @@ sub lei_import { # the main "lei import" method import_start($lei); } -sub ipc_atfork_child { - my ($self) = @_; - my $lei = $self->{lei}; - delete $lei->{imp}; # drop circular ref - $lei->lei_atfork_child; - $self->SUPER::ipc_atfork_child; - $lei->{auth}->do_auth_atfork($self) if $lei->{auth}; - undef; -} - sub _import_maildir { # maildir_each_eml cb my ($f, $kw, $eml, $sto, $set_kw) = @_; $sto->ipc_do('set_eml', $eml, $set_kw ? { kw => $kw }: ()); @@ -137,6 +127,9 @@ sub import_stdin { $self->input_fh($lei->{opt}->{'in-format'}, $in, ''); } -no warnings 'once'; # the following works even when LeiAuth is lazy-loaded +no warnings 'once'; +*ipc_atfork_child = \&PublicInbox::LeiInput::input_only_atfork_child; + +# the following works even when LeiAuth is lazy-loaded *net_merge_all = \&PublicInbox::LeiAuth::net_merge_all; 1;