| … | |
… | |
| 313 | $self->send ($_) |
313 | $self->send ($_) |
| 314 | for @$queue; |
314 | for @$queue; |
| 315 | |
315 | |
| 316 | # receive handling |
316 | # receive handling |
| 317 | my $src_node = $self->{node}; |
317 | my $src_node = $self->{node}; |
|
|
318 | Scalar::Util::weaken $src_node; |
| 318 | |
319 | |
| 319 | my $rmsg; $rmsg = sub { |
320 | my $rmsg; $rmsg = sub { |
| 320 | $_[0]->push_read ($r_framing => $rmsg); |
321 | $_[0]->push_read ($r_framing => $rmsg); |
| 321 | |
322 | |
| 322 | local $AnyEvent::MP::Kernel::SRCNODE = $src_node; |
323 | local $AnyEvent::MP::Kernel::SRCNODE = $src_node; |
