- my $n;
- do {
- $n = $self->{wq}->recv_and_run($self->{sock});
- } while ($n);
- return if !defined($n) && $! == EAGAIN; # likely
- warn "wq worker error: $!\n" if !defined($n) && $! != ECONNRESET;
- $self->{wq}->wq_atexit_child if $self->{sock} == $self->{wq}->{-wq_s2};
+ my $n = $self->{wq}->recv_and_run($self->{sock}) and return;
+ unless (defined $n) {
+ return if $! == EAGAIN;
+ warn "recvmsg: $!" if $! != ECONNRESET;
+ }
+ $self->{sock} == $self->{wq}->{-wq_s2} and
+ $self->{wq}->wq_atexit_child;