… | |
… | |
267 | my $kv_txt = JSON::XS->new->encode ($kv);#d# |
267 | my $kv_txt = JSON::XS->new->encode ($kv);#d# |
268 | $AnyEvent::MP::Kernel::WARN->(9, "$node told us it knows about $kv_txt.");#d# |
268 | $AnyEvent::MP::Kernel::WARN->(9, "$node told us it knows about $kv_txt.");#d# |
269 | |
269 | |
270 | while (my ($id, $addresses) = each %$kv) { |
270 | while (my ($id, $addresses) = each %$kv) { |
271 | my $node = AnyEvent::MP::Kernel::add_node $id; |
271 | my $node = AnyEvent::MP::Kernel::add_node $id; |
272 | $node->connect (@$addresses); |
272 | #$node->connect (@$addresses); |
|
|
273 | #d# |
|
|
274 | die; |
273 | start_node $id; |
275 | start_node $id; |
274 | } |
276 | } |
275 | }, |
277 | }, |
276 | set => sub { |
278 | set => sub { |
277 | set_groups $node, shift; |
279 | set_groups $node, shift; |