| … | |
… | |
| 54 | |
54 | |
| 55 | $self->{send} = sub { |
55 | $self->{send} = sub { |
| 56 | push @{$self->{queue}}, shift; |
56 | push @{$self->{queue}}, shift; |
| 57 | $self->connect; |
57 | $self->connect; |
| 58 | }; |
58 | }; |
| 59 | |
|
|
| 60 | $self->connect |
|
|
| 61 | if $self->{autoconnect}; |
|
|
| 62 | } |
59 | } |
| 63 | |
60 | |
| 64 | # called only after successful handshake |
61 | # called only after successful handshake |
| 65 | sub transport_error { |
62 | sub transport_error { |
| 66 | my ($self, @reason) = @_; |
63 | my ($self, @reason) = @_; |
| … | |
… | |
| 71 | delete $self->{connect_to}; |
68 | delete $self->{connect_to}; |
| 72 | |
69 | |
| 73 | delete $self->{queue}; |
70 | delete $self->{queue}; |
| 74 | $self->transport_reset; |
71 | $self->transport_reset; |
| 75 | |
72 | |
| 76 | AnyEvent::MP::Kernel::_inject_nodeevent ($self, 0, @reason) |
|
|
| 77 | unless $no_transport; |
|
|
| 78 | |
|
|
| 79 | if (my $mon = delete $self->{lmon}) { |
73 | if (my $mon = delete $self->{lmon}) { |
| 80 | $_->(@reason) for map @$_, values %$mon; |
74 | $_->(@reason) for map @$_, values %$mon; |
| 81 | } |
75 | } |
|
|
76 | |
|
|
77 | AnyEvent::MP::Kernel::_inject_nodeevent ($self, 0, @reason) |
|
|
78 | unless $no_transport; |
| 82 | } |
79 | } |
| 83 | |
80 | |
| 84 | # called after handshake was successful |
81 | # called after handshake was successful |
| 85 | sub transport_connect { |
82 | sub transport_connect { |
| 86 | my ($self, $transport) = @_; |
83 | my ($self, $transport) = @_; |
