| … | |
… | |
| 143 | } |
143 | } |
| 144 | |
144 | |
| 145 | sub _ANY_() { 1 } |
145 | sub _ANY_() { 1 } |
| 146 | sub _any_() { \&_ANY_ } |
146 | sub _any_() { \&_ANY_ } |
| 147 | |
147 | |
| 148 | sub TRACE() { 1 } |
148 | sub TRACE() { 0 } |
| 149 | |
149 | |
| 150 | sub _inject { |
150 | sub _inject { |
| 151 | warn "RCV $SRCNODE->{noderef} -> @_\n" if TRACE;#d# |
151 | warn "RCV $SRCNODE->{noderef} -> @_\n" if TRACE;#d# |
| 152 | &{ $PORT{+shift} or return }; |
152 | &{ $PORT{+shift} or return }; |
| 153 | } |
153 | } |
| … | |
… | |
| 276 | $cv->end; |
276 | $cv->end; |
| 277 | |
277 | |
| 278 | $cv |
278 | $cv |
| 279 | } |
279 | } |
| 280 | |
280 | |
| 281 | sub initialise_node($;@) { |
281 | sub initialise_node(@) { |
| 282 | my ($noderef, @others) = @_; |
282 | my ($noderef, @others) = @_; |
| 283 | |
283 | |
| 284 | if ($noderef =~ /^slave\/(.*)$/) { |
284 | if ($noderef =~ /^slave\/(.*)$/) { |
| 285 | $SLAVE = AE::cv; |
285 | $SLAVE = AE::cv; |
| 286 | my $name = $1; |
286 | my $name = $1; |
