X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FLeiAuth.pm;h=bbd713f0c7684787325344c1c0b7eb05991a2cfa;hb=d2670108f71b1eff11ddb4288cc18a6c1f3d4322;hp=877ae6a3c081b7bb4d1409f6ef831470a5946d3e;hpb=3be19bfae0e1e458441979b65461d647abf5599a;p=public-inbox.git diff --git a/lib/PublicInbox/LeiAuth.pm b/lib/PublicInbox/LeiAuth.pm index 877ae6a3..bbd713f0 100644 --- a/lib/PublicInbox/LeiAuth.pm +++ b/lib/PublicInbox/LeiAuth.pm @@ -6,7 +6,6 @@ package PublicInbox::LeiAuth; use strict; use v5.10.1; -use PublicInbox::PktOp qw(pkt_do); sub do_auth_atfork { # used by IPC WQ workers my ($self, $wq) = @_; @@ -16,7 +15,7 @@ sub do_auth_atfork { # used by IPC WQ workers eval { my $mics = $net->imap_common_init($lei); my $nn = $net->nntp_common_init($lei); - pkt_do($lei->{pkt_op_p}, 'net_merge_continue', $net) or + $lei->{pkt_op_p}->pkt_do('net_merge_continue', $net) or die "pkt_do net_merge_continue: $!"; $net->{mics_cached} = $mics if $mics; $net->{nn_cached} = $nn if $nn; @@ -34,7 +33,7 @@ sub net_merge_all { # called in wq worker via wq_broadcast my ($wq, $net_new) = @_; my $net = $wq->{lei}->{net}; %$net = (%$net, %$net_new); - pkt_do($wq->{lei}->{pkt_op_p}, 'net_merge_done1') or + $wq->{lei}->{pkt_op_p}->pkt_do('net_merge_done1') or die "pkt_op_do net_merge_done1: $!"; }