Annotation of loncom/lonManage, revision 1.22

1.1       foxr        1: #!/usr/bin/perl
                      2: # The LearningOnline Network with CAPA
                      3: #
                      4: #  lonManage supports remote management of nodes in a LonCAPA cluster.
                      5: #
1.22    ! foxr        6: #  $Id: lonManage,v 1.21 2003/11/03 10:39:24 foxr Exp $
1.1       foxr        7: #
1.22    ! foxr        8: # $Id: lonManage,v 1.21 2003/11/03 10:39:24 foxr Exp $
1.1       foxr        9: #
                     10: # Copyright Michigan State University Board of Trustees
                     11: #
                     12: # This file is part of the LearningOnline Network with CAPA (LON-CAPA).
                     13: ## LON-CAPA is free software; you can redistribute it and/or modify
                     14: # it under the terms of the GNU General Public License as published by
                     15: # the Free Software Foundation; either version 2 of the License, or
                     16: # (at your option) any later version.
                     17: #
                     18: # LON-CAPA is distributed in the hope that it will be useful,
                     19: # but WITHOUT ANY WARRANTY; without even the implied warranty of
                     20: # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
                     21: # GNU General Public License for more details.
                     22: #
                     23: # You should have received a copy of the GNU General Public License
                     24: # along with LON-CAPA; if not, write to the Free Software
                     25: # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
                     26: #
                     27: # /home/httpd/html/adm/gpl.txt
                     28: #
                     29: # http://www.lon-capa.org/
                     30: #
                     31: #
                     32: #   lonManage supports management of remot nodes in a lonCAPA cluster.
                     33: #   it is a command line tool.  The following command line syntax (usage)
                     34: #   is supported:
                     35: #
1.16      foxr       36: #    lonManage  -push   <tablename>  newfile  [host]
1.1       foxr       37: #        Push <tablename> to the lonTabs directory.  Note that
                     38: #        <tablename> must be one of:
1.15      foxr       39: #           host  (hosts.tab)
1.1       foxr       40: #           domain (domain.tab)
                     41: #
1.16      foxr       42: #    lonManage  -reinit lonc [host]
1.1       foxr       43: #           Sends a HUP signal to the remote systems's lond.
                     44: #
1.16      foxr       45: #    lonmanage  -reinit lond [host]
1.1       foxr       46: #          Requests the remote system's lond perform the same action as if
                     47: #          it had received a HUP signal.
                     48: #
                     49: #    In the above syntax, the host above is the hosts.tab name of a host,
1.16      foxr       50: #    not the IP address of the host
                     51: #  
                     52: #   If [host] is not supplied, every host in the client's hosts.tab
                     53: #   table is iterated through and procesed..
1.1       foxr       54: #
1.3       foxr       55: #
1.10      foxr       56: 
1.14      foxr       57: 
1.13      foxr       58: 
1.10      foxr       59: # Modules required:
                     60: 
1.17      foxr       61: use lib ".";
                     62: 
1.7       foxr       63: use strict;			# Because it's good practice.
                     64: use English;			# Cause I like meaningful names.
1.3       foxr       65: use Getopt::Long;
1.13      foxr       66: use IO::Socket::UNIX;		# To communicate with lonc.
1.17      foxr       67: use LondConnection;
1.10      foxr       68: 
                     69: # File scoped variables:
                     70: 
                     71: my %perlvar;			# Perl variable defs from apache config.
                     72: my %hostshash;			# Host table as a host indexed hash.
1.2       foxr       73: 
1.19      foxr       74: my $MyHost="";			# Host name to use as me.
                     75: my $ForeignHostTab="";		# Name of foreign hosts table.
1.21      foxr       76: my $ServerPort;			# Port used to connect to lond.
1.18      foxr       77: 
1.13      foxr       78: #
                     79: #   prints out utility's command usage info.
                     80: #
