--- AnyEvent-MP/MP/Node.pm 2009/08/04 23:16:57 1.9 +++ AnyEvent-MP/MP/Node.pm 2009/08/05 09:38:56 1.11 @@ -56,7 +56,7 @@ sub monitor { my ($self, $portid, $cb) = @_; - return $cb->("node failed conenction") + return $cb->(transport_error => "node unreachable") if $self->{failed}; my $list = $self->{lmon}{$portid} ||= []; @@ -157,6 +157,7 @@ }; } else { delete $self->{retry}; + $self->fail (transport_error => $self->{noderef}, "unable to connect"); } $self->{next_connect} = AE::timer $AnyEvent::MP::Base::CONNECT_INTERVAL, 0, sub {