1 files changed, 101 insertions, 0 deletions
diff --git a/bin/PerlACE/Process_Unix.pm b/bin/PerlACE/Process_Unix.pm
new file mode 100644
index 00000000000..4f5a37ae611
--- /dev/null
+++ b/bin/PerlACE/Process_Unix.pm
@@ -0,0 +1,101 @@
+# $Id$
+
+package PerlACE::Process;
+
+use POSIX "sys_wait_h";
+use Cwd;
+
+### @todo finish
+
+$EXEPREFIX = "./";
+$TARGETHOSTNAME = "localhost";
+
+$cwd = getcwd();
+PerlACE::checkForTarget($cwd);
+
+  for($i = 0; $i <= $#ARGV; $i++) {
+    if ($ARGV[$i] eq '-chorus') {  
+      if (defined $ARGV[$i + 1]) {
+        $::TARGETHOSTNAME = $ARGV[$i + 1];
+        $::EXEPREFIX = "rsh $::TARGETHOSTNAME arun $cwd$::DIR_SEPARATOR";
+      }
+      else {
+        print STDERR "The -chorus option requires " .
+                     "the hostname of the target\n";
+        exit(1);
+      }
+      splice(@ARGV, $i, 2);
+      # Don't break from the loop just in case there
+      # is an accidental duplication of the -chorus option
+    }
+  }
+
+
+sub Create
+{
+  my $name = shift;
+  my $args = shift;
+  my $self = [];
+
+  FORK:
+  {
+    if ($self->[0] = fork)
+    {
+      #parent here
+      bless $self;
+    }
+    elsif (defined $self->[0])
+    {
+      #child here
+      exec $name." ".$args;
+      die "ERROR: exec failed for <$name> <$args>";
+    }
+    elsif ($! =~ /No more process/)
+    {
+      #EAGAIN, supposedly recoverable fork error
+      sleep 5;
+      redo FORK;
+    }
+    else 
+    {
+      # weird fork error
+      print STDERR "ERROR: Can't fork: $!\n";
+    }
+  }
+}
+
+sub Terminate
+{
+  my $self = shift;
+  kill ('TERM', $self->[0]);
+  # print STDERR "Process_Unix::Kill 'TERM' $self->[0]\n";
+}
+
+sub Kill
+{
+  my $self = shift;
+  kill ('KILL', $self->[0]);
+  # print STDERR "Process_Unix::Kill 'TERM' $self->[0]\n";
+}
+
+sub Wait
+{
+  my $self = shift;
+  waitpid ($self->[0], 0);
+}
+
+sub TimedWait
+{
+  my $self = shift;
+  my $maxtime = shift;
+  while ($maxtime-- != 0) {
+    my $pid = waitpid ($self->[0], &WNOHANG);
+    if ($pid != 0 && $? != -1) {
+      return $?;
+    }
+    sleep 1;
+  }
+  return -1;
+}
+
+1;