| … | |
… | |
| 130 | |
130 | |
| 131 | my $endpoint = shift @endpoints; |
131 | my $endpoint = shift @endpoints; |
| 132 | |
132 | |
| 133 | $trial{$endpoint} ||= do { |
133 | $trial{$endpoint} ||= do { |
| 134 | my ($host, $port) = AnyEvent::Socket::parse_hostport $endpoint |
134 | my ($host, $port) = AnyEvent::Socket::parse_hostport $endpoint |
| 135 | or return $AnyEvent::MP::Kernel::WARN->("$self->{noderef}: not a resolved node reference."); |
135 | or return $AnyEvent::MP::Kernel::WARN->(1, "$self->{noderef}: not a resolved node reference."); |
| 136 | |
136 | |
| 137 | AnyEvent::MP::Transport::mp_connect |
137 | AnyEvent::MP::Transport::mp_connect |
| 138 | $host, $port, |
138 | $host, $port, |
| 139 | sub { delete $trial{$endpoint} } |
139 | sub { delete $trial{$endpoint} } |
| 140 | ; |
140 | ; |
| … | |
… | |
| 246 | delete $AnyEvent::MP::Kernel::PORT{$port}; |
246 | delete $AnyEvent::MP::Kernel::PORT{$port}; |
| 247 | delete $AnyEvent::MP::Kernel::PORT_DATA{$port}; |
247 | delete $AnyEvent::MP::Kernel::PORT_DATA{$port}; |
| 248 | |
248 | |
| 249 | my $mon = delete $AnyEvent::MP::Kernel::LMON{$port} |
249 | my $mon = delete $AnyEvent::MP::Kernel::LMON{$port} |
| 250 | or !@reason |
250 | or !@reason |
| 251 | or $AnyEvent::MP::Kernel::WARN->("unmonitored local port $port died with reason: @reason"); |
251 | or $AnyEvent::MP::Kernel::WARN->(2, "unmonitored local port $port died with reason: @reason"); |
| 252 | |
252 | |
| 253 | $_->(@reason) for values %$mon; |
253 | $_->(@reason) for values %$mon; |
| 254 | } |
254 | } |
| 255 | |
255 | |
| 256 | sub monitor { |
256 | sub monitor { |
