bin/Process_Unix.pm


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

# $Id$
package Process;

use POSIX "sys_wait_h";

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;