| … | |
… | |
| 330 | addr => sub { |
330 | addr => sub { |
| 331 | my $addresses = shift; |
331 | my $addresses = shift; |
| 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 |
|
|
336 | # at the same time. |
|
|
337 | after 1 + rand 2, sub { |
| 335 | for my $slave (keys %SEEDME) { |
338 | for my $slave (keys %SEEDME) { |
| 336 | snd $port{$slave}, nodes => { $node => $addresses }; |
339 | snd $port{$slave}, nodes => { $node => $addresses }; |
|
|
340 | } |
| 337 | } |
341 | }; |
| 338 | }, |
342 | }, |
| 339 | nodes => sub { |
343 | nodes => sub { |
| 340 | my ($kv) = @_; |
344 | my ($kv) = @_; |
| 341 | |
345 | |
| 342 | use JSON::XS;#d# |
346 | use JSON::XS;#d# |
