X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FObject%2FRemote%2FRole%2FConnector%2FPerlInterpreter.pm;h=5406428295b1e59cd2b007b9a472f2b6f6adf343;hb=b1f10b7944d395e404beb995813271d857d143f7;hp=4f74078d6799a4cc907746ce52532767696aa6cb;hpb=353556c4b81bcb3a0c3fff934eff5ab2f19733d4;p=scpubgit%2FObject-Remote.git diff --git a/lib/Object/Remote/Role/Connector/PerlInterpreter.pm b/lib/Object/Remote/Role/Connector/PerlInterpreter.pm index 4f74078..5406428 100644 --- a/lib/Object/Remote/Role/Connector/PerlInterpreter.pm +++ b/lib/Object/Remote/Role/Connector/PerlInterpreter.pm @@ -14,6 +14,10 @@ use Moo::Role; 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 perl_command => (is => 'lazy'); #if no child_stderr file handle is specified then stderr #of the child will be connected to stderr of the parent @@ -26,11 +30,24 @@ sub _build_module_sender { return $hook ? $hook->sender : Object::Remote::ModuleSender->new; } -has perl_command => (is => 'lazy'); -has watchdog_timeout => ( is => 'ro', required => 1, default => sub { 0 } ); - -#TODO convert the ulimit and nice values into configurable attributes -sub _build_perl_command {[ 'sh -c "ulimit -v 200000; nice -n 15 perl -"' ] } +sub _build_perl_command { + my ($self) = @_; + my $nice = $self->nice; + my $ulimit = $self->ulimit; + my $shell_code = ''; + + if (defined($ulimit)) { + $shell_code .= "ulimit -v $ulimit; "; + } + + if (defined($nice)) { + $shell_code .= "nice -n $nice "; + } + + $shell_code .= 'perl -'; + + return [ 'sh', '-c', $shell_code ]; +} around connect => sub { my ($orig, $self) = (shift, shift); @@ -64,7 +81,7 @@ sub _start_perl { if (defined($given_stderr)) { #if the stderr data goes to an existing file handle - #an need an anonymous file handle is required + #an anonymous file handle is required #as the other half of a pipe style file handle pair #so the file handles can go into the run loop $foreign_stderr = gensym(); @@ -181,8 +198,6 @@ sub fatnode_text { $text = "my \$WATCHDOG_TIMEOUT = undef;\n"; } - $text .= 'BEGIN { $ENV{OBJECT_REMOTE_DEBUG} = 1 }'."\n" - if $ENV{OBJECT_REMOTE_DEBUG}; $text .= <<'END'; $INC{'Object/Remote/FatNode.pm'} = __FILE__; $Object::Remote::FatNode::DATA = <<'ENDFAT';