1.3       foxr       81: sub Usage  {
1.2       foxr       82:     print "Usage:";
                     83:     print <<USAGE;
1.18      foxr       84:  lonManage  [--myname=host --hosts=table] --push=<tablename>  newfile  [host]
1.2       foxr       85:         Push <tablename> to the lonTabs directory.  Note that
                     86:         <tablename> must be one of:
1.15      foxr       87:            host  (hosts.tab)
1.2       foxr       88:            domain (domain.tab)
                     89: 
1.18      foxr       90:  lonManage [--myname=host --hosts=table] --reinit=lonc [host]
1.15      foxr       91:        Causes lonc in the remote system to reread hosts.tab and
                     92:        adjust the set of clients that are being maintained to match
                     93:        the new file.
                     94:        
1.2       foxr       95: 
1.18      foxr       96:  lonManage [--myname=host --hosts=table] --reinit=lond [host]
1.15      foxr       97:        Causes lond in the remote system to reread the hosts.tab file
                     98:        and adjust the set of servers to match changes in that file.
1.2       foxr       99: 
                    100:     In the above syntax, the host above is the hosts.tab name of a host,
                    101:     not the IP address of the host.
1.16      foxr      102: 
                    103:     If [host] is omitted, all hosts in the hosts.tab file are iterated
                    104:     over.
                    105: 
1.18      foxr      106:  For all of the above syntaxes if --myname=host and --hosts=table are
                    107:  supplied (both must be present), the utility runs in standalone mode
                    108:  presenting itself to the world as 'host' and using the hosts.tab file
                    109:  specified in the --hosts switch.
1.2       foxr      110: USAGE
                    111: 
                    112: 
                    113: }
1.21      foxr      114: 
                    115: sub MakeLondConnection {
                    116:     my $host = shift;
1.22    ! foxr      117: 
        !           118:     my $Connection = LondConnection->new($host, $ServerPort);
        !           119:     return return $Connection;
1.21      foxr      120: }
                    121: 
                    122: sub NegotiateStartup {
                    123:     my $connection = shift;
                    124: 
                    125:     return "ok";
                    126: }
                    127: sub PerformTransaction {
                    128:     my $connection  = shift;
                    129:     my $command     = shift;
                    130: 
                    131:     return "ok";
                    132: }
1.13      foxr      133: #
1.21      foxr      134: # Performs a transaction direct to a remote lond.
1.13      foxr      135: #   Parameter:
                    136: #      cmd  - The text of the request.
                    137: #      host - The host to which the request ultimately goes.
                    138: #   Returns:
                    139: #      The text of the reply from the lond or con_lost if not able to contact
                    140: #      lond/lonc etc.
                    141: #
                    142: sub subreply {
1.21      foxr      143:     my $cmd = shift;
                    144:     my $host = shift;
                    145: 
                    146: 
                    147:     my $connection  = MakeLondConnection($host);
                    148:     if ($connection eq undef) {
                    149: 	return "Connect Failed";
                    150:     }
                    151:     my $reply = NegotiateStartup($connection);
                    152:     if($reply != "ok") {
                    153: 	return "connection negotiation failed";
                    154:     }
                    155:     my $reply =  PerformTransaction($connection, $cmd);
                    156:     return $reply;
                    157: 
                    158: 
                    159:      #    my ($cmd,$server)=@_;
                    160:      #    my $peerfile="$perlvar{'lonSockDir'}/$server";
                    161:      #    my $client=IO::Socket::UNIX->new(Peer    =>"$peerfile",
                    162:      #                                     Type    => SOCK_STREAM,
                    163:      #                                     Timeout => 10)
                    164:      #       or return "con_lost";
                    165:      #    print $client "$cmd\n";
                    166:      #    my $answer=<$client>;
                    167:      #    if (!$answer) { $answer="con_lost"; }
                    168:      #    chomp($answer);
                    169:      #    return $answer;
1.13      foxr      170: }
                    171: #   >>> BUGBUG <<< 
1.2       foxr      172: #
1.3       foxr      173: #  Use Getopt::Long to parse the parameters of the program.
                    174: #
                    175: #  Return value is a list consisting of:
                    176: #    A 'command' which is one of:
                    177: #       push   - table push requested.
                    178: #       reinit - reinit requested.
                    179: #   Additional parameters as follows:
                    180: #       for push: Tablename, hostname
                    181: #       for reinit: Appname  hostname
                    182: #
                    183: #   This function does not validation of the parameters of push and
                    184: #   reinit.
1.4       foxr      185: #
                    186: #   returns a list.  The first element of the list is the operation name
                    187: #   (e.g. reinit or push).  The second element is the switch parameter.
                    188: #   for push, this is the table name, for reinit, this is the process name.
                    189: #   Additional elements of the list are the command argument.  The count of
                    190: #   command arguments is validated, but not their semantics.
                    191: #
1.3       foxr      192: #   returns an empty list if the parse fails.
                    193: #
                    194: 
