| … | |
… | |
| 191 | mon $port, sub { |
191 | mon $port, sub { |
| 192 | unreg_groups $node; |
192 | unreg_groups $node; |
| 193 | delete $port{$node}; |
193 | delete $port{$node}; |
| 194 | }; |
194 | }; |
| 195 | |
195 | |
| 196 | snd $port, addr => $AnyEvent::MP::Kernel::LISTENER if @$AnyEvent::MP::Kernel::LISTENER; |
196 | snd $port, addr => $AnyEvent::MP::Kernel::LISTENER; |
| 197 | snd $port, connect_nodes => \%addr if %addr; |
197 | snd $port, connect_nodes => \%addr if %addr; |
| 198 | snd $port, set => \%lreg if %lreg; |
198 | snd $port, set => \%lreg if %lreg; |
| 199 | } |
199 | } |
| 200 | |
200 | |
| 201 | # other nodes connect via this |
201 | # other nodes connect via this |
