|
version 1.146, 2003/09/16 10:28:14
|
version 1.165.2.3, 2004/03/08 20:13:07
|
|
Line 24
|
Line 24
|
| # |
# |
| # /home/httpd/html/adm/gpl.txt |
# /home/httpd/html/adm/gpl.txt |
| # |
# |
| |
|
| |
|
| # http://www.lon-capa.org/ |
# http://www.lon-capa.org/ |
| # |
# |
| # 5/26/99,6/4,6/10,6/11,6/14,6/15,6/26,6/28,6/30, |
|
| # 7/8,7/9,7/10,7/12,7/17,7/19,9/21, |
|
| # 10/7,10/8,10/9,10/11,10/13,10/15,11/4,11/16, |
|
| # 12/7,12/15,01/06,01/11,01/12,01/14,2/8, |
|
| # 03/07,05/31 Gerd Kortemeyer |
|
| # 06/29,06/30,07/14,07/15,07/17,07/20,07/25,09/18 Gerd Kortemeyer |
|
| # 12/05,12/13,12/29 Gerd Kortemeyer |
|
| # YEAR=2001 |
|
| # 02/12 Gerd Kortemeyer |
|
| # 03/24 Gerd Kortemeyer |
|
| # 05/11,05/28,08/30 Gerd Kortemeyer |
|
| # 11/26,11/27 Gerd Kortemeyer |
|
| # 12/22 Gerd Kortemeyer |
|
| # YEAR=2002 |
|
| # 01/20/02,02/05 Gerd Kortemeyer |
|
| # 02/05 Guy Albertelli |
|
| # 02/12 Gerd Kortemeyer |
|
| # 02/19 Matthew Hall |
|
| # 02/25 Gerd Kortemeyer |
|
| # 01/xx/2003 Ron Fox.. Remove preforking. This makes the general daemon |
|
| # logic simpler (and there were problems maintaining the preforked |
|
| # population). Since the time averaged connection rate is close to zero |
|
| # because lonc's purpose is to maintain near continuous connnections, |
|
| # preforking is not really needed. |
|
| # 08/xx/2003 Ron Fox: Add management requests. Management requests |
|
| # will be validated via a call to ValidateManager. At present, this |
|
| # is done by simple host verification. In the future we can modify |
|
| # this function to do a certificate check. |
|
| # Management functions supported include: |
|
| # - pushing /home/httpd/lonTabs/hosts.tab |
|
| # - pushing /home/httpd/lonTabs/domain.tab |
|
| # 09/08/2003 Ron Fox: Told lond to take care of change logging so we |
|
| # don't have to remember it: |
|
| # $Log$ |
|
| # Revision 1.146 2003/09/16 10:28:14 foxr |
|
| # ReinitProcess - decode the process selector and produce the associated pid |
|
| # filename. Note: While it is possible to test that valid process selectors are |
|
| # handled properly I am not able to test that invalid process selectors produce |
|
| # the appropriate error as lonManage also blocks the use of invalid process selectors. |
|
| # |
|
| # Revision 1.145 2003/09/16 10:13:20 foxr |
|
| # Added ReinitProcess function to oversee the parsing and processing of the |
|
| # reinit:<process> client request. |
|
| # |
|
| # Revision 1.144 2003/09/16 09:47:01 foxr |
|
| # Added skeletal support for SIGUSR2 (update hosts.tab) |
|
| # |
|
| # Revision 1.143 2003/09/15 10:03:52 foxr |
|
| # Completed and tested code for pushfile. |
|
| # |
|
| # Revision 1.142 2003/09/09 20:47:46 www |
|
| # Permanently store chatroom entries in chatroom.log |
|
| # |
|
| # Revision 1.141 2003/09/08 10:32:07 foxr |
|
| # Added PushFile sub This sub oversees the push of a new configuration table file |
|
| # Currently supported files are: |
|
| # - hosts.tab (transaction pushfile:hosts:contents) |
|
| # - domain.tab (transaction pushfile:domain:contents) |
|
| # |
|
| |
|
| |
|
| use strict; |
use strict; |
| use lib '/home/httpd/lib/perl/'; |
use lib '/home/httpd/lib/perl/'; |
|
Line 117 my $currentdomainid;
|
Line 59 my $currentdomainid;
|
| |
|
| my $client; |
my $client; |
| my $clientip; |
my $clientip; |
| |
my $clientname; |
| |
|
| my $server; |
my $server; |
| my $thisserver; |
my $thisserver; |
| |
|
| |
# |
| |
# Connection type is: |
| |
# client - All client actions are allowed |
| |
# manager - only management functions allowed. |
| |
# both - Both management and client actions are allowed |
| |
# |
| |
|
| |
my $ConnectionType; |
| |
|
| my %hostid; |
my %hostid; |
| my %hostdom; |
my %hostdom; |
| my %hostip; |
my %hostip; |
| |
|
| |
my %managers; # Ip -> manager names |
| |
|
| my %perlvar; # Will have the apache conf defined perl vars. |
my %perlvar; # Will have the apache conf defined perl vars. |
| |
|
| # |
# |
|
Line 154 my @adderrors = ("ok",
|
Line 109 my @adderrors = ("ok",
|
| "lcuseradd Incorrect number of stdinput lines, must be 3", |
"lcuseradd Incorrect number of stdinput lines, must be 3", |
| "lcuseradd Too many other simultaneous pwd changes in progress", |
"lcuseradd Too many other simultaneous pwd changes in progress", |
| "lcuseradd User does not exist", |
"lcuseradd User does not exist", |
| "lcuseradd Unabel to mak ewww member of users's group", |
"lcuseradd Unable to make www member of users's group", |
| "lcuseradd Unable to su to root", |
"lcuseradd Unable to su to root", |
| "lcuseradd Unable to set password", |
"lcuseradd Unable to set password", |
| "lcuseradd Usrname has invbalid charcters", |
"lcuseradd Usrname has invalid characters", |
| "lcuseradd Password has an invalid character", |
"lcuseradd Password has an invalid character", |
| "lcuseradd User already exists", |
"lcuseradd User already exists", |
| "lcuseradd Could not add user.", |
"lcuseradd Could not add user.", |
|
Line 181 sub GetCertificate {
|
Line 136 sub GetCertificate {
|
| return $clientip; |
return $clientip; |
| } |
} |
| |
|
| |
# |
| |
# Return true if client is a manager. |
| |
# |
| |
sub isManager { |
| |
return (($ConnectionType eq "manager") || ($ConnectionType eq "both")); |
| |
} |
| |
# |
| |
# Return tru if client can do client functions |
| |
# |
| |
sub isClient { |
| |
return (($ConnectionType eq "client") || ($ConnectionType eq "both")); |
| |
} |
| |
|
| |
|
| |
# |
| |
# ReadManagerTable: Reads in the current manager table. For now this is |
| |
# done on each manager authentication because: |
| |
# - These authentications are not frequent |
| |
# - This allows dynamic changes to the manager table |
| |
# without the need to signal to the lond. |
| |
# |
| |
|
| |
sub ReadManagerTable { |
| |
|
| |
# Clean out the old table first.. |
| |
|
| |
foreach my $key (keys %managers) { |
| |
delete $managers{$key}; |
| |
} |
| |
|
| |
my $tablename = $perlvar{'lonTabDir'}."/managers.tab"; |
| |
if (!open (MANAGERS, $tablename)) { |
| |
logthis('<font color="red">No manager table. Nobody can manage!!</font>'); |
| |
return; |
| |
} |
| |
while(my $host = <MANAGERS>) { |
| |
chomp($host); |
| |
if (!defined $hostip{$host}) { # This is a non cluster member |
| |
|
| |
# The entry is of the form: |
| |
# cluname:hostname |
| |
# cluname - A 'cluster hostname' is needed in order to negotiate |
| |
# the host key. |
| |
# hostname- The dns name of the host. |
| |
# |
| |
|
| |
my($cluname, $dnsname) = split(/:/, $host); |
| |
open(MGRPIPE, "/usr/bin/host $dnsname |") || die "Can't make host pipeline"; |
| |
my $dnsinfo = <MGRPIPE>; |
| |
chomp $dnsinfo; |
| |
close MGRPIPE; |
| |
my($jname, $jhas, $jaddress, $hostip) = split(/ /, $dnsinfo); |
| |
$managers{$hostip} = $cluname; |
| |
} else { |
| |
$managers{$hostip{$host}} = $host; # Use info from cluster tab if clumemeber |
| |
} |
| |
} |
| |
} |
| |
|
| # |
# |
| # ValidManager: Determines if a given certificate represents a valid manager. |
# ValidManager: Determines if a given certificate represents a valid manager. |
|
Line 192 sub GetCertificate {
|
Line 205 sub GetCertificate {
|
| sub ValidManager { |
sub ValidManager { |
| my $certificate = shift; |
my $certificate = shift; |
| |
|
| my $hostentry = $hostid{$certificate}; |
return isManager; |
| if ($hostentry ne undef) { |
|
| &logthis('<font color="yellow">Authenticating manager'. |
|
| " $hostentry</font>"); |
|
| return 1; |
|
| } else { |
|
| &logthis('<font color="red"> Failed manager authentication '. |
|
| "$certificate </font>"); |
|
| } |
|
| } |
} |
| # |
# |
| # CopyFile: Called as part of the process of installing a |
# CopyFile: Called as part of the process of installing a |
|
Line 251 sub CopyFile {
|
Line 256 sub CopyFile {
|
| return 0; |
return 0; |
| } |
} |
| } |
} |
| |
# |
| |
# Host files are passed out with externally visible host IPs. |
| |
# If, for example, we are behind a fire-wall or NAT host, our |
| |
# internally visible IP may be different than the externally |
| |
# visible IP. Therefore, we always adjust the contents of the |
| |
# host file so that the entry for ME is the IP that we believe |
| |
# we have. At present, this is defined as the entry that |
| |
# DNS has for us. If by some chance we are not able to get a |
| |
# DNS translation for us, then we assume that the host.tab file |
| |
# is correct. |
| |
# BUGBUGBUG - in the future, we really should see if we can |
| |
# easily query the interface(s) instead. |
| |
# Parameter(s): |
| |
# contents - The contents of the host.tab to check. |
| |
# Returns: |
| |
# newcontents - The adjusted contents. |
| |
# |
| |
# |
| |
sub AdjustHostContents { |
| |
my $contents = shift; |
| |
my $adjusted; |
| |
my $me = $perlvar{'lonHostID'}; |
| |
|
| |
foreach my $line (split(/\n/,$contents)) { |
| |
if(!(($line eq "") || ($line =~ /^ *\#/) || ($line =~ /^ *$/))) { |
| |
chomp($line); |
| |
my ($id,$domain,$role,$name,$ip,$maxcon,$idleto,$mincon)=split(/:/,$line); |
| |
if ($id eq $me) { |
| |
open(PIPE, " /usr/bin/host $name |") || die "Cant' make host pipeline"; |
| |
my $hostinfo = <PIPE>; |
| |
close PIPE; |
| |
|
| |
my ($hostname, $has, $address, $ipnew) = split(/ /,$hostinfo); |
| |
&logthis('<font color="green">'. |
| |
"hostname = $hostname me = $me, name = $name actual ip = $ipnew </font>"); |
| |
|
| |
if ($hostname eq $name) { # Lookup succeeded.. |
| |
&logthis('<font color="green"> look up ok <font>'); |
| |
$ip = $ipnew; |
| |
} else { |
| |
&logthis('<font color="green"> Lookup failed: ' |
| |
.$hostname." ne $name </font>"); |
| |
} |
| |
# Reconstruct the host line and append to adjusted: |
| |
|
| |
my $newline = "$id:$domain:$role:$name:$ip"; |
| |
if($maxcon ne "") { # Not all hosts have loncnew tuning params |
| |
$newline .= ":$maxcon:$idleto:$mincon"; |
| |
} |
| |
$adjusted .= $newline."\n"; |
| |
|
| |
} else { # Not me, pass unmodified. |
| |
$adjusted .= $line."\n"; |
| |
} |
| |
} else { # Blank or comment never re-written. |
| |
$adjusted .= $line."\n"; # Pass blanks and comments as is. |
| |
} |
| |
} |
| |
return $adjusted; |
| |
} |
| # |
# |
| # InstallFile: Called to install an administrative file: |
# InstallFile: Called to install an administrative file: |
| # - The file is created with <name>.tmp |
# - The file is created with <name>.tmp |
|
Line 344 sub PushFile {
|
Line 408 sub PushFile {
|
| &logthis('<font color="green"> Pushfile: backed up ' |
&logthis('<font color="green"> Pushfile: backed up ' |
| .$tablefile." to $backupfile</font>"); |
.$tablefile." to $backupfile</font>"); |
| |
|
| |
# If the file being pushed is the host file, we adjust the entry for ourself so that the |
| |
# IP will be our current IP as looked up in dns. Note this is only 99% good as it's possible |
| |
# to conceive of conditions where we don't have a DNS entry locally. This is possible in a |
| |
# network sense but it doesn't make much sense in a LonCAPA sense so we ignore (for now) |
| |
# that possibilty. |
| |
|
| |
if($filename eq "host") { |
| |
$contents = AdjustHostContents($contents); |
| |
} |
| |
|
| # Install the new file: |
# Install the new file: |
| |
|
| if(!InstallFile($tablefile, $contents)) { |
if(!InstallFile($tablefile, $contents)) { |
|
Line 388 sub ReinitProcess {
|
Line 462 sub ReinitProcess {
|
| # |
# |
| # |
# |
| my ($junk, $process) = split(":", $request); |
my ($junk, $process) = split(":", $request); |
| my $processpidfile = $perlvar{'lonDaemons'}.'/'; |
my $processpidfile = $perlvar{'lonDaemons'}.'/logs/'; |
| if($process eq 'lonc') { |
if($process eq 'lonc') { |
| $processpidfile = $processpidfile."lonc.pid"; |
$processpidfile = $processpidfile."lonc.pid"; |
| |
if (!open(PIDFILE, "< $processpidfile")) { |
| |
return "error:Open failed for $processpidfile"; |
| |
} |
| |
my $loncpid = <PIDFILE>; |
| |
close(PIDFILE); |
| |
logthis('<font color="red"> Reinitializing lonc pid='.$loncpid |
| |
."</font>"); |
| |
kill("USR2", $loncpid); |
| } elsif ($process eq 'lond') { |
} elsif ($process eq 'lond') { |
| $processpidfile = $processpidfile."lond.pid"; |
logthis('<font color="red"> Reinitializing self (lond) </font>'); |
| |
&UpdateHosts; # Lond is us!! |
| } else { |
} else { |
| &logthis('<font color="yellow" Invalid reinit request for '.$process |
&logthis('<font color="yellow" Invalid reinit request for '.$process |
| ."</font>"); |
."</font>"); |
| return "error:Invalid process identifier $process"; |
return "error:Invalid process identifier $process"; |
| } |
} |
| &logthis('<font color="red"> Reinitializing '.$process." </font>"); |
|
| return 'ok'; |
return 'ok'; |
| } |
} |
| |
|
|
Line 431 sub catchexception {
|
Line 513 sub catchexception {
|
| my ($error)=@_; |
my ($error)=@_; |
| $SIG{'QUIT'}='DEFAULT'; |
$SIG{'QUIT'}='DEFAULT'; |
| $SIG{__DIE__}='DEFAULT'; |
$SIG{__DIE__}='DEFAULT'; |
| |
&status("Catching exception"); |
| &logthis("<font color=red>CRITICAL: " |
&logthis("<font color=red>CRITICAL: " |
| ."ABNORMAL EXIT. Child $$ for server $thisserver died through " |
."ABNORMAL EXIT. Child $$ for server $thisserver died through " |
| ."a crash with this error msg->[$error]</font>"); |
."a crash with this error msg->[$error]</font>"); |
|
Line 441 sub catchexception {
|
Line 524 sub catchexception {
|
| } |
} |
| |
|
| sub timeout { |
sub timeout { |
| |
&status("Handling Timeout"); |
| &logthis("<font color=ref>CRITICAL: TIME OUT ".$$."</font>"); |
&logthis("<font color=ref>CRITICAL: TIME OUT ".$$."</font>"); |
| &catchexception('Timeout'); |
&catchexception('Timeout'); |
| } |
} |
|
Line 478 if (-e $pidfile) {
|
Line 562 if (-e $pidfile) {
|
| |
|
| # ------------------------------------------------------------- Read hosts file |
# ------------------------------------------------------------- Read hosts file |
| |
|
| open (CONFIG,"$perlvar{'lonTabDir'}/hosts.tab") || die "Can't read host file"; |
|
| |
|
| while (my $configline=<CONFIG>) { |
|
| my ($id,$domain,$role,$name,$ip)=split(/:/,$configline); |
|
| chomp($ip); $ip=~s/\D+$//; |
|
| $hostid{$ip}=$id; |
|
| $hostdom{$id}=$domain; |
|
| $hostip{$id}=$ip; |
|
| if ($id eq $perlvar{'lonHostID'}) { $thisserver=$name; } |
|
| } |
|
| close(CONFIG); |
|
| |
|
| # establish SERVER socket, bind and listen. |
# establish SERVER socket, bind and listen. |
| $server = IO::Socket::INET->new(LocalPort => $perlvar{'londPort'}, |
$server = IO::Socket::INET->new(LocalPort => $perlvar{'londPort'}, |
|
Line 503 $server = IO::Socket::INET->new(LocalPor
|
Line 577 $server = IO::Socket::INET->new(LocalPor
|
| # global variables |
# global variables |
| |
|
| my %children = (); # keys are current child process IDs |
my %children = (); # keys are current child process IDs |
| my $children = 0; # current number of children |
|
| |
|
| sub REAPER { # takes care of dead children |
sub REAPER { # takes care of dead children |
| $SIG{CHLD} = \&REAPER; |
$SIG{CHLD} = \&REAPER; |
| my $pid = wait; |
&status("Handling child death"); |
| if (defined($children{$pid})) { |
my $pid; |
| &logthis("Child $pid died"); |
do { |
| $children --; |
$pid = waitpid(-1,&WNOHANG()); |
| delete $children{$pid}; |
if (defined($children{$pid})) { |
| } else { |
&logthis("Child $pid died"); |
| &logthis("Unknown Child $pid died"); |
delete($children{$pid}); |
| |
} else { |
| |
&logthis("Unknown Child $pid died"); |
| |
} |
| |
} while ( $pid > 0 ); |
| |
foreach my $child (keys(%children)) { |
| |
$pid = waitpid($child,&WNOHANG()); |
| |
if ($pid > 0) { |
| |
&logthis("Child $child - $pid looks like we missed it's death"); |
| |
delete($children{$pid}); |
| |
} |
| } |
} |
| |
&status("Finished Handling child death"); |
| } |
} |
| |
|
| sub HUNTSMAN { # signal handler for SIGINT |
sub HUNTSMAN { # signal handler for SIGINT |
| |
&status("Killing children (INT)"); |
| local($SIG{CHLD}) = 'IGNORE'; # we're going to kill our children |
local($SIG{CHLD}) = 'IGNORE'; # we're going to kill our children |
| kill 'INT' => keys %children; |
kill 'INT' => keys %children; |
| &logthis("Free socket: ".shutdown($server,2)); # free up socket |
&logthis("Free socket: ".shutdown($server,2)); # free up socket |
| my $execdir=$perlvar{'lonDaemons'}; |
my $execdir=$perlvar{'lonDaemons'}; |
| unlink("$execdir/logs/lond.pid"); |
unlink("$execdir/logs/lond.pid"); |
| &logthis("<font color=red>CRITICAL: Shutting down</font>"); |
&logthis("<font color=red>CRITICAL: Shutting down</font>"); |
| |
&status("Done killing children"); |
| exit; # clean up with dignity |
exit; # clean up with dignity |
| } |
} |
| |
|
| sub HUPSMAN { # signal handler for SIGHUP |
sub HUPSMAN { # signal handler for SIGHUP |
| local($SIG{CHLD}) = 'IGNORE'; # we're going to kill our children |
local($SIG{CHLD}) = 'IGNORE'; # we're going to kill our children |
| |
&status("Killing children for restart (HUP)"); |
| kill 'INT' => keys %children; |
kill 'INT' => keys %children; |
| &logthis("Free socket: ".shutdown($server,2)); # free up socket |
&logthis("Free socket: ".shutdown($server,2)); # free up socket |
| &logthis("<font color=red>CRITICAL: Restarting</font>"); |
&logthis("<font color=red>CRITICAL: Restarting</font>"); |
| my $execdir=$perlvar{'lonDaemons'}; |
my $execdir=$perlvar{'lonDaemons'}; |
| unlink("$execdir/logs/lond.pid"); |
unlink("$execdir/logs/lond.pid"); |
| |
&status("Restarting self (HUP)"); |
| exec("$execdir/lond"); # here we go again |
exec("$execdir/lond"); # here we go again |
| } |
} |
| |
|
| # |
# |
| |
# Kill off hashes that describe the host table prior to re-reading it. |
| |
# Hashes affected are: |
| |
# %hostid, %hostdom %hostip |
| |
# |
| |
sub KillHostHashes { |
| |
foreach my $key (keys %hostid) { |
| |
delete $hostid{$key}; |
| |
} |
| |
foreach my $key (keys %hostdom) { |
| |
delete $hostdom{$key}; |
| |
} |
| |
foreach my $key (keys %hostip) { |
| |
delete $hostip{$key}; |
| |
} |
| |
} |
| |
# |
| |
# Read in the host table from file and distribute it into the various hashes: |
| |
# |
| |
# - %hostid - Indexed by IP, the loncapa hostname. |
| |
# - %hostdom - Indexed by loncapa hostname, the domain. |
| |
# - %hostip - Indexed by hostid, the Ip address of the host. |
| |
sub ReadHostTable { |
| |
|
| |
open (CONFIG,"$perlvar{'lonTabDir'}/hosts.tab") || die "Can't read host file"; |
| |
|
| |
while (my $configline=<CONFIG>) { |
| |
if (!($configline =~ /^\s*\#/)) { |
| |
my ($id,$domain,$role,$name,$ip)=split(/:/,$configline); |
| |
chomp($ip); $ip=~s/\D+$//; |
| |
$hostid{$ip}=$id; |
| |
$hostdom{$id}=$domain; |
| |
$hostip{$id}=$ip; |
| |
if ($id eq $perlvar{'lonHostID'}) { $thisserver=$name; } |
| |
} |
| |
} |
| |
close(CONFIG); |
| |
} |
| |
# |
| |
# Reload the Apache daemon's state. |
| |
# This is done by invoking /home/httpd/perl/apachereload |
| |
# a setuid perl script that can be root for us to do this job. |
| |
# |
| |
sub ReloadApache { |
| |
my $execdir = $perlvar{'lonDaemons'}; |
| |
my $script = $execdir."/apachereload"; |
| |
system($script); |
| |
} |
| |
|
| |
# |
| # Called in response to a USR2 signal. |
# Called in response to a USR2 signal. |
| # - Reread hosts.tab |
# - Reread hosts.tab |
| # - All children connected to hosts that were removed from hosts.tab |
# - All children connected to hosts that were removed from hosts.tab |
|
Line 548 sub HUPSMAN { # sig
|
Line 685 sub HUPSMAN { # sig
|
| # now be honored. |
# now be honored. |
| # |
# |
| sub UpdateHosts { |
sub UpdateHosts { |
| |
&status("Reload hosts.tab"); |
| |
logthis('<font color="blue"> Updating connections </font>'); |
| |
# |
| |
# The %children hash has the set of IP's we currently have children |
| |
# on. These need to be matched against records in the hosts.tab |
| |
# Any ip's no longer in the table get killed off they correspond to |
| |
# either dropped or changed hosts. Note that the re-read of the table |
| |
# will take care of new and changed hosts as connections come into being. |
| |
|
| |
|
| |
KillHostHashes; |
| |
ReadHostTable; |
| |
|
| |
foreach my $child (keys %children) { |
| |
my $childip = $children{$child}; |
| |
if(!$hostid{$childip}) { |
| |
logthis('<font color="blue"> UpdateHosts killing child ' |
| |
." $child for ip $childip </font>"); |
| |
kill('INT', $child); |
| |
} else { |
| |
logthis('<font color="green"> keeping child for ip ' |
| |
." $childip (pid=$child) </font>"); |
| |
} |
| |
} |
| |
ReloadApache; |
| |
&status("Finished reloading hosts.tab"); |
| } |
} |
| |
|
| |
|
| sub checkchildren { |
sub checkchildren { |
| |
&status("Checking on the children (sending signals)"); |
| &initnewstatus(); |
&initnewstatus(); |
| &logstatus(); |
&logstatus(); |
| &logthis('Going to check on the children'); |
&logthis('Going to check on the children'); |
|
Line 565 sub checkchildren {
|
Line 730 sub checkchildren {
|
| sleep 5; |
sleep 5; |
| $SIG{ALRM} = sub { die "timeout" }; |
$SIG{ALRM} = sub { die "timeout" }; |
| $SIG{__DIE__} = 'DEFAULT'; |
$SIG{__DIE__} = 'DEFAULT'; |
| |
&status("Checking on the children (waiting for reports)"); |
| foreach (sort keys %children) { |
foreach (sort keys %children) { |
| unless (-e "$docdir/lon-status/londchld/$_.txt") { |
unless (-e "$docdir/lon-status/londchld/$_.txt") { |
| eval { |
eval { |
|
Line 581 sub checkchildren {
|
Line 747 sub checkchildren {
|
| } |
} |
| } |
} |
| $SIG{ALRM} = 'DEFAULT'; |
$SIG{ALRM} = 'DEFAULT'; |
| $SIG{__DIE__} = \&cathcexception; |
$SIG{__DIE__} = \&catchexception; |
| |
&status("Finished checking children"); |
| } |
} |
| |
|
| # --------------------------------------------------------------------- Logging |
# --------------------------------------------------------------------- Logging |
|
Line 603 sub Debug {
|
Line 770 sub Debug {
|
| &logthis($message); |
&logthis($message); |
| } |
} |
| } |
} |
| |
|
| |
# |
| |
# Sub to do replies to client.. this gives a hook for some |
| |
# debug tracing too: |
| |
# Parameters: |
| |
# fd - File open on client. |
| |
# reply - Text to send to client. |
| |
# request - Original request from client. |
| |
# |
| |
sub Reply { |
| |
my $fd = shift; |
| |
my $reply = shift; |
| |
my $request = shift; |
| |
|
| |
print $fd $reply; |
| |
Debug("Request was $request Reply was $reply"); |
| |
|
| |
} |
| # ------------------------------------------------------------------ Log status |
# ------------------------------------------------------------------ Log status |
| |
|
| sub logstatus { |
sub logstatus { |
| |
&status("Doing logging"); |
| my $docdir=$perlvar{'lonDocRoot'}; |
my $docdir=$perlvar{'lonDocRoot'}; |
| { |
{ |
| my $fh=IO::File->new(">>$docdir/lon-status/londstatus.txt"); |
my $fh=IO::File->new(">>$docdir/lon-status/londstatus.txt"); |
| print $fh $$."\t".$currenthostid."\t".$status."\t".$lastlog."\n"; |
print $fh $$."\t".$clientname."\t".$currenthostid."\t".$status."\t".$lastlog."\n"; |
| $fh->close(); |
$fh->close(); |
| } |
} |
| |
&status("Finished londstatus.txt"); |
| { |
{ |
| my $fh=IO::File->new(">$docdir/lon-status/londchld/$$.txt"); |
my $fh=IO::File->new(">$docdir/lon-status/londchld/$$.txt"); |
| print $fh $status."\n".$lastlog."\n".time; |
print $fh $status."\n".$lastlog."\n".time; |
| $fh->close(); |
$fh->close(); |
| } |
} |
| |
&status("Finished logging"); |
| } |
} |
| |
|
| sub initnewstatus { |
sub initnewstatus { |
|
Line 794 $SIG{HUP} = \&HUPSMAN;
|
Line 982 $SIG{HUP} = \&HUPSMAN;
|
| $SIG{USR1} = \&checkchildren; |
$SIG{USR1} = \&checkchildren; |
| $SIG{USR2} = \&UpdateHosts; |
$SIG{USR2} = \&UpdateHosts; |
| |
|
| |
# Read the host hashes: |
| |
|
| |
ReadHostTable; |
| |
|
| # -------------------------------------------------------------- |
# -------------------------------------------------------------- |
| # Accept connections. When a connection comes in, it is validated |
# Accept connections. When a connection comes in, it is validated |
|
Line 801 $SIG{USR2} = \&UpdateHosts;
|
Line 992 $SIG{USR2} = \&UpdateHosts;
|
| # along the connection. |
# along the connection. |
| |
|
| while (1) { |
while (1) { |
| |
&status('Starting accept'); |
| $client = $server->accept() or next; |
$client = $server->accept() or next; |
| |
&status('Accepted '.$client.' off to spawn'); |
| make_new_child($client); |
make_new_child($client); |
| |
&status('Finished spawning'); |
| } |
} |
| |
|
| sub make_new_child { |
sub make_new_child { |
|
Line 811 sub make_new_child {
|
Line 1005 sub make_new_child {
|
| my $sigset; |
my $sigset; |
| |
|
| $client = shift; |
$client = shift; |
| &logthis("Attempting to start child"); |
&status('Starting new child '.$client); |
| |
&logthis('<font color="green"> Attempting to start child ('.$client. |
| |
")</font>"); |
| # block signal for fork |
# block signal for fork |
| $sigset = POSIX::SigSet->new(SIGINT); |
$sigset = POSIX::SigSet->new(SIGINT); |
| sigprocmask(SIG_BLOCK, $sigset) |
sigprocmask(SIG_BLOCK, $sigset) |
| or die "Can't block SIGINT for fork: $!\n"; |
or die "Can't block SIGINT for fork: $!\n"; |
| |
|
| die "fork: $!" unless defined ($pid = fork); |
die "fork: $!" unless defined ($pid = fork); |
| |
|
| |
$client->sockopt(SO_KEEPALIVE, 1); # Enable monitoring of |
| |
# connection liveness. |
| |
|
| |
# |
| |
# Figure out who we're talking to so we can record the peer in |
| |
# the pid hash. |
| |
# |
| |
my $caller = getpeername($client); |
| |
my ($port,$iaddr)=unpack_sockaddr_in($caller); |
| |
$clientip=inet_ntoa($iaddr); |
| |
|
| if ($pid) { |
if ($pid) { |
| # Parent records the child's birth and returns. |
# Parent records the child's birth and returns. |
| sigprocmask(SIG_UNBLOCK, $sigset) |
sigprocmask(SIG_UNBLOCK, $sigset) |
| or die "Can't unblock SIGINT for fork: $!\n"; |
or die "Can't unblock SIGINT for fork: $!\n"; |
| $children{$pid} = 1; |
$children{$pid} = $clientip; |
| $children++; |
|
| &status('Started child '.$pid); |
&status('Started child '.$pid); |
| return; |
return; |
| } else { |
} else { |
|
Line 846 sub make_new_child {
|
Line 1052 sub make_new_child {
|
| &Authen::Krb5::init_context(); |
&Authen::Krb5::init_context(); |
| &Authen::Krb5::init_ets(); |
&Authen::Krb5::init_ets(); |
| |
|
| &status('Accepted connection'); |
&status('Accepted connection'); |
| # ============================================================================= |
# ============================================================================= |
| # do something with the connection |
# do something with the connection |
| # ----------------------------------------------------------------------------- |
# ----------------------------------------------------------------------------- |
| $client->sockopt(SO_KEEPALIVE, 1);# Enable monitoring of |
# see if we know client and check for spoof IP by challenge |
| # connection liveness. |
|
| # see if we know client and check for spoof IP by challenge |
ReadManagerTable; # May also be a manager!! |
| my $caller = getpeername($client); |
|
| my ($port,$iaddr)=unpack_sockaddr_in($caller); |
my $clientrec=($hostid{$clientip} ne undef); |
| $clientip=inet_ntoa($iaddr); |
my $ismanager=($managers{$clientip} ne undef); |
| my $clientrec=($hostid{$clientip} ne undef); |
$clientname = "[unknonwn]"; |
| &logthis( |
if($clientrec) { # Establish client type. |
| "<font color=yellow>INFO: Connection, $clientip ($hostid{$clientip})</font>" |
$ConnectionType = "client"; |
| ); |
$clientname = $hostid{$clientip}; |
| &status("Connecting $clientip ($hostid{$clientip})"); |
if($ismanager) { |
| my $clientok; |
$ConnectionType = "both"; |
| if ($clientrec) { |
} |
| &status("Waiting for init from $clientip ($hostid{$clientip})"); |
} else { |
| my $remotereq=<$client>; |
$ConnectionType = "manager"; |
| $remotereq=~s/[^\w:]//g; |
$clientname = $managers{$clientip}; |
| if ($remotereq =~ /^init/) { |
} |
| &sethost("sethost:$perlvar{'lonHostID'}"); |
my $clientok; |
| my $challenge="$$".time; |
if ($clientrec || $ismanager) { |
| print $client "$challenge\n"; |
&status("Waiting for init from $clientip $clientname"); |
| &status( |
&logthis('<font color="yellow">INFO: Connection, '. |
| "Waiting for challenge reply from $clientip ($hostid{$clientip})"); |
$clientip. |
| $remotereq=<$client>; |
" ($clientname) connection type = $ConnectionType </font>" ); |
| $remotereq=~s/\W//g; |
&status("Connecting $clientip ($clientname))"); |
| if ($challenge eq $remotereq) { |
my $remotereq=<$client>; |
| $clientok=1; |
$remotereq=~s/[^\w:]//g; |
| print $client "ok\n"; |
if ($remotereq =~ /^init/) { |
| } else { |
&sethost("sethost:$perlvar{'lonHostID'}"); |
| &logthis( |
my $challenge="$$".time; |
| "<font color=blue>WARNING: $clientip did not reply challenge</font>"); |
print $client "$challenge\n"; |
| &status('No challenge reply '.$clientip); |
&status( |
| } |
"Waiting for challenge reply from $clientip ($clientname)"); |
| } else { |
$remotereq=<$client>; |
| &logthis( |
$remotereq=~s/\W//g; |
| "<font color=blue>WARNING: " |
if ($challenge eq $remotereq) { |
| ."$clientip failed to initialize: >$remotereq< </font>"); |
$clientok=1; |
| &status('No init '.$clientip); |
print $client "ok\n"; |
| } |
} else { |
| |
&logthis( |
| |
"<font color=blue>WARNING: $clientip did not reply challenge</font>"); |
| |
&status('No challenge reply '.$clientip); |
| |
} |
| } else { |
} else { |
| &logthis( |
&logthis( |
| "<font color=blue>WARNING: Unknown client $clientip</font>"); |
"<font color=blue>WARNING: " |
| &status('Hung up on '.$clientip); |
."$clientip failed to initialize: >$remotereq< </font>"); |
| } |
&status('No init '.$clientip); |
| if ($clientok) { |
} |
| |
} else { |
| |
&logthis( |
| |
"<font color=blue>WARNING: Unknown client $clientip</font>"); |
| |
&status('Hung up on '.$clientip); |
| |
} |
| |
if ($clientok) { |
| # ---------------- New known client connecting, could mean machine online again |
# ---------------- New known client connecting, could mean machine online again |
| |
|
| foreach my $id (keys(%hostip)) { |
foreach my $id (keys(%hostip)) { |
| if ($hostip{$id} ne $clientip || |
if ($hostip{$id} ne $clientip || |
| $hostip{$currenthostid} eq $clientip) { |
$hostip{$currenthostid} eq $clientip) { |
| # no need to try to do recon's to myself |
# no need to try to do recon's to myself |
| next; |
next; |
| } |
|
| &reconlonc("$perlvar{'lonSockDir'}/$id"); |
|
| } |
} |
| &logthis("<font color=green>Established connection: $hostid{$clientip}</font>"); |
&reconlonc("$perlvar{'lonSockDir'}/$id"); |
| &status('Will listen to '.$hostid{$clientip}); |
} |
| |
&logthis("<font color=green>Established connection: $clientname</font>"); |
| |
&status('Will listen to '.$clientname); |
| # ------------------------------------------------------------ Process requests |
# ------------------------------------------------------------ Process requests |
| while (my $userinput=<$client>) { |
while (my $userinput=<$client>) { |
| chomp($userinput); |
chomp($userinput); |
| Debug("Request = $userinput\n"); |
Debug("Request = $userinput\n"); |
| &status('Processing '.$hostid{$clientip}.': '.$userinput); |
&status('Processing '.$clientname.': '.$userinput); |
| my $wasenc=0; |
my $wasenc=0; |
| alarm(120); |
alarm(120); |
| # ------------------------------------------------------------ See if encrypted |
# ------------------------------------------------------------ See if encrypted |
| if ($userinput =~ /^enc/) { |
if ($userinput =~ /^enc/) { |
| if ($cipher) { |
if ($cipher) { |
| my ($cmd,$cmdlength,$encinput)=split(/:/,$userinput); |
my ($cmd,$cmdlength,$encinput)=split(/:/,$userinput); |
| $userinput=''; |
$userinput=''; |
| for (my $encidx=0;$encidx<length($encinput);$encidx+=16) { |
for (my $encidx=0;$encidx<length($encinput);$encidx+=16) { |
| $userinput.= |
$userinput.= |
| $cipher->decrypt( |
$cipher->decrypt( |
| pack("H16",substr($encinput,$encidx,16)) |
pack("H16",substr($encinput,$encidx,16)) |
| ); |
); |
| |
} |
| |
$userinput=substr($userinput,0,$cmdlength); |
| |
$wasenc=1; |
| } |
} |
| $userinput=substr($userinput,0,$cmdlength); |
|
| $wasenc=1; |
|
| } |
} |
| } |
|
| |
|
| # ------------------------------------------------------------- Normal commands |
# ------------------------------------------------------------- Normal commands |
| # ------------------------------------------------------------------------ ping |
# ------------------------------------------------------------------------ ping |
| if ($userinput =~ /^ping/) { |
if ($userinput =~ /^ping/) { # client only |
| print $client "$currenthostid\n"; |
if(isClient) { |
| |
print $client "$currenthostid\n"; |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
} |
| # ------------------------------------------------------------------------ pong |
# ------------------------------------------------------------------------ pong |
| }elsif ($userinput =~ /^pong/) { |
}elsif ($userinput =~ /^pong/) { # client only |
| my $reply=&reply("ping",$hostid{$clientip}); |
if(isClient) { |
| print $client "$currenthostid:$reply\n"; |
my $reply=&reply("ping",$clientname); |
| |
print $client "$currenthostid:$reply\n"; |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
} |
| # ------------------------------------------------------------------------ ekey |
# ------------------------------------------------------------------------ ekey |
| } elsif ($userinput =~ /^ekey/) { |
} elsif ($userinput =~ /^ekey/) { # ok for both clients & mgrs |
| my $buildkey=time.$$.int(rand 100000); |
my $buildkey=time.$$.int(rand 100000); |
| $buildkey=~tr/1-6/A-F/; |
$buildkey=~tr/1-6/A-F/; |
| $buildkey=int(rand 100000).$buildkey.int(rand 100000); |
$buildkey=int(rand 100000).$buildkey.int(rand 100000); |
| my $key=$currenthostid.$hostid{$clientip}; |
my $key=$currenthostid.$clientname; |
| $key=~tr/a-z/A-Z/; |
$key=~tr/a-z/A-Z/; |
| $key=~tr/G-P/0-9/; |
$key=~tr/G-P/0-9/; |
| $key=~tr/Q-Z/0-9/; |
$key=~tr/Q-Z/0-9/; |
| $key=$key.$buildkey.$key.$buildkey.$key.$buildkey; |
$key=$key.$buildkey.$key.$buildkey.$key.$buildkey; |
| $key=substr($key,0,32); |
$key=substr($key,0,32); |
| my $cipherkey=pack("H32",$key); |
my $cipherkey=pack("H32",$key); |
| $cipher=new IDEA $cipherkey; |
$cipher=new IDEA $cipherkey; |
| print $client "$buildkey\n"; |
print $client "$buildkey\n"; |
| # ------------------------------------------------------------------------ load |
# ------------------------------------------------------------------------ load |
| } elsif ($userinput =~ /^load/) { |
} elsif ($userinput =~ /^load/) { # client only |
| my $loadavg; |
if (isClient) { |
| { |
my $loadavg; |
| my $loadfile=IO::File->new('/proc/loadavg'); |
{ |
| $loadavg=<$loadfile>; |
my $loadfile=IO::File->new('/proc/loadavg'); |
| } |
$loadavg=<$loadfile>; |
| $loadavg =~ s/\s.*//g; |
} |
| my $loadpercent=100*$loadavg/$perlvar{'lonLoadLim'}; |
$loadavg =~ s/\s.*//g; |
| print $client "$loadpercent\n"; |
my $loadpercent=100*$loadavg/$perlvar{'lonLoadLim'}; |
| |
print $client "$loadpercent\n"; |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # -------------------------------------------------------------------- userload |
# -------------------------------------------------------------------- userload |
| } elsif ($userinput =~ /^userload/) { |
} elsif ($userinput =~ /^userload/) { # client only |
| my $userloadpercent=&userload(); |
if(isClient) { |
| print $client "$userloadpercent\n"; |
my $userloadpercent=&userload(); |
| |
print $client "$userloadpercent\n"; |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # |
# |
| # Transactions requiring encryption: |
# Transactions requiring encryption: |
| # |
# |
| # ----------------------------------------------------------------- currentauth |
# ----------------------------------------------------------------- currentauth |
| } elsif ($userinput =~ /^currentauth/) { |
} elsif ($userinput =~ /^currentauth/) { |
| if ($wasenc==1) { |
if (($wasenc==1) && isClient) { # Encoded & client only. |
| my ($cmd,$udom,$uname)=split(/:/,$userinput); |
my ($cmd,$udom,$uname)=split(/:/,$userinput); |
| my $result = GetAuthType($udom, $uname); |
my $result = GetAuthType($udom, $uname); |
| if($result eq "nouser") { |
if($result eq "nouser") { |
| print $client "unknown_user\n"; |
print $client "unknown_user\n"; |
| } |
} |
| else { |
else { |
| print $client "$result\n" |
print $client "$result\n" |
| } |
} |
| } else { |
} else { |
| print $client "refused\n"; |
Reply($client, "refused\n", $userinput); |
| } |
|
| |
} |
| #--------------------------------------------------------------------- pushfile |
#--------------------------------------------------------------------- pushfile |
| } elsif($userinput =~ /^pushfile/) { |
} elsif($userinput =~ /^pushfile/) { # encoded & manager. |
| if($wasenc == 1) { |
if(($wasenc == 1) && isManager) { |
| my $cert = GetCertificate($userinput); |
my $cert = GetCertificate($userinput); |
| if(ValidManager($cert)) { |
if(ValidManager($cert)) { |
| my $reply = PushFile($userinput); |
my $reply = PushFile($userinput); |
| print $client "$reply\n"; |
print $client "$reply\n"; |
| } else { |
} else { |
| print $client "refused\n"; |
print $client "refused\n"; |
| } |
} |
| } else { |
} else { |
| print $client "refused\n"; |
Reply($client, "refused\n", $userinput); |
| } |
|
| |
} |
| #--------------------------------------------------------------------- reinit |
#--------------------------------------------------------------------- reinit |
| } elsif($userinput =~ /^reinit/) { |
} elsif($userinput =~ /^reinit/) { # Encoded and manager |
| if ($wasenc == 1) { |
if (($wasenc == 1) && isManager) { |
| my $cert = GetCertificate($userinput); |
my $cert = GetCertificate($userinput); |
| if(ValidManager($cert)) { |
if(ValidManager($cert)) { |
| chomp($userinput); |
chomp($userinput); |
| my $reply = ReinitProcess($userinput); |
my $reply = ReinitProcess($userinput); |
| print $client "$reply\n"; |
print $client "$reply\n"; |
| } else { |
} else { |
| print $client "refused\n"; |
print $client "refused\n"; |
| } |
} |
| } else { |
} else { |
| print $client "refused\n"; |
Reply($client, "refused\n", $userinput); |
| } |
|
| |
|
| |
} |
| # ------------------------------------------------------------------------ auth |
# ------------------------------------------------------------------------ auth |
| } elsif ($userinput =~ /^auth/) { |
} elsif ($userinput =~ /^auth/) { # Encoded and client only. |
| if ($wasenc==1) { |
if (($wasenc==1) && isClient) { |
| my ($cmd,$udom,$uname,$upass)=split(/:/,$userinput); |
my ($cmd,$udom,$uname,$upass)=split(/:/,$userinput); |
| chomp($upass); |
chomp($upass); |
| $upass=unescape($upass); |
$upass=unescape($upass); |
| my $proname=propath($udom,$uname); |
my $proname=propath($udom,$uname); |
| my $passfilename="$proname/passwd"; |
my $passfilename="$proname/passwd"; |
| if (-e $passfilename) { |
if (-e $passfilename) { |
| my $pf = IO::File->new($passfilename); |
my $pf = IO::File->new($passfilename); |
| my $realpasswd=<$pf>; |
my $realpasswd=<$pf>; |
| chomp($realpasswd); |
chomp($realpasswd); |
| my ($howpwd,$contentpwd)=split(/:/,$realpasswd); |
my ($howpwd,$contentpwd)=split(/:/,$realpasswd); |
| my $pwdcorrect=0; |
my $pwdcorrect=0; |
| if ($howpwd eq 'internal') { |
if ($howpwd eq 'internal') { |
| &Debug("Internal auth"); |
&Debug("Internal auth"); |
| $pwdcorrect= |
$pwdcorrect= |
| (crypt($upass,$contentpwd) eq $contentpwd); |
(crypt($upass,$contentpwd) eq $contentpwd); |
| } elsif ($howpwd eq 'unix') { |
} elsif ($howpwd eq 'unix') { |
| &Debug("Unix auth"); |
&Debug("Unix auth"); |
| if((getpwnam($uname))[1] eq "") { #no such user! |
if((getpwnam($uname))[1] eq "") { #no such user! |
| $pwdcorrect = 0; |
$pwdcorrect = 0; |
| } else { |
} else { |
| $contentpwd=(getpwnam($uname))[1]; |
$contentpwd=(getpwnam($uname))[1]; |
| my $pwauth_path="/usr/local/sbin/pwauth"; |
my $pwauth_path="/usr/local/sbin/pwauth"; |
| unless ($contentpwd eq 'x') { |
unless ($contentpwd eq 'x') { |
| $pwdcorrect= |
$pwdcorrect= |
| (crypt($upass,$contentpwd) eq |
(crypt($upass,$contentpwd) eq |
| $contentpwd); |
$contentpwd); |
| } |
} |
| |
|
| elsif (-e $pwauth_path) { |
elsif (-e $pwauth_path) { |
| open PWAUTH, "|$pwauth_path" or |
open PWAUTH, "|$pwauth_path" or |
| die "Cannot invoke authentication"; |
die "Cannot invoke authentication"; |
| print PWAUTH "$uname\n$upass\n"; |
print PWAUTH "$uname\n$upass\n"; |
| close PWAUTH; |
close PWAUTH; |
| $pwdcorrect=!$?; |
$pwdcorrect=!$?; |
| } |
} |
| } |
} |
| } elsif ($howpwd eq 'krb4') { |
} elsif ($howpwd eq 'krb4') { |
| my $null=pack("C",0); |
my $null=pack("C",0); |
| unless ($upass=~/$null/) { |
unless ($upass=~/$null/) { |
| my $krb4_error = &Authen::Krb4::get_pw_in_tkt |
my $krb4_error = &Authen::Krb4::get_pw_in_tkt |
| ($uname,"",$contentpwd,'krbtgt', |
($uname,"",$contentpwd,'krbtgt', |
| $contentpwd,1,$upass); |
$contentpwd,1,$upass); |
| if (!$krb4_error) { |
if (!$krb4_error) { |
| $pwdcorrect = 1; |
$pwdcorrect = 1; |
| } else { |
} else { |
| $pwdcorrect=0; |
$pwdcorrect=0; |
| # log error if it is not a bad password |
# log error if it is not a bad password |
| if ($krb4_error != 62) { |
if ($krb4_error != 62) { |
| &logthis('krb4:'.$uname.','.$contentpwd.','. |
&logthis('krb4:'.$uname.','.$contentpwd.','. |
| &Authen::Krb4::get_err_txt($Authen::Krb4::error)); |
&Authen::Krb4::get_err_txt($Authen::Krb4::error)); |
| } |
} |
| } |
} |
| } |
} |
| } elsif ($howpwd eq 'krb5') { |
} elsif ($howpwd eq 'krb5') { |
| my $null=pack("C",0); |
my $null=pack("C",0); |
| unless ($upass=~/$null/) { |
unless ($upass=~/$null/) { |
| my $krbclient=&Authen::Krb5::parse_name($uname.'@'.$contentpwd); |
my $krbclient=&Authen::Krb5::parse_name($uname.'@'.$contentpwd); |
| my $krbservice="krbtgt/".$contentpwd."\@".$contentpwd; |
my $krbservice="krbtgt/".$contentpwd."\@".$contentpwd; |
| my $krbserver=&Authen::Krb5::parse_name($krbservice); |
my $krbserver=&Authen::Krb5::parse_name($krbservice); |
| my $credentials=&Authen::Krb5::cc_default(); |
my $credentials=&Authen::Krb5::cc_default(); |
| $credentials->initialize($krbclient); |
$credentials->initialize($krbclient); |
| my $krbreturn = |
my $krbreturn = |
| &Authen::Krb5::get_in_tkt_with_password( |
&Authen::Krb5::get_in_tkt_with_password( |
| $krbclient,$krbserver,$upass,$credentials); |
$krbclient,$krbserver,$upass,$credentials); |
| # unless ($krbreturn) { |
# unless ($krbreturn) { |
| # &logthis("Krb5 Error: ". |
# &logthis("Krb5 Error: ". |
| # &Authen::Krb5::error()); |
# &Authen::Krb5::error()); |
| # } |
# } |
| $pwdcorrect = ($krbreturn == 1); |
$pwdcorrect = ($krbreturn == 1); |
| } else { $pwdcorrect=0; } |
} else { $pwdcorrect=0; } |
| } elsif ($howpwd eq 'localauth') { |
} elsif ($howpwd eq 'localauth') { |
| $pwdcorrect=&localauth::localauth($uname,$upass, |
$pwdcorrect=&localauth::localauth($uname,$upass, |
| $contentpwd); |
$contentpwd); |
| } |
} |
| if ($pwdcorrect) { |
if ($pwdcorrect) { |
| print $client "authorized\n"; |
print $client "authorized\n"; |
| } else { |
} else { |
| print $client "non_authorized\n"; |
print $client "non_authorized\n"; |
| } |
} |
| } else { |
} else { |
| print $client "unknown_user\n"; |
print $client "unknown_user\n"; |
| } |
} |
| } else { |
} else { |
| print $client "refused\n"; |
Reply($client, "refused\n", $userinput); |
| } |
|
| |
} |
| # ---------------------------------------------------------------------- passwd |
# ---------------------------------------------------------------------- passwd |
| } elsif ($userinput =~ /^passwd/) { |
} elsif ($userinput =~ /^passwd/) { # encoded and client |
| if ($wasenc==1) { |
if (($wasenc==1) && isClient) { |
| my |
my |
| ($cmd,$udom,$uname,$upass,$npass)=split(/:/,$userinput); |
($cmd,$udom,$uname,$upass,$npass)=split(/:/,$userinput); |
| chomp($npass); |
chomp($npass); |
| $upass=&unescape($upass); |
$upass=&unescape($upass); |
| $npass=&unescape($npass); |
$npass=&unescape($npass); |
| &Debug("Trying to change password for $uname"); |
&Debug("Trying to change password for $uname"); |
| my $proname=propath($udom,$uname); |
my $proname=propath($udom,$uname); |
| my $passfilename="$proname/passwd"; |
my $passfilename="$proname/passwd"; |
| if (-e $passfilename) { |
if (-e $passfilename) { |
| my $realpasswd; |
my $realpasswd; |
| { my $pf = IO::File->new($passfilename); |
{ my $pf = IO::File->new($passfilename); |
| $realpasswd=<$pf>; } |
$realpasswd=<$pf>; } |
| chomp($realpasswd); |
chomp($realpasswd); |
| my ($howpwd,$contentpwd)=split(/:/,$realpasswd); |
my ($howpwd,$contentpwd)=split(/:/,$realpasswd); |
| if ($howpwd eq 'internal') { |
if ($howpwd eq 'internal') { |
| &Debug("internal auth"); |
&Debug("internal auth"); |
| if (crypt($upass,$contentpwd) eq $contentpwd) { |
if (crypt($upass,$contentpwd) eq $contentpwd) { |
| my $salt=time; |
my $salt=time; |
| $salt=substr($salt,6,2); |
$salt=substr($salt,6,2); |
| my $ncpass=crypt($npass,$salt); |
my $ncpass=crypt($npass,$salt); |
| { |
{ |
| my $pf; |
my $pf; |
| if ($pf = IO::File->new(">$passfilename")) { |
if ($pf = IO::File->new(">$passfilename")) { |
| print $pf "internal:$ncpass\n"; |
print $pf "internal:$ncpass\n"; |
| &logthis("Result of password change for $uname: pwchange_success"); |
&logthis("Result of password change for $uname: pwchange_success"); |
| print $client "ok\n"; |
print $client "ok\n"; |
| } else { |
} else { |
| &logthis("Unable to open $uname passwd to change password"); |
&logthis("Unable to open $uname passwd to change password"); |
| print $client "non_authorized\n"; |
print $client "non_authorized\n"; |
| } |
} |
| } |
} |
| |
|
| } else { |
} else { |
| print $client "non_authorized\n"; |
print $client "non_authorized\n"; |
| } |
} |
| } elsif ($howpwd eq 'unix') { |
} elsif ($howpwd eq 'unix') { |
| # Unix means we have to access /etc/password |
# Unix means we have to access /etc/password |
| # one way or another. |
# one way or another. |
| # First: Make sure the current password is |
# First: Make sure the current password is |
| # correct |
# correct |
| &Debug("auth is unix"); |
&Debug("auth is unix"); |
| $contentpwd=(getpwnam($uname))[1]; |
$contentpwd=(getpwnam($uname))[1]; |
| my $pwdcorrect = "0"; |
my $pwdcorrect = "0"; |
| my $pwauth_path="/usr/local/sbin/pwauth"; |
my $pwauth_path="/usr/local/sbin/pwauth"; |
| unless ($contentpwd eq 'x') { |
unless ($contentpwd eq 'x') { |
| $pwdcorrect= |
$pwdcorrect= |
| (crypt($upass,$contentpwd) eq $contentpwd); |
(crypt($upass,$contentpwd) eq $contentpwd); |
| } elsif (-e $pwauth_path) { |
} elsif (-e $pwauth_path) { |
| open PWAUTH, "|$pwauth_path" or |
open PWAUTH, "|$pwauth_path" or |
| die "Cannot invoke authentication"; |
die "Cannot invoke authentication"; |
| print PWAUTH "$uname\n$upass\n"; |
print PWAUTH "$uname\n$upass\n"; |
| close PWAUTH; |
close PWAUTH; |
| &Debug("exited pwauth with $? ($uname,$upass) "); |
&Debug("exited pwauth with $? ($uname,$upass) "); |
| $pwdcorrect=($? == 0); |
$pwdcorrect=($? == 0); |
| } |
} |
| if ($pwdcorrect) { |
if ($pwdcorrect) { |
| my $execdir=$perlvar{'lonDaemons'}; |
my $execdir=$perlvar{'lonDaemons'}; |
| &Debug("Opening lcpasswd pipeline"); |
&Debug("Opening lcpasswd pipeline"); |
| my $pf = IO::File->new("|$execdir/lcpasswd > $perlvar{'lonDaemons'}/logs/lcpasswd.log"); |
my $pf = IO::File->new("|$execdir/lcpasswd > $perlvar{'lonDaemons'}/logs/lcpasswd.log"); |
| print $pf "$uname\n$npass\n$npass\n"; |
print $pf "$uname\n$npass\n$npass\n"; |
| close $pf; |
close $pf; |
| my $err = $?; |
my $err = $?; |
| my $result = ($err>0 ? 'pwchange_failure' |
my $result = ($err>0 ? 'pwchange_failure' |
| : 'ok'); |
: 'ok'); |
| &logthis("Result of password change for $uname: ". |
&logthis("Result of password change for $uname: ". |
| &lcpasswdstrerror($?)); |
&lcpasswdstrerror($?)); |
| print $client "$result\n"; |
print $client "$result\n"; |
| } else { |
} else { |
| print $client "non_authorized\n"; |
print $client "non_authorized\n"; |
| } |
} |
| } else { |
} else { |
| print $client "auth_mode_error\n"; |
print $client "auth_mode_error\n"; |
| } |
} |
| } else { |
} else { |
| print $client "unknown_user\n"; |
print $client "unknown_user\n"; |
| } |
} |
| } else { |
} else { |
| print $client "refused\n"; |
Reply($client, "refused\n", $userinput); |
| } |
|
| |
} |
| # -------------------------------------------------------------------- makeuser |
# -------------------------------------------------------------------- makeuser |
| } elsif ($userinput =~ /^makeuser/) { |
} elsif ($userinput =~ /^makeuser/) { # encoded and client. |
| &Debug("Make user received"); |
&Debug("Make user received"); |
| my $oldumask=umask(0077); |
my $oldumask=umask(0077); |
| if ($wasenc==1) { |
if (($wasenc==1) && isClient) { |
| my |
my |
| ($cmd,$udom,$uname,$umode,$npass)=split(/:/,$userinput); |
($cmd,$udom,$uname,$umode,$npass)=split(/:/,$userinput); |
| &Debug("cmd =".$cmd." $udom =".$udom. |
&Debug("cmd =".$cmd." $udom =".$udom. |
| " uname=".$uname); |
" uname=".$uname); |
| chomp($npass); |
chomp($npass); |
| $npass=&unescape($npass); |
$npass=&unescape($npass); |
| my $proname=propath($udom,$uname); |
my $proname=propath($udom,$uname); |
| my $passfilename="$proname/passwd"; |
my $passfilename="$proname/passwd"; |
| &Debug("Password file created will be:". |
&Debug("Password file created will be:". |
| $passfilename); |
$passfilename); |
| if (-e $passfilename) { |
if (-e $passfilename) { |
| print $client "already_exists\n"; |
print $client "already_exists\n"; |
| } elsif ($udom ne $currentdomainid) { |
} elsif ($udom ne $currentdomainid) { |
| print $client "not_right_domain\n"; |
print $client "not_right_domain\n"; |
| } else { |
} else { |
| my @fpparts=split(/\//,$proname); |
my @fpparts=split(/\//,$proname); |
| my $fpnow=$fpparts[0].'/'.$fpparts[1].'/'.$fpparts[2]; |
my $fpnow=$fpparts[0].'/'.$fpparts[1].'/'.$fpparts[2]; |
| my $fperror=''; |
my $fperror=''; |
| for (my $i=3;$i<=$#fpparts;$i++) { |
for (my $i=3;$i<=$#fpparts;$i++) { |
| $fpnow.='/'.$fpparts[$i]; |
$fpnow.='/'.$fpparts[$i]; |
| unless (-e $fpnow) { |
unless (-e $fpnow) { |
| unless (mkdir($fpnow,0777)) { |
unless (mkdir($fpnow,0777)) { |
| $fperror="error: ".($!+0) |
$fperror="error: ".($!+0) |
| ." mkdir failed while attempting " |
." mkdir failed while attempting " |
| ."makeuser\n"; |
."makeuser"; |
| } |
} |
| } |
} |
| } |
} |
| unless ($fperror) { |
unless ($fperror) { |
| my $result=&make_passwd_file($uname, $umode,$npass, |
my $result=&make_passwd_file($uname, $umode,$npass, |
| $passfilename); |
$passfilename); |
| print $client $result; |
print $client $result; |
| } else { |
} else { |
| print $client "$fperror\n"; |
print $client "$fperror\n"; |
| } |
} |
| } |
} |
| } else { |
} else { |
| print $client "refused\n"; |
Reply($client, "refused\n", $userinput); |
| } |
|
| umask($oldumask); |
} |
| |
umask($oldumask); |
| # -------------------------------------------------------------- changeuserauth |
# -------------------------------------------------------------- changeuserauth |
| } elsif ($userinput =~ /^changeuserauth/) { |
} elsif ($userinput =~ /^changeuserauth/) { # encoded & client |
| &Debug("Changing authorization"); |
&Debug("Changing authorization"); |
| if ($wasenc==1) { |
if (($wasenc==1) && isClient) { |
| my |
my |
| ($cmd,$udom,$uname,$umode,$npass)=split(/:/,$userinput); |
($cmd,$udom,$uname,$umode,$npass)=split(/:/,$userinput); |
| chomp($npass); |
chomp($npass); |
| &Debug("cmd = ".$cmd." domain= ".$udom. |
&Debug("cmd = ".$cmd." domain= ".$udom. |
| "uname =".$uname." umode= ".$umode); |
"uname =".$uname." umode= ".$umode); |
| $npass=&unescape($npass); |
$npass=&unescape($npass); |
| my $proname=&propath($udom,$uname); |
my $proname=&propath($udom,$uname); |
| my $passfilename="$proname/passwd"; |
my $passfilename="$proname/passwd"; |
| if ($udom ne $currentdomainid) { |
if ($udom ne $currentdomainid) { |
| print $client "not_right_domain\n"; |
print $client "not_right_domain\n"; |
| } else { |
} else { |
| my $result=&make_passwd_file($uname, $umode,$npass, |
my $result=&make_passwd_file($uname, $umode,$npass, |
| $passfilename); |
$passfilename); |
| print $client $result; |
print $client $result; |
| } |
} |
| } else { |
} else { |
| print $client "refused\n"; |
Reply($client, "refused\n", $userinput); |
| } |
|
| |
} |
| # ------------------------------------------------------------------------ home |
# ------------------------------------------------------------------------ home |
| } elsif ($userinput =~ /^home/) { |
} elsif ($userinput =~ /^home/) { # client clear or encoded |
| my ($cmd,$udom,$uname)=split(/:/,$userinput); |
if(isClient) { |
| chomp($uname); |
my ($cmd,$udom,$uname)=split(/:/,$userinput); |
| my $proname=propath($udom,$uname); |
chomp($uname); |
| if (-e $proname) { |
my $proname=propath($udom,$uname); |
| print $client "found\n"; |
if (-e $proname) { |
| } else { |
print $client "found\n"; |
| print $client "not_found\n"; |
} else { |
| } |
print $client "not_found\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ---------------------------------------------------------------------- update |
# ---------------------------------------------------------------------- update |
| } elsif ($userinput =~ /^update/) { |
} elsif ($userinput =~ /^update/) { # client clear or encoded. |
| my ($cmd,$fname)=split(/:/,$userinput); |
if(isClient) { |
| my $ownership=ishome($fname); |
my ($cmd,$fname)=split(/:/,$userinput); |
| if ($ownership eq 'not_owner') { |
my $ownership=ishome($fname); |
| if (-e $fname) { |
if ($ownership eq 'not_owner') { |
| my ($dev,$ino,$mode,$nlink, |
if (-e $fname) { |
| $uid,$gid,$rdev,$size, |
my ($dev,$ino,$mode,$nlink, |
| $atime,$mtime,$ctime, |
$uid,$gid,$rdev,$size, |
| $blksize,$blocks)=stat($fname); |
$atime,$mtime,$ctime, |
| my $now=time; |
$blksize,$blocks)=stat($fname); |
| my $since=$now-$atime; |
my $now=time; |
| if ($since>$perlvar{'lonExpire'}) { |
my $since=$now-$atime; |
| my $reply= |
if ($since>$perlvar{'lonExpire'}) { |
| &reply("unsub:$fname","$hostid{$clientip}"); |
my $reply= |
| unlink("$fname"); |
&reply("unsub:$fname","$clientname"); |
| } else { |
unlink("$fname"); |
| my $transname="$fname.in.transfer"; |
} else { |
| my $remoteurl= |
my $transname="$fname.in.transfer"; |
| reply("sub:$fname","$hostid{$clientip}"); |
my $remoteurl= |
| my $response; |
&reply("sub:$fname","$clientname"); |
| { |
my $response; |
| my $ua=new LWP::UserAgent; |
{ |
| my $request=new HTTP::Request('GET',"$remoteurl"); |
my $ua=new LWP::UserAgent; |
| $response=$ua->request($request,$transname); |
my $request=new HTTP::Request('GET',"$remoteurl"); |
| } |
$response=$ua->request($request,$transname); |
| if ($response->is_error()) { |
} |
| unlink($transname); |
if ($response->is_error()) { |
| my $message=$response->status_line; |
unlink($transname); |
| &logthis( |
my $message=$response->status_line; |
| "LWP GET: $message for $fname ($remoteurl)"); |
&logthis( |
| } else { |
"LWP GET: $message for $fname ($remoteurl)"); |
| if ($remoteurl!~/\.meta$/) { |
} else { |
| my $ua=new LWP::UserAgent; |
if ($remoteurl!~/\.meta$/) { |
| my $mrequest= |
my $ua=new LWP::UserAgent; |
| new HTTP::Request('GET',$remoteurl.'.meta'); |
my $mrequest= |
| my $mresponse= |
new HTTP::Request('GET',$remoteurl.'.meta'); |
| $ua->request($mrequest,$fname.'.meta'); |
my $mresponse= |
| if ($mresponse->is_error()) { |
$ua->request($mrequest,$fname.'.meta'); |
| unlink($fname.'.meta'); |
if ($mresponse->is_error()) { |
| } |
unlink($fname.'.meta'); |
| } |
} |
| rename($transname,$fname); |
} |
| } |
rename($transname,$fname); |
| } |
} |
| print $client "ok\n"; |
} |
| } else { |
print $client "ok\n"; |
| print $client "not_found\n"; |
} else { |
| } |
print $client "not_found\n"; |
| } else { |
} |
| print $client "rejected\n"; |
} else { |
| } |
print $client "rejected\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # -------------------------------------- fetch a user file from a remote server |
# -------------------------------------- fetch a user file from a remote server |
| } elsif ($userinput =~ /^fetchuserfile/) { |
} elsif ($userinput =~ /^fetchuserfile/) { # Client clear or enc. |
| my ($cmd,$fname)=split(/:/,$userinput); |
if(isClient) { |
| my ($udom,$uname,$ufile)=split(/\//,$fname); |
my ($cmd,$fname)=split(/:/,$userinput); |
| my $udir=propath($udom,$uname).'/userfiles'; |
my ($udom,$uname,$ufile)=split(/\//,$fname); |
| unless (-e $udir) { mkdir($udir,0770); } |
my $udir=propath($udom,$uname).'/userfiles'; |
| if (-e $udir) { |
unless (-e $udir) { mkdir($udir,0770); } |
| $ufile=~s/^[\.\~]+//; |
if (-e $udir) { |
| $ufile=~s/\///g; |
$ufile=~s/^[\.\~]+//; |
| my $transname=$udir.'/'.$ufile; |
$ufile=~s/\///g; |
| my $remoteurl='http://'.$clientip.'/userfiles/'.$fname; |
my $destname=$udir.'/'.$ufile; |
| my $response; |
my $transname=$udir.'/'.$ufile.'.in.transit'; |
| { |
my $remoteurl='http://'.$clientip.'/userfiles/'.$fname; |
| my $ua=new LWP::UserAgent; |
my $response; |
| my $request=new HTTP::Request('GET',"$remoteurl"); |
{ |
| $response=$ua->request($request,$transname); |
my $ua=new LWP::UserAgent; |
| } |
my $request=new HTTP::Request('GET',"$remoteurl"); |
| if ($response->is_error()) { |
$response=$ua->request($request,$transname); |
| unlink($transname); |
} |
| my $message=$response->status_line; |
if ($response->is_error()) { |
| &logthis( |
unlink($transname); |
| "LWP GET: $message for $fname ($remoteurl)"); |
my $message=$response->status_line; |
| print $client "failed\n"; |
&logthis("LWP GET: $message for $fname ($remoteurl)"); |
| } else { |
print $client "failed\n"; |
| print $client "ok\n"; |
} else { |
| } |
if (!rename($transname,$destname)) { |
| } else { |
&logthis("Unable to move $transname to $destname"); |
| print $client "not_home\n"; |
unlink($transname); |
| } |
print $client "failed\n"; |
| |
} else { |
| |
print $client "ok\n"; |
| |
} |
| |
} |
| |
} else { |
| |
print $client "not_home\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------ authenticate access to a user file |
# ------------------------------------------ authenticate access to a user file |
| } elsif ($userinput =~ /^tokenauthuserfile/) { |
} elsif ($userinput =~ /^tokenauthuserfile/) { # Client only |
| my ($cmd,$fname,$session)=split(/:/,$userinput); |
if(isClient) { |
| chomp($session); |
my ($cmd,$fname,$session)=split(/:/,$userinput); |
| my $reply='non_auth'; |
chomp($session); |
| if (open(ENVIN,$perlvar{'lonIDsDir'}.'/'. |
my $reply='non_auth'; |
| $session.'.id')) { |
if (open(ENVIN,$perlvar{'lonIDsDir'}.'/'. |
| while (my $line=<ENVIN>) { |
$session.'.id')) { |
| if ($line=~/userfile\.$fname\=/) { $reply='ok'; } |
while (my $line=<ENVIN>) { |
| } |
if ($line=~/userfile\.$fname\=/) { $reply='ok'; } |
| close(ENVIN); |
} |
| print $client $reply."\n"; |
close(ENVIN); |
| } else { |
print $client $reply."\n"; |
| print $client "invalid_token\n"; |
} else { |
| } |
print $client "invalid_token\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ----------------------------------------------------------------- unsubscribe |
# ----------------------------------------------------------------- unsubscribe |
| } elsif ($userinput =~ /^unsub/) { |
} elsif ($userinput =~ /^unsub/) { |
| my ($cmd,$fname)=split(/:/,$userinput); |
if(isClient) { |
| if (-e $fname) { |
my ($cmd,$fname)=split(/:/,$userinput); |
| print $client &unsub($client,$fname,$clientip); |
if (-e $fname) { |
| } else { |
print $client &unsub($client,$fname,$clientip); |
| print $client "not_found\n"; |
} else { |
| } |
print $client "not_found\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------------- subscribe |
# ------------------------------------------------------------------- subscribe |
| } elsif ($userinput =~ /^sub/) { |
} elsif ($userinput =~ /^sub/) { |
| print $client &subscribe($userinput,$clientip); |
if(isClient) { |
| |
print $client &subscribe($userinput,$clientip); |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------- current version |
# ------------------------------------------------------------- current version |
| } elsif ($userinput =~ /^currentversion/) { |
} elsif ($userinput =~ /^currentversion/) { |
| my ($cmd,$fname)=split(/:/,$userinput); |
if(isClient) { |
| print $client ¤tversion($fname)."\n"; |
my ($cmd,$fname)=split(/:/,$userinput); |
| |
print $client ¤tversion($fname)."\n"; |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------------------- log |
# ------------------------------------------------------------------------- log |
| } elsif ($userinput =~ /^log/) { |
} elsif ($userinput =~ /^log/) { |
| my ($cmd,$udom,$uname,$what)=split(/:/,$userinput); |
if(isClient) { |
| chomp($what); |
my ($cmd,$udom,$uname,$what)=split(/:/,$userinput); |
| my $proname=propath($udom,$uname); |
chomp($what); |
| my $now=time; |
my $proname=propath($udom,$uname); |
| { |
my $now=time; |
| my $hfh; |
{ |
| if ($hfh=IO::File->new(">>$proname/activity.log")) { |
my $hfh; |
| print $hfh "$now:$hostid{$clientip}:$what\n"; |
if ($hfh=IO::File->new(">>$proname/activity.log")) { |
| print $client "ok\n"; |
print $hfh "$now:$clientname:$what\n"; |
| } else { |
print $client "ok\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." IO::File->new Failed " |
print $client "error: ".($!+0) |
| ."while attempting log\n"; |
." IO::File->new Failed " |
| } |
."while attempting log\n"; |
| } |
} |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------------------- put |
# ------------------------------------------------------------------------- put |
| } elsif ($userinput =~ /^put/) { |
} elsif ($userinput =~ /^put/) { |
| my ($cmd,$udom,$uname,$namespace,$what) |
if(isClient) { |
| =split(/:/,$userinput); |
my ($cmd,$udom,$uname,$namespace,$what) |
| $namespace=~s/\//\_/g; |
=split(/:/,$userinput); |
| $namespace=~s/\W//g; |
$namespace=~s/\//\_/g; |
| if ($namespace ne 'roles') { |
$namespace=~s/\W//g; |
| chomp($what); |
if ($namespace ne 'roles') { |
| my $proname=propath($udom,$uname); |
chomp($what); |
| my $now=time; |
my $proname=propath($udom,$uname); |
| unless ($namespace=~/^nohist\_/) { |
my $now=time; |
| my $hfh; |
unless ($namespace=~/^nohist\_/) { |
| if ( |
my $hfh; |
| $hfh=IO::File->new(">>$proname/$namespace.hist") |
if ( |
| ) { print $hfh "P:$now:$what\n"; } |
$hfh=IO::File->new(">>$proname/$namespace.hist") |
| } |
) { print $hfh "P:$now:$what\n"; } |
| my @pairs=split(/\&/,$what); |
} |
| my %hash; |
my @pairs=split(/\&/,$what); |
| if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_WRCREAT(),0640)) { |
my %hash; |
| foreach my $pair (@pairs) { |
if (tie(%hash,'GDBM_File', |
| my ($key,$value)=split(/=/,$pair); |
"$proname/$namespace.db", |
| $hash{$key}=$value; |
&GDBM_WRCREAT(),0640)) { |
| } |
foreach my $pair (@pairs) { |
| if (untie(%hash)) { |
my ($key,$value)=split(/=/,$pair); |
| print $client "ok\n"; |
$hash{$key}=$value; |
| } else { |
} |
| print $client "error: ".($!+0) |
if (untie(%hash)) { |
| ." untie(GDBM) failed ". |
print $client "ok\n"; |
| "while attempting put\n"; |
} else { |
| } |
print $client "error: ".($!+0) |
| } else { |
." untie(GDBM) failed ". |
| print $client "error: ".($!) |
"while attempting put\n"; |
| ." tie(GDBM) Failed ". |
} |
| "while attempting put\n"; |
} else { |
| } |
print $client "error: ".($!) |
| } else { |
." tie(GDBM) Failed ". |
| print $client "refused\n"; |
"while attempting put\n"; |
| } |
} |
| |
} else { |
| |
print $client "refused\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| |
# ------------------------------------------------------------------- inc |
| |
} elsif ($userinput =~ /^inc:/) { |
| |
if(isClient) { |
| |
my ($cmd,$udom,$uname,$namespace,$what) |
| |
=split(/:/,$userinput); |
| |
$namespace=~s/\//\_/g; |
| |
$namespace=~s/\W//g; |
| |
if ($namespace ne 'roles') { |
| |
chomp($what); |
| |
my $proname=propath($udom,$uname); |
| |
my $now=time; |
| |
unless ($namespace=~/^nohist\_/) { |
| |
my $hfh; |
| |
if ( |
| |
$hfh=IO::File->new(">>$proname/$namespace.hist") |
| |
) { print $hfh "P:$now:$what\n"; } |
| |
} |
| |
my @pairs=split(/\&/,$what); |
| |
my %hash; |
| |
if (tie(%hash,'GDBM_File', |
| |
"$proname/$namespace.db", |
| |
&GDBM_WRCREAT(),0640)) { |
| |
foreach my $pair (@pairs) { |
| |
my ($key,$value)=split(/=/,$pair); |
| |
# We could check that we have a number... |
| |
if (! defined($value) || $value eq '') { |
| |
$value = 1; |
| |
} |
| |
$hash{$key}+=$value; |
| |
} |
| |
if (untie(%hash)) { |
| |
print $client "ok\n"; |
| |
} else { |
| |
print $client "error: ".($!+0) |
| |
." untie(GDBM) failed ". |
| |
"while attempting put\n"; |
| |
} |
| |
} else { |
| |
print $client "error: ".($!) |
| |
." tie(GDBM) Failed ". |
| |
"while attempting put\n"; |
| |
} |
| |
} else { |
| |
print $client "refused\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # -------------------------------------------------------------------- rolesput |
# -------------------------------------------------------------------- rolesput |
| } elsif ($userinput =~ /^rolesput/) { |
} elsif ($userinput =~ /^rolesput/) { |
| &Debug("rolesput"); |
if(isClient) { |
| if ($wasenc==1) { |
&Debug("rolesput"); |
| my ($cmd,$exedom,$exeuser,$udom,$uname,$what) |
if ($wasenc==1) { |
| =split(/:/,$userinput); |
my ($cmd,$exedom,$exeuser,$udom,$uname,$what) |
| &Debug("cmd = ".$cmd." exedom= ".$exedom. |
=split(/:/,$userinput); |
| "user = ".$exeuser." udom=".$udom. |
&Debug("cmd = ".$cmd." exedom= ".$exedom. |
| "what = ".$what); |
"user = ".$exeuser." udom=".$udom. |
| my $namespace='roles'; |
"what = ".$what); |
| chomp($what); |
my $namespace='roles'; |
| my $proname=propath($udom,$uname); |
chomp($what); |
| my $now=time; |
my $proname=propath($udom,$uname); |
| { |
my $now=time; |
| my $hfh; |
{ |
| if ( |
my $hfh; |
| $hfh=IO::File->new(">>$proname/$namespace.hist") |
if ( |
| ) { |
$hfh=IO::File->new(">>$proname/$namespace.hist") |
| print $hfh "P:$now:$exedom:$exeuser:$what\n"; |
) { |
| } |
print $hfh "P:$now:$exedom:$exeuser:$what\n"; |
| } |
} |
| my @pairs=split(/\&/,$what); |
} |
| my %hash; |
my @pairs=split(/\&/,$what); |
| if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_WRCREAT(),0640)) { |
my %hash; |
| foreach my $pair (@pairs) { |
if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_WRCREAT(),0640)) { |
| my ($key,$value)=split(/=/,$pair); |
foreach my $pair (@pairs) { |
| &ManagePermissions($key, $udom, $uname, |
my ($key,$value)=split(/=/,$pair); |
| &GetAuthType( $udom, |
&ManagePermissions($key, $udom, $uname, |
| $uname)); |
&GetAuthType( $udom, |
| $hash{$key}=$value; |
$uname)); |
| } |
$hash{$key}=$value; |
| if (untie(%hash)) { |
} |
| print $client "ok\n"; |
if (untie(%hash)) { |
| } else { |
print $client "ok\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting rolesput\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting rolesput\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting rolesput\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting rolesput\n"; |
| } else { |
} |
| print $client "refused\n"; |
} else { |
| } |
print $client "refused\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # -------------------------------------------------------------------- rolesdel |
# -------------------------------------------------------------------- rolesdel |
| } elsif ($userinput =~ /^rolesdel/) { |
} elsif ($userinput =~ /^rolesdel/) { |
| &Debug("rolesdel"); |
if(isClient) { |
| if ($wasenc==1) { |
&Debug("rolesdel"); |
| my ($cmd,$exedom,$exeuser,$udom,$uname,$what) |
if ($wasenc==1) { |
| =split(/:/,$userinput); |
my ($cmd,$exedom,$exeuser,$udom,$uname,$what) |
| &Debug("cmd = ".$cmd." exedom= ".$exedom. |
=split(/:/,$userinput); |
| "user = ".$exeuser." udom=".$udom. |
&Debug("cmd = ".$cmd." exedom= ".$exedom. |
| "what = ".$what); |
"user = ".$exeuser." udom=".$udom. |
| my $namespace='roles'; |
"what = ".$what); |
| chomp($what); |
my $namespace='roles'; |
| my $proname=propath($udom,$uname); |
chomp($what); |
| my $now=time; |
my $proname=propath($udom,$uname); |
| { |
my $now=time; |
| my $hfh; |
{ |
| if ( |
my $hfh; |
| $hfh=IO::File->new(">>$proname/$namespace.hist") |
if ( |
| ) { |
$hfh=IO::File->new(">>$proname/$namespace.hist") |
| print $hfh "D:$now:$exedom:$exeuser:$what\n"; |
) { |
| } |
print $hfh "D:$now:$exedom:$exeuser:$what\n"; |
| } |
} |
| my @rolekeys=split(/\&/,$what); |
} |
| my %hash; |
my @rolekeys=split(/\&/,$what); |
| if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_WRCREAT(),0640)) { |
my %hash; |
| foreach my $key (@rolekeys) { |
if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_WRCREAT(),0640)) { |
| delete $hash{$key}; |
foreach my $key (@rolekeys) { |
| } |
delete $hash{$key}; |
| if (untie(%hash)) { |
} |
| print $client "ok\n"; |
if (untie(%hash)) { |
| } else { |
print $client "ok\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting rolesdel\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting rolesdel\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting rolesdel\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting rolesdel\n"; |
| } else { |
} |
| print $client "refused\n"; |
} else { |
| } |
print $client "refused\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------------------- get |
# ------------------------------------------------------------------------- get |
| } elsif ($userinput =~ /^get/) { |
} elsif ($userinput =~ /^get/) { |
| my ($cmd,$udom,$uname,$namespace,$what) |
if(isClient) { |
| =split(/:/,$userinput); |
my ($cmd,$udom,$uname,$namespace,$what) |
| $namespace=~s/\//\_/g; |
=split(/:/,$userinput); |
| $namespace=~s/\W//g; |
$namespace=~s/\//\_/g; |
| chomp($what); |
$namespace=~s/\W//g; |
| my @queries=split(/\&/,$what); |
chomp($what); |
| my $proname=propath($udom,$uname); |
my @queries=split(/\&/,$what); |
| my $qresult=''; |
my $proname=propath($udom,$uname); |
| my %hash; |
my $qresult=''; |
| if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_READER(),0640)) { |
my %hash; |
| for (my $i=0;$i<=$#queries;$i++) { |
if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_READER(),0640)) { |
| $qresult.="$hash{$queries[$i]}&"; |
for (my $i=0;$i<=$#queries;$i++) { |
| } |
$qresult.="$hash{$queries[$i]}&"; |
| if (untie(%hash)) { |
} |
| $qresult=~s/\&$//; |
if (untie(%hash)) { |
| print $client "$qresult\n"; |
$qresult=~s/\&$//; |
| } else { |
print $client "$qresult\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting get\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting get\n"; |
| } else { |
} |
| if ($!+0 == 2) { |
} else { |
| print $client "error:No such file or ". |
if ($!+0 == 2) { |
| "GDBM reported bad block error\n"; |
print $client "error:No such file or ". |
| } else { |
"GDBM reported bad block error\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting get\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting get\n"; |
| } |
} |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------------------ eget |
# ------------------------------------------------------------------------ eget |
| } elsif ($userinput =~ /^eget/) { |
} elsif ($userinput =~ /^eget/) { |
| my ($cmd,$udom,$uname,$namespace,$what) |
if (isClient) { |
| =split(/:/,$userinput); |
my ($cmd,$udom,$uname,$namespace,$what) |
| $namespace=~s/\//\_/g; |
=split(/:/,$userinput); |
| $namespace=~s/\W//g; |
$namespace=~s/\//\_/g; |
| chomp($what); |
$namespace=~s/\W//g; |
| my @queries=split(/\&/,$what); |
chomp($what); |
| my $proname=propath($udom,$uname); |
my @queries=split(/\&/,$what); |
| my $qresult=''; |
my $proname=propath($udom,$uname); |
| my %hash; |
my $qresult=''; |
| if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_READER(),0640)) { |
my %hash; |
| for (my $i=0;$i<=$#queries;$i++) { |
if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_READER(),0640)) { |
| $qresult.="$hash{$queries[$i]}&"; |
for (my $i=0;$i<=$#queries;$i++) { |
| } |
$qresult.="$hash{$queries[$i]}&"; |
| if (untie(%hash)) { |
} |
| $qresult=~s/\&$//; |
if (untie(%hash)) { |
| if ($cipher) { |
$qresult=~s/\&$//; |
| my $cmdlength=length($qresult); |
if ($cipher) { |
| $qresult.=" "; |
my $cmdlength=length($qresult); |
| my $encqresult=''; |
$qresult.=" "; |
| for |
my $encqresult=''; |
| (my $encidx=0;$encidx<=$cmdlength;$encidx+=8) { |
for |
| $encqresult.= |
(my $encidx=0;$encidx<=$cmdlength;$encidx+=8) { |
| unpack("H16", |
$encqresult.= |
| $cipher->encrypt(substr($qresult,$encidx,8))); |
unpack("H16", |
| } |
$cipher->encrypt(substr($qresult,$encidx,8))); |
| print $client "enc:$cmdlength:$encqresult\n"; |
} |
| } else { |
print $client "enc:$cmdlength:$encqresult\n"; |
| print $client "error:no_key\n"; |
} else { |
| } |
print $client "error:no_key\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting eget\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting eget\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting eget\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting eget\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------------------- del |
# ------------------------------------------------------------------------- del |
| } elsif ($userinput =~ /^del/) { |
} elsif ($userinput =~ /^del/) { |
| my ($cmd,$udom,$uname,$namespace,$what) |
if(isClient) { |
| =split(/:/,$userinput); |
my ($cmd,$udom,$uname,$namespace,$what) |
| $namespace=~s/\//\_/g; |
=split(/:/,$userinput); |
| $namespace=~s/\W//g; |
$namespace=~s/\//\_/g; |
| chomp($what); |
$namespace=~s/\W//g; |
| my $proname=propath($udom,$uname); |
chomp($what); |
| my $now=time; |
my $proname=propath($udom,$uname); |
| unless ($namespace=~/^nohist\_/) { |
my $now=time; |
| my $hfh; |
unless ($namespace=~/^nohist\_/) { |
| if ( |
my $hfh; |
| $hfh=IO::File->new(">>$proname/$namespace.hist") |
if ( |
| ) { print $hfh "D:$now:$what\n"; } |
$hfh=IO::File->new(">>$proname/$namespace.hist") |
| } |
) { print $hfh "D:$now:$what\n"; } |
| my @keys=split(/\&/,$what); |
} |
| my %hash; |
my @keys=split(/\&/,$what); |
| if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_WRCREAT(),0640)) { |
my %hash; |
| foreach my $key (@keys) { |
if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_WRCREAT(),0640)) { |
| delete($hash{$key}); |
foreach my $key (@keys) { |
| } |
delete($hash{$key}); |
| if (untie(%hash)) { |
} |
| print $client "ok\n"; |
if (untie(%hash)) { |
| } else { |
print $client "ok\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting del\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting del\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting del\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting del\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------------------ keys |
# ------------------------------------------------------------------------ keys |
| } elsif ($userinput =~ /^keys/) { |
} elsif ($userinput =~ /^keys/) { |
| my ($cmd,$udom,$uname,$namespace) |
if(isClient) { |
| =split(/:/,$userinput); |
my ($cmd,$udom,$uname,$namespace) |
| $namespace=~s/\//\_/g; |
=split(/:/,$userinput); |
| $namespace=~s/\W//g; |
$namespace=~s/\//\_/g; |
| my $proname=propath($udom,$uname); |
$namespace=~s/\W//g; |
| my $qresult=''; |
my $proname=propath($udom,$uname); |
| my %hash; |
my $qresult=''; |
| if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_READER(),0640)) { |
my %hash; |
| foreach my $key (keys %hash) { |
if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_READER(),0640)) { |
| $qresult.="$key&"; |
foreach my $key (keys %hash) { |
| } |
$qresult.="$key&"; |
| if (untie(%hash)) { |
} |
| $qresult=~s/\&$//; |
if (untie(%hash)) { |
| print $client "$qresult\n"; |
$qresult=~s/\&$//; |
| } else { |
print $client "$qresult\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting keys\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting keys\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting keys\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting keys\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ----------------------------------------------------------------- dumpcurrent |
# ----------------------------------------------------------------- dumpcurrent |
| } elsif ($userinput =~ /^currentdump/) { |
} elsif ($userinput =~ /^currentdump/) { |
| my ($cmd,$udom,$uname,$namespace) |
if (isClient) { |
| =split(/:/,$userinput); |
my ($cmd,$udom,$uname,$namespace) |
| $namespace=~s/\//\_/g; |
=split(/:/,$userinput); |
| $namespace=~s/\W//g; |
$namespace=~s/\//\_/g; |
| my $qresult=''; |
$namespace=~s/\W//g; |
| my $proname=propath($udom,$uname); |
my $qresult=''; |
| my %hash; |
my $proname=propath($udom,$uname); |
| if (tie(%hash,'GDBM_File', |
my %hash; |
| "$proname/$namespace.db", |
if (tie(%hash,'GDBM_File', |
| &GDBM_READER(),0640)) { |
"$proname/$namespace.db", |
| # Structure of %data: |
&GDBM_READER(),0640)) { |
| # $data{$symb}->{$parameter}=$value; |
# Structure of %data: |
| # $data{$symb}->{'v.'.$parameter}=$version; |
# $data{$symb}->{$parameter}=$value; |
| # since $parameter will be unescaped, we do not |
# $data{$symb}->{'v.'.$parameter}=$version; |
| # have to worry about silly parameter names... |
# since $parameter will be unescaped, we do not |
| my %data = (); |
# have to worry about silly parameter names... |
| while (my ($key,$value) = each(%hash)) { |
my %data = (); |
| my ($v,$symb,$param) = split(/:/,$key); |
while (my ($key,$value) = each(%hash)) { |
| next if ($v eq 'version' || $symb eq 'keys'); |
my ($v,$symb,$param) = split(/:/,$key); |
| next if (exists($data{$symb}) && |
next if ($v eq 'version' || $symb eq 'keys'); |
| exists($data{$symb}->{$param}) && |
next if (exists($data{$symb}) && |
| $data{$symb}->{'v.'.$param} > $v); |
exists($data{$symb}->{$param}) && |
| $data{$symb}->{$param}=$value; |
$data{$symb}->{'v.'.$param} > $v); |
| $data{$symb}->{'v.'.$param}=$v; |
$data{$symb}->{$param}=$value; |
| } |
$data{$symb}->{'v.'.$param}=$v; |
| if (untie(%hash)) { |
} |
| while (my ($symb,$param_hash) = each(%data)) { |
if (untie(%hash)) { |
| while(my ($param,$value) = each (%$param_hash)){ |
while (my ($symb,$param_hash) = each(%data)) { |
| next if ($param =~ /^v\./); |
while(my ($param,$value) = each (%$param_hash)){ |
| $qresult.=$symb.':'.$param.'='.$value.'&'; |
next if ($param =~ /^v\./); |
| } |
$qresult.=$symb.':'.$param.'='.$value.'&'; |
| } |
} |
| chop($qresult); |
} |
| print $client "$qresult\n"; |
chop($qresult); |
| } else { |
print $client "$qresult\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting currentdump\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting currentdump\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting currentdump\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting currentdump\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
} |
| # ------------------------------------------------------------------------ dump |
# ------------------------------------------------------------------------ dump |
| } elsif ($userinput =~ /^dump/) { |
} elsif ($userinput =~ /^dump/) { |
| my ($cmd,$udom,$uname,$namespace,$regexp) |
if(isClient) { |
| =split(/:/,$userinput); |
my ($cmd,$udom,$uname,$namespace,$regexp) |
| $namespace=~s/\//\_/g; |
=split(/:/,$userinput); |
| $namespace=~s/\W//g; |
$namespace=~s/\//\_/g; |
| if (defined($regexp)) { |
$namespace=~s/\W//g; |
| $regexp=&unescape($regexp); |
if (defined($regexp)) { |
| } else { |
$regexp=&unescape($regexp); |
| $regexp='.'; |
} else { |
| } |
$regexp='.'; |
| my $qresult=''; |
} |
| my $proname=propath($udom,$uname); |
my $qresult=''; |
| my %hash; |
my $proname=propath($udom,$uname); |
| if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_READER(),0640)) { |
my %hash; |
| study($regexp); |
if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_READER(),0640)) { |
| while (my ($key,$value) = each(%hash)) { |
study($regexp); |
| if ($regexp eq '.') { |
while (my ($key,$value) = each(%hash)) { |
| $qresult.=$key.'='.$value.'&'; |
if ($regexp eq '.') { |
| } else { |
$qresult.=$key.'='.$value.'&'; |
| my $unescapeKey = &unescape($key); |
} else { |
| if (eval('$unescapeKey=~/$regexp/')) { |
my $unescapeKey = &unescape($key); |
| $qresult.="$key=$value&"; |
if (eval('$unescapeKey=~/$regexp/')) { |
| } |
$qresult.="$key=$value&"; |
| } |
} |
| } |
} |
| if (untie(%hash)) { |
} |
| chop($qresult); |
if (untie(%hash)) { |
| print $client "$qresult\n"; |
chop($qresult); |
| } else { |
print $client "$qresult\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| |
." untie(GDBM) Failed ". |
| "while attempting dump\n"; |
"while attempting dump\n"; |
| } |
} |
| } else { |
} else { |
| print $client "error: ".($!+0) |
print $client "error: ".($!+0) |
| ." tie(GDBM) Failed ". |
." tie(GDBM) Failed ". |
| "while attempting dump\n"; |
"while attempting dump\n"; |
| } |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ----------------------------------------------------------------------- store |
# ----------------------------------------------------------------------- store |
| } elsif ($userinput =~ /^store/) { |
} elsif ($userinput =~ /^store/) { |
| my ($cmd,$udom,$uname,$namespace,$rid,$what) |
if(isClient) { |
| =split(/:/,$userinput); |
my ($cmd,$udom,$uname,$namespace,$rid,$what) |
| $namespace=~s/\//\_/g; |
=split(/:/,$userinput); |
| $namespace=~s/\W//g; |
$namespace=~s/\//\_/g; |
| if ($namespace ne 'roles') { |
$namespace=~s/\W//g; |
| chomp($what); |
if ($namespace ne 'roles') { |
| my $proname=propath($udom,$uname); |
chomp($what); |
| my $now=time; |
my $proname=propath($udom,$uname); |
| unless ($namespace=~/^nohist\_/) { |
my $now=time; |
| my $hfh; |
unless ($namespace=~/^nohist\_/) { |
| if ( |
my $hfh; |
| $hfh=IO::File->new(">>$proname/$namespace.hist") |
if ( |
| ) { print $hfh "P:$now:$rid:$what\n"; } |
$hfh=IO::File->new(">>$proname/$namespace.hist") |
| } |
) { print $hfh "P:$now:$rid:$what\n"; } |
| my @pairs=split(/\&/,$what); |
} |
| my %hash; |
my @pairs=split(/\&/,$what); |
| if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_WRCREAT(),0640)) { |
my %hash; |
| my @previouskeys=split(/&/,$hash{"keys:$rid"}); |
if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_WRCREAT(),0640)) { |
| my $key; |
my @previouskeys=split(/&/,$hash{"keys:$rid"}); |
| $hash{"version:$rid"}++; |
my $key; |
| my $version=$hash{"version:$rid"}; |
$hash{"version:$rid"}++; |
| my $allkeys=''; |
my $version=$hash{"version:$rid"}; |
| foreach my $pair (@pairs) { |
my $allkeys=''; |
| my ($key,$value)=split(/=/,$pair); |
foreach my $pair (@pairs) { |
| $allkeys.=$key.':'; |
my ($key,$value)=split(/=/,$pair); |
| $hash{"$version:$rid:$key"}=$value; |
$allkeys.=$key.':'; |
| } |
$hash{"$version:$rid:$key"}=$value; |
| $hash{"$version:$rid:timestamp"}=$now; |
} |
| $allkeys.='timestamp'; |
$hash{"$version:$rid:timestamp"}=$now; |
| $hash{"$version:keys:$rid"}=$allkeys; |
$allkeys.='timestamp'; |
| if (untie(%hash)) { |
$hash{"$version:keys:$rid"}=$allkeys; |
| print $client "ok\n"; |
if (untie(%hash)) { |
| } else { |
print $client "ok\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting store\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting store\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting store\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting store\n"; |
| } else { |
} |
| print $client "refused\n"; |
} else { |
| } |
print $client "refused\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # --------------------------------------------------------------------- restore |
# --------------------------------------------------------------------- restore |
| } elsif ($userinput =~ /^restore/) { |
} elsif ($userinput =~ /^restore/) { |
| my ($cmd,$udom,$uname,$namespace,$rid) |
if(isClient) { |
| =split(/:/,$userinput); |
my ($cmd,$udom,$uname,$namespace,$rid) |
| $namespace=~s/\//\_/g; |
=split(/:/,$userinput); |
| $namespace=~s/\W//g; |
$namespace=~s/\//\_/g; |
| chomp($rid); |
$namespace=~s/\W//g; |
| my $proname=propath($udom,$uname); |
chomp($rid); |
| my $qresult=''; |
my $proname=propath($udom,$uname); |
| my %hash; |
my $qresult=''; |
| if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_READER(),0640)) { |
my %hash; |
| my $version=$hash{"version:$rid"}; |
if (tie(%hash,'GDBM_File',"$proname/$namespace.db",&GDBM_READER(),0640)) { |
| $qresult.="version=$version&"; |
my $version=$hash{"version:$rid"}; |
| my $scope; |
$qresult.="version=$version&"; |
| for ($scope=1;$scope<=$version;$scope++) { |
my $scope; |
| my $vkeys=$hash{"$scope:keys:$rid"}; |
for ($scope=1;$scope<=$version;$scope++) { |
| my @keys=split(/:/,$vkeys); |
my $vkeys=$hash{"$scope:keys:$rid"}; |
| my $key; |
my @keys=split(/:/,$vkeys); |
| $qresult.="$scope:keys=$vkeys&"; |
my $key; |
| foreach $key (@keys) { |
$qresult.="$scope:keys=$vkeys&"; |
| $qresult.="$scope:$key=".$hash{"$scope:$rid:$key"}."&"; |
foreach $key (@keys) { |
| } |
$qresult.="$scope:$key=".$hash{"$scope:$rid:$key"}."&"; |
| } |
} |
| if (untie(%hash)) { |
} |
| $qresult=~s/\&$//; |
if (untie(%hash)) { |
| print $client "$qresult\n"; |
$qresult=~s/\&$//; |
| } else { |
print $client "$qresult\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting restore\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting restore\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting restore\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting restore\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # -------------------------------------------------------------------- chatsend |
# -------------------------------------------------------------------- chatsend |
| } elsif ($userinput =~ /^chatsend/) { |
} elsif ($userinput =~ /^chatsend/) { |
| my ($cmd,$cdom,$cnum,$newpost)=split(/\:/,$userinput); |
if(isClient) { |
| &chatadd($cdom,$cnum,$newpost); |
my ($cmd,$cdom,$cnum,$newpost)=split(/\:/,$userinput); |
| print $client "ok\n"; |
&chatadd($cdom,$cnum,$newpost); |
| |
print $client "ok\n"; |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # -------------------------------------------------------------------- chatretr |
# -------------------------------------------------------------------- chatretr |
| } elsif ($userinput =~ /^chatretr/) { |
} elsif ($userinput =~ /^chatretr/) { |
| my |
if(isClient) { |
| ($cmd,$cdom,$cnum,$udom,$uname)=split(/\:/,$userinput); |
my |
| my $reply=''; |
($cmd,$cdom,$cnum,$udom,$uname)=split(/\:/,$userinput); |
| foreach (&getchat($cdom,$cnum,$udom,$uname)) { |
my $reply=''; |
| $reply.=&escape($_).':'; |
foreach (&getchat($cdom,$cnum,$udom,$uname)) { |
| } |
$reply.=&escape($_).':'; |
| $reply=~s/\:$//; |
} |
| print $client $reply."\n"; |
$reply=~s/\:$//; |
| |
print $client $reply."\n"; |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------------- querysend |
# ------------------------------------------------------------------- querysend |
| } elsif ($userinput =~ /^querysend/) { |
} elsif ($userinput =~ /^querysend/) { |
| my ($cmd,$query, |
if(isClient) { |
| $arg1,$arg2,$arg3)=split(/\:/,$userinput); |
my ($cmd,$query, |
| $query=~s/\n*$//g; |
$arg1,$arg2,$arg3)=split(/\:/,$userinput); |
| print $client "". |
$query=~s/\n*$//g; |
| sqlreply("$hostid{$clientip}\&$query". |
print $client "". |
| "\&$arg1"."\&$arg2"."\&$arg3")."\n"; |
sqlreply("$clientname\&$query". |
| |
"\&$arg1"."\&$arg2"."\&$arg3")."\n"; |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------------ queryreply |
# ------------------------------------------------------------------ queryreply |
| } elsif ($userinput =~ /^queryreply/) { |
} elsif ($userinput =~ /^queryreply/) { |
| my ($cmd,$id,$reply)=split(/:/,$userinput); |
if(isClient) { |
| my $store; |
my ($cmd,$id,$reply)=split(/:/,$userinput); |
| my $execdir=$perlvar{'lonDaemons'}; |
my $store; |
| if ($store=IO::File->new(">$execdir/tmp/$id")) { |
my $execdir=$perlvar{'lonDaemons'}; |
| $reply=~s/\&/\n/g; |
if ($store=IO::File->new(">$execdir/tmp/$id")) { |
| print $store $reply; |
$reply=~s/\&/\n/g; |
| close $store; |
print $store $reply; |
| my $store2=IO::File->new(">$execdir/tmp/$id.end"); |
close $store; |
| print $store2 "done\n"; |
my $store2=IO::File->new(">$execdir/tmp/$id.end"); |
| close $store2; |
print $store2 "done\n"; |
| print $client "ok\n"; |
close $store2; |
| } |
print $client "ok\n"; |
| else { |
} |
| print $client "error: ".($!+0) |
else { |
| ." IO::File->new Failed ". |
print $client "error: ".($!+0) |
| "while attempting queryreply\n"; |
." IO::File->new Failed ". |
| } |
"while attempting queryreply\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ----------------------------------------------------------------- courseidput |
# ----------------------------------------------------------------- courseidput |
| } elsif ($userinput =~ /^courseidput/) { |
} elsif ($userinput =~ /^courseidput/) { |
| my ($cmd,$udom,$what)=split(/:/,$userinput); |
if(isClient) { |
| chomp($what); |
my ($cmd,$udom,$what)=split(/:/,$userinput); |
| $udom=~s/\W//g; |
chomp($what); |
| my $proname= |
$udom=~s/\W//g; |
| "$perlvar{'lonUsersDir'}/$udom/nohist_courseids"; |
my $proname= |
| my $now=time; |
"$perlvar{'lonUsersDir'}/$udom/nohist_courseids"; |
| my @pairs=split(/\&/,$what); |
my $now=time; |
| my %hash; |
my @pairs=split(/\&/,$what); |
| if (tie(%hash,'GDBM_File',"$proname.db",&GDBM_WRCREAT(),0640)) { |
my %hash; |
| foreach my $pair (@pairs) { |
if (tie(%hash,'GDBM_File',"$proname.db",&GDBM_WRCREAT(),0640)) { |
| my ($key,$value)=split(/=/,$pair); |
foreach my $pair (@pairs) { |
| $hash{$key}=$value.':'.$now; |
my ($key,$value)=split(/=/,$pair); |
| } |
$hash{$key}=$value.':'.$now; |
| if (untie(%hash)) { |
} |
| print $client "ok\n"; |
if (untie(%hash)) { |
| } else { |
print $client "ok\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting courseidput\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting courseidput\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting courseidput\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting courseidput\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ---------------------------------------------------------------- courseiddump |
# ---------------------------------------------------------------- courseiddump |
| } elsif ($userinput =~ /^courseiddump/) { |
} elsif ($userinput =~ /^courseiddump/) { |
| my ($cmd,$udom,$since,$description) |
if(isClient) { |
| =split(/:/,$userinput); |
my ($cmd,$udom,$since,$description) |
| if (defined($description)) { |
=split(/:/,$userinput); |
| $description=&unescape($description); |
if (defined($description)) { |
| } else { |
$description=&unescape($description); |
| $description='.'; |
} else { |
| } |
$description='.'; |
| unless (defined($since)) { $since=0; } |
} |
| my $qresult=''; |
unless (defined($since)) { $since=0; } |
| my $proname= |
my $qresult=''; |
| "$perlvar{'lonUsersDir'}/$udom/nohist_courseids"; |
my $proname= |
| my %hash; |
"$perlvar{'lonUsersDir'}/$udom/nohist_courseids"; |
| if (tie(%hash,'GDBM_File',"$proname.db",&GDBM_READER(),0640)) { |
my %hash; |
| while (my ($key,$value) = each(%hash)) { |
if (tie(%hash,'GDBM_File',"$proname.db",&GDBM_READER(),0640)) { |
| my ($descr,$lasttime)=split(/\:/,$value); |
while (my ($key,$value) = each(%hash)) { |
| if ($lasttime<$since) { next; } |
my ($descr,$lasttime)=split(/\:/,$value); |
| if ($description eq '.') { |
if ($lasttime<$since) { next; } |
| $qresult.=$key.'='.$descr.'&'; |
if ($description eq '.') { |
| } else { |
$qresult.=$key.'='.$descr.'&'; |
| my $unescapeVal = &unescape($descr); |
} else { |
| if (eval('$unescapeVal=~/$description/i')) { |
my $unescapeVal = &unescape($descr); |
| $qresult.="$key=$descr&"; |
if (eval('$unescapeVal=~/$description/i')) { |
| } |
$qresult.="$key=$descr&"; |
| } |
} |
| } |
} |
| if (untie(%hash)) { |
} |
| chop($qresult); |
if (untie(%hash)) { |
| print $client "$qresult\n"; |
chop($qresult); |
| } else { |
print $client "$qresult\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting courseiddump\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting courseiddump\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting courseiddump\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting courseiddump\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ----------------------------------------------------------------------- idput |
# ----------------------------------------------------------------------- idput |
| } elsif ($userinput =~ /^idput/) { |
} elsif ($userinput =~ /^idput/) { |
| my ($cmd,$udom,$what)=split(/:/,$userinput); |
if(isClient) { |
| chomp($what); |
my ($cmd,$udom,$what)=split(/:/,$userinput); |
| $udom=~s/\W//g; |
chomp($what); |
| my $proname="$perlvar{'lonUsersDir'}/$udom/ids"; |
$udom=~s/\W//g; |
| my $now=time; |
my $proname="$perlvar{'lonUsersDir'}/$udom/ids"; |
| { |
my $now=time; |
| my $hfh; |
{ |
| if ( |
my $hfh; |
| $hfh=IO::File->new(">>$proname.hist") |
if ( |
| ) { print $hfh "P:$now:$what\n"; } |
$hfh=IO::File->new(">>$proname.hist") |
| } |
) { print $hfh "P:$now:$what\n"; } |
| my @pairs=split(/\&/,$what); |
} |
| my %hash; |
my @pairs=split(/\&/,$what); |
| if (tie(%hash,'GDBM_File',"$proname.db",&GDBM_WRCREAT(),0640)) { |
my %hash; |
| foreach my $pair (@pairs) { |
if (tie(%hash,'GDBM_File',"$proname.db",&GDBM_WRCREAT(),0640)) { |
| my ($key,$value)=split(/=/,$pair); |
foreach my $pair (@pairs) { |
| $hash{$key}=$value; |
my ($key,$value)=split(/=/,$pair); |
| } |
$hash{$key}=$value; |
| if (untie(%hash)) { |
} |
| print $client "ok\n"; |
if (untie(%hash)) { |
| } else { |
print $client "ok\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting idput\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting idput\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting idput\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting idput\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ----------------------------------------------------------------------- idget |
# ----------------------------------------------------------------------- idget |
| } elsif ($userinput =~ /^idget/) { |
} elsif ($userinput =~ /^idget/) { |
| my ($cmd,$udom,$what)=split(/:/,$userinput); |
if(isClient) { |
| chomp($what); |
my ($cmd,$udom,$what)=split(/:/,$userinput); |
| $udom=~s/\W//g; |
chomp($what); |
| my $proname="$perlvar{'lonUsersDir'}/$udom/ids"; |
$udom=~s/\W//g; |
| my @queries=split(/\&/,$what); |
my $proname="$perlvar{'lonUsersDir'}/$udom/ids"; |
| my $qresult=''; |
my @queries=split(/\&/,$what); |
| my %hash; |
my $qresult=''; |
| if (tie(%hash,'GDBM_File',"$proname.db",&GDBM_READER(),0640)) { |
my %hash; |
| for (my $i=0;$i<=$#queries;$i++) { |
if (tie(%hash,'GDBM_File',"$proname.db",&GDBM_READER(),0640)) { |
| $qresult.="$hash{$queries[$i]}&"; |
for (my $i=0;$i<=$#queries;$i++) { |
| } |
$qresult.="$hash{$queries[$i]}&"; |
| if (untie(%hash)) { |
} |
| $qresult=~s/\&$//; |
if (untie(%hash)) { |
| print $client "$qresult\n"; |
$qresult=~s/\&$//; |
| } else { |
print $client "$qresult\n"; |
| print $client "error: ".($!+0) |
} else { |
| ." untie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting idget\n"; |
." untie(GDBM) Failed ". |
| } |
"while attempting idget\n"; |
| } else { |
} |
| print $client "error: ".($!+0) |
} else { |
| ." tie(GDBM) Failed ". |
print $client "error: ".($!+0) |
| "while attempting idget\n"; |
." tie(GDBM) Failed ". |
| } |
"while attempting idget\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ---------------------------------------------------------------------- tmpput |
# ---------------------------------------------------------------------- tmpput |
| } elsif ($userinput =~ /^tmpput/) { |
} elsif ($userinput =~ /^tmpput/) { |
| my ($cmd,$what)=split(/:/,$userinput); |
if(isClient) { |
| my $store; |
my ($cmd,$what)=split(/:/,$userinput); |
| $tmpsnum++; |
my $store; |
| my $id=$$.'_'.$clientip.'_'.$tmpsnum; |
$tmpsnum++; |
| $id=~s/\W/\_/g; |
my $id=$$.'_'.$clientip.'_'.$tmpsnum; |
| $what=~s/\n//g; |
$id=~s/\W/\_/g; |
| my $execdir=$perlvar{'lonDaemons'}; |
$what=~s/\n//g; |
| if ($store=IO::File->new(">$execdir/tmp/$id.tmp")) { |
my $execdir=$perlvar{'lonDaemons'}; |
| print $store $what; |
if ($store=IO::File->new(">$execdir/tmp/$id.tmp")) { |
| close $store; |
print $store $what; |
| print $client "$id\n"; |
close $store; |
| } |
print $client "$id\n"; |
| else { |
} |
| print $client "error: ".($!+0) |
else { |
| ."IO::File->new Failed ". |
print $client "error: ".($!+0) |
| "while attempting tmpput\n"; |
."IO::File->new Failed ". |
| } |
"while attempting tmpput\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| |
|
| # ---------------------------------------------------------------------- tmpget |
# ---------------------------------------------------------------------- tmpget |
| } elsif ($userinput =~ /^tmpget/) { |
} elsif ($userinput =~ /^tmpget/) { |
| my ($cmd,$id)=split(/:/,$userinput); |
if(isClient) { |
| chomp($id); |
my ($cmd,$id)=split(/:/,$userinput); |
| $id=~s/\W/\_/g; |
chomp($id); |
| my $store; |
$id=~s/\W/\_/g; |
| my $execdir=$perlvar{'lonDaemons'}; |
my $store; |
| if ($store=IO::File->new("$execdir/tmp/$id.tmp")) { |
my $execdir=$perlvar{'lonDaemons'}; |
| my $reply=<$store>; |
if ($store=IO::File->new("$execdir/tmp/$id.tmp")) { |
| print $client "$reply\n"; |
my $reply=<$store>; |
| close $store; |
print $client "$reply\n"; |
| } |
close $store; |
| else { |
} |
| print $client "error: ".($!+0) |
else { |
| ."IO::File->new Failed ". |
print $client "error: ".($!+0) |
| "while attempting tmpget\n"; |
."IO::File->new Failed ". |
| } |
"while attempting tmpget\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ---------------------------------------------------------------------- tmpdel |
# ---------------------------------------------------------------------- tmpdel |
| } elsif ($userinput =~ /^tmpdel/) { |
} elsif ($userinput =~ /^tmpdel/) { |
| my ($cmd,$id)=split(/:/,$userinput); |
if(isClient) { |
| chomp($id); |
my ($cmd,$id)=split(/:/,$userinput); |
| $id=~s/\W/\_/g; |
chomp($id); |
| my $execdir=$perlvar{'lonDaemons'}; |
$id=~s/\W/\_/g; |
| if (unlink("$execdir/tmp/$id.tmp")) { |
my $execdir=$perlvar{'lonDaemons'}; |
| print $client "ok\n"; |
if (unlink("$execdir/tmp/$id.tmp")) { |
| } else { |
print $client "ok\n"; |
| print $client "error: ".($!+0) |
} else { |
| ."Unlink tmp Failed ". |
print $client "error: ".($!+0) |
| "while attempting tmpdel\n"; |
."Unlink tmp Failed ". |
| } |
"while attempting tmpdel\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # -------------------------------------------------------------------------- ls |
# -------------------------------------------------------------------------- ls |
| } elsif ($userinput =~ /^ls/) { |
} elsif ($userinput =~ /^ls/) { |
| my ($cmd,$ulsdir)=split(/:/,$userinput); |
if(isClient) { |
| my $ulsout=''; |
my ($cmd,$ulsdir)=split(/:/,$userinput); |
| my $ulsfn; |
my $ulsout=''; |
| if (-e $ulsdir) { |
my $ulsfn; |
| if(-d $ulsdir) { |
if (-e $ulsdir) { |
| if (opendir(LSDIR,$ulsdir)) { |
if(-d $ulsdir) { |
| while ($ulsfn=readdir(LSDIR)) { |
if (opendir(LSDIR,$ulsdir)) { |
| my @ulsstats=stat($ulsdir.'/'.$ulsfn); |
while ($ulsfn=readdir(LSDIR)) { |
| $ulsout.=$ulsfn.'&'. |
my @ulsstats=stat($ulsdir.'/'.$ulsfn); |
| join('&',@ulsstats).':'; |
$ulsout.=$ulsfn.'&'. |
| } |
join('&',@ulsstats).':'; |
| closedir(LSDIR); |
} |
| } |
closedir(LSDIR); |
| } else { |
} |
| my @ulsstats=stat($ulsdir); |
} else { |
| $ulsout.=$ulsfn.'&'.join('&',@ulsstats).':'; |
my @ulsstats=stat($ulsdir); |
| } |
$ulsout.=$ulsfn.'&'.join('&',@ulsstats).':'; |
| } else { |
} |
| $ulsout='no_such_dir'; |
} else { |
| } |
$ulsout='no_such_dir'; |
| if ($ulsout eq '') { $ulsout='empty'; } |
} |
| print $client "$ulsout\n"; |
if ($ulsout eq '') { $ulsout='empty'; } |
| |
print $client "$ulsout\n"; |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ----------------------------------------------------------------- setannounce |
# ----------------------------------------------------------------- setannounce |
| } elsif ($userinput =~ /^setannounce/) { |
} elsif ($userinput =~ /^setannounce/) { |
| my ($cmd,$announcement)=split(/:/,$userinput); |
if (isClient) { |
| chomp($announcement); |
my ($cmd,$announcement)=split(/:/,$userinput); |
| $announcement=&unescape($announcement); |
chomp($announcement); |
| if (my $store=IO::File->new('>'.$perlvar{'lonDocRoot'}. |
$announcement=&unescape($announcement); |
| '/announcement.txt')) { |
if (my $store=IO::File->new('>'.$perlvar{'lonDocRoot'}. |
| print $store $announcement; |
'/announcement.txt')) { |
| close $store; |
print $store $announcement; |
| print $client "ok\n"; |
close $store; |
| } else { |
print $client "ok\n"; |
| print $client "error: ".($!+0)."\n"; |
} else { |
| } |
print $client "error: ".($!+0)."\n"; |
| |
} |
| |
} else { |
| |
Reply($client, "refused\n", $userinput); |
| |
|
| |
} |
| # ------------------------------------------------------------------ Hanging up |
# ------------------------------------------------------------------ Hanging up |
| } elsif (($userinput =~ /^exit/) || |
} elsif (($userinput =~ /^exit/) || |
| ($userinput =~ /^init/)) { |
($userinput =~ /^init/)) { # no restrictions. |
| &logthis( |
&logthis( |
| "Client $clientip ($hostid{$clientip}) hanging up: $userinput"); |
"Client $clientip ($clientname) hanging up: $userinput"); |
| print $client "bye\n"; |
print $client "bye\n"; |
| $client->close(); |
$client->shutdown(2); # shutdown the socket forcibly. |
| last; |
$client->close(); |
| |
last; |
| |
|
| |
# ---------------------------------- set current host/domain |
| |
} elsif ($userinput =~ /^sethost:/) { |
| |
if (isClient) { |
| |
print $client &sethost($userinput)."\n"; |
| |
} else { |
| |
print $client "refused\n"; |
| |
} |
| |
#---------------------------------- request file (?) version. |
| |
} elsif ($userinput =~/^version:/) { |
| |
if (isClient) { |
| |
print $client &version($userinput)."\n"; |
| |
} else { |
| |
print $client "refused\n"; |
| |
} |
| # ------------------------------------------------------------- unknown command |
# ------------------------------------------------------------- unknown command |
| } elsif ($userinput =~ /^sethost:/) { |
|
| print $client &sethost($userinput)."\n"; |
} else { |
| } elsif ($userinput =~/^version:/) { |
# unknown command |
| print $client &version($userinput)."\n"; |
print $client "unknown_cmd\n"; |
| } else { |
} |
| # unknown command |
|
| print $client "unknown_cmd\n"; |
|
| } |
|
| # -------------------------------------------------------------------- complete |
# -------------------------------------------------------------------- complete |
| alarm(0); |
alarm(0); |
| &status('Listening to '.$hostid{$clientip}); |
&status('Listening to '.$clientname); |
| } |
} |
| # --------------------------------------------- client unknown or fishy, refuse |
# --------------------------------------------- client unknown or fishy, refuse |
| } else { |
} else { |
| print $client "refused\n"; |
print $client "refused\n"; |
| $client->close(); |
$client->close(); |
| &logthis("<font color=blue>WARNING: " |
&logthis("<font color=blue>WARNING: " |
| ."Rejected client $clientip, closing connection</font>"); |
."Rejected client $clientip, closing connection</font>"); |
| } |
} |
| } |
} |
| |
|
| # ============================================================================= |
# ============================================================================= |
| |
|
| &logthis("<font color=red>CRITICAL: " |
&logthis("<font color=red>CRITICAL: " |
| ."Disconnect from $clientip ($hostid{$clientip})</font>"); |
."Disconnect from $clientip ($clientname)</font>"); |
| |
|
| |
|
| # this exit is VERY important, otherwise the child will become |
# this exit is VERY important, otherwise the child will become |
| # a producer of more and more children, forking yourself into |
# a producer of more and more children, forking yourself into |
| # process death. |
# process death. |
| exit; |
exit; |
| |
|
| } |
} |
| |
|
|
Line 2255 sub chatadd {
|
Line 2724 sub chatadd {
|
| sub unsub { |
sub unsub { |
| my ($fname,$clientip)=@_; |
my ($fname,$clientip)=@_; |
| my $result; |
my $result; |
| if (unlink("$fname.$hostid{$clientip}")) { |
if (unlink("$fname.$clientname")) { |
| $result="ok\n"; |
$result="ok\n"; |
| } else { |
} else { |
| $result="not_subscribed\n"; |
$result="not_subscribed\n"; |
| } |
} |
| if (-e "$fname.subscription") { |
if (-e "$fname.subscription") { |
| my $found=&addline($fname,$hostid{$clientip},$clientip,''); |
my $found=&addline($fname,$clientname,$clientip,''); |
| if ($found) { $result="ok\n"; } |
if ($found) { $result="ok\n"; } |
| } else { |
} else { |
| if ($result != "ok\n") { $result="not_subscribed\n"; } |
if ($result != "ok\n") { $result="not_subscribed\n"; } |
|
Line 2293 sub currentversion {
|
Line 2762 sub currentversion {
|
| # see if this is a regular file (ignore links produced earlier) |
# see if this is a regular file (ignore links produced earlier) |
| my $thisfile=$ulsdir.'/'.$ulsfn; |
my $thisfile=$ulsdir.'/'.$ulsfn; |
| unless (-l $thisfile) { |
unless (-l $thisfile) { |
| if ($thisfile=~/\Q$fnamere1\E(\d+)\Q$fnamere2\E/) { |
if ($thisfile=~/\Q$fnamere1\E(\d+)\Q$fnamere2\E$/) { |
| if ($1>$version) { $version=$1; } |
if ($1>$version) { $version=$1; } |
| } |
} |
| } |
} |
|
Line 2341 sub subscribe {
|
Line 2810 sub subscribe {
|
| if (-d $fname) { |
if (-d $fname) { |
| $result="directory\n"; |
$result="directory\n"; |
| } else { |
} else { |
| if (-e "$fname.$hostid{$clientip}") {&unsub($fname,$clientip);} |
if (-e "$fname.$clientname") {&unsub($fname,$clientip);} |
| my $now=time; |
my $now=time; |
| my $found=&addline($fname,$hostid{$clientip},$clientip, |
my $found=&addline($fname,$clientname,$clientip, |
| "$hostid{$clientip}:$clientip:$now\n"); |
"$clientname:$clientip:$now\n"); |
| if ($found) { $result="$fname\n"; } |
if ($found) { $result="$fname\n"; } |
| # if they were subscribed to only meta data, delete that |
# if they were subscribed to only meta data, delete that |
| # subscription, when you subscribe to a file you also get |
# subscription, when you subscribe to a file you also get |
|
Line 2446 sub userload {
|
Line 2915 sub userload {
|
| while ($filename=readdir(LONIDS)) { |
while ($filename=readdir(LONIDS)) { |
| if ($filename eq '.' || $filename eq '..') {next;} |
if ($filename eq '.' || $filename eq '..') {next;} |
| my ($mtime)=(stat($perlvar{'lonIDsDir'}.'/'.$filename))[9]; |
my ($mtime)=(stat($perlvar{'lonIDsDir'}.'/'.$filename))[9]; |
| if ($curtime-$mtime < 3600) { $numusers++; } |
if ($curtime-$mtime < 1800) { $numusers++; } |
| } |
} |
| closedir(LONIDS); |
closedir(LONIDS); |
| } |
} |
![[BACK]](/icons/back.gif){kind=icon}
Return to lond CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [LON-CAPA] / loncom