1.18      foxr      195: 
1.3       foxr      196: sub ParseArgs {
1.4       foxr      197:     my $pushing   = '';
1.7       foxr      198:     my $reinitting = '';
1.5       foxr      199: 
1.4       foxr      200:     if(!GetOptions('push=s'    => \$pushing,
1.18      foxr      201: 	           'reinit=s'  => \$reinitting,
                    202: 		   'myname=s' => \$MyHost,
                    203: 		   'hosts=s' => \$ForeignHostTab)) {
                    204: 	return ();
                    205:     }
                    206:     #  The --myname and --hosts switch must have values and
                    207:     #  most both appear if either appears:
                    208: 
                    209:     if(($MyHost ne "") && ($ForeignHostTab eq "")) {
                    210: 	return ();
                    211:     }
                    212:     if(($ForeignHostTab ne "") && ($MyHost eq "")) {
1.4       foxr      213: 	return ();
                    214:     }
                    215: 
                    216:     #  Require exactly   one of --push and --reinit
                    217: 
1.5       foxr      218:     my $command    = '';
1.4       foxr      219:     my $commandarg = '';
1.5       foxr      220:     my $paramcount = @ARGV; 	# Number of additional arguments.
                    221:     
                    222: 
1.4       foxr      223:     if($pushing ne '') {
1.5       foxr      224: 
1.16      foxr      225:         # --push takes in addition a table, and an optional  host:
1.5       foxr      226:         #
1.16      foxr      227: 	if(($paramcount != 2) && ($paramcount != 1)) {
1.5       foxr      228: 	    return ();		# Invalid parameter count.
                    229: 	}
1.4       foxr      230: 	if($command ne '') {
                    231: 	    return ();
                    232: 	} else {
1.5       foxr      233: 	    
1.4       foxr      234: 	    $command    = 'push';
                    235: 	    $commandarg = $pushing;
                    236: 	}
                    237:     }
1.5       foxr      238: 
1.4       foxr      239:     if ($reinitting ne '') {
1.5       foxr      240: 
1.16      foxr      241: 	# --reinit takes in addition just an optional  host name
1.5       foxr      242: 
1.16      foxr      243: 	if($paramcount > 1) {
1.5       foxr      244: 	    return ();
                    245: 	}
1.4       foxr      246: 	if($command ne '') {
                    247: 	    return ();
                    248: 	} else {
                    249: 	    $command    = 'reinit';
                    250: 	    $commandarg = $reinitting; 
                    251: 	}
                    252:     }
                    253: 
1.5       foxr      254:     #  Build the result list:
                    255: 
                    256:     my @result = ($command, $commandarg);
                    257:     my $i;
                    258:     for($i = 0; $i < $paramcount; $i++) {
                    259: 	push(@result, $ARGV[$i]);
                    260:     }
                    261:     
                    262:     return @result;
1.3       foxr      263: }
1.10      foxr      264: #
1.19      foxr      265: #  Read the loncapa configuration stuff.  If ForeignHostTab is empty,
                    266: #  assume we are part of a loncapa cluster and read the hosts.tab
                    267: #  file from the config directory.  Otherwise, ForeignHossTab
                    268: #  is the name of an alternate configuration file to read in 
                    269: #  standalone mode.
1.11      foxr      270: #
                    271: sub ReadConfig {
1.19      foxr      272: 
                    273:     if($ForeignHostTab eq "") {
                    274: 	my $perlvarref = LondConnection::read_conf('loncapa.conf');
                    275: 	%perlvar       = %{$perlvarref};
                    276: 	my $hoststab   = LondConnection::read_hosts(
                    277: 					    "$perlvar{'lonTabDir'}/hosts.tab");
                    278: 	%hostshash     = %{$hoststab};
1.20      foxr      279: 	$MyHost        = $perlvar{lonHostID}; # Set hostname from vars.
1.21      foxr      280: 	$ServerPort    = $perlvar{londPort};
1.19      foxr      281:     } else {
                    282: 	my $hoststab   = LondConnection::read_hosts($ForeignHostTab);
                    283: 	%hostshash     = %{$hoststab};
1.21      foxr      284: 	$ServerPort    = 5663;
1.19      foxr      285:     }
1.11      foxr      286: 
                    287: }
                    288: #
1.10      foxr      289: #  Determine if the target host is valid.
                    290: #  This is done by reading the current hosts.tab file.
                    291: #  For the host to be valid, it must be inthe file.
                    292: #
                    293: #  Parameters:
                    294: #     host   - Name of host to check on.
                    295: #  Returns:
                    296: #     true   if host is valid.
                    297: #     false  if host is invalid.
                    298: #
1.8       foxr      299: sub ValidHost {
1.10      foxr      300:     my $host       = shift;
1.11      foxr      301:    
1.10      foxr      302: 
                    303:     return defined $hostshash{$host};
                    304: 
1.8       foxr      305: }
1.13      foxr      306: 
                    307: 
                    308: 
