[ViewVC] Diff of: cvs/AnyEvent-MP/bin/aemp

Comparing AnyEvent-MP/bin/aemp (file contents):
Revision 1.56 by root, Wed Mar 21 15:22:16 2012 UTC vs.
Revision 1.57 by root, Wed Mar 21 21:02:04 2012 UTC

 sub trace {
    my ($seed) = @_;
    my $cv = AE::cv;
    my %seen;
+   my $exit;
-   my $to;
+   my %to;
    init;
    my $reply = port {
       my ($node, undef, @neigh) = @_;
-      $to = AE::timer 15, 0, sub { exit 1 };
+      delete $to{$node};
       @neigh = grep $_ ne $NODE, @neigh;
       print $node, " -> ", (join " ", @neigh), "\n";
-      for (@neigh) {
+      for my $neigh (@neigh) {
-         unless ($seen{$_}++) {
+         unless ($seen{$neigh}++) {
             $cv->begin;
+            $to{$neigh} = AE::timer 15, 0, sub {
+               print "$neigh (timeout)\n";
+               $exit = 1;
+               $cv->end;
+            };
-            AnyEvent::MP::Kernel::eval_on $_, "AnyEvent::MP::Kernel::up_nodes" => $SELF => $_;
+            AnyEvent::MP::Kernel::eval_on $neigh, "AnyEvent::MP::Kernel::up_nodes" => $SELF => $neigh;
          }
       }
       $cv->end;
    };
    $cv->begin;
    snd $reply, seed => undef, $seed;
    $cv->recv;
+   exit $exit;
 }
 sub shell {
    init;

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