X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?p=scpubgit%2FObject-Remote.git;a=blobdiff_plain;f=lib%2FObject%2FRemote%2FRole%2FConnector.pm;h=8ad06c239da6e95cea54f0b6cae75e16c1651c30;hp=747341c777355d0c2abe000db1aae6bd5d822b5d;hb=55c0d0209fa9d9265ff178f54ae9fe5fdddef3c1;hpb=f1d7083568d3d8322a66f9c1265ef326999c5a23 diff --git a/lib/Object/Remote/Role/Connector.pm b/lib/Object/Remote/Role/Connector.pm index 747341c..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: $_" } @_; @@ -51,10 +53,10 @@ sub connect { $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; } }