1.12      foxr      309: #
                    310: #  Performs a transaction with lonc.
                    311: #  By the time this is called, the transaction has already been
                    312: #  validated by the caller.
                    313: #
                    314: #   Parameters:
                    315: #
                    316: #   host    - hosts.tab name of the host whose lonc we'll be talking to.
                    317: #   command - The base command we'll be asking lond to execute.
                    318: #   body    - [optional] If supplied, this is a command body that is a ref.
                    319: #             to an array of lines that will be appended to the 
                    320: #             command.
                    321: #
                    322: #  NOTE:
                    323: #    The command will be done as an encrypted operation.
                    324: #
1.8       foxr      325: sub Transact {
1.12      foxr      326:     my $host    = shift;
                    327:     my $command = shift;
                    328:     my $haveBody= 0;
                    329:     my $body;
                    330:     my $i;
                    331: 
                    332:     if(scalar @ARG) {
                    333: 	$body = shift;
                    334: 	$haveBody = 1;
                    335:     }
                    336:     #  Construct the command to send to the server:
                    337:     
                    338:     my $request = "encrypt\:";	# All requests are encrypted.
                    339:     $request   .= $command;
                    340:     if($haveBody) {
                    341: 	$request .= "\:";
                    342: 	my $bodylines = scalar @$body;
                    343: 	for($i = 0; $i < $bodylines; $i++) {
                    344: 	    $request .= $$body[$i];
                    345: 	}
                    346:     } else {
                    347: 	$request .= "\n";
                    348:     }
1.13      foxr      349:     # Body is now built... transact with lond..
                    350:     
                    351:     my $answer = subreply($request, $host);
                    352: 
                    353:     print "$answer\n";
1.10      foxr      354: 
1.8       foxr      355: }
1.7       foxr      356: #
                    357: #   Called to push a file to the remote system.
                    358: #   The only legal files to push are hosts.tab and domain.tab.
                    359: #   Security is somewhat improved by
                    360: #   
                    361: #   - Requiring the user run as root.
                    362: #   - Connecting with lonc rather than lond directly ensuring this is a loncapa
                    363: #     host
                    364: #   - We must appear in the remote host's hosts.tab file.
                    365: #   - The host must appear in our hosts.tab file.
                    366: #
                    367: #  Parameters:
                    368: #     tablename - must be one of hosts or domain.
                    369: #     tablefile - name of the file containing the table to push.
                    370: #     host      - name of the host to push this file to.     
                    371: #
1.13      foxr      372: #    >>>BUGBUG<<< This belongs in lonnet.pm.
                    373: #
1.7       foxr      374: sub PushFile {
                    375:     my $tablename = shift;
                    376:     my $tablefile = shift;
                    377:     my $host      = shift;
                    378:     
1.8       foxr      379:     # Open the table file:
                    380: 
                    381:     if(!open(TABLEFILE, "<$tablefile")) {
                    382: 	die "ENOENT - No such file or directory $tablefile";
                    383:     }
                    384:   
                    385:     # Require that the host be valid:
                    386: 
                    387:     if(!ValidHost($host)) {
                    388: 	die "EHOSTINVAL - Invalid host $host"; # Ok so I invented this 'errno'.
                    389:     }
                    390:     # Read in the file.  If the table name is valid, push it.
                    391: 
                    392:     my @table = <TABLEFILE>;	#  These files are pretty small.
                    393:     close TABLEFILE;
                    394: 
                    395:     if( ($tablename eq "host")    ||
                    396: 	($tablename eq "domain")) {
1.16      foxr      397: 	print("Pushing $tablename to $host\n");
1.12      foxr      398: 	Transact($host, "pushfile:$tablename",\@table);
1.8       foxr      399:     } else {
                    400: 	die "EINVAL - Invalid parameter. tablename: $tablename must be host or domain";
                    401:     }
1.7       foxr      402: }
1.9       foxr      403: #
                    404: #   This function is called to reinitialize a server in a remote host.
                    405: #   The servers that can be reinitialized are:
                    406: #   - lonc   - The lonc client process.
                    407: #   - lond   - The lond daemon.
                    408: #  NOTE:
                    409: #    Reinitialization in this case means re-scanning the hosts table,
                    410: #    starting new lond/lonc's as approprate and stopping existing lonc/lond's.
                    411: #
                    412: #  Parameters:
                    413: #     process - The name of the process to reinit (lonc or lond).
                    414: #     host    - The host in which this reinit will happen.
                    415: #
1.13      foxr      416: #   >>>BUGBUG<<<< This belongs  in lonnet.pm
                    417: #
