Closing the socket for script/lei needs to be done AFTER the
final message(s) are printed.
use v5.10.1;
sub new {
- my ($cls, $io) = @_;
- bless [ $io, $$ ], $cls;
+ my ($cls, $lei) = @_;
+ bless [ @$lei{qw(2 sock)}, $$ ], $cls;
}
sub DESTROY {
my ($self) = @_;
- my $io = shift @$self;
- shift(@$self) == $$ and print $io @$self;
+ my ($stderr, $sock, $pid) = splice(@$self, 0, 3);
+ print $stderr @$self if $pid == $$;
+ # script/lei disconnects when $sock SvREFCNT drops to zero
}
1;
sub redispatch_all ($$) {
my ($self, $lei) = @_;
# re-dispatch into our event loop w/o creating an extra fork-level
- $lei->{fmsg} = PublicInbox::LeiFinmsg->new($lei->{2});
+ $lei->{fmsg} = PublicInbox::LeiFinmsg->new($lei);
my ($op_c, $op_p) = PublicInbox::PktOp->pair;
for my $o (@{$self->{local} // []}, @{$self->{remote} // []}) {
PublicInbox::DS::requeue(sub {