… | |
… | |
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 | } |