--- AnyEvent-MP/MP/Node.pm 2009/08/08 00:22:16 1.14 +++ AnyEvent-MP/MP/Node.pm 2009/08/08 21:56:29 1.15 @@ -56,9 +56,6 @@ sub monitor { my ($self, $portid, $cb) = @_; - return $cb->(transport_error => "node unreachable") - if $self->{failed}; - my $list = $self->{lmon}{$portid} ||= []; $self->send (["", mon1 => $portid]) @@ -87,20 +84,10 @@ $self->clr_transport if $self->{transport}; - if ( - exists $self->{remote_uniq} - && $self->{remote_uniq} ne $transport->{remote_uniq} - ) { - # uniq changed, different node - $self->fail (transport_error => $self->{noderef}, "node was restarted"); - } - delete $self->{trial}; delete $self->{next_connect}; - delete $self->{failed}; - $self->{remote_uniq} = $transport->{remote_uniq}; - $self->{transport} = $transport; + $self->{transport} = $transport; $transport->send ($_) for @{ delete $self->{queue} || [] }; @@ -111,8 +98,6 @@ delete $self->{queue}; - $self->{failed} = 1; - if (my $mon = delete $self->{lmon}) { $_->(@reason) for map @$_, values %$mon; }