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.93 by root, Tue Sep 22 14:14:29 2009 UTC vs.
Revision 1.130 by root, Fri Mar 9 17:05:26 2012 UTC

30 rcv $port, pong => sub { warn "pong received\n" }; 30 rcv $port, pong => sub { warn "pong received\n" };
31 31
32 # create a port on another node 32 # create a port on another node
33 my $port = spawn $node, $initfunc, @initdata; 33 my $port = spawn $node, $initfunc, @initdata;
34 34
35 # destroy a port again
36 kil $port; # "normal" kill
37 kil $port, my_error => "everything is broken"; # error kill
38
35 # monitoring 39 # monitoring
36 mon $localport, $cb->(@msg) # callback is invoked on death 40 mon $port, $cb->(@msg) # callback is invoked on death
37 mon $localport, $otherport # kill otherport on abnormal death 41 mon $port, $localport # kill localport on abnormal death
38 mon $localport, $otherport, @msg # send message on death 42 mon $port, $localport, @msg # send message on death
43
44 # temporarily execute code in port context
45 peval $port, sub { die "kill the port!" };
46
47 # execute callbacks in $SELF port context
48 my $timer = AE::timer 1, 0, psub {
49 die "kill the port, delayed";
50 };
39 51
40=head1 CURRENT STATUS 52=head1 CURRENT STATUS
41 53
42 bin/aemp - stable. 54 bin/aemp - stable.
43 AnyEvent::MP - stable API, should work. 55 AnyEvent::MP - stable API, should work.
66 78
67Ports allow you to register C<rcv> handlers that can match all or just 79Ports allow you to register C<rcv> handlers that can match all or just
68some messages. Messages send to ports will not be queued, regardless of 80some messages. Messages send to ports will not be queued, regardless of
69anything was listening for them or not. 81anything was listening for them or not.
70 82
83Ports are represented by (printable) strings called "port IDs".
84
71=item port ID - C<nodeid#portname> 85=item port ID - C<nodeid#portname>
72 86
73A port ID is the concatenation of a node ID, a hash-mark (C<#>) as 87A port ID is the concatenation of a node ID, a hash-mark (C<#>)
74separator, and a port name (a printable string of unspecified format). 88as separator, and a port name (a printable string of unspecified
89format created by AnyEvent::MP).
75 90
76=item node 91=item node
77 92
78A node is a single process containing at least one port - the node port, 93A node is a single process containing at least one port - the node port,
79which enables nodes to manage each other remotely, and to create new 94which enables nodes to manage each other remotely, and to create new
80ports. 95ports.
81 96
82Nodes are either public (have one or more listening ports) or private 97Nodes are either public (have one or more listening ports) or private
83(no listening ports). Private nodes cannot talk to other private nodes 98(no listening ports). Private nodes cannot talk to other private nodes
84currently. 99currently, but all nodes can talk to public nodes.
85 100
101Nodes is represented by (printable) strings called "node IDs".
102
86=item node ID - C<[A-Z_][a-zA-Z0-9_\-.:]*> 103=item node ID - C<[A-Za-z0-9_\-.:]*>
87 104
88A node ID is a string that uniquely identifies the node within a 105A node ID is a string that uniquely identifies the node within a
89network. Depending on the configuration used, node IDs can look like a 106network. Depending on the configuration used, node IDs can look like a
90hostname, a hostname and a port, or a random string. AnyEvent::MP itself 107hostname, a hostname and a port, or a random string. AnyEvent::MP itself
91doesn't interpret node IDs in any way. 108doesn't interpret node IDs in any way except to uniquely identify a node.
92 109
93=item binds - C<ip:port> 110=item binds - C<ip:port>
94 111
95Nodes can only talk to each other by creating some kind of connection to 112Nodes can only talk to each other by creating some kind of connection to
96each other. To do this, nodes should listen on one or more local transport 113each other. To do this, nodes should listen on one or more local transport
114endpoints - binds.
115
97endpoints - binds. Currently, only standard C<ip:port> specifications can 116Currently, only standard C<ip:port> specifications can be used, which
98be used, which specify TCP ports to listen on. 117specify TCP ports to listen on. So a bind is basically just a tcp socket
118in listening mode thta accepts conenctions form other nodes.
99 119
100=item seed nodes 120=item seed nodes
101 121
102When a node starts, it knows nothing about the network. To teach the node 122When a node starts, it knows nothing about the network it is in - it
103about the network it first has to contact some other node within the 123needs to connect to at least one other node that is already in the
104network. This node is called a seed. 124network. These other nodes are called "seed nodes".
105 125
106Apart from the fact that other nodes know them as seed nodes and they have 126Seed nodes themselves are not special - they are seed nodes only because
107to have fixed listening addresses, seed nodes are perfectly normal nodes - 127some other node I<uses> them as such, but any node can be used as seed
108any node can function as a seed node for others. 128node for other nodes, and eahc node cna use a different set of seed nodes.
109 129
110In addition to discovering the network, seed nodes are also used to 130In addition to discovering the network, seed nodes are also used to
111maintain the network and to connect nodes that otherwise would have 131maintain the network - all nodes using the same seed node form are part of
112trouble connecting. They form the backbone of an AnyEvent::MP network. 132the same network. If a network is split into multiple subnets because e.g.
133the network link between the parts goes down, then using the same seed
134nodes for all nodes ensures that eventually the subnets get merged again.
113 135
114Seed nodes are expected to be long-running, and at least one seed node 136Seed nodes are expected to be long-running, and at least one seed node
115should always be available. They should also be relatively responsive - a 137should always be available. They should also be relatively responsive - a
116seed node that blocks for long periods will slow down everybody else. 138seed node that blocks for long periods will slow down everybody else.
117 139
140For small networks, it's best if every node uses the same set of seed
141nodes. For large networks, it can be useful to specify "regional" seed
142nodes for most nodes in an area, and use all seed nodes as seed nodes for
143each other. What's important is that all seed nodes connections form a
144complete graph, so that the network cannot split into separate subnets
145forever.
146
147Seed nodes are represented by seed IDs.
148
118=item seeds - C<host:port> 149=item seed IDs - C<host:port>
119 150
120Seeds are transport endpoint(s) (usually a hostname/IP address and a 151Seed IDs are transport endpoint(s) (usually a hostname/IP address and a
121TCP port) of nodes thta should be used as seed nodes. 152TCP port) of nodes that should be used as seed nodes.
122 153
123The nodes listening on those endpoints are expected to be long-running, 154=item global nodes
124and at least one of those should always be available. When nodes run out 155
125of connections (e.g. due to a network error), they try to re-establish 156An AEMP network needs a discovery service - nodes need to know how to
126connections to some seednodes again to join the network. 157connect to other nodes they only know by name. In addition, AEMP offers a
158distributed "group database", which maps group names to a list of strings
159- for example, to register worker ports.
160
161A network needs at least one global node to work, and allows every node to
162be a global node.
163
164Any node that loads the L<AnyEvent::MP::Global> module becomes a global
165node and tries to keep connections to all other nodes. So while it can
166make sense to make every node "global" in small networks, it usually makes
167sense to only make seed nodes into global nodes in large networks (nodes
168keep connections to seed nodes and global nodes, so makign them the same
169reduces overhead).
127 170
128=back 171=back
129 172
130=head1 VARIABLES/FUNCTIONS 173=head1 VARIABLES/FUNCTIONS
131 174
133 176
134=cut 177=cut
135 178
136package AnyEvent::MP; 179package AnyEvent::MP;
137 180
181use AnyEvent::MP::Config ();
138use AnyEvent::MP::Kernel; 182use AnyEvent::MP::Kernel;
183use AnyEvent::MP::Kernel qw(%NODE %PORT %PORT_DATA $UNIQ $RUNIQ $ID);
139 184
140use common::sense; 185use common::sense;
141 186
142use Carp (); 187use Carp ();
143 188
144use AE (); 189use AE ();
190use Guard ();
145 191
146use base "Exporter"; 192use base "Exporter";
147 193
148our $VERSION = $AnyEvent::MP::Kernel::VERSION; 194our $VERSION = $AnyEvent::MP::Config::VERSION;
149 195
150our @EXPORT = qw( 196our @EXPORT = qw(
151 NODE $NODE *SELF node_of after 197 NODE $NODE *SELF node_of after
152 configure 198 configure
153 snd rcv mon mon_guard kil psub spawn cal 199 snd rcv mon mon_guard kil psub peval spawn cal
154 port 200 port
201 db_set db_del db_reg
202 db_mon db_family db_keys db_values
155); 203);
156 204
157our $SELF; 205our $SELF;
158 206
159sub _self_die() { 207sub _self_die() {
182some other nodes in the network to discover other nodes. 230some other nodes in the network to discover other nodes.
183 231
184This function configures a node - it must be called exactly once (or 232This function configures a node - it must be called exactly once (or
185never) before calling other AnyEvent::MP functions. 233never) before calling other AnyEvent::MP functions.
186 234
235The key/value pairs are basically the same ones as documented for the
236F<aemp> command line utility (sans the set/del prefix), with these additions:
237
238=over 4
239
240=item norc => $boolean (default false)
241
242If true, then the rc file (e.g. F<~/.perl-anyevent-mp>) will I<not>
243be consulted - all configuraiton options must be specified in the
244C<configure> call.
245
246=item force => $boolean (default false)
247
248IF true, then the values specified in the C<configure> will take
249precedence over any values configured via the rc file. The default is for
250the rc file to override any options specified in the program.
251
252=item secure => $pass->($nodeid)
253
254In addition to specifying a boolean, you can specify a code reference that
255is called for every remote execution attempt - the execution request is
256granted iff the callback returns a true value.
257
258See F<semp setsecure> for more info.
259
260=back
261
187=over 4 262=over 4
188 263
189=item step 1, gathering configuration from profiles 264=item step 1, gathering configuration from profiles
190 265
191The function first looks up a profile in the aemp configuration (see the 266The function first looks up a profile in the aemp configuration (see the
204That means that the values specified in the profile have highest priority 279That means that the values specified in the profile have highest priority
205and the values specified directly via C<configure> have lowest priority, 280and the values specified directly via C<configure> have lowest priority,
206and can only be used to specify defaults. 281and can only be used to specify defaults.
207 282
208If the profile specifies a node ID, then this will become the node ID of 283If the profile specifies a node ID, then this will become the node ID of
209this process. If not, then the profile name will be used as node ID. The 284this process. If not, then the profile name will be used as node ID, with
210special node ID of C<anon/> will be replaced by a random node ID. 285a unique randoms tring (C</%u>) appended.
286
287The node ID can contain some C<%> sequences that are expanded: C<%n>
288is expanded to the local nodename, C<%u> is replaced by a random
289strign to make the node unique. For example, the F<aemp> commandline
290utility uses C<aemp/%n/%u> as nodename, which might expand to
291C<aemp/cerebro/ZQDGSIkRhEZQDGSIkRhE>.
211 292
212=item step 2, bind listener sockets 293=item step 2, bind listener sockets
213 294
214The next step is to look up the binds in the profile, followed by binding 295The next step is to look up the binds in the profile, followed by binding
215aemp protocol listeners on all binds specified (it is possible and valid 296aemp protocol listeners on all binds specified (it is possible and valid
221used, meaning the node will bind on a dynamically-assigned port on every 302used, meaning the node will bind on a dynamically-assigned port on every
222local IP address it finds. 303local IP address it finds.
223 304
224=item step 3, connect to seed nodes 305=item step 3, connect to seed nodes
225 306
226As the last step, the seeds list from the profile is passed to the 307As the last step, the seed ID list from the profile is passed to the
227L<AnyEvent::MP::Global> module, which will then use it to keep 308L<AnyEvent::MP::Global> module, which will then use it to keep
228connectivity with at least one node at any point in time. 309connectivity with at least one node at any point in time.
229 310
230=back 311=back
231 312
232Example: become a distributed node using the local node name as profile. 313Example: become a distributed node using the local node name as profile.
233This should be the most common form of invocation for "daemon"-type nodes. 314This should be the most common form of invocation for "daemon"-type nodes.
234 315
235 configure 316 configure
236 317
237Example: become an anonymous node. This form is often used for commandline 318Example: become a semi-anonymous node. This form is often used for
238clients. 319commandline clients.
239 320
240 configure nodeid => "anon/"; 321 configure nodeid => "myscript/%n/%u";
241 322
242Example: configure a node using a profile called seed, which si suitable 323Example: configure a node using a profile called seed, which is suitable
243for a seed node as it binds on all local addresses on a fixed port (4040, 324for a seed node as it binds on all local addresses on a fixed port (4040,
244customary for aemp). 325customary for aemp).
245 326
246 # use the aemp commandline utility 327 # use the aemp commandline utility
247 # aemp profile seed nodeid anon/ binds '*:4040' 328 # aemp profile seed binds '*:4040'
248 329
249 # then use it 330 # then use it
250 configure profile => "seed"; 331 configure profile => "seed";
251 332
252 # or simply use aemp from the shell again: 333 # or simply use aemp from the shell again:
322sub _kilme { 403sub _kilme {
323 die "received message on port without callback"; 404 die "received message on port without callback";
324} 405}
325 406
326sub port(;&) { 407sub port(;&) {
327 my $id = "$UNIQ." . $ID++; 408 my $id = $UNIQ . ++$ID;
328 my $port = "$NODE#$id"; 409 my $port = "$NODE#$id";
329 410
330 rcv $port, shift || \&_kilme; 411 rcv $port, shift || \&_kilme;
331 412
332 $port 413 $port
371 msg1 => sub { ... }, 452 msg1 => sub { ... },
372 ... 453 ...
373 ; 454 ;
374 455
375Example: temporarily register a rcv callback for a tag matching some port 456Example: temporarily register a rcv callback for a tag matching some port
376(e.g. for a rpc reply) and unregister it after a message was received. 457(e.g. for an rpc reply) and unregister it after a message was received.
377 458
378 rcv $port, $otherport => sub { 459 rcv $port, $otherport => sub {
379 my @reply = @_; 460 my @reply = @_;
380 461
381 rcv $SELF, $otherport; 462 rcv $SELF, $otherport;
394 if (ref $_[0]) { 475 if (ref $_[0]) {
395 if (my $self = $PORT_DATA{$portid}) { 476 if (my $self = $PORT_DATA{$portid}) {
396 "AnyEvent::MP::Port" eq ref $self 477 "AnyEvent::MP::Port" eq ref $self
397 or Carp::croak "$port: rcv can only be called on message matching ports, caught"; 478 or Carp::croak "$port: rcv can only be called on message matching ports, caught";
398 479
399 $self->[2] = shift; 480 $self->[0] = shift;
400 } else { 481 } else {
401 my $cb = shift; 482 my $cb = shift;
402 $PORT{$portid} = sub { 483 $PORT{$portid} = sub {
403 local $SELF = $port; 484 local $SELF = $port;
404 eval { &$cb }; _self_die if $@; 485 eval { &$cb }; _self_die if $@;
405 }; 486 };
406 } 487 }
407 } elsif (defined $_[0]) { 488 } elsif (defined $_[0]) {
408 my $self = $PORT_DATA{$portid} ||= do { 489 my $self = $PORT_DATA{$portid} ||= do {
409 my $self = bless [$PORT{$port} || sub { }, { }, $port], "AnyEvent::MP::Port"; 490 my $self = bless [$PORT{$portid} || sub { }, { }, $port], "AnyEvent::MP::Port";
410 491
411 $PORT{$portid} = sub { 492 $PORT{$portid} = sub {
412 local $SELF = $port; 493 local $SELF = $port;
413 494
414 if (my $cb = $self->[1]{$_[0]}) { 495 if (my $cb = $self->[1]{$_[0]}) {
436 } 517 }
437 518
438 $port 519 $port
439} 520}
440 521
522=item peval $port, $coderef[, @args]
523
524Evaluates the given C<$codref> within the contetx of C<$port>, that is,
525when the code throews an exception the C<$port> will be killed.
526
527Any remaining args will be passed to the callback. Any return values will
528be returned to the caller.
529
530This is useful when you temporarily want to execute code in the context of
531a port.
532
533Example: create a port and run some initialisation code in it's context.
534
535 my $port = port { ... };
536
537 peval $port, sub {
538 init
539 or die "unable to init";
540 };
541
542=cut
543
544sub peval($$) {
545 local $SELF = shift;
546 my $cb = shift;
547
548 if (wantarray) {
549 my @res = eval { &$cb };
550 _self_die if $@;
551 @res
552 } else {
553 my $res = eval { &$cb };
554 _self_die if $@;
555 $res
556 }
557}
558
441=item $closure = psub { BLOCK } 559=item $closure = psub { BLOCK }
442 560
443Remembers C<$SELF> and creates a closure out of the BLOCK. When the 561Remembers C<$SELF> and creates a closure out of the BLOCK. When the
444closure is executed, sets up the environment in the same way as in C<rcv> 562closure is executed, sets up the environment in the same way as in C<rcv>
445callbacks, i.e. runtime errors will cause the port to get C<kil>ed. 563callbacks, i.e. runtime errors will cause the port to get C<kil>ed.
564
565The effect is basically as if it returned C<< sub { peval $SELF, sub {
566BLOCK }, @_ } >>.
446 567
447This is useful when you register callbacks from C<rcv> callbacks: 568This is useful when you register callbacks from C<rcv> callbacks:
448 569
449 rcv delayed_reply => sub { 570 rcv delayed_reply => sub {
450 my ($delay, @reply) = @_; 571 my ($delay, @reply) = @_;
523delivered again. 644delivered again.
524 645
525Inter-host-connection timeouts and monitoring depend on the transport 646Inter-host-connection timeouts and monitoring depend on the transport
526used. The only transport currently implemented is TCP, and AnyEvent::MP 647used. The only transport currently implemented is TCP, and AnyEvent::MP
527relies on TCP to detect node-downs (this can take 10-15 minutes on a 648relies on TCP to detect node-downs (this can take 10-15 minutes on a
528non-idle connection, and usually around two hours for idle conenctions). 649non-idle connection, and usually around two hours for idle connections).
529 650
530This means that monitoring is good for program errors and cleaning up 651This means that monitoring is good for program errors and cleaning up
531stuff eventually, but they are no replacement for a timeout when you need 652stuff eventually, but they are no replacement for a timeout when you need
532to ensure some maximum latency. 653to ensure some maximum latency.
533 654
565 } 686 }
566 687
567 $node->monitor ($port, $cb); 688 $node->monitor ($port, $cb);
568 689
569 defined wantarray 690 defined wantarray
570 and $cb += 0
571 and AnyEvent::Util::guard { $node->unmonitor ($port, $cb) } 691 and ($cb += 0, Guard::guard { $node->unmonitor ($port, $cb) })
572} 692}
573 693
574=item $guard = mon_guard $port, $ref, $ref... 694=item $guard = mon_guard $port, $ref, $ref...
575 695
576Monitors the given C<$port> and keeps the passed references. When the port 696Monitors the given C<$port> and keeps the passed references. When the port
599 719
600=item kil $port[, @reason] 720=item kil $port[, @reason]
601 721
602Kill the specified port with the given C<@reason>. 722Kill the specified port with the given C<@reason>.
603 723
604If no C<@reason> is specified, then the port is killed "normally" (ports 724If no C<@reason> is specified, then the port is killed "normally" -
605monitoring other ports will not necessarily die because a port dies 725monitor callback will be invoked, but the kil will not cause linked ports
606"normally"). 726(C<mon $mport, $lport> form) to get killed.
607 727
608Otherwise, linked ports get killed with the same reason (second form of 728If a C<@reason> is specified, then linked ports (C<mon $mport, $lport>
609C<mon>, see above). 729form) get killed with the same reason.
610 730
611Runtime errors while evaluating C<rcv> callbacks or inside C<psub> blocks 731Runtime errors while evaluating C<rcv> callbacks or inside C<psub> blocks
612will be reported as reason C<< die => $@ >>. 732will be reported as reason C<< die => $@ >>.
613 733
614Transport/communication errors are reported as C<< transport_error => 734Transport/communication errors are reported as C<< transport_error =>
680} 800}
681 801
682sub spawn(@) { 802sub spawn(@) {
683 my ($nodeid, undef) = split /#/, shift, 2; 803 my ($nodeid, undef) = split /#/, shift, 2;
684 804
685 my $id = "$RUNIQ." . $ID++; 805 my $id = $RUNIQ . ++$ID;
686 806
687 $_[0] =~ /::/ 807 $_[0] =~ /::/
688 or Carp::croak "spawn init function must be a fully-qualified name, caught"; 808 or Carp::croak "spawn init function must be a fully-qualified name, caught";
689 809
690 snd_to_func $nodeid, "AnyEvent::MP::_spawn" => $id, @_; 810 snd_to_func $nodeid, "AnyEvent::MP::_spawn" => $id, @_;
691 811
692 "$nodeid#$id" 812 "$nodeid#$id"
693} 813}
814
694 815
695=item after $timeout, @msg 816=item after $timeout, @msg
696 817
697=item after $timeout, $callback 818=item after $timeout, $callback
698 819
714 ? $action[0]() 835 ? $action[0]()
715 : snd @action; 836 : snd @action;
716 }; 837 };
717} 838}
718 839
840#=item $cb2 = timeout $seconds, $cb[, @args]
841
719=item cal $port, @msg, $callback[, $timeout] 842=item cal $port, @msg, $callback[, $timeout]
720 843
721A simple form of RPC - sends a message to the given C<$port> with the 844A simple form of RPC - sends a message to the given C<$port> with the
722given contents (C<@msg>), but adds a reply port to the message. 845given contents (C<@msg>), but adds a reply port to the message.
723 846
728 851
729If an optional time-out (in seconds) is given and it is not C<undef>, 852If an optional time-out (in seconds) is given and it is not C<undef>,
730then the callback will be called without any arguments after the time-out 853then the callback will be called without any arguments after the time-out
731elapsed and the port is C<kil>ed. 854elapsed and the port is C<kil>ed.
732 855
733If no time-out is given, then the local port will monitor the remote port 856If no time-out is given (or it is C<undef>), then the local port will
734instead, so it eventually gets cleaned-up. 857monitor the remote port instead, so it eventually gets cleaned-up.
735 858
736Currently this function returns the temporary port, but this "feature" 859Currently this function returns the temporary port, but this "feature"
737might go in future versions unless you can make a convincing case that 860might go in future versions unless you can make a convincing case that
738this is indeed useful for something. 861this is indeed useful for something.
739 862
768 $port 891 $port
769} 892}
770 893
771=back 894=back
772 895
896=head1 DISTRIBUTED DATABASE
897
898AnyEvent::MP comes with a simple distributed database. The database will
899be mirrored asynchronously at all global nodes. Other nodes bind to one of
900the global nodes for their needs.
901
902The database consists of a two-level hash - a hash contains a hash which
903contains values.
904
905The top level hash key is called "family", and the second-level hash key
906is called "subkey" or simply "key".
907
908The family must be alphanumeric, i.e. start with a letter and consist
909of letters, digits, underscores and colons (C<[A-Za-z][A-Za-z0-9_:]*>,
910pretty much like Perl module names.
911
912As the family namespace is global, it is recommended to prefix family names
913with the name of the application or module using it.
914
915The subkeys must be non-empty strings, with no further restrictions.
916
917The values should preferably be strings, but other perl scalars should
918work as well (such as undef, arrays and hashes).
919
920Every database entry is owned by one node - adding the same family/subkey
921combination on multiple nodes will not cause discomfort for AnyEvent::MP,
922but the result might be nondeterministic, i.e. the key might have
923different values on different nodes.
924
925Different subkeys in the same family can be owned by different nodes
926without problems, and in fact, this is the common method to create worker
927pools. For example, a worker port for image scaling might do this:
928
929 db_set my_image_scalers => $port;
930
931And clients looking for an image scaler will want to get the
932C<my_image_scalers> keys from time to time:
933
934 db_keys my_image_scalers => sub {
935 @ports = @{ $_[0] };
936 };
937
938Or better yet, they want to monitor the database family, so they always
939have a reasonable up-to-date copy:
940
941 db_mon my_image_scalers => sub {
942 @ports = keys %{ $_[0] };
943 };
944
945In general, you can set or delete single subkeys, but query and monitor
946whole families only.
947
948If you feel the need to monitor or query a single subkey, try giving it
949it's own family.
950
951=over
952
953=item db_set $family => $subkey [=> $value]
954
955Sets (or replaces) a key to the database - if C<$value> is omitted,
956C<undef> is used instead.
957
958=item db_del $family => $subkey...
959
960Deletes one or more subkeys from the database family.
961
962=item $guard = db_reg $family => $subkey [=> $value]
963
964Sets the key on the database and returns a guard. When the guard is
965destroyed, the key is deleted from the database. If C<$value> is missing,
966then C<undef> is used.
967
968=item db_family $family => $cb->(\%familyhash)
969
970Queries the named database C<$family> and call the callback with the
971family represented as a hash. You can keep and freely modify the hash.
972
973=item db_keys $family => $cb->(\@keys)
974
975Same as C<db_family>, except it only queries the family I<subkeys> and passes
976them as array reference to the callback.
977
978=item db_values $family => $cb->(\@values)
979
980Same as C<db_family>, except it only queries the family I<values> and passes them
981as array reference to the callback.
982
983=item $guard = db_mon $family => $cb->($familyhash, \@added, \@changed, \@deleted)
984
985Creates a monitor on the given database family. Each time a key is set
986or or is deleted the callback is called with a hash containing the
987database family and three lists of added, changed and deleted subkeys,
988respectively. If no keys have changed then the array reference might be
989C<undef> or even missing.
990
991The family hash reference and the key arrays belong to AnyEvent::MP and
992B<must not be modified or stored> by the callback. When in doubt, make a
993copy.
994
995As soon as possible after the monitoring starts, the callback will be
996called with the intiial contents of the family, even if it is empty,
997i.e. there will always be a timely call to the callback with the current
998contents.
999
1000It is possible that the callback is called with a change event even though
1001the subkey is already present and the value has not changed.
1002
1003The monitoring stops when the guard object is destroyed.
1004
1005Example: on every change to the family "mygroup", print out all keys.
1006
1007 my $guard = db_mon mygroup => sub {
1008 my ($family, $a, $c, $d) = @_;
1009 print "mygroup members: ", (join " ", keys %$family), "\n";
1010 };
1011
1012Exmaple: wait until the family "My::Module::workers" is non-empty.
1013
1014 my $guard; $guard = db_mon My::Module::workers => sub {
1015 my ($family, $a, $c, $d) = @_;
1016 return unless %$family;
1017 undef $guard;
1018 print "My::Module::workers now nonempty\n";
1019 };
1020
1021Example: print all changes to the family "AnyRvent::Fantasy::Module".
1022
1023 my $guard = db_mon AnyRvent::Fantasy::Module => sub {
1024 my ($family, $a, $c, $d) = @_;
1025
1026 print "+$_=$family->{$_}\n" for @$a;
1027 print "*$_=$family->{$_}\n" for @$c;
1028 print "-$_=$family->{$_}\n" for @$d;
1029 };
1030
1031=cut
1032
1033=back
1034
773=head1 AnyEvent::MP vs. Distributed Erlang 1035=head1 AnyEvent::MP vs. Distributed Erlang
774 1036
775AnyEvent::MP got lots of its ideas from distributed Erlang (Erlang node 1037AnyEvent::MP got lots of its ideas from distributed Erlang (Erlang node
776== aemp node, Erlang process == aemp port), so many of the documents and 1038== aemp node, Erlang process == aemp port), so many of the documents and
777programming techniques employed by Erlang apply to AnyEvent::MP. Here is a 1039programming techniques employed by Erlang apply to AnyEvent::MP. Here is a
778sample: 1040sample:
779 1041
780 http://www.Erlang.se/doc/programming_rules.shtml 1042 http://www.erlang.se/doc/programming_rules.shtml
781 http://Erlang.org/doc/getting_started/part_frame.html # chapters 3 and 4 1043 http://erlang.org/doc/getting_started/part_frame.html # chapters 3 and 4
782 http://Erlang.org/download/Erlang-book-part1.pdf # chapters 5 and 6 1044 http://erlang.org/download/erlang-book-part1.pdf # chapters 5 and 6
783 http://Erlang.org/download/armstrong_thesis_2003.pdf # chapters 4 and 5 1045 http://erlang.org/download/armstrong_thesis_2003.pdf # chapters 4 and 5
784 1046
785Despite the similarities, there are also some important differences: 1047Despite the similarities, there are also some important differences:
786 1048
787=over 4 1049=over 4
788 1050
789=item * Node IDs are arbitrary strings in AEMP. 1051=item * Node IDs are arbitrary strings in AEMP.
790 1052
791Erlang relies on special naming and DNS to work everywhere in the same 1053Erlang relies on special naming and DNS to work everywhere in the same
792way. AEMP relies on each node somehow knowing its own address(es) (e.g. by 1054way. AEMP relies on each node somehow knowing its own address(es) (e.g. by
793configuration or DNS), but will otherwise discover other odes itself. 1055configuration or DNS), and possibly the addresses of some seed nodes, but
1056will otherwise discover other nodes (and their IDs) itself.
794 1057
795=item * Erlang has a "remote ports are like local ports" philosophy, AEMP 1058=item * Erlang has a "remote ports are like local ports" philosophy, AEMP
796uses "local ports are like remote ports". 1059uses "local ports are like remote ports".
797 1060
798The failure modes for local ports are quite different (runtime errors 1061The failure modes for local ports are quite different (runtime errors
807ports being the special case/exception, where transport errors cannot 1070ports being the special case/exception, where transport errors cannot
808occur. 1071occur.
809 1072
810=item * Erlang uses processes and a mailbox, AEMP does not queue. 1073=item * Erlang uses processes and a mailbox, AEMP does not queue.
811 1074
812Erlang uses processes that selectively receive messages, and therefore 1075Erlang uses processes that selectively receive messages out of order, and
813needs a queue. AEMP is event based, queuing messages would serve no 1076therefore needs a queue. AEMP is event based, queuing messages would serve
814useful purpose. For the same reason the pattern-matching abilities of 1077no useful purpose. For the same reason the pattern-matching abilities
815AnyEvent::MP are more limited, as there is little need to be able to 1078of AnyEvent::MP are more limited, as there is little need to be able to
816filter messages without dequeuing them. 1079filter messages without dequeuing them.
817 1080
818(But see L<Coro::MP> for a more Erlang-like process model on top of AEMP). 1081This is not a philosophical difference, but simply stems from AnyEvent::MP
1082being event-based, while Erlang is process-based.
1083
1084You cna have a look at L<Coro::MP> for a more Erlang-like process model on
1085top of AEMP and Coro threads.
819 1086
820=item * Erlang sends are synchronous, AEMP sends are asynchronous. 1087=item * Erlang sends are synchronous, AEMP sends are asynchronous.
821 1088
822Sending messages in Erlang is synchronous and blocks the process (and 1089Sending messages in Erlang is synchronous and blocks the process until
1090a conenction has been established and the message sent (and so does not
823so does not need a queue that can overflow). AEMP sends are immediate, 1091need a queue that can overflow). AEMP sends return immediately, connection
824connection establishment is handled in the background. 1092establishment is handled in the background.
825 1093
826=item * Erlang suffers from silent message loss, AEMP does not. 1094=item * Erlang suffers from silent message loss, AEMP does not.
827 1095
828Erlang makes few guarantees on messages delivery - messages can get lost 1096Erlang implements few guarantees on messages delivery - messages can get
829without any of the processes realising it (i.e. you send messages a, b, 1097lost without any of the processes realising it (i.e. you send messages a,
830and c, and the other side only receives messages a and c). 1098b, and c, and the other side only receives messages a and c).
831 1099
832AEMP guarantees correct ordering, and the guarantee that after one message 1100AEMP guarantees (modulo hardware errors) correct ordering, and the
833is lost, all following ones sent to the same port are lost as well, until 1101guarantee that after one message is lost, all following ones sent to the
834monitoring raises an error, so there are no silent "holes" in the message 1102same port are lost as well, until monitoring raises an error, so there are
835sequence. 1103no silent "holes" in the message sequence.
1104
1105If you want your software to be very reliable, you have to cope with
1106corrupted and even out-of-order messages in both Erlang and AEMP. AEMP
1107simply tries to work better in common error cases, such as when a network
1108link goes down.
836 1109
837=item * Erlang can send messages to the wrong port, AEMP does not. 1110=item * Erlang can send messages to the wrong port, AEMP does not.
838 1111
839In Erlang it is quite likely that a node that restarts reuses a process ID 1112In Erlang it is quite likely that a node that restarts reuses an Erlang
840known to other nodes for a completely different process, causing messages 1113process ID known to other nodes for a completely different process,
841destined for that process to end up in an unrelated process. 1114causing messages destined for that process to end up in an unrelated
1115process.
842 1116
843AEMP never reuses port IDs, so old messages or old port IDs floating 1117AEMP does not reuse port IDs, so old messages or old port IDs floating
844around in the network will not be sent to an unrelated port. 1118around in the network will not be sent to an unrelated port.
845 1119
846=item * Erlang uses unprotected connections, AEMP uses secure 1120=item * Erlang uses unprotected connections, AEMP uses secure
847authentication and can use TLS. 1121authentication and can use TLS.
848 1122
851 1125
852=item * The AEMP protocol is optimised for both text-based and binary 1126=item * The AEMP protocol is optimised for both text-based and binary
853communications. 1127communications.
854 1128
855The AEMP protocol, unlike the Erlang protocol, supports both programming 1129The AEMP protocol, unlike the Erlang protocol, supports both programming
856language independent text-only protocols (good for debugging) and binary, 1130language independent text-only protocols (good for debugging), and binary,
857language-specific serialisers (e.g. Storable). By default, unless TLS is 1131language-specific serialisers (e.g. Storable). By default, unless TLS is
858used, the protocol is actually completely text-based. 1132used, the protocol is actually completely text-based.
859 1133
860It has also been carefully designed to be implementable in other languages 1134It has also been carefully designed to be implementable in other languages
861with a minimum of work while gracefully degrading functionality to make the 1135with a minimum of work while gracefully degrading functionality to make the
862protocol simple. 1136protocol simple.
863 1137
864=item * AEMP has more flexible monitoring options than Erlang. 1138=item * AEMP has more flexible monitoring options than Erlang.
865 1139
866In Erlang, you can chose to receive I<all> exit signals as messages 1140In Erlang, you can chose to receive I<all> exit signals as messages or
867or I<none>, there is no in-between, so monitoring single processes is 1141I<none>, there is no in-between, so monitoring single Erlang processes is
868difficult to implement. Monitoring in AEMP is more flexible than in 1142difficult to implement.
869Erlang, as one can choose between automatic kill, exit message or callback 1143
870on a per-process basis. 1144Monitoring in AEMP is more flexible than in Erlang, as one can choose
1145between automatic kill, exit message or callback on a per-port basis.
871 1146
872=item * Erlang tries to hide remote/local connections, AEMP does not. 1147=item * Erlang tries to hide remote/local connections, AEMP does not.
873 1148
874Monitoring in Erlang is not an indicator of process death/crashes, in the 1149Monitoring in Erlang is not an indicator of process death/crashes, in the
875same way as linking is (except linking is unreliable in Erlang). 1150same way as linking is (except linking is unreliable in Erlang).
897overhead, as well as having to keep a proxy object everywhere. 1172overhead, as well as having to keep a proxy object everywhere.
898 1173
899Strings can easily be printed, easily serialised etc. and need no special 1174Strings can easily be printed, easily serialised etc. and need no special
900procedures to be "valid". 1175procedures to be "valid".
901 1176
902And as a result, a miniport consists of a single closure stored in a 1177And as a result, a port with just a default receiver consists of a single
903global hash - it can't become much cheaper. 1178code reference stored in a global hash - it can't become much cheaper.
904 1179
905=item Why favour JSON, why not a real serialising format such as Storable? 1180=item Why favour JSON, why not a real serialising format such as Storable?
906 1181
907In fact, any AnyEvent::MP node will happily accept Storable as framing 1182In fact, any AnyEvent::MP node will happily accept Storable as framing
908format, but currently there is no way to make a node use Storable by 1183format, but currently there is no way to make a node use Storable by
924 1199
925L<AnyEvent::MP::Intro> - a gentle introduction. 1200L<AnyEvent::MP::Intro> - a gentle introduction.
926 1201
927L<AnyEvent::MP::Kernel> - more, lower-level, stuff. 1202L<AnyEvent::MP::Kernel> - more, lower-level, stuff.
928 1203
929L<AnyEvent::MP::Global> - network maintainance and port groups, to find 1204L<AnyEvent::MP::Global> - network maintenance and port groups, to find
930your applications. 1205your applications.
1206
1207L<AnyEvent::MP::DataConn> - establish data connections between nodes.
931 1208
932L<AnyEvent::MP::LogCatcher> - simple service to display log messages from 1209L<AnyEvent::MP::LogCatcher> - simple service to display log messages from
933all nodes. 1210all nodes.
934 1211
935L<AnyEvent>. 1212L<AnyEvent>.

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines