with 'Object::Remote::Role::Connector';
has module_sender => (is => 'lazy');
-has ulimit => ( is => 'ro' );
-has nice => ( is => 'ro' );
-has watchdog_timeout => ( is => 'ro', required => 1, default => sub { undef } );
+has ulimit => ( is => 'ro');
+has nice => ( is => 'ro');
+has watchdog_timeout => ( is => 'ro', required => 1, default => sub { undef });
has perl_command => (is => 'lazy');
+has pid => (is => 'rwp');
+has connection_id => (is => 'rwp');
#if no child_stderr file handle is specified then stderr
#of the child will be connected to stderr of the parent
}
sub _build_perl_command {
- my ($self) = @_;
+ my ($self) = @_;
my $nice = $self->nice;
my $ulimit = $self->ulimit;
- my $shell_code = '';
-
+ my $perl_path = 'perl';
+ my $shell_code = '';
+
if (defined($ulimit)) {
- $shell_code .= "ulimit -v $ulimit; ";
+ $shell_code .= "ulimit $ulimit || exit 1; ";
}
-
+
if (defined($nice)) {
$shell_code .= "nice -n $nice ";
}
-
- $shell_code .= 'perl -';
-
- return [ 'sh', '-c', $shell_code ];
+
+ if (defined($ENV{OBJECT_REMOTE_PERL_BIN})) {
+ log_debug { "Using OBJECT_REMOTE_PERL_BIN environment variable as perl path" };
+ $perl_path = $ENV{OBJECT_REMOTE_PERL_BIN};
+ }
+
+ $shell_code .= $perl_path . ' -';
+
+ return [ 'bash', '-c', $shell_code ];
}
around connect => sub {
return future {
$f->on_done(sub {
my ($conn) = $f->get;
- $self->_setup_watchdog_reset($conn);
- my $sub = $conn->remote_sub('Object::Remote::Logging::init_logging_forwarding');
+ $self->_setup_watchdog_reset($conn);
+ my $sub = $conn->remote_sub('Object::Remote::Logging::init_remote_logging');
$sub->('Object::Remote::Logging', router => router(), connection_id => $conn->_id);
Object::Remote::Handle->new(
connection => $conn,
my $given_stderr = $self->stderr;
my $foreign_stderr;
- Dlog_debug { "invoking connection to perl interpreter using command line: $_" } @{$self->final_perl_command};
+ Dlog_verbose {
+ s/\n/ /g; "invoking connection to perl interpreter using command line: $_"
+ } @{$self->final_perl_command};
if (defined($given_stderr)) {
#if the stderr data goes to an existing file handle
@{$self->final_perl_command},
) or die "Failed to run perl at '$_[0]': $!";
+ $self->_set_pid($pid);
+
if (defined($given_stderr)) {
Dlog_debug { "Child process STDERR is being handled via run loop" };
my $self = shift;
my ($foreign_stdin, $foreign_stdout, $pid) = $self->_start_perl(@_);
my $to_send = $self->fatnode_text;
- log_debug { my $len = length($to_send); "Sending contents of fat node to remote node; size is '$len' characters" };
+ log_debug { my $len = length($to_send); "Sending contents of fat node to remote node; size is '$len' characters" };
Object::Remote->current_loop
->watch_io(
handle => $foreign_stdin,
}
if (defined($watchdog_timeout)) {
- $text .= "my \$WATCHDOG_TIMEOUT = $watchdog_timeout;\n";
+ $text .= "my \$WATCHDOG_TIMEOUT = $watchdog_timeout;\n";
} else {
$text .= "my \$WATCHDOG_TIMEOUT = undef;\n";
}
+ $text .= '$Object::Remote::FatNode::REMOTE_NODE = "1";' . "\n";
+
$text .= <<'END';
$INC{'Object/Remote/FatNode.pm'} = __FILE__;
$Object::Remote::FatNode::DATA = <<'ENDFAT';