… | |
… | |
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) = @_; |