… | |
… | |
205 | } |
205 | } |
206 | |
206 | |
207 | sub snd(@) { |
207 | sub snd(@) { |
208 | my ($nodeid, $portid) = split /#/, shift, 2; |
208 | my ($nodeid, $portid) = split /#/, shift, 2; |
209 | |
209 | |
210 | warn "SND $nodeid <- " . eval { JSON::XS->new->encode ([$portid, @_]) } . "\n" if TRACE && @_; |
210 | warn "SND $nodeid <- " . eval { JSON::XS->new->encode (["$portid", @_]) } . "\n" if TRACE && @_; |
211 | |
211 | |
212 | ($NODE{$nodeid} || add_node $nodeid) |
212 | ($NODE{$nodeid} || add_node $nodeid) |
213 | ->{send} (["$portid", @_]); |
213 | ->{send} (["$portid", @_]); |
214 | } |
214 | } |
215 | |
215 | |