[ViewVC] Diff of: cvs/AnyEvent-MP/MP/Node.pm

Comparing AnyEvent-MP/MP/Node.pm (file contents):
Revision 1.37 by root, Sun Sep 6 00:13:21 2009 UTC vs.
Revision 1.38 by root, Mon Sep 7 12:04:32 2009 UTC

 sub connect {
    # we are trivially connected
 }
+# delay every so often to avoid recursion, also used to delay after spawn
+our $DELAY;
+our @DELAY;
+our $DELAY_W;
+sub _send_delayed {
+   local $AnyEvent::MP::Kernel::SRCNODE = $AnyEvent::MP::Kernel::NODE{""};
+   AnyEvent::MP::Kernel::_inject (@{ shift @DELAY })
+      while @DELAY;
+   undef $DELAY_W;
+   $DELAY = -50;
+}
 sub transport_reset {
    my ($self) = @_;
    Scalar::Util::weaken $self;
    $self->{send} = sub {
+      if ($DELAY++ >= 0) {
+         push @DELAY, $_[0];
+         $DELAY_W ||= AE::timer 0, 0, \&_send_delayed;
+      } else {
-      local $AnyEvent::MP::Kernel::SRCNODE = $self;
+         local $AnyEvent::MP::Kernel::SRCNODE = $self;
-      AnyEvent::MP::Kernel::_inject (@{ $_[0] });
+         AnyEvent::MP::Kernel::_inject (@{ $_[0] });
+      }
    };
 }
 sub transport_connect {
    my ($self, $tp) = @_;

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines