X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FObject%2FRemote%2FConnection.pm;h=e6a5a98c0a5d6f7467d2df778f6782fa1776ca56;hb=f21d2f9042fbad3e958979f4db37f051b3c50998;hp=7d640719d3b278907d99cf779631caa0a27cd0d3;hpb=e1a0b9ca22fab8555fb597473b6f3a4074d7b48b;p=scpubgit%2FObject-Remote.git diff --git a/lib/Object/Remote/Connection.pm b/lib/Object/Remote/Connection.pm index 7d64071..e6a5a98 100644 --- a/lib/Object/Remote/Connection.pm +++ b/lib/Object/Remote/Connection.pm @@ -32,9 +32,9 @@ has _id => ( is => 'ro', required => 1, default => sub { our $NEXT_CONNECTION_ID has send_to_fh => ( is => 'ro', required => 1, trigger => sub { - my $self = $_[0]; - $_[1]->autoflush(1); - Dlog_trace { my $id = $self->_id; "connection had send_to_fh set to $_" } $_[1]; + my $self = $_[0]; + $_[1]->autoflush(1); + Dlog_trace { my $id = $self->_id; "connection had send_to_fh set to $_" } $_[1]; }, ); @@ -56,8 +56,8 @@ has read_channel => ( has on_close => ( is => 'rw', default => sub { $_[0]->_install_future_handlers(CPS::Future->new) }, trigger => sub { - log_trace { "Installing handlers into future via trigger" }; - $_[0]->_install_future_handlers($_[1]) + log_trace { "Installing handlers into future via trigger" }; + $_[0]->_install_future_handlers($_[1]) }, ); @@ -88,8 +88,8 @@ after BUILD => sub { my $pid = $self->child_pid; unless (defined $pid) { - log_trace { "After BUILD invoked for connection but there was no pid" }; - return; + log_trace { "After BUILD invoked for connection but there was no pid" }; + return; } log_trace { "Setting process group of child process '$pid'" }; @@ -236,9 +236,9 @@ sub conn_from_spec { } sub new_from_spec { - my ($class, $spec) = @_; + my ($class, $spec, @args) = @_; return $spec if blessed $spec; - my $conn = $class->conn_from_spec($spec); + my $conn = $class->conn_from_spec($spec, @args); die "Couldn't figure out what to do with ${spec}" unless defined $conn;