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

Comparing AnyEvent-MP/MP/Transport.pm (file contents):
Revision 1.21 by root, Tue Aug 4 23:35:51 2009 UTC vs.
Revision 1.22 by root, Wed Aug 5 19:55:58 2009 UTC

… …
270 my $src_node = $self->{node}; 270 my $src_node = $self->{node};
271 271
272 $hdl->push_write ($self->{s_framing} => $_) 272 $hdl->push_write ($self->{s_framing} => $_)
273 for @$queue; 273 for @$queue;
274 274
275 my $rmsg; $rmsg = sub { 275 my $rmsg; $rmsg = sub {
276 $_[0]->push_read ($r_framing => $rmsg); 276 $_[0]->push_read ($r_framing => $rmsg);
277 277
278 local $AnyEvent::MP::Base::SRCNODE = $src_node; 278 local $AnyEvent::MP::Base::SRCNODE = $src_node;
279 AnyEvent::MP::Base::_inject (@{ $_[1] }); 279 AnyEvent::MP::Base::_inject (@{ $_[1] });
280 }; 280 };

Diff Legend

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