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=a6df92c8de7a309e4222f4983c6101e7c965c639;hp=7ab6b1f1aef11e541c3a1fb4aea97ca1fce93d78;hb=47c83a1379a33fc8baa4a128edc1d75d780776b0;hpb=ad4f54b29c5f84aa010b456303b24647c0e28ae7 diff --git a/lib/Object/Remote/Connection.pm b/lib/Object/Remote/Connection.pm index 7ab6b1f..a6df92c 100644 --- a/lib/Object/Remote/Connection.pm +++ b/lib/Object/Remote/Connection.pm @@ -31,6 +31,8 @@ has receive_from_fh => ( has on_close => (is => 'rw', default => sub {}); +has child_pid => (is => 'ro'); + has _receive_data_buffer => (is => 'ro', default => sub { my $x = ''; \$x }); has local_objects_by_id => (is => 'ro', default => sub { {} }); @@ -163,15 +165,21 @@ sub receive_free { sub receive_call { my ($self, $future, $id, @rest) = @_; - $future->{method} = 'call_discard'; + $future->{method} = 'call_discard_free'; my $local = $self->local_objects_by_id->{$id} or do { $future->fail("No such object $id"); return }; $self->_invoke($future, $local, @rest); } +sub receive_call_free { + my ($self, $future, $id, @rest) = @_; + $self->receive_call($future, $id, @rest); + $self->receive_free($id); +} + sub receive_class_call { my ($self, $future, $class, @rest) = @_; - $future->{method} = 'call_discard'; + $future->{method} = 'call_discard_free'; eval { use_module($class) } or do { $future->fail("Error loading ${class}: $@"); return }; $self->_invoke($future, $class, @rest);