| … | |
… | |
| 289 | |
289 | |
| 290 | sub error { |
290 | sub error { |
| 291 | my ($self, $msg) = @_; |
291 | my ($self, $msg) = @_; |
| 292 | |
292 | |
| 293 | if ($self->{node} && $self->{node}{transport} == $self) { |
293 | if ($self->{node} && $self->{node}{transport} == $self) { |
|
|
294 | #TODO: store error, but do not instantly fail |
| 294 | $self->{node}->fail (transport_error => $msg); |
295 | $self->{node}->fail (transport_error => $self->{node}{noderef}, $msg); |
| 295 | $self->{node}->clr_transport; |
296 | $self->{node}->clr_transport; |
| 296 | } |
297 | } |
| 297 | $AnyEvent::MP::Base::WARN->("$self->{peerhost}:$self->{peerport}: $msg"); |
298 | $AnyEvent::MP::Base::WARN->("$self->{peerhost}:$self->{peerport}: $msg"); |
| 298 | $self->destroy; |
299 | $self->destroy; |
| 299 | } |
300 | } |
