ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent-MP/MP/Node.pm
(Generate patch)

Comparing AnyEvent-MP/MP/Node.pm (file contents):
Revision 1.49 by root, Wed Dec 30 15:33:08 2009 UTC vs.
Revision 1.52 by root, Sat Mar 13 20:29:04 2010 UTC

… …
89sub transport_connect { 89sub transport_connect {
90 my ($self, $transport) = @_; 90 my ($self, $transport) = @_;
91 91
92 delete $self->{trial}; 92 delete $self->{trial};
93 93
94 $self->transport_error (transport_error => "switched connections") 94 $self->transport_error (transport_error => $self->{id}, "switched connections")
95 if $self->{transport}; 95 if $self->{transport};
96 96
97 delete $self->{connect_addr}; 97 delete $self->{connect_addr};
98 delete $self->{connect_w}; 98 delete $self->{connect_w};
99 delete $self->{connect_to}; 99 delete $self->{connect_to};
100 100
101 $self->{transport} = $transport; 101 $self->{transport} = $transport;
102 102
103 my $transport_send = $transport->can ("send"); 103 my $transport_send = $transport->{send};
104 104
105 AnyEvent::MP::Kernel::_inject_nodeevent ($self, 1); 105 AnyEvent::MP::Kernel::_inject_nodeevent ($self, 1);
106 106
107 $self->{send} = sub { 107 $self->{send} = $transport_send;
108 $transport_send->($transport, $_[0]);
109 };
110 108
111 $transport->send ($_) 109 $transport_send->($_)
112 for @{ delete $self->{queue} || [] }; 110 for @{ delete $self->{queue} || [] };
113} 111}
114 112
115sub connect { 113sub connect {
116 my ($self, @addresses) = @_; 114 my ($self, @addresses) = @_;
… …
255 push @DELAY, sub { AnyEvent::MP::Kernel::_kill (@args) }; 253 push @DELAY, sub { AnyEvent::MP::Kernel::_kill (@args) };
256 $DELAY_W ||= AE::timer 0, 0, \&_send_delayed; 254 $DELAY_W ||= AE::timer 0, 0, \&_send_delayed;
257} 255}
258 256
259sub monitor { 257sub monitor {
260 # shortcut 258 # maybe always delay, too?
261 if ($DELAY_W) { 259 if ($DELAY_W) {
262 my @args = @_; 260 my @args = @_;
263 push @DELAY, sub { AnyEvent::MP::Kernel::_monitor (@args) }; 261 push @DELAY, sub { AnyEvent::MP::Kernel::_monitor (@args) };
264 return; 262 return;
265 } 263 }
266 &AnyEvent::MP::Kernel::_monitor; 264 &AnyEvent::MP::Kernel::_monitor;
267} 265}
268 266
269sub unmonitor { 267sub unmonitor {
268 # no need to always delay
270 if ($DELAY_W) { 269 if ($DELAY_W) {
271 my @args = @_; 270 my @args = @_;
272 push @DELAY, sub { AnyEvent::MP::Kernel::_unmonitor (@args) }; 271 push @DELAY, sub { AnyEvent::MP::Kernel::_unmonitor (@args) };
273 return; 272 return;
274 } 273 }

Diff Legend

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