ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent-MP/MP.pm
(Generate patch)

Comparing AnyEvent-MP/MP.pm (file contents):
Revision 1.147 by root, Mon Jun 20 16:58:15 2016 UTC vs.
Revision 1.154 by root, Fri Nov 15 09:47:38 2019 UTC

… …
204use AnyEvent (); 204use AnyEvent ();
205use Guard (); 205use Guard ();
206 206
207use base "Exporter"; 207use base "Exporter";
208 208
209our $VERSION = $AnyEvent::MP::Config::VERSION; 209our $VERSION = '2.02'; # also in MP/Config.pm
210 210
211our @EXPORT = qw( 211our @EXPORT = qw(
212 configure
213
212 NODE $NODE 214 NODE $NODE
213 configure 215 *SELF
216
214 node_of port_is_local 217 node_of port_is_local
218
215 snd kil 219 snd kil
216 db_set db_del
217 db_mon db_family db_keys db_values
218
219 *SELF
220
221 port rcv mon mon_guard psub peval spawn cal 220 port rcv mon mon_guard psub peval spawn cal
222 db_set db_del db_reg 221 db_set db_del db_reg
223 db_mon db_family db_keys db_values 222 db_mon db_family db_keys db_values
224 223
225 after 224 after
… …
311 310
312=item step 2, bind listener sockets 311=item step 2, bind listener sockets
313 312
314The next step is to look up the binds in the profile, followed by binding 313The next step is to look up the binds in the profile, followed by binding
315aemp protocol listeners on all binds specified (it is possible and valid 314aemp protocol listeners on all binds specified (it is possible and valid
316to have no binds, meaning that the node cannot be contacted form the 315to have no binds, meaning that the node cannot be contacted from the
317outside. This means the node cannot talk to other nodes that also have no 316outside. This means the node cannot talk to other nodes that also have no
318binds, but it can still talk to all "normal" nodes). 317binds, but it can still talk to all "normal" nodes).
319 318
320If the profile does not specify a binds list, then a default of C<*> is 319If the profile does not specify a binds list, then a default of C<*> is
321used, meaning the node will bind on a dynamically-assigned port on every 320used, meaning the node will bind on a dynamically-assigned port on every
… …
418=cut 417=cut
419 418
420sub rcv($@); 419sub rcv($@);
421 420
422my $KILME = sub { 421my $KILME = sub {
423 (my $tag = substr $_[0], 0, 30) =~ s/([\x20-\x7e])/./g; 422 (my $tag = substr $_[0], 0, 30) =~ s/([^\x20-\x7e])/./g;
424 kil $SELF, unhandled_message => "no callback found for message '$tag'"; 423 kil $SELF, unhandled_message => "no callback found for message '$tag'";
425}; 424};
426 425
427sub port(;&) { 426sub port(;&) {
428 my $id = $UNIQ . ++$ID; 427 my $id = $UNIQ . ++$ID;
… …
539 $port 538 $port
540} 539}
541 540
542=item peval $port, $coderef[, @args] 541=item peval $port, $coderef[, @args]
543 542
544Evaluates the given C<$codref> within the contetx of C<$port>, that is, 543Evaluates the given C<$codref> within the context of C<$port>, that is,
545when the code throws an exception the C<$port> will be killed. 544when the code throws an exception the C<$port> will be killed.
546 545
547Any remaining args will be passed to the callback. Any return values will 546Any remaining args will be passed to the callback. Any return values will
548be returned to the caller. 547be returned to the caller.
549 548
… …
651In the last form (message), a message of the form C<$rcvport, @msg, 650In the last form (message), a message of the form C<$rcvport, @msg,
652@reason> will be C<snd>. 651@reason> will be C<snd>.
653 652
654Monitoring-actions are one-shot: once messages are lost (and a monitoring 653Monitoring-actions are one-shot: once messages are lost (and a monitoring
655alert was raised), they are removed and will not trigger again, even if it 654alert was raised), they are removed and will not trigger again, even if it
656turns out that the port is still alive. 655turns out that the port is still alive (but monitoring actions added after
656that will again trigger).
657 657
658As a rule of thumb, monitoring requests should always monitor a remote 658As a rule of thumb, monitoring requests should always monitor a remote
659port locally (using a local C<$rcvport> or a callback). The reason is that 659port locally (using a local C<$rcvport> or a callback). The reason is that
660kill messages might get lost, just like any other message. Another less 660kill messages might get lost, just like any other message. Another less
661obvious reason is that even monitoring requests can get lost (for example, 661obvious reason is that even monitoring requests can get lost (for example,
… …
877#=item $cb2 = timeout $seconds, $cb[, @args] 877#=item $cb2 = timeout $seconds, $cb[, @args]
878 878
879=item cal $port, @msg, $callback[, $timeout] 879=item cal $port, @msg, $callback[, $timeout]
880 880
881A simple form of RPC - sends a message to the given C<$port> with the 881A simple form of RPC - sends a message to the given C<$port> with the
882given contents (C<@msg>), but adds a reply port to the message. 882given contents (C<@msg>), but appends a reply port to the message.
883 883
884The reply port is created temporarily just for the purpose of receiving 884The reply port is created temporarily just for the purpose of receiving
885the reply, and will be C<kil>ed when no longer needed. 885the reply, and will be C<kil>ed when no longer needed.
886 886
887A reply message sent to the port is passed to the C<$callback> as-is. 887A reply message sent to the port is passed to the C<$callback> as-is.
… …
1314C<grp_mon> can be replaced by C<db_mon> with minor changes - C<db_mon> 1314C<grp_mon> can be replaced by C<db_mon> with minor changes - C<db_mon>
1315passes a hash as first argument, and an extra C<$chg> argument that can be 1315passes a hash as first argument, and an extra C<$chg> argument that can be
1316ignored: 1316ignored:
1317 1317
1318 db_mon $group => sub { 1318 db_mon $group => sub {
1319 my ($ports, $add, $chg, $lde) = @_; 1319 my ($ports, $add, $chg, $del) = @_;
1320 $ports = [keys %$ports]; 1320 $ports = [keys %$ports];
1321 1321
1322 # now $ports, $add and $del are the same as 1322 # now $ports, $add and $del are the same as
1323 # were originally passed by grp_mon. 1323 # were originally passed by grp_mon.
1324 ... 1324 ...
… …
1378=back 1378=back
1379 1379
1380=head1 LOGGING 1380=head1 LOGGING
1381 1381
1382AnyEvent::MP does not normally log anything by itself, but since it is the 1382AnyEvent::MP does not normally log anything by itself, but since it is the
1383root of the contetx hierarchy for AnyEvent::MP modules, it will receive 1383root of the context hierarchy for AnyEvent::MP modules, it will receive
1384all log messages by submodules. 1384all log messages by submodules.
1385 1385
1386=head1 SEE ALSO 1386=head1 SEE ALSO
1387 1387
1388L<AnyEvent::MP::Intro> - a gentle introduction. 1388L<AnyEvent::MP::Intro> - a gentle introduction.

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines