| … | |
… | |
| 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 { |
