version 1.66, 2006/02/06 09:08:56
|
version 1.68, 2006/10/25 21:33:54
|
Line 486 sub test_connections {
|
Line 486 sub test_connections {
|
foreach my $tryserver (sort(keys(%{$hostname}))) { |
foreach my $tryserver (sort(keys(%{$hostname}))) { |
print("."); |
print("."); |
my $result; |
my $result; |
my $answer=reply("ping",$tryserver,$hostname); |
my $answer=&reply("ping",$tryserver,$hostname); |
if ($answer eq "$tryserver:$perlvar{'lonHostID'}") { |
if ($answer eq "$tryserver:$perlvar{'lonHostID'}") { |
$result="<b>ok</b>"; |
$result="<b>ok</b>"; |
$good++; |
$good++; |
Line 511 sub test_connections {
|
Line 511 sub test_connections {
|
|
|
# ------------------------------------------------------------ Delayed messages |
# ------------------------------------------------------------ Delayed messages |
sub check_delayed_msg { |
sub check_delayed_msg { |
my ($fh)=@_; |
my ($fh,$hostname)=@_; |
&log($fh,'<hr /><a name="delayed" /><h2>Delayed Messages</h2>'); |
&log($fh,'<hr /><a name="delayed" /><h2>Delayed Messages</h2>'); |
print "checking buffers\n"; |
print "checking buffers\n"; |
|
|
Line 536 sub check_delayed_msg {
|
Line 536 sub check_delayed_msg {
|
|
|
if ($unsend) { $simplestatus{'unsend'}=$unsend; } |
if ($unsend) { $simplestatus{'unsend'}=$unsend; } |
&log($fh,"<h3>Outgoing Buffer</h3>\n<pre>"); |
&log($fh,"<h3>Outgoing Buffer</h3>\n<pre>"); |
|
# list directory with delayed messages and remember offline servers |
|
my %servers=(); |
open (DFH,"ls -lF $perlvar{'lonSockDir'}/delayed|"); |
open (DFH,"ls -lF $perlvar{'lonSockDir'}/delayed|"); |
while (my $line=<DFH>) { |
while (my $line=<DFH>) { |
|
my ($server)=($line=~/\.(\w+)$/); |
|
if ($server) { $servers{$server}=1; } |
&log($fh,&encode_entities($line,'<>&"')); |
&log($fh,&encode_entities($line,'<>&"')); |
} |
} |
&log($fh,"</pre>\n"); |
&log($fh,"</pre>\n"); |
close (DFH); |
close (DFH); |
|
# pong to all servers that have delayed messages |
|
# this will trigger a reverse connection, which should flush the buffers |
|
foreach my $tryserver (keys %servers) { |
|
my $answer=&reply("pong",$tryserver,$hostname); |
|
&log($fh,"Pong to $tryserver: $answer"); |
|
} |
} |
} |
|
|
sub finish_logging { |
sub finish_logging { |
Line 707 sub main () {
|
Line 716 sub main () {
|
} |
} |
my $args='new'; |
my $args='new'; |
if ($oldlonc) { $args = ''; } |
if ($oldlonc) { $args = ''; } |
&checkon_daemon($fh,'lonc',40000,'USR2',$args); |
&checkon_daemon($fh,'lonc',40000,'USR1',$args); |
&checkon_daemon($fh,'lonhttpd',40000); |
&checkon_daemon($fh,'lonhttpd',40000); |
&checkon_daemon($fh,'lonmemcached',40000); |
&checkon_daemon($fh,'lonmemcached',40000); |
} |
} |
Line 721 sub main () {
|
Line 730 sub main () {
|
&test_connections($fh,\%hostname); |
&test_connections($fh,\%hostname); |
} |
} |
if (!$justcheckdaemons && !$justcheckconnections && !$justreload) { |
if (!$justcheckdaemons && !$justcheckconnections && !$justreload) { |
&check_delayed_msg($fh); |
&check_delayed_msg($fh,\%hostname); |
&finish_logging($fh); |
&finish_logging($fh); |
&log_simplestatus(); |
&log_simplestatus(); |
|
|