… | |
… | |
268 | our $DELAY = -50; |
268 | our $DELAY = -50; |
269 | our @DELAY; |
269 | our @DELAY; |
270 | our $DELAY_W; |
270 | our $DELAY_W; |
271 | |
271 | |
272 | sub _send_delayed { |
272 | sub _send_delayed { |
273 | local $AnyEvent::MP::Kernel::SRCNODE = $AnyEvent::MP::Kernel::NODE{""}; |
273 | $AnyEvent::MP::Kernel::SRCNODE = $AnyEvent::MP::Kernel::NODE; |
274 | (shift @DELAY)->() |
274 | (shift @DELAY)->() |
275 | while @DELAY; |
275 | while @DELAY; |
276 | undef $DELAY_W; |
276 | undef $DELAY_W; |
277 | $DELAY = -50; |
277 | $DELAY = -50; |
278 | } |
278 | } |
… | |
… | |
288 | push @DELAY, sub { AnyEvent::MP::Kernel::_inject (@$msg) }; |
288 | push @DELAY, sub { AnyEvent::MP::Kernel::_inject (@$msg) }; |
289 | $DELAY_W ||= AE::timer 0, 0, \&_send_delayed; |
289 | $DELAY_W ||= AE::timer 0, 0, \&_send_delayed; |
290 | return; |
290 | return; |
291 | } |
291 | } |
292 | |
292 | |
293 | local $AnyEvent::MP::Kernel::SRCNODE = $self; |
293 | local $AnyEvent::MP::Kernel::SRCNODE = $AnyEvent::MP::Kernel::NODE; |
294 | AnyEvent::MP::Kernel::_inject (@{ $_[0] }); |
294 | AnyEvent::MP::Kernel::_inject (@{ $_[0] }); |
295 | }; |
295 | }; |
296 | } |
296 | } |
297 | |
297 | |
298 | sub transport_connect { |
298 | sub transport_connect { |