| … | |
… | |
| 332 | $AnyEvent::MP::Kernel::WARN->(9, "$node told us its addresses (@$addresses)."); |
332 | $AnyEvent::MP::Kernel::WARN->(9, "$node told us its addresses (@$addresses)."); |
| 333 | $addr{$node} = $addresses; |
333 | $addr{$node} = $addresses; |
| 334 | |
334 | |
| 335 | # delay broadcast by a random amount, to avoid nodes connecting to each other |
335 | # delay broadcast by a random amount, to avoid nodes connecting to each other |
| 336 | # at the same time. |
336 | # at the same time. |
| 337 | after 1 + rand 2, sub { |
337 | after 2 + rand, sub { |
| 338 | for my $slave (keys %SEEDME) { |
338 | for my $slave (keys %SEEDME) { |
| 339 | snd $port{$slave}, nodes => { $node => $addresses }; |
339 | snd $port{$slave} || next, nodes => { $node => $addresses }; |
| 340 | } |
340 | } |
| 341 | }; |
341 | }; |
| 342 | }, |
342 | }, |
| 343 | nodes => sub { |
343 | nodes => sub { |
| 344 | my ($kv) = @_; |
344 | my ($kv) = @_; |
