… | |
… | |
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 |