… | |
… | |
511 | }, |
511 | }, |
512 | |
512 | |
513 | # public services |
513 | # public services |
514 | |
514 | |
515 | # relay message to another node / generic echo |
515 | # relay message to another node / generic echo |
516 | relay => sub { |
516 | snd => \&snd, |
517 | &snd; |
|
|
518 | }, |
|
|
519 | relay_multiple => sub { |
517 | snd_multi => sub { |
520 | snd @$_ for @_ |
518 | snd @$_ for @_ |
521 | }, |
519 | }, |
522 | |
520 | |
523 | # informational |
521 | # informational |
524 | info => sub { |
522 | info => sub { |
… | |
… | |
539 | time => sub { |
537 | time => sub { |
540 | snd @_, AE::time; |
538 | snd @_, AE::time; |
541 | }, |
539 | }, |
542 | devnull => sub { |
540 | devnull => sub { |
543 | # |
541 | # |
|
|
542 | }, |
|
|
543 | "" => sub { |
|
|
544 | # empty messages are sent by monitoring |
544 | }, |
545 | }, |
545 | ); |
546 | ); |
546 | |
547 | |
547 | $NODE{""} = $NODE{$NODE} = new AnyEvent::MP::Node::Self noderef => $NODE; |
548 | $NODE{""} = $NODE{$NODE} = new AnyEvent::MP::Node::Self noderef => $NODE; |
548 | $PORT{""} = sub { |
549 | $PORT{""} = sub { |