X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?p=scpubgit%2FObject-Remote.git;a=blobdiff_plain;f=lib%2FObject%2FRemote%2FNode.pm;h=f11c40647cfaafa76dba9d872cdcce650617104e;hp=7363f5e885e1330f0eb78136644cd6adebe78ea0;hb=55c0d0209fa9d9265ff178f54ae9fe5fdddef3c1;hpb=5ccce2d5c1fb651f83c73c811069003e4a591a53 diff --git a/lib/Object/Remote/Node.pm b/lib/Object/Remote/Node.pm index 7363f5e..f11c406 100644 --- a/lib/Object/Remote/Node.pm +++ b/lib/Object/Remote/Node.pm @@ -8,18 +8,18 @@ use Object::Remote; use CPS::Future; sub run { - my ($class, %args) = @_; + my ($class, %args) = @_; log_trace { "run() has been invoked on remote node" }; - + my $c = Object::Remote::Connector::STDIO->new->connect; - + $c->register_class_call_handler; my $loop = Object::Remote->current_loop; - - $c->on_close->on_ready(sub { + + $c->on_close->on_ready(sub { log_debug { "Node connection with call handler has closed" }; - $loop->want_stop + $loop->want_stop }); Dlog_trace { "Node is sending 'Shere' to $_" } $c->send_to_fh; @@ -28,8 +28,8 @@ sub run { log_debug { "Node is going to start the run loop" }; #TODO the alarm should be reset after the run loop starts #at a minimum - the remote side node should probably send - #a command that clears the alarm in all instances - even - #if the Object::Remote::Watchdog is not being used + #a command that clears the alarm in all instances - even + #if the Object::Remote::Watchdog is not being used if ($args{watchdog_timeout}) { Object::Remote::WatchDog->new(timeout => $args{watchdog_timeout}); } else {