| … | |
… | |
| 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 { |
