X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?p=scpubgit%2FObject-Remote.git;a=blobdiff_plain;f=lib%2FObject%2FRemote%2FConnection.pm;h=7d640719d3b278907d99cf779631caa0a27cd0d3;hp=412039510bb872c0dc72d06983cba819fe4b50e5;hb=e1a0b9ca22fab8555fb597473b6f3a4074d7b48b;hpb=5add5e29851e82862e4d8f6d67dfce559f6685ce diff --git a/lib/Object/Remote/Connection.pm b/lib/Object/Remote/Connection.pm index 4120395..7d64071 100644 --- a/lib/Object/Remote/Connection.pm +++ b/lib/Object/Remote/Connection.pm @@ -18,10 +18,7 @@ use JSON::PP qw(encode_json); use Moo; use Carp qw(croak); -BEGIN { - router()->exclude_forwarding; - $SIG{PIPE} = sub { log_debug { "Got a PIPE signal" } }; -} +BEGIN { router()->exclude_forwarding } END { log_debug { "Killing all child processes in the process group" }; @@ -121,6 +118,7 @@ sub _fail_outstanding { foreach(keys(%$outstanding)) { log_trace { "Failing future for $_" }; my $future = $outstanding->{$_}; + $future->fail("$error\n"); } %$outstanding = ();