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

Comparing AnyEvent-MP/MP/Node.pm (file contents):
Revision 1.12 by root, Wed Aug 5 19:55:58 2009 UTC vs.
Revision 1.13 by root, Wed Aug 5 22:40:51 2009 UTC

90 if ( 90 if (
91 exists $self->{remote_uniq} 91 exists $self->{remote_uniq}
92 && $self->{remote_uniq} ne $transport->{remote_uniq} 92 && $self->{remote_uniq} ne $transport->{remote_uniq}
93 ) { 93 ) {
94 # uniq changed, different node 94 # uniq changed, different node
95 $self->fail ("node restart detected"); 95 $self->fail (transport_error => $self->{noderef}, "node was restarted");
96 } 96 }
97 97
98 delete $self->{trial}; 98 delete $self->{trial};
99 delete $self->{next_connect}; 99 delete $self->{next_connect};
100 delete $self->{failed}; 100 delete $self->{failed};
163 $self->{next_connect} = AE::timer $AnyEvent::MP::Base::CONNECT_INTERVAL, 0, sub { 163 $self->{next_connect} = AE::timer $AnyEvent::MP::Base::CONNECT_INTERVAL, 0, sub {
164 $self->connect; 164 $self->connect;
165 }; 165 };
166} 166}
167 167
168package AnyEvent::MP::Node::Slave;
169
170use base "AnyEvent::MP::Node::Direct";
171
172sub connect {
173 my ($self) = @_;
174
175 $self->fail (transport_error => $self->{noderef}, "unable to connect to slave node");
176}
177
168package AnyEvent::MP::Node::Self; 178package AnyEvent::MP::Node::Self;
169 179
170use base "AnyEvent::MP::Node"; 180use base "AnyEvent::MP::Node";
171 181
172sub set_transport { 182sub set_transport {

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines