version 1.64, 2004/08/20 16:42:41
|
version 1.73, 2006/02/08 17:11:46
|
Line 241 unless ($dbh = DBI->connect("DBI:mysql:l
|
Line 241 unless ($dbh = DBI->connect("DBI:mysql:l
|
|
|
exit 1; |
exit 1; |
} else { |
} else { |
|
unlink('/home/httpd/html/lon-status/mysql.txt'); |
$dbh->disconnect; |
$dbh->disconnect; |
} |
} |
|
|
Line 258 if (-e $pidfile) {
|
Line 259 if (-e $pidfile) {
|
# |
# |
# Read hosts file |
# Read hosts file |
# |
# |
my %hostip; |
|
my $thisserver; |
my $thisserver; |
|
my %hostname; |
my $PREFORK=4; # number of children to maintain, at least four spare |
my $PREFORK=4; # number of children to maintain, at least four spare |
open (CONFIG,"$perlvar{'lonTabDir'}/hosts.tab") || die "Can't read host file"; |
open (CONFIG,"$perlvar{'lonTabDir'}/hosts.tab") || die "Can't read host file"; |
while (my $configline=<CONFIG>) { |
while (my $configline=<CONFIG>) { |
my ($id,$domain,$role,$name,$ip)=split(/:/,$configline); |
my ($id,$domain,$role,$name)=split(/:/,$configline); |
chomp($ip); |
$name=~s/\s//g; |
$hostip{$ip}=$id; |
|
$thisserver=$name if ($id eq $perlvar{'lonHostID'}); |
$thisserver=$name if ($id eq $perlvar{'lonHostID'}); |
$PREFORK++; |
$hostname{$id}=$name; |
|
#$PREFORK++; |
} |
} |
close(CONFIG); |
close(CONFIG); |
# |
# |
$PREFORK=int($PREFORK/4); |
#$PREFORK=int($PREFORK/4); |
|
|
# |
# |
# Create a socket to talk to lond |
# Create a socket to talk to lond |
Line 387 sub make_new_child {
|
Line 388 sub make_new_child {
|
$run = $run+1; |
$run = $run+1; |
my $userinput = <$client>; |
my $userinput = <$client>; |
chomp($userinput); |
chomp($userinput); |
|
$userinput=~s/\:(\w+)$//; |
|
my $searchdomain=$1; |
# |
# |
my ($conserver,$query, |
my ($conserver,$query, |
$arg1,$arg2,$arg3)=split(/&/,$userinput); |
$arg1,$arg2,$arg3)=split(/&/,$userinput); |
Line 424 sub make_new_child {
|
Line 427 sub make_new_child {
|
$result='no_such_file'; |
$result='no_such_file'; |
} |
} |
# end of log query |
# end of log query |
} elsif ($query eq 'fetchenrollment') { |
} elsif (($query eq 'fetchenrollment') || |
|
($query eq 'institutionalphotos')) { |
# retrieve institutional class lists |
# retrieve institutional class lists |
my $dom = &unescape($arg1); |
my $dom = &unescape($arg1); |
my %affiliates = (); |
my %affiliates = (); |
Line 432 sub make_new_child {
|
Line 436 sub make_new_child {
|
my $locresult = ''; |
my $locresult = ''; |
my $querystr = &unescape($arg3); |
my $querystr = &unescape($arg3); |
foreach (split/%%/,$querystr) { |
foreach (split/%%/,$querystr) { |
if (/^(\w+)=([^=]+)$/) { |
if (/^([^=]+)=([^=]+)$/) { |
@{$affiliates{$1}} = split/,/,$2; |
@{$affiliates{$1}} = split/,/,$2; |
} |
} |
} |
} |
$locresult = &localenroll::fetch_enrollment($dom,\%affiliates,\%replies); |
if ($query eq 'fetchenrollment') { |
|
$locresult = &localenroll::fetch_enrollment($dom,\%affiliates,\%replies); |
|
} elsif ($query eq 'institutionalphotos') { |
|
my $crs = &unescape($arg2); |
|
$locresult = &localenroll::institutional_photos($dom,$crs,\%affiliates,\%replies,'update'); |
|
} |
$result = &escape($locresult.':'); |
$result = &escape($locresult.':'); |
if ($locresult) { |
if ($locresult) { |
$result .= &escape(join(':',map{$_.'='.$replies{$_}} keys %replies)); |
$result .= &escape(join(':',map{$_.'='.$replies{$_}} keys %replies)); |
Line 509 sub process_file {
|
Line 518 sub process_file {
|
|
|
sub do_sql_query { |
sub do_sql_query { |
my ($query,$custom,$customshow) = @_; |
my ($query,$custom,$customshow) = @_; |
&logthis('doing query '.$query); |
# &logthis('doing query '.$query); |
$custom = &unescape($custom); |
$custom = &unescape($custom); |
$customshow = &unescape($customshow); |
$customshow = &unescape($customshow); |
# |
# |
Line 653 Returns: The results of the message or '
|
Line 662 Returns: The results of the message or '
|
######################################################## |
######################################################## |
sub subreply { |
sub subreply { |
my ($cmd,$server)=@_; |
my ($cmd,$server)=@_; |
my $peerfile="$perlvar{'lonSockDir'}/$server"; |
my $peerfile="$perlvar{'lonSockDir'}/".$hostname{$server}; |
my $sclient=IO::Socket::UNIX->new(Peer =>"$peerfile", |
my $sclient=IO::Socket::UNIX->new(Peer =>"$peerfile", |
Type => SOCK_STREAM, |
Type => SOCK_STREAM, |
Timeout => 10) |
Timeout => 10) |
or return "con_lost"; |
or return "con_lost"; |
print $sclient "$cmd\n"; |
print $sclient "sethost:$server:$cmd\n"; |
my $answer=<$sclient>; |
my $answer=<$sclient>; |
chomp($answer); |
chomp($answer); |
$answer="con_lost" if (!$answer); |
$answer="con_lost" if (!$answer); |