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=3f1574877036a0872a6b3baeefb023f40c704902;hp=e23c82360b662b36765bed04948eb328f7017b0a;hb=b7a853b30e7397854a813f6a5878e50703a20079;hpb=b9baacc29444767f88abdbca93f65c8bd5e5a676 diff --git a/lib/Object/Remote/Connection.pm b/lib/Object/Remote/Connection.pm index e23c823..3f15748 100644 --- a/lib/Object/Remote/Connection.pm +++ b/lib/Object/Remote/Connection.pm @@ -37,13 +37,15 @@ BEGIN { #in waitpid() $SIG{CHLD} = sub { my $kid; - log_debug { "CHLD signal handler is executing" }; + log_trace { "CHLD signal handler is executing" }; do { $kid = waitpid(-1, WNOHANG); - log_trace { "waitpid() returned '$kid'" }; + log_debug { "waitpid() returned '$kid'" }; } while $kid > 0; log_trace { "CHLD signal handler is done" }; - }; + }; + + $SIG{PIPE} = sub { log_debug { "Got a PIPE signal" } }; } END { @@ -109,7 +111,6 @@ after BUILD => sub { }; - has on_close => ( is => 'rw', default => sub { CPS::Future->new }, trigger => sub { @@ -141,7 +142,7 @@ sub _fail_outstanding { my ($self, $error) = @_; Dlog_debug { "Failing outstanding futures with '$error' for connection $_" } $self->_id; my $outstanding = $self->outstanding_futures; - $_->fail($error) for values %$outstanding; + $_->fail("$error\n") for values %$outstanding; %$outstanding = (); return; }