boot systemrescue 1.6.1
[pxelator] / lib / PXElator / daemons.pm
1 package daemons;
2
3 use warnings;
4 use strict;
5
6 use File::Slurp;
7 use Data::Dump qw/dump/;
8
9 use x11;
10 use store;
11
12 our $pids;
13 $pids = {
14         httpd => $$,
15         kvm => 'not started',
16         wireshark => 'not started',
17 } unless defined $pids; # keep pids on refresh
18
19 sub DESTROY {
20         warn "pids ",dump( $pids );
21         foreach ( values %$pids ) {
22                 warn "kill $_";
23                 kill 1,$_ || kill 9, $_;
24         }
25 }
26
27 $SIG{CHLD} = 'IGNORE';
28
29 sub audit {
30         my $msg = shift;
31         my $daemon = shift;
32         store::audit( $msg, $daemon, { daemon => $daemon, message => $msg, @_ } );
33 }
34
35 mkdir "$server::conf/pid" unless -d "$server::conf/pid";
36
37 sub start_stop {
38         my ($daemon,$param) = @_;
39
40         $daemon .= '.' . $param->{nr} if defined $param->{nr}; # XXX nr for kvm
41
42         my $pid = $pids->{$daemon};
43         my $pid_path = $daemon;
44         $pid_path =~ s{/}{-}g;
45         $pid_path = "$server::conf/pid/$pid_path";
46
47         warn "# start_stop $daemon ",dump( $param );
48
49         if ( ! $pid && -e $pid_path ) {
50                 my $p = read_file $pid_path;
51                 if ( kill 0, $p ) {
52                         audit 'adopted', $daemon, pid => $p;
53                         return $pids->{$daemon} = $p;
54                 } else {
55                         audit 'not running', $daemon, pid => $p;
56                         unlink $pid_path;
57                 }
58         }
59
60         $pid ||= 'not started';
61         warn "start_stop $daemon $pid\n";
62
63         if ( $pid =~ m{^\d+$} && kill 0, $pid ) {
64                 my $pstree = `pstree -p $pid`;
65                 my @pids = $pstree =~ m{\((\d+)\)}g;
66                 warn "pstree $pstree pids ",dump( @pids );
67                 foreach ( @pids ) {
68                         warn "kill $_\n";
69                         kill 1, $_;
70                         if ( kill 0, $_ ) {
71                                 warn "kill 9 $_";
72                                 kill 9, $_;
73                         }
74                 }
75                 $pids->{$daemon} = 'stopped';
76                 audit 'stopped', $daemon, pid => $pid;
77                 return qq|$daemon pid $pid stopped|;
78         } else {
79
80                 $ENV{$_} = $param->{$_} foreach keys %$param;
81
82                 if ( $pid = fork ) {
83                         # parent
84                         $pids->{$daemon} = $pid;
85                         write_file $pid_path, $pid;
86                         audit 'forked', $daemon, pid => $pid;
87
88                         delete $ENV{$_} foreach keys %$param; # cleanup enviroment
89
90                         return qq|$daemon pid $pid started|;
91                 } elsif ( defined $pid ) {
92                         # child
93                         my $invoke = 'start';
94                         $invoke = $1 if $daemon =~ s{/(.+)}{};
95                         #warn "## ENV child ",dump( %ENV );
96                         if ( $daemon =~ m{dhcpd|tftpd|dnsd|syslogd} ) {
97                                 my $exec = "perl -I$server::base_dir/lib -I$server::base_dir/lib/PXElator -M$daemon -e ${daemon}::${invoke}";
98                                 audit 'exec', $daemon, 'exec' => $exec;
99                                 x11::xterm( $daemon => $exec );
100                         } else {
101                                 $daemon =~ s{\.\d+$}{} if defined $ENV{nr};
102                                 my $eval = $daemon . '::' . $invoke . '(' . dump( $param ) . ')';
103                                 audit 'eval', $daemon, 'eval' => $eval;
104                                 eval $eval;
105                                 audit 'error', $daemon, error => $@  if $@;
106                         }
107                         exit;
108                 } else {
109                         audit 'error', $daemon, error => $!;
110                         die "fork error $!";
111                 }
112         }
113 }
114