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.83 by root, Tue Sep 8 01:38:16 2009 UTC vs.
Revision 1.88 by root, Fri Sep 11 15:02:17 2009 UTC

… …
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 - explains 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 but incomplete, protocol not yet final. 46 AnyEvent::MP::Global - stable API.
47
48stay 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
… …
83 81
84Nodes are either public (have one or more listening ports) or private 82Nodes are either public (have one or more listening ports) or private
85(no listening ports). Private nodes cannot talk to other private nodes 83(no listening ports). Private nodes cannot talk to other private nodes
86currently. 84currently.
87 85
88=item node ID - C<[a-za-Z0-9_\-.:]+> 86=item node ID - C<[A-Z_][a-zA-Z0-9_\-.:]*>
89 87
90A 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
91network. Depending on the configuration used, node IDs can look like a 89network. Depending on the configuration used, node IDs can look like a
92hostname, 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
93doesn't interpret node IDs in any way. 91doesn't interpret node IDs in any way.
… …
109to have fixed listening addresses, seed nodes are perfectly normal nodes - 107to have fixed listening addresses, seed nodes are perfectly normal nodes -
110any node can function as a seed node for others. 108any node can function as a seed node for others.
111 109
112In addition to discovering the network, seed nodes are also used to 110In addition to discovering the network, seed nodes are also used to
113maintain the network and to connect nodes that otherwise would have 111maintain the network and to connect nodes that otherwise would have
114trouble connecting. They form the backbone of the AnyEvent::MP network. 112trouble connecting. They form the backbone of an AnyEvent::MP network.
115 113
116Seed nodes are expected to be long-running, and at least one seed node 114Seed nodes are expected to be long-running, and at least one seed node
117should always be available. 115should always be available. They should also be relatively responsive - a
116seed node that blocks for long periods will slow down everybody else.
118 117
119=item seeds - C<host:port> 118=item seeds - C<host:port>
120 119
121Seeds are transport endpoint(s) (usually a hostname/IP address and a 120Seeds are transport endpoint(s) (usually a hostname/IP address and a
122TCP port) of nodes thta should be used as seed nodes. 121TCP port) of nodes thta should be used as seed nodes.
… …
149our $VERSION = $AnyEvent::MP::Kernel::VERSION; 148our $VERSION = $AnyEvent::MP::Kernel::VERSION;
150 149
151our @EXPORT = qw( 150our @EXPORT = qw(
152 NODE $NODE *SELF node_of after 151 NODE $NODE *SELF node_of after
153 configure 152 configure
154 snd rcv mon mon_guard kil reg psub spawn 153 snd rcv mon mon_guard kil reg psub spawn cal
155 port 154 port
156); 155);
157 156
158our $SELF; 157our $SELF;
159 158
… …
228L<AnyEvent::MP::Global> module, which will then use it to keep 227L<AnyEvent::MP::Global> module, which will then use it to keep
229connectivity with at least one node at any point in time. 228connectivity with at least one node at any point in time.
230 229
231=back 230=back
232 231
233Example: become a distributed node using the locla node name as profile. 232Example: become a distributed node using the local node name as profile.
234This 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.
235 234
236 configure 235 configure
237 236
238Example: become an anonymous node. This form is often used for commandline 237Example: become an anonymous node. This form is often used for commandline
… …
714 ? $action[0]() 713 ? $action[0]()
715 : snd @action; 714 : snd @action;
716 }; 715 };
717} 716}
718 717
718=item cal $port, @msg, $callback[, $timeout]
719
720A simple form of RPC - sends a message to the given C<$port> with the
721given contents (C<@msg>), but adds a reply port to the message.
722
723The reply port is created temporarily just for the purpose of receiving
724the reply, and will be C<kil>ed when no longer needed.
725
726A reply message sent to the port is passed to the C<$callback> as-is.
727
728If an optional time-out (in seconds) is given and it is not C<undef>,
729then the callback will be called without any arguments after the time-out
730elapsed and the port is C<kil>ed.
731
732If no time-out is given, then the local port will monitor the remote port
733instead, so it eventually gets cleaned-up.
734
735Currently this function returns the temporary port, but this "feature"
736might go in future versions unless you can make a convincing case that
737this is indeed useful for something.
738
739=cut
740
741sub cal(@) {
742 my $timeout = ref $_[-1] ? undef : pop;
743 my $cb = pop;
744
745 my $port = port {
746 undef $timeout;
747 kil $SELF;
748 &$cb;
749 };
750
751 if (defined $timeout) {
752 $timeout = AE::timer $timeout, 0, sub {
753 undef $timeout;
754 kil $port;
755 $cb->();
756 };
757 } else {
758 mon $_[0], sub {
759 kil $port;
760 $cb->();
761 };
762 }
763
764 push @_, $port;
765 &snd;
766
767 $port
768}
769
719=back 770=back
720 771
721=head1 AnyEvent::MP vs. Distributed Erlang 772=head1 AnyEvent::MP vs. Distributed Erlang
722 773
723AnyEvent::MP got lots of its ideas from distributed Erlang (Erlang node 774AnyEvent::MP got lots of its ideas from distributed Erlang (Erlang node

Diff Legend

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