| … | |
… | |
| 105 | |
105 | |
| 106 | =cut |
106 | =cut |
| 107 | |
107 | |
| 108 | package AnyEvent::MP; |
108 | package AnyEvent::MP; |
| 109 | |
109 | |
| 110 | use AnyEvent::MP::Base; |
110 | use AnyEvent::MP::Kernel; |
| 111 | |
111 | |
| 112 | use common::sense; |
112 | use common::sense; |
| 113 | |
113 | |
| 114 | use Carp (); |
114 | use Carp (); |
| 115 | |
115 | |
| 116 | use AE (); |
116 | use AE (); |
| 117 | |
117 | |
| 118 | use base "Exporter"; |
118 | use base "Exporter"; |
| 119 | |
119 | |
| 120 | our $VERSION = '0.1'; |
120 | our $VERSION = $AnyEvent::MP::Kernel::VERSION; |
|
|
121 | |
| 121 | our @EXPORT = qw( |
122 | our @EXPORT = qw( |
| 122 | NODE $NODE *SELF node_of _any_ |
123 | NODE $NODE *SELF node_of _any_ |
| 123 | resolve_node initialise_node |
124 | resolve_node initialise_node |
| 124 | snd rcv mon kil reg psub spawn |
125 | snd rcv mon kil reg psub spawn |
| 125 | port |
126 | port |
| … | |
… | |
| 501 | |
502 | |
| 502 | =item $guard = mon $port |
503 | =item $guard = mon $port |
| 503 | |
504 | |
| 504 | =item $guard = mon $port, $rcvport, @msg |
505 | =item $guard = mon $port, $rcvport, @msg |
| 505 | |
506 | |
| 506 | Monitor the given port and do something when the port is killed, and |
507 | Monitor the given port and do something when the port is killed or |
| 507 | optionally return a guard that can be used to stop monitoring again. |
508 | messages to it were lost, and optionally return a guard that can be used |
|
|
509 | to stop monitoring again. |
|
|
510 | |
|
|
511 | C<mon> effectively guarantees that, in the absence of hardware failures, |
|
|
512 | that after starting the monitor, either all messages sent to the port |
|
|
513 | will arrive, or the monitoring action will be invoked after possible |
|
|
514 | message loss has been detected. No messages will be lost "in between" |
|
|
515 | (after the first lost message no further messages will be received by the |
|
|
516 | port). After the monitoring action was invoked, further messages might get |
|
|
517 | delivered again. |
| 508 | |
518 | |
| 509 | In the first form (callback), the callback is simply called with any |
519 | In the first form (callback), the callback is simply called with any |
| 510 | number of C<@reason> elements (no @reason means that the port was deleted |
520 | number of C<@reason> elements (no @reason means that the port was deleted |
| 511 | "normally"). Note also that I<< the callback B<must> never die >>, so use |
521 | "normally"). Note also that I<< the callback B<must> never die >>, so use |
| 512 | C<eval> if unsure. |
522 | C<eval> if unsure. |
| 513 | |
523 | |
| 514 | In the second form (another port given), the other port (C<$rcvport) |
524 | In the second form (another port given), the other port (C<$rcvport>) |
| 515 | will be C<kil>'ed with C<@reason>, iff a @reason was specified, i.e. on |
525 | will be C<kil>'ed with C<@reason>, iff a @reason was specified, i.e. on |
| 516 | "normal" kils nothing happens, while under all other conditions, the other |
526 | "normal" kils nothing happens, while under all other conditions, the other |
| 517 | port is killed with the same reason. |
527 | port is killed with the same reason. |
| 518 | |
528 | |
| 519 | The third form (kill self) is the same as the second form, except that |
529 | The third form (kill self) is the same as the second form, except that |
