[ViewVC] Diff of: cvs/AnyEvent-MP/MP/Global.pm

Comparing AnyEvent-MP/MP/Global.pm (file contents):
Revision 1.2 by root, Sat Aug 15 04:12:38 2009 UTC vs.
Revision 1.3 by root, Sat Aug 15 04:34:34 2009 UTC

 This module provides an assortment of network-global functions: group name
 registration and non-local locks.
 It will also try to build and maintain a full mesh of all network nodes.
+While it isn't mandatory to run the global services, running it on one
+node will automatically run it on all nodes.
 =head1 GLOBALS AND FUNCTIONS
 =over 4
 use AnyEvent::MP::Kernel;
 our $VERSION = $AnyEvent::MP::VERSION;
 our $port = port;
+our %other; # our rendevouz port on the other side
-# in response to up_nodes request
+sub connect {
+   my ($noderef) = @_;
+   # monitor them, silently die
+   mon $noderef, psub { kil $SELF };
-rcv $port, connect_nodes => sub {
+   rcv $SELF, connect_nodes => sub {
-   connect_node $_ for @_;
+      connect_node $_ for @_;
-};
+   };
+}
 sub mon_node {
    my ($noderef, $is_up) = @_;
    if ($is_up) {
+      # establish connection
+      my $other = $other{$noderef} = spawn $noderef, "AnyEvent::MP::Global::connect", $NODE;
       # request any other nodes possibly known to us
-      snd $noderef, up_nodes => $port, "connect_nodes";
+      snd $other, connect_nodes => up_nodes;
    } else {
+      kil delete $other{$noderef};
    }
    #warn "node<$noderef,$is_up>\n";#d#
 }
 mon_node $_, 1

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