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

Comparing cvsroot/AnyEvent-MP/MP.pm (file contents):
Revision 1.76 by root, Mon Aug 31 18:45:05 2009 UTC vs.
Revision 1.93 by root, Tue Sep 22 14:14:29 2009 UTC

1=head1 NAME 1=head1 NAME
2 2
3AnyEvent::MP - multi-processing/message-passing framework 3AnyEvent::MP - erlang-style multi-processing/message-passing framework
4 4
5=head1 SYNOPSIS 5=head1 SYNOPSIS
6 6
7 use AnyEvent::MP; 7 use AnyEvent::MP;
8 8
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 # monitoring 35 # monitoring
36 mon $port, $cb->(@msg) # callback is invoked on death 36 mon $localport, $cb->(@msg) # callback is invoked on death
37 mon $port, $otherport # kill otherport on abnormal death 37 mon $localport, $otherport # kill otherport on abnormal death
38 mon $port, $otherport, @msg # send message on death 38 mon $localport, $otherport, @msg # send message on death
39 39
40=head1 CURRENT STATUS 40=head1 CURRENT STATUS
41 41
42 bin/aemp - stable. 42 bin/aemp - stable.
43 AnyEvent::MP - stable API, should work. 43 AnyEvent::MP - stable API, should work.
44 AnyEvent::MP::Intro - epxlains most concepts. 44 AnyEvent::MP::Intro - explains most concepts.
45 AnyEvent::MP::Kernel - mostly stable. 45 AnyEvent::MP::Kernel - mostly stable API.
46 AnyEvent::MP::Global - stable API, protocol not yet final. 46 AnyEvent::MP::Global - stable API.
47
48 stay tuned.
49 47
50=head1 DESCRIPTION 48=head1 DESCRIPTION
51 49
52This module (-family) implements a simple message passing framework. 50This module (-family) implements a simple message passing framework.
53 51
61 59
62=over 4 60=over 4
63 61
64=item port 62=item port
65 63
66A port is something you can send messages to (with the C<snd> function). 64Not to be confused with a TCP port, a "port" is something you can send
65messages to (with the C<snd> function).
67 66
68Ports allow you to register C<rcv> handlers that can match all or just 67Ports allow you to register C<rcv> handlers that can match all or just
69some messages. Messages send to ports will not be queued, regardless of 68some messages. Messages send to ports will not be queued, regardless of
70anything was listening for them or not. 69anything was listening for them or not.
71 70
82 81
83Nodes are either public (have one or more listening ports) or private 82Nodes are either public (have one or more listening ports) or private
84(no listening ports). Private nodes cannot talk to other private nodes 83(no listening ports). Private nodes cannot talk to other private nodes
85currently. 84currently.
86 85
87=item node ID - C<[a-za-Z0-9_\-.:]+> 86=item node ID - C<[A-Z_][a-zA-Z0-9_\-.:]*>
88 87
89A node ID is a string that uniquely identifies the node within a 88A node ID is a string that uniquely identifies the node within a
90network. Depending on the configuration used, node IDs can look like a 89network. Depending on the configuration used, node IDs can look like a
91hostname, a hostname and a port, or a random string. AnyEvent::MP itself 90hostname, a hostname and a port, or a random string. AnyEvent::MP itself
92doesn't interpret node IDs in any way. 91doesn't interpret node IDs in any way.
96Nodes can only talk to each other by creating some kind of connection to 95Nodes can only talk to each other by creating some kind of connection to
97each other. To do this, nodes should listen on one or more local transport 96each other. To do this, nodes should listen on one or more local transport
98endpoints - binds. Currently, only standard C<ip:port> specifications can 97endpoints - binds. Currently, only standard C<ip:port> specifications can
99be used, which specify TCP ports to listen on. 98be used, which specify TCP ports to listen on.
100 99
101=item seeds - C<host:port> 100=item seed nodes
102 101
103When a node starts, it knows nothing about the network. To teach the node 102When a node starts, it knows nothing about the network. To teach the node
104about the network it first has to contact some other node within the 103about the network it first has to contact some other node within the
105network. This node is called a seed. 104network. This node is called a seed.
106 105
107Seeds are transport endpoint(s) of as many nodes as one wants. Those nodes 106Apart from the fact that other nodes know them as seed nodes and they have
107to have fixed listening addresses, seed nodes are perfectly normal nodes -
108any node can function as a seed node for others.
109
110In addition to discovering the network, seed nodes are also used to
111maintain the network and to connect nodes that otherwise would have
112trouble connecting. They form the backbone of an AnyEvent::MP network.
113
108are expected to be long-running, and at least one of those should always 114Seed nodes are expected to be long-running, and at least one seed node
109be available. When nodes run out of connections (e.g. due to a network 115should always be available. They should also be relatively responsive - a
110error), they try to re-establish connections to some seednodes again to 116seed node that blocks for long periods will slow down everybody else.
111join the network.
112 117
113Apart from being sued for seeding, seednodes are not special in any way - 118=item seeds - C<host:port>
114every public node can be a seednode. 119
120Seeds are transport endpoint(s) (usually a hostname/IP address and a
121TCP port) of nodes thta should be used as seed nodes.
122
123The nodes listening on those endpoints are expected to be long-running,
124and at least one of those should always be available. When nodes run out
125of connections (e.g. due to a network error), they try to re-establish
126connections to some seednodes again to join the network.
115 127
116=back 128=back
117 129
118=head1 VARIABLES/FUNCTIONS 130=head1 VARIABLES/FUNCTIONS
119 131
136our $VERSION = $AnyEvent::MP::Kernel::VERSION; 148our $VERSION = $AnyEvent::MP::Kernel::VERSION;
137 149
138our @EXPORT = qw( 150our @EXPORT = qw(
139 NODE $NODE *SELF node_of after 151 NODE $NODE *SELF node_of after
140 configure 152 configure
141 snd rcv mon mon_guard kil reg psub spawn 153 snd rcv mon mon_guard kil psub spawn cal
142 port 154 port
143); 155);
144 156
145our $SELF; 157our $SELF;
146 158
158 170
159=item $nodeid = node_of $port 171=item $nodeid = node_of $port
160 172
161Extracts and returns the node ID from a port ID or a node ID. 173Extracts and returns the node ID from a port ID or a node ID.
162 174
175=item configure $profile, key => value...
176
163=item configure key => value... 177=item configure key => value...
164 178
165Before a node can talk to other nodes on the network (i.e. enter 179Before a node can talk to other nodes on the network (i.e. enter
166"distributed mode") it has to configure itself - the minimum a node needs 180"distributed mode") it has to configure itself - the minimum a node needs
167to know is its own name, and optionally it should know the addresses of 181to know is its own name, and optionally it should know the addresses of
174 188
175=item step 1, gathering configuration from profiles 189=item step 1, gathering configuration from profiles
176 190
177The function first looks up a profile in the aemp configuration (see the 191The function first looks up a profile in the aemp configuration (see the
178L<aemp> commandline utility). The profile name can be specified via the 192L<aemp> commandline utility). The profile name can be specified via the
179named C<profile> parameter. If it is missing, then the nodename (F<uname 193named C<profile> parameter or can simply be the first parameter). If it is
180-n>) will be used as profile name. 194missing, then the nodename (F<uname -n>) will be used as profile name.
181 195
182The profile data is then gathered as follows: 196The profile data is then gathered as follows:
183 197
184First, all remaining key => value pairs (all of which are conviniently 198First, all remaining key => value pairs (all of which are conveniently
185undocumented at the moment) will be interpreted as configuration 199undocumented at the moment) will be interpreted as configuration
186data. Then they will be overwritten by any values specified in the global 200data. Then they will be overwritten by any values specified in the global
187default configuration (see the F<aemp> utility), then the chain of 201default configuration (see the F<aemp> utility), then the chain of
188profiles chosen by the profile name (and any C<parent> attributes). 202profiles chosen by the profile name (and any C<parent> attributes).
189 203
213L<AnyEvent::MP::Global> module, which will then use it to keep 227L<AnyEvent::MP::Global> module, which will then use it to keep
214connectivity with at least one node at any point in time. 228connectivity with at least one node at any point in time.
215 229
216=back 230=back
217 231
218Example: become a distributed node using the locla node name as profile. 232Example: become a distributed node using the local node name as profile.
219This should be the most common form of invocation for "daemon"-type nodes. 233This should be the most common form of invocation for "daemon"-type nodes.
220 234
221 configure 235 configure
222 236
223Example: become an anonymous node. This form is often used for commandline 237Example: become an anonymous node. This form is often used for commandline
472 486
473Monitor the given port and do something when the port is killed or 487Monitor the given port and do something when the port is killed or
474messages to it were lost, and optionally return a guard that can be used 488messages to it were lost, and optionally return a guard that can be used
475to stop monitoring again. 489to stop monitoring again.
476 490
491In the first form (callback), the callback is simply called with any
492number of C<@reason> elements (no @reason means that the port was deleted
493"normally"). Note also that I<< the callback B<must> never die >>, so use
494C<eval> if unsure.
495
496In the second form (another port given), the other port (C<$rcvport>)
497will be C<kil>'ed with C<@reason>, if a @reason was specified, i.e. on
498"normal" kils nothing happens, while under all other conditions, the other
499port is killed with the same reason.
500
501The third form (kill self) is the same as the second form, except that
502C<$rvport> defaults to C<$SELF>.
503
504In the last form (message), a message of the form C<@msg, @reason> will be
505C<snd>.
506
507Monitoring-actions are one-shot: once messages are lost (and a monitoring
508alert was raised), they are removed and will not trigger again.
509
510As a rule of thumb, monitoring requests should always monitor a port from
511a local port (or callback). The reason is that kill messages might get
512lost, just like any other message. Another less obvious reason is that
513even monitoring requests can get lost (for example, when the connection
514to the other node goes down permanently). When monitoring a port locally
515these problems do not exist.
516
477C<mon> effectively guarantees that, in the absence of hardware failures, 517C<mon> effectively guarantees that, in the absence of hardware failures,
478after starting the monitor, either all messages sent to the port will 518after starting the monitor, either all messages sent to the port will
479arrive, or the monitoring action will be invoked after possible message 519arrive, or the monitoring action will be invoked after possible message
480loss has been detected. No messages will be lost "in between" (after 520loss has been detected. No messages will be lost "in between" (after
481the first lost message no further messages will be received by the 521the first lost message no further messages will be received by the
482port). After the monitoring action was invoked, further messages might get 522port). After the monitoring action was invoked, further messages might get
483delivered again. 523delivered again.
484 524
485Note that monitoring-actions are one-shot: once messages are lost (and a 525Inter-host-connection timeouts and monitoring depend on the transport
486monitoring alert was raised), they are removed and will not trigger again. 526used. 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
528non-idle connection, and usually around two hours for idle conenctions).
487 529
488In the first form (callback), the callback is simply called with any 530This means that monitoring is good for program errors and cleaning up
489number of C<@reason> elements (no @reason means that the port was deleted 531stuff eventually, but they are no replacement for a timeout when you need
490"normally"). Note also that I<< the callback B<must> never die >>, so use 532to ensure some maximum latency.
491C<eval> if unsure.
492
493In the second form (another port given), the other port (C<$rcvport>)
494will be C<kil>'ed with C<@reason>, iff a @reason was specified, i.e. on
495"normal" kils nothing happens, while under all other conditions, the other
496port is killed with the same reason.
497
498The third form (kill self) is the same as the second form, except that
499C<$rvport> defaults to C<$SELF>.
500
501In the last form (message), a message of the form C<@msg, @reason> will be
502C<snd>.
503
504As a rule of thumb, monitoring requests should always monitor a port from
505a local port (or callback). The reason is that kill messages might get
506lost, just like any other message. Another less obvious reason is that
507even monitoring requests can get lost (for exmaple, when the connection
508to the other node goes down permanently). When monitoring a port locally
509these problems do not exist.
510 533
511Example: call a given callback when C<$port> is killed. 534Example: call a given callback when C<$port> is killed.
512 535
513 mon $port, sub { warn "port died because of <@_>\n" }; 536 mon $port, sub { warn "port died because of <@_>\n" };
514 537
542 } 565 }
543 566
544 $node->monitor ($port, $cb); 567 $node->monitor ($port, $cb);
545 568
546 defined wantarray 569 defined wantarray
570 and $cb += 0
547 and AnyEvent::Util::guard { $node->unmonitor ($port, $cb) } 571 and AnyEvent::Util::guard { $node->unmonitor ($port, $cb) }
548} 572}
549 573
550=item $guard = mon_guard $port, $ref, $ref... 574=item $guard = mon_guard $port, $ref, $ref...
551 575
609the package, then the package above the package and so on (e.g. 633the package, then the package above the package and so on (e.g.
610C<MyApp::Chat::Server>, C<MyApp::Chat>, C<MyApp>) until the function 634C<MyApp::Chat::Server>, C<MyApp::Chat>, C<MyApp>) until the function
611exists or it runs out of package names. 635exists or it runs out of package names.
612 636
613The init function is then called with the newly-created port as context 637The init function is then called with the newly-created port as context
614object (C<$SELF>) and the C<@initdata> values as arguments. 638object (C<$SELF>) and the C<@initdata> values as arguments. It I<must>
639call one of the C<rcv> functions to set callbacks on C<$SELF>, otherwise
640the port might not get created.
615 641
616A common idiom is to pass a local port, immediately monitor the spawned 642A common idiom is to pass a local port, immediately monitor the spawned
617port, and in the remote init function, immediately monitor the passed 643port, and in the remote init function, immediately monitor the passed
618local port. This two-way monitoring ensures that both ports get cleaned up 644local port. This two-way monitoring ensures that both ports get cleaned up
619when there is a problem. 645when there is a problem.
620 646
647C<spawn> guarantees that the C<$initfunc> has no visible effects on the
648caller before C<spawn> returns (by delaying invocation when spawn is
649called for the local node).
650
621Example: spawn a chat server port on C<$othernode>. 651Example: spawn a chat server port on C<$othernode>.
622 652
623 # this node, executed from within a port context: 653 # this node, executed from within a port context:
624 my $server = spawn $othernode, "MyApp::Chat::Server::connect", $SELF; 654 my $server = spawn $othernode, "MyApp::Chat::Server::connect", $SELF;
625 mon $server; 655 mon $server;
639 669
640sub _spawn { 670sub _spawn {
641 my $port = shift; 671 my $port = shift;
642 my $init = shift; 672 my $init = shift;
643 673
674 # rcv will create the actual port
644 local $SELF = "$NODE#$port"; 675 local $SELF = "$NODE#$port";
645 eval { 676 eval {
646 &{ load_func $init } 677 &{ load_func $init }
647 }; 678 };
648 _self_die if $@; 679 _self_die if $@;
683 ? $action[0]() 714 ? $action[0]()
684 : snd @action; 715 : snd @action;
685 }; 716 };
686} 717}
687 718
719=item cal $port, @msg, $callback[, $timeout]
720
721A 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.
723
724The reply port is created temporarily just for the purpose of receiving
725the reply, and will be C<kil>ed when no longer needed.
726
727A reply message sent to the port is passed to the C<$callback> as-is.
728
729If 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
731elapsed and the port is C<kil>ed.
732
733If no time-out is given, then the local port will monitor the remote port
734instead, so it eventually gets cleaned-up.
735
736Currently this function returns the temporary port, but this "feature"
737might go in future versions unless you can make a convincing case that
738this is indeed useful for something.
739
740=cut
741
742sub cal(@) {
743 my $timeout = ref $_[-1] ? undef : pop;
744 my $cb = pop;
745
746 my $port = port {
747 undef $timeout;
748 kil $SELF;
749 &$cb;
750 };
751
752 if (defined $timeout) {
753 $timeout = AE::timer $timeout, 0, sub {
754 undef $timeout;
755 kil $port;
756 $cb->();
757 };
758 } else {
759 mon $_[0], sub {
760 kil $port;
761 $cb->();
762 };
763 }
764
765 push @_, $port;
766 &snd;
767
768 $port
769}
770
688=back 771=back
689 772
690=head1 AnyEvent::MP vs. Distributed Erlang 773=head1 AnyEvent::MP vs. Distributed Erlang
691 774
692AnyEvent::MP got lots of its ideas from distributed Erlang (Erlang node 775AnyEvent::MP got lots of its ideas from distributed Erlang (Erlang node
705 788
706=item * Node IDs are arbitrary strings in AEMP. 789=item * Node IDs are arbitrary strings in AEMP.
707 790
708Erlang relies on special naming and DNS to work everywhere in the same 791Erlang relies on special naming and DNS to work everywhere in the same
709way. AEMP relies on each node somehow knowing its own address(es) (e.g. by 792way. AEMP relies on each node somehow knowing its own address(es) (e.g. by
710configuraiton or DNS), but will otherwise discover other odes itself. 793configuration or DNS), but will otherwise discover other odes itself.
711 794
712=item * Erlang has a "remote ports are like local ports" philosophy, AEMP 795=item * Erlang has a "remote ports are like local ports" philosophy, AEMP
713uses "local ports are like remote ports". 796uses "local ports are like remote ports".
714 797
715The failure modes for local ports are quite different (runtime errors 798The failure modes for local ports are quite different (runtime errors
728 811
729Erlang uses processes that selectively receive messages, and therefore 812Erlang uses processes that selectively receive messages, and therefore
730needs a queue. AEMP is event based, queuing messages would serve no 813needs a queue. AEMP is event based, queuing messages would serve no
731useful purpose. For the same reason the pattern-matching abilities of 814useful purpose. For the same reason the pattern-matching abilities of
732AnyEvent::MP are more limited, as there is little need to be able to 815AnyEvent::MP are more limited, as there is little need to be able to
733filter messages without dequeing them. 816filter messages without dequeuing them.
734 817
735(But see L<Coro::MP> for a more Erlang-like process model on top of AEMP). 818(But see L<Coro::MP> for a more Erlang-like process model on top of AEMP).
736 819
737=item * Erlang sends are synchronous, AEMP sends are asynchronous. 820=item * Erlang sends are synchronous, AEMP sends are asynchronous.
738 821
844L<AnyEvent::MP::Kernel> - more, lower-level, stuff. 927L<AnyEvent::MP::Kernel> - more, lower-level, stuff.
845 928
846L<AnyEvent::MP::Global> - network maintainance and port groups, to find 929L<AnyEvent::MP::Global> - network maintainance and port groups, to find
847your applications. 930your applications.
848 931
932L<AnyEvent::MP::LogCatcher> - simple service to display log messages from
933all nodes.
934
849L<AnyEvent>. 935L<AnyEvent>.
850 936
851=head1 AUTHOR 937=head1 AUTHOR
852 938
853 Marc Lehmann <schmorp@schmorp.de> 939 Marc Lehmann <schmorp@schmorp.de>

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines