--- loncom/loncron 2005/10/06 20:35:50 1.61 +++ loncom/loncron 2006/01/27 21:30:53 1.64 @@ -2,7 +2,7 @@ # Housekeeping program, started by cron, loncontrol and loncron.pl # -# $Id: loncron,v 1.61 2005/10/06 20:35:50 albertel Exp $ +# $Id: loncron,v 1.64 2006/01/27 21:30:53 albertel Exp $ # # Copyright Michigan State University Board of Trustees # @@ -45,13 +45,13 @@ my $statusdir="/home/httpd/html/lon-stat # -------------------------------------------------- Non-critical communication sub reply { - my ($cmd,$server)=@_; - my $peerfile="$perlvar{'lonSockDir'}/$server"; + my ($cmd,$server,$hostname)=@_; + my $peerfile="$perlvar{'lonSockDir'}/".$hostname->{$server}; my $client=IO::Socket::UNIX->new(Peer =>"$peerfile", Type => SOCK_STREAM, Timeout => 10) or return "con_lost"; - print $client "$cmd\n"; + print $client "sethost:$server:$cmd\n"; my $answer=<$client>; chomp($answer); if (!$answer) { $answer="con_lost"; } @@ -98,7 +98,7 @@ sub start_daemon { my $lfh=IO::File->new("$pidfile"); my $daemonpid=<$lfh>; chomp($daemonpid); - if (kill 0 => $daemonpid) { + if ($daemonpid =~ /^\d+$/ && kill 0 => $daemonpid) { return 1; } else { return 0; @@ -112,6 +112,7 @@ sub start_daemon { sub checkon_daemon { my ($fh,$daemon,$maxsize,$send,$args)=@_; + my $result; &log($fh,'
');
printf("%-15s ",$daemon);
if (-e "$perlvar{'lonDaemons'}/logs/$daemon.log"){
@@ -134,7 +135,7 @@ sub checkon_daemon {
my $lfh=IO::File->new("$pidfile");
$daemonpid=<$lfh>;
chomp($daemonpid);
- if (kill 0 => $daemonpid) {
+ if ($daemonpid =~ /^\d+$/ && kill 0 => $daemonpid) {
&log($fh,"$daemon at pid $daemonpid responding");
if ($send) { &log($fh,", sending $send"); }
&log($fh,"
");
@@ -142,8 +143,10 @@ sub checkon_daemon {
if ($send eq 'USR2') { kill USR2 => $daemonpid; }
$restartflag=0;
if ($send eq 'USR2') {
+ $result = 'reloaded';
print "reloaded\n";
} else {
+ $result = 'running';
print "running\n";
}
} else {
@@ -169,6 +172,7 @@ sub checkon_daemon {
if (&start_daemon($fh,$daemon,$pidfile,$args)) {
&log($fh,"$daemon at pid $daemonpid responding
");
$simplestatus{$daemon}='restarted';
+ $result = 'started';
print "started\n";
} else {
$errors++;
@@ -178,8 +182,10 @@ sub checkon_daemon {
if (&start_daemon($fh,$daemon,$pidfile,$args)) {
&log($fh,"$daemon at pid $daemonpid responding
");
$simplestatus{$daemon}='restarted';
+ $result = 'started';
print "started\n";
} else {
+ $result = 'failed';
print " failed\n";
$simplestatus{$daemon}='failed';
$errors++; $errors++;
@@ -216,6 +222,7 @@ sub checkon_daemon {
}
&errout($fh);
+ return $result;
}
# --------------------------------------------------------------------- Machine
@@ -479,7 +486,7 @@ sub test_connections {
foreach my $tryserver (sort(keys(%{$hostname}))) {
print(".");
my $result;
- my $answer=reply("ping",$tryserver);
+ my $answer=reply("ping",$tryserver,$hostname);
if ($answer eq "$tryserver:$perlvar{'lonHostID'}") {
$result="ok";
$good++;
@@ -695,10 +702,14 @@ sub main () {
}
if (!$justcheckconnections && !$justreload) {
&checkon_daemon($fh,'lonsql',200000);
- &checkon_daemon($fh,'lond',40000,'USR1');
+ if ( &checkon_daemon($fh,'lond',40000,'USR1') eq 'running') {
+ &checkon_daemon($fh,'lond',40000,'USR2');
+ }
my $args='new';
if ($oldlonc) { $args = ''; }
- &checkon_daemon($fh,'lonc',40000,'USR1',$args);
+ if ( &checkon_daemon($fh,'lonc',40000,'USR1',$args) eq 'running') {
+ &checkon_daemon($fh,'lond',40000,'USR2',$args);
+ }
&checkon_daemon($fh,'lonhttpd',40000);
&checkon_daemon($fh,'lonmemcached',40000);
}
@@ -708,7 +719,7 @@ sub main () {
if ($oldlonc) { $args = ''; }
&checkon_daemon($fh,'lonc',40000,'USR2',$args);
}
- if (!$justcheckdaemons && !$justreload) {
+ if ($justcheckconnections) {
&test_connections($fh,\%hostname);
}
if (!$justcheckdaemons && !$justcheckconnections && !$justreload) {