| … | |
… | |
| 128 | }; |
128 | }; |
| 129 | |
129 | |
| 130 | initialise_node "slave/", $node; |
130 | initialise_node "slave/", $node; |
| 131 | |
131 | |
| 132 | my $reply = port { |
132 | my $reply = port { |
|
|
133 | my ($node, @neigh) = @_; |
|
|
134 | |
|
|
135 | @neigh = grep $_ ne $NODE, @neigh; |
|
|
136 | |
| 133 | print +(join " ", @_), "\n"; |
137 | print +(join " ", $node, @neigh), "\n"; |
| 134 | |
138 | |
| 135 | shift; |
|
|
| 136 | for (@_) { |
139 | for (@neigh) { |
| 137 | unless ($seen{$_}++) { |
140 | unless ($seen{$_}++) { |
| 138 | $cv->begin; |
141 | $cv->begin; |
| 139 | snd $_, up_nodes => $SELF => $_; |
142 | snd $_, up_nodes => $SELF => $_; |
| 140 | } |
143 | } |
| 141 | } |
144 | } |