1.9       foxr      418: sub ReinitProcess {
                    419:     my $process = shift;
                    420:     my $host    = shift;
1.3       foxr      421: 
1.9       foxr      422:     #  Ensure the host is valid:
                    423:     
                    424:     if(!ValidHost($host)) {
                    425: 	die "EHOSTINVAL - Invalid host $host";
                    426:     }
                    427:     # Ensure target process selector is valid:
                    428: 
                    429:     if(($process eq "lonc") ||
                    430:        ($process eq "lond")) {
1.16      foxr      431: 	print("Reinitializing $process in $host\n");
1.9       foxr      432: 	Transact($host, "reinit:$process");
                    433:     } else {
                    434: 	die "EINVAL -Invalid parameter. Process $process must be lonc or lond";
                    435:     }
1.7       foxr      436: }
1.6       foxr      437: #--------------------------- Entry point: --------------------------
                    438: 
1.16      foxr      439: 
                    440: 
1.6       foxr      441: #  Parse the parameters
                    442: #  If command parsing failed, then print usage:
1.2       foxr      443: 
1.7       foxr      444: my @params   = ParseArgs;
                    445: my $nparam   = @params;
1.3       foxr      446: 
                    447: if($nparam == 0) {
1.2       foxr      448:     Usage;
1.4       foxr      449:     exit -1;
1.2       foxr      450: }
1.7       foxr      451: #
                    452: #   Next, ensure we are running as EID root.
                    453: #
                    454: if ($EUID != 0) {
                    455:     die "ENOPRIV - No privilege for requested operation"
1.6       foxr      456: }
                    457: 
1.19      foxr      458: #
                    459: #   Read the configuration file.
                    460: #   
                    461: 
                    462: ReadConfig;			# Read the configuration info (incl.hosts).
1.4       foxr      463: 
1.6       foxr      464: #   Based on the operation requested invoke the appropriate function:
                    465: 
1.7       foxr      466: my $operation = shift @params;
1.6       foxr      467: 
                    468: if($operation eq "push") {  # push tablename filename host
1.7       foxr      469:     my $tablename = shift @params;
                    470:     my $tablefile = shift @params;
                    471:     my $host      = shift @params;
1.16      foxr      472:     if($host) {
                    473: 	PushFile($tablename, $tablefile, $host);
                    474:     } else {			# Push to whole cluster.
                    475: 	foreach my $host (keys %hostshash) {
                    476: 	    PushFile($tablename, $tablefile, $host);
                    477: 	}
                    478:     }
1.6       foxr      479: 
1.7       foxr      480: } elsif($operation eq "reinit") {	# reinit processname host.
                    481:     my $process   = shift @params;
                    482:     my $host      = shift @params;
1.16      foxr      483:     if ($host) {
                    484: 	ReinitProcess($process, $host);
                    485:     } else {			# Reinit whole cluster.
                    486: 	foreach my $host (keys %hostshash) {
                    487: 	    ReinitProcess($process,$host);
                    488: 	}
                    489:     }
                    490: } 
1.7       foxr      491: else {
                    492:     Usage;
1.6       foxr      493: }
1.4       foxr      494: exit 0;
1.2       foxr      495: 
                    496: =head1 NAME
                    497:     lonManage - Command line utility for remote management of lonCAPA
                    498:     cluster nodes.
                    499: 
                    500: =head1 SYNOPSIS
                    501: 
                    502: Usage:
1.3       foxr      503:     B<lonManage  --push=<tablename>  newfile  host>
1.2       foxr      504:         Push <tablename> to the lonTabs directory.  Note that
                    505:         <tablename> must be one of:
                    506:            hosts  (hosts.tab)
                    507:            domain (domain.tab)
                    508: 
1.3       foxr      509:     B<lonManage  --reinit=lonc host>
1.2       foxr      510:            Sends a HUP signal to the remote systems's lond.
                    511: 
1.3       foxr      512:     B<lonmanage  --reinit=lond host>
1.2       foxr      513:           Requests the remote system's lond perform the same action as if
                    514:           it had received a HUP signal.
                    515: 
                    516:     In the above syntax, the host above is the hosts.tab name of a host,
                    517:     not the IP address of the host.
                    518: 
                    519: 
                    520: =head1 DESCRIPTION
                    521: 
                    522: =head1 PREREQUISITES
1.3       foxr      523: 
1.7       foxr      524: =item strict
1.3       foxr      525: =item Getopt::Long
1.7       foxr      526: =item English
1.13      foxr      527: =item IO::Socket::UNIX
                    528: 
                    529: =head1 KEY Subroutines.
1.2       foxr      530: 
                    531: =head1  CATEGORIES
                    532:     Command line utility
                    533: 
                    534: =cut

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>