X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FObject%2FRemote%2FRole%2FConnector.pm;h=8ad06c239da6e95cea54f0b6cae75e16c1651c30;hb=de9062cfef7f98d0efc01b114328959f2f84ada4;hp=a4bce2e426d28bf498004e8e1370a28c6130e2cd;hpb=8faf2a289aa3409e7cafe2536f943fb43033b086;p=scpubgit%2FObject-Remote.git diff --git a/lib/Object/Remote/Role/Connector.pm b/lib/Object/Remote/Role/Connector.pm index a4bce2e..8ad06c2 100644 --- a/lib/Object/Remote/Role/Connector.pm +++ b/lib/Object/Remote/Role/Connector.pm @@ -2,13 +2,15 @@ package Object::Remote::Role::Connector; use Module::Runtime qw(use_module); use Object::Remote::Future; -use Object::Remote::Logging qw(:log :dlog ); +use Object::Remote::Logging qw(:log :dlog router); use Moo::Role; requires '_open2_for'; has timeout => (is => 'ro', default => sub { 10 }); +BEGIN { router()->exclude_forwarding; } + sub connect { my $self = shift; Dlog_debug { "Preparing to create connection with args of: $_" } @_; @@ -45,16 +47,16 @@ sub connect { ->watch_time( after => $self->timeout, code => sub { - Dlog_trace { "Connection timeout timer has fired for child pid '$child_pid'; is_ready: $_" } $f->is_ready; + Dlog_trace {"Connection timeout timer has fired for child pid '$child_pid'; is_ready: $_" } $f->is_ready; unless($f->is_ready) { log_warn { "Connection with child pid '$child_pid' has timed out" }; - $f->fail("Connection timed out") unless $f->is_ready; + $f->fail("Connection timed out") unless $f->is_ready; } undef($channel); - + } ); - log_trace { "connection for child pid '$child_pid' has been initialized" }; + log_trace { "connection for child pid '$child_pid' has been initialized" }; $f; } }