| … | |
… | |
| 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) = @_; |
