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

Comparing AnyEvent-MP/MP/Node.pm (file contents):
Revision 1.9 by root, Tue Aug 4 23:16:57 2009 UTC vs.
Revision 1.13 by root, Wed Aug 5 22:40:51 2009 UTC

 }
 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} ||= [];
    $self->send (["", mon1 => $portid])
    if (
       exists $self->{remote_uniq}
       && $self->{remote_uniq} ne $transport->{remote_uniq}
    ) {
       # uniq changed, different node
-      $self->fail ("node restart detected");
+      $self->fail (transport_error => $self->{noderef}, "node was restarted");
    }
    delete $self->{trial};
    delete $self->{next_connect};
    delete $self->{failed};
          [$w, \$g]
       };
    } 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 {
       $self->connect;
    };
 }
+package AnyEvent::MP::Node::Slave;
+use base "AnyEvent::MP::Node::Direct";
+sub connect {
+   my ($self) = @_;
+   $self->fail (transport_error => $self->{noderef}, "unable to connect to slave node");
+}
 package AnyEvent::MP::Node::Self;
 use base "AnyEvent::MP::Node";
 sub set_transport {
-   die "FATAL error, set_transport was called";
+   Carp::confess "FATAL error, set_transport was called on local node";
 }
 sub send {
    local $AnyEvent::MP::Base::SRCNODE = $_[0];
    AnyEvent::MP::Base::_inject (@{ $_[1] });

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