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

Comparing AnyEvent-MP/MP/Transport.pm (file contents):
Revision 1.80 by root, Thu Mar 22 00:48:29 2012 UTC vs.
Revision 1.81 by root, Thu Mar 22 00:50:00 2012 UTC

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

…		…
393	delete $self->{keepalive};	393	delete $self->{keepalive};
394		394
395	if ($self->{protocol}) {	395	if ($self->{protocol}) {
396	$HOOK_PROTOCOL{$self->{protocol}}->($self, $msg);	396	$HOOK_PROTOCOL{$self->{protocol}}->($self, $msg);
397	} else {	397	} else {
398	AE::log 8 => "$self->{peerhost}:$self->{peerport} $msg";	398	AE::log 8 => "$self->{peerhost}:$self->{peerport} $msg.";
399		399
400	$self->{node}->transport_error (transport_error => $self->{node}{id}, $msg)	400	$self->{node}->transport_error (transport_error => $self->{node}{id}, $msg)
401	if $self->{node} && $self->{node}{transport} == $self;	401	if $self->{node} && $self->{node}{transport} == $self;
402	}	402	}
403		403
…		…
414		414
415	if ($self->{protocol}) {	415	if ($self->{protocol}) {
416	$self->{hdl}->on_error (undef);	416	$self->{hdl}->on_error (undef);
417	$HOOK_PROTOCOL{$self->{protocol}}->($self, undef);	417	$HOOK_PROTOCOL{$self->{protocol}}->($self, undef);
418	} else {	418	} else {
419	AE::log 9 => "$self->{peerhost}:$self->{peerport} connected as $self->{remote_node}";	419	AE::log 9 => "$self->{peerhost}:$self->{peerport} connected as $self->{remote_node}.";
420		420
421	my $node = AnyEvent::MP::Kernel::add_node ($self->{remote_node});	421	my $node = AnyEvent::MP::Kernel::add_node ($self->{remote_node});
422	Scalar::Util::weaken ($self->{node} = $node);	422	Scalar::Util::weaken ($self->{node} = $node);
423	$node->transport_connect ($self);	423	$node->transport_connect ($self);
424		424