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

Comparing AnyEvent-MP/MP/Global.pm (file contents):
Revision 1.34 by root, Thu Nov 5 01:12:41 2009 UTC vs.
Revision 1.35 by root, Sat Nov 7 02:36:31 2009 UTC

    grp_get
    grp_mon
 );
 our $GLOBAL_VERSION = 0;
+our %ON_SETUP; # take note: not public
 our %addr; # port ID => [address...] mapping
 our %port; # our rendezvous port on the other side
 our %lreg; # local registry, name => [pid...]
    };
    snd $port, addr => $AnyEvent::MP::Kernel::LISTENER;
    snd $port, nodes => \%addr if %addr;
    snd $port, set => \%lreg if %lreg;
+   snd $port, "setup"; # tell the other side that we are in business now
 }
 # other nodes connect via this
 sub connect {
    my ($version, $node) = @_;
       delete $SEEDME{$node};
       kil $SELF;
    };
    rcv $SELF,
+      setup => sub {
+         $_->($node) for values %ON_SETUP;
+      },
       addr => sub {
          my $addresses = shift;
          $AnyEvent::MP::Kernel::WARN->(9, "$node told us its addresses (@$addresses).");
          $addr{$node} = $addresses;
             my $node = AnyEvent::MP::Kernel::add_node $id;
             $node->connect (@$addresses);
             start_node $id;
          }
       },
+      set => sub {
+         set_groups $node, shift;
+      },
       find => sub {
          my ($othernode) = @_;
          $AnyEvent::MP::Kernel::WARN->(9, "$node asked us to find $othernode.");
          snd $port{$node}, nodes => { $othernode => $addr{$othernode} }
             if $addr{$othernode};
-      },
-      set => sub {
-         set_groups $node, shift;
       },
       reg0 => sub {
          _change $_[0], [], [$_[1]];
       },
       reg1 => sub {

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