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.3 by root, Sat Aug 1 07:11:45 2009 UTC vs.
Revision 1.7 by root, Sat Aug 1 15:04:30 2009 UTC

… …
27This module (-family) implements a simple message passing framework. 27This module (-family) implements a simple message passing framework.
28 28
29Despite its simplicity, you can securely message other processes running 29Despite its simplicity, you can securely message other processes running
30on the same or other hosts. 30on the same or other hosts.
31 31
32At the moment, this module family is severly brokena nd underdocumented,
33so do not use. This was uploaded mainly to resreve the CPAN namespace -
34stay tuned!
35
32=head1 CONCEPTS 36=head1 CONCEPTS
33 37
34=over 4 38=over 4
35 39
36=item port 40=item port
… …
52 56
53Initially, nodes are either private (single-process only) or hidden 57Initially, nodes are either private (single-process only) or hidden
54(connected to a master node only). Only when they epxlicitly "become 58(connected to a master node only). Only when they epxlicitly "become
55public" can you send them messages from unrelated other nodes. 59public" can you send them messages from unrelated other nodes.
56 60
57=item noderef - C<host:port,host:port...>, C<id@noderef, C<id> 61=item noderef - C<host:port,host:port...>, C<id@noderef>, C<id>
58 62
59A noderef is a string that either uniquely identifies a given node (for 63A noderef is a string that either uniquely identifies a given node (for
60private and hidden nodes), or contains a recipe on how to reach a given 64private and hidden nodes), or contains a recipe on how to reach a given
61node (for public nodes). 65node (for public nodes).
62 66
… …
81 85
82use AE (); 86use AE ();
83 87
84use base "Exporter"; 88use base "Exporter";
85 89
86our $VERSION = '0.0'; 90our $VERSION = '0.01';
87our @EXPORT = qw(NODE $NODE $PORT snd rcv _any_); 91our @EXPORT = qw(NODE $NODE $PORT snd rcv _any_);
88 92
89our $DEFAULT_SECRET; 93our $DEFAULT_SECRET;
90our $DEFAULT_PORT = "4040"; 94our $DEFAULT_PORT = "4040";
91 95
… …
111C<become_slave>, after which all local port identifiers become invalid. 115C<become_slave>, after which all local port identifiers become invalid.
112 116
113=cut 117=cut
114 118
115our $UNIQ = sprintf "%x.%x", $$, time; # per-process/node unique cookie 119our $UNIQ = sprintf "%x.%x", $$, time; # per-process/node unique cookie
120our $ID = "a0";
116our $PUBLIC = 0; 121our $PUBLIC = 0;
117our $NODE; 122our $NODE;
118our $PORT; 123our $PORT;
119 124
120our %NODE; # node id to transport mapping, or "undef", for local node 125our %NODE; # node id to transport mapping, or "undef", for local node
… …
172that Storable can serialise and deserialise is allowed, and for the local 177that Storable can serialise and deserialise is allowed, and for the local
173node, anything can be passed. 178node, anything can be passed.
174 179
175=cut 180=cut
176 181
177sub snd($@) { 182sub snd(@) {
178 my ($noderef, $port) = split /#/, shift, 2; 183 my ($noderef, $port) = split /#/, shift, 2;
179 184
180 add_node $noderef 185 add_node $noderef
181 unless exists $NODE{$noderef}; 186 unless exists $NODE{$noderef};
182 187
… …
254 && &{$_->[0]} 259 && &{$_->[0]}
255 && undef $_; 260 && undef $_;
256 } 261 }
257 262
258 for (@{ $port->{any} }) { 263 for (@{ $port->{any} }) {
259 $_ && [@_[0..$#{$_->[1]}]] ~~ $_->[1] 264 $_ && [@_[0..$#{$_->[1]}]] ~~ $_->[1]
260 && &{$_->[0]} 265 && &{$_->[0]}
261 && undef $_; 266 && undef $_;
262 } 267 }
263} 268}
264 269
… …
362 } 367 }
363 368
364 $PUBLIC = 1; 369 $PUBLIC = 1;
365} 370}
366 371
372=back
373
374=head1 NODE MESSAGES
375
376Nodes understand the following messages sent to them. Many of them take
377arguments called C<@reply>, which will simply be used to compose a reply
378message - C<$reply[0]> is the port to reply to, C<$reply[1]> the type and
379the remaining arguments are simply the message data.
380
381=over 4
382
383=cut
384
367############################################################################# 385#############################################################################
368# self node code 386# self node code
369 387
370sub _new_port($) { 388sub _new_port($) {
371 my ($name) = @_; 389 my ($name) = @_;
… …
379} 397}
380 398
381$NODE{""} = new AnyEvent::MP::Node::Self noderef => $NODE; 399$NODE{""} = new AnyEvent::MP::Node::Self noderef => $NODE;
382_new_port ""; 400_new_port "";
383 401
402=item devnull => ...
403
404Generic data sink/CPU heat conversion.
405
406=cut
407
408rcv "", devnull => sub { () };
409
410=item relay => $port, @msg
411
412Simply forwards the message to the given port.
413
414=cut
415
384rcv "", relay => \&snd; 416rcv "", relay => sub { \&snd; () };
417
418=item eval => $string[ @reply]
419
420Evaluates the given string. If C<@reply> is given, then a message of the
421form C<@reply, $@, @evalres> is sent.
422
423Example: crash another node.
424
425 snd $othernode, eval => "exit";
426
427=cut
428
429rcv "", eval => sub {
430 my (undef, $string, @reply) = @_;
431 my @res = eval $string;
432 snd @reply, "$@", @res if @reply;
433 ()
434};
435
436=item time => @reply
437
438Replies the the current node time to C<@reply>.
439
440Example: tell the current node to send the current time to C<$myport> in a
441C<timereply> message.
442
443 snd $NODE, time => $myport, timereply => 1, 2;
444 # => snd $myport, timereply => 1, 2, <time>
445
446=cut
447
448rcv "", time => sub { shift; snd @_, AE::time; () };
385 449
386=back 450=back
387 451
388=head1 SEE ALSO 452=head1 SEE ALSO
389 453

Diff Legend

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