| … | |
… | |
| 172 | |
172 | |
| 173 | package AnyEvent::MP::Node::Indirect; |
173 | package AnyEvent::MP::Node::Indirect; |
| 174 | |
174 | |
| 175 | use base "AnyEvent::MP::Node::Direct"; |
175 | use base "AnyEvent::MP::Node::Direct"; |
| 176 | |
176 | |
|
|
177 | sub transport_reset { |
|
|
178 | my ($self) = @_; |
|
|
179 | |
|
|
180 | # as an optimisation, immediately nuke slave nodes |
|
|
181 | delete $AnyEvent::MP::Kernel::NODE{$self->{noderef}} |
|
|
182 | if $self->{transport}; |
|
|
183 | |
|
|
184 | $self->SUPER::transport_reset; |
|
|
185 | } |
|
|
186 | |
| 177 | sub connect { |
187 | sub connect { |
| 178 | my ($self) = @_; |
188 | my ($self) = @_; |
| 179 | |
189 | |
| 180 | $self->transport_error (transport_error => $self->{noderef}, "unable to connect to indirect node"); |
190 | $self->transport_error (transport_error => $self->{noderef}, "unable to connect to indirect node"); |
| 181 | } |
191 | } |
