| … | |
… | |
| 54 | } |
54 | } |
| 55 | |
55 | |
| 56 | sub monitor { |
56 | sub monitor { |
| 57 | my ($self, $portid, $cb) = @_; |
57 | my ($self, $portid, $cb) = @_; |
| 58 | |
58 | |
| 59 | return $cb->(transport_error => "node unreachable") |
|
|
| 60 | if $self->{failed}; |
|
|
| 61 | |
|
|
| 62 | my $list = $self->{lmon}{$portid} ||= []; |
59 | my $list = $self->{lmon}{$portid} ||= []; |
| 63 | |
60 | |
| 64 | $self->send (["", mon1 => $portid]) |
61 | $self->send (["", mon1 => $portid]) |
| 65 | unless @$list; |
62 | unless @$list; |
| 66 | |
63 | |
| … | |
… | |
| 85 | my ($self, $transport) = @_; |
82 | my ($self, $transport) = @_; |
| 86 | |
83 | |
| 87 | $self->clr_transport |
84 | $self->clr_transport |
| 88 | if $self->{transport}; |
85 | if $self->{transport}; |
| 89 | |
86 | |
| 90 | if ( |
|
|
| 91 | exists $self->{remote_uniq} |
|
|
| 92 | && $self->{remote_uniq} ne $transport->{remote_uniq} |
|
|
| 93 | ) { |
|
|
| 94 | # uniq changed, different node |
|
|
| 95 | $self->fail (transport_error => $self->{noderef}, "node was restarted"); |
|
|
| 96 | } |
|
|
| 97 | |
|
|
| 98 | delete $self->{trial}; |
87 | delete $self->{trial}; |
| 99 | delete $self->{next_connect}; |
88 | delete $self->{next_connect}; |
| 100 | delete $self->{failed}; |
|
|
| 101 | |
89 | |
| 102 | $self->{remote_uniq} = $transport->{remote_uniq}; |
|
|
| 103 | $self->{transport} = $transport; |
90 | $self->{transport} = $transport; |
| 104 | |
91 | |
| 105 | $transport->send ($_) |
92 | $transport->send ($_) |
| 106 | for @{ delete $self->{queue} || [] }; |
93 | for @{ delete $self->{queue} || [] }; |
| 107 | } |
94 | } |
| 108 | |
95 | |
| 109 | sub fail { |
96 | sub fail { |
| 110 | my ($self, @reason) = @_; |
97 | my ($self, @reason) = @_; |
| 111 | |
98 | |
| 112 | delete $self->{queue}; |
99 | delete $self->{queue}; |
| 113 | |
|
|
| 114 | $self->{failed} = 1; |
|
|
| 115 | |
100 | |
| 116 | if (my $mon = delete $self->{lmon}) { |
101 | if (my $mon = delete $self->{lmon}) { |
| 117 | $_->(@reason) for map @$_, values %$mon; |
102 | $_->(@reason) for map @$_, values %$mon; |
| 118 | } |
103 | } |
| 119 | } |
104 | } |
