From: Chris Nehren <c.nehren@shadowcat.co.uk>
Date: Tue, 21 Aug 2012 20:31:31 +0000 (+0000)
Subject: break out future polling to be one at a time to try to determine which one is hanging
X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=commitdiff_plain;h=14bf47a262374a3f4c8ad98dd9c3c553e373f851;p=scpubgit%2FObject-Remote.git

break out future polling to be one at a time to try to determine which one is hanging
---

diff --git a/lib/Object/Remote/Future.pm b/lib/Object/Remote/Future.pm
index 893fb6d..80fd6bf 100644
--- a/lib/Object/Remote/Future.pm
+++ b/lib/Object/Remote/Future.pm
@@ -26,6 +26,7 @@ sub await_future {
     $f->on_ready(sub {
       $loop->stop if $f == $await[-1]
     });
+    warn "running loop for ${f} [@{await}]";
     $loop->run;
   }
   if (@await and $await[-1]->is_ready) {
@@ -35,7 +36,11 @@ sub await_future {
 }
 
 sub await_all {
-  await_future(CPS::Future->wait_all(@_));
+  my @subs = @_;
+  for my $sub (@subs) {
+    warn "awaiting ${sub}";
+    await_future(CPS::Future->wait_all($sub));
+  }
   map $_->get, @_;
 }