… | |
… | |
222 | $self->{send} = sub { |
222 | $self->{send} = sub { |
223 | if ($DELAY++ >= 0) { |
223 | if ($DELAY++ >= 0) { |
224 | my $msg = $_[0]; |
224 | my $msg = $_[0]; |
225 | push @DELAY, sub { AnyEvent::MP::Kernel::_inject (@$msg) }; |
225 | push @DELAY, sub { AnyEvent::MP::Kernel::_inject (@$msg) }; |
226 | $DELAY_W ||= AE::timer 0, 0, \&_send_delayed; |
226 | $DELAY_W ||= AE::timer 0, 0, \&_send_delayed; |
227 | } else { |
227 | return; |
228 | local $AnyEvent::MP::Kernel::SRCNODE = $self; |
|
|
229 | AnyEvent::MP::Kernel::_inject (@{ $_[0] }); |
|
|
230 | } |
228 | } |
|
|
229 | |
|
|
230 | local $AnyEvent::MP::Kernel::SRCNODE = $self; |
|
|
231 | AnyEvent::MP::Kernel::_inject (@{ $_[0] }); |
231 | }; |
232 | }; |
232 | } |
233 | } |
233 | |
234 | |
234 | sub transport_connect { |
235 | sub transport_connect { |
235 | my ($self, $tp) = @_; |
236 | my ($self, $tp) = @_; |