--- lib/PXElator/httpd.pm 2009/07/30 12:10:53 53
+++ lib/PXElator/httpd.pm 2009/07/31 18:48:29 91
@@ -18,48 +18,114 @@
#use JSON;
use IO::Socket::INET;
use Module::Refresh;
-use Parallel::ForkManager;
-our $port = 7777;
-our $debug = 1;
+our $pids;
+$pids = { httpd => $$ } unless defined $pids; # keep pids on refresh
-my $pm = Parallel::ForkManager->new(10);
+sub DESTROY {
+ warn "pids ",dump( $pids );
+ foreach ( values %$pids ) {
+ warn "kill $_";
+ kill 1,$_ || kill 9, $_;
+ }
+}
-our $screen_pid;
+our $port = 7777;
use server;
-our $url = "http://$server::ip:$port/";
+our $debug = server::debug;
+our $url = "http://$server::ip:$port";
use html;
+our $static_pids;
sub static {
my ($client,$path) = @_;
- $path = "tftp/$path";
+ my $full = "$server::base_dir/tftp/$path";
+
+ return if ! -f $full;
- if ( ! -e $path || -d $path ) {
- print $client "HTTP/1.0 404 $path not found\r\n";
- return;
+ if ( my $pid = fork ) {
+ # parent
+ close($client);
+ print "http static child $pid\n";
+ $static_pids->{$pid} = $path;
+ return 1;
}
- my $type = 'text/plain';
+ my $type = 'application/octet-stream';
$type = 'text/html' if $path =~ m{\.htm};
$type = 'application/javascript' if $path =~ m{\.js};
+ $type = 'text/plain' if $path =~ m{\.txt};
+
+ my $size = -s $full || return;
- print $client "HTTP/1.0 200 OK\r\nContent-Type: $type\r\nContent-Length: ", -s $path,"\r\n\r\n";
- open(my $html, $path);
- while(<$html>) {
- print $client $_;
+ print $client "HTTP/1.0 200 OK\r\nContent-Type: $type\r\nContent-Length: $size\r\nConnection: close\r\n\r\n";
+
+ open(my $fh, $full);
+ print "static $path $type $size\n";
+
+ my $block = 8192;
+ my $buff;
+ my $pos = 0;
+
+ while( my $len = read $fh, $buff, $block ) {
+ print $client $buff;
+ $pos += $len;
+ printf "%s %d/%d %.2f%%\r", $path, $pos, $size, $pos * 100 / $size;
}
- close($html);
+ close($fh);
+ close($client);
- return $path;
-}
+ print "$path $pos == $size OK\n";
-my $ok = "HTTP/1.0 200 OK\r\nContent-Type: text/html\r\nConnection: close\r\n\r\n";
+ exit;
+}
use boolean;
+
use screen;
+use kvm;
+
+$SIG{CHLD} = 'IGNORE';
+
+sub start_stop {
+ my $daemon = shift;
+ my $pid = $pids->{$daemon};
+
+ warn "start_stop $daemon $pid pids: ",dump( $pids );
+
+ if ( $pid =~ m{^\d+$} ) {
+ my $pstree = `pstree -p $pid`;
+ my @pids = $pstree =~ m{\((\d+)\)}g;
+ warn "pstree $pstree pids ",dump( @pids );
+ kill 1, $_ foreach reverse @pids;
+ $pids->{$daemon} = 'stopped';
+ return qq|$daemon pid $pid stopped|;
+ } else {
+ if ( $pid = fork ) {
+ # parent
+ $pids->{$daemon} = $pid;
+ warn "forked $daemon $pid";
+ return qq|$daemon pid $pid started|;
+ } elsif ( defined $pid ) {
+ # child
+ my $invoke = 'start';
+ $invoke = $1 if $daemon =~ s{/(.+)}{};
+ my $eval = $daemon . '::' . $invoke . '(' . ( @_ ? dump(@_) : '' ) . ')';
+ warn "eval $eval";
+ eval $eval;
+ warn "can't start $daemon: $@" if $@;
+ exit;
+ } else {
+ die "fork error $!";
+ }
+ }
+}
+
+my $ok = qq|HTTP/1.0 200 OK\r\nContent-Type: text/html\r\nConnection: close\r\n\r\n|;
+my $redirect = qq|HTTP/1.1 302 Found\r\nContent-type: text/html\r\nLocation: $url\r\n\r\n|;
sub get_request {
my ( $client, $path, $param ) = @_;
@@ -70,40 +136,88 @@
warn "static $found" if $debug;
} elsif ( $path eq '/' ) {
- my $screen = $screen_pid ? qq|stop $screen_pid| : 'start';
+ my $screen = $pids->{screen} ? qq|stop $pids->{screen}| : 'start';
+ my $kvm = $pids->{kvm} ? qq|stop $pids->{kvm}| :
+ $pids->{screen} ? qq|start| : qq|start screen first|;
+
+ my @rows = (
+ 'ip', html::tt( $server::ip ),
+ 'netmask', html::tt( $server::netmask ),
- print $client $ok,
- html::table( 2,
- 'pid', $$,
- 'debug', qq|$debug|,
- 'screen', qq|$screen|,
+ 'debug', qq|$debug|,
);
- } elsif ( $path =~ m{^/our/(\w+)/(\S+)} ) {
- eval 'our $' . $1 . ' = ' . $2;
- warn $@ if $@;
- print $client qq|HTTP/1.1 302 Found\r\nLocation: $url\r\nContent-type: text/html\r\n\r\n$1 = $2
Location: $url|;
- } elsif ( $path =~ m{^/screen} ) {
+ my $debug_proc;
+
+ warn 'pids: ', dump( $pids ) if $debug;
+ foreach my $name ( sort keys %$pids ) {
+ my $pid = $pids->{$name} || next;
+
+ my $html = qq|$pid|;
+
+ my $proc = "/proc/$pid/status";
+
+ if ( -e $proc ) {
+ if ( $debug ) {
+ $html .= qq| ?|;
+
+ $debug_proc
+ .= qq|$proc
| + . read_file($proc) + . qq|| + ; + } + + if ( $name->can('start_fork') ) { + $html .= qq| $_| foreach $name->start_fork; + } - if ( $screen_pid ) { - if ( ! kill $screen_pid ) { - warn "kill -9 $screen_pid"; - if ( kill 9, $screen_pid ) { - print $client $ok, qq|screen pid $screen_pid stopped|; - $screen_pid = 0; - } else { - print $client $ok, qq|can't stop screen $screen_pid: $!|; + if ( $name->can('actions') ) { + $html .= qq| $_| foreach $name->actions; } } - } else { - if ( $screen_pid = $pm->start ) { - print $client $ok, qq|screen started pid $screen_pid|; + + push @rows, ( $name => $html ); + } + + my $below_table = ''; + + warn 'static_pids: ', dump( $static_pids ) if $debug; + foreach my $pid ( keys %$static_pids ) { + my $path = $static_pids->{$pid}; + if ( -d "/proc/$pid" ) { + push @rows, ( $path => qq|$pid| ); + } elsif ( $param->{clean_completed_downloads} ) { + delete $static_pids->{$pid} } else { - screen::start; - $pm->finish; + push @rows, ( $path => "$pid competed" ); + $below_table = qq|clean completed downloads|; } } + print $client $ok + , html::table( 2, @rows ) + , $below_table + , html::tabs( log::mac_changes ) + , $debug_proc + ; + + } elsif ( $path =~ m{^/our/(\w+)/(\S+)} ) { + eval 'our $' . $1 . ' = ' . $2; + warn $@ if $@; + print $client $redirect, qq|$1 = $2