… | |
… | |
182 | my ($noderef, $portid) = split /#/, shift, 2; |
182 | my ($noderef, $portid) = split /#/, shift, 2; |
183 | |
183 | |
184 | warn "SND $noderef <- $portid @_\n" if TRACE;#d# |
184 | warn "SND $noderef <- $portid @_\n" if TRACE;#d# |
185 | |
185 | |
186 | ($NODE{$noderef} || add_node $noderef) |
186 | ($NODE{$noderef} || add_node $noderef) |
187 | ->send (["$portid", @_]); |
187 | ->{send} (["$portid", @_]); |
188 | } |
188 | } |
189 | |
189 | |
190 | sub kil(@) { |
190 | sub kil(@) { |
191 | my ($noderef, $portid) = split /#/, shift, 2; |
191 | my ($noderef, $portid) = split /#/, shift, 2; |
192 | |
192 | |
… | |
… | |
314 | (my $via = $MASTER) =~ s/,/!/g; |
314 | (my $via = $MASTER) =~ s/,/!/g; |
315 | |
315 | |
316 | $NODE .= "\@$via"; |
316 | $NODE .= "\@$via"; |
317 | $NODE{$NODE} = $NODE{""}; |
317 | $NODE{$NODE} = $NODE{""}; |
318 | |
318 | |
319 | $_->send ([iam => $NODE]) |
319 | $_->send (["", iam => $NODE]) |
320 | for values %NODE; |
320 | for values %NODE; |
321 | |
321 | |
322 | $SLAVE = 1; |
322 | $SLAVE = 1; |
323 | } |
323 | } |
324 | } |
324 | } |