--- loncom/Attic/lonManage 2003/08/18 10:25:46 1.9
+++ loncom/Attic/lonManage 2003/10/21 09:44:04 1.16
@@ -3,9 +3,9 @@
#
# lonManage supports remote management of nodes in a LonCAPA cluster.
#
-# $Id: lonManage,v 1.9 2003/08/18 10:25:46 foxr Exp $
+# $Id: lonManage,v 1.16 2003/10/21 09:44:04 foxr Exp $
#
-# $Id: lonManage,v 1.9 2003/08/18 10:25:46 foxr Exp $
+# $Id: lonManage,v 1.16 2003/10/21 09:44:04 foxr Exp $
#
# Copyright Michigan State University Board of Trustees
#
@@ -33,23 +33,54 @@
# it is a command line tool. The following command line syntax (usage)
# is supported:
#
-# lonManage -push <tablename> newfile host
+# lonManage -push <tablename> newfile [host]
# Push <tablename> to the lonTabs directory. Note that
# <tablename> must be one of:
-# hosts (hosts.tab)
+# host (hosts.tab)
# domain (domain.tab)
#
-# lonManage -reinit lonc host
+# lonManage -reinit lonc [host]
# Sends a HUP signal to the remote systems's lond.
#
-# lonmanage -reinit lond host
+# lonmanage -reinit lond [host]
# Requests the remote system's lond perform the same action as if
# it had received a HUP signal.
#
# In the above syntax, the host above is the hosts.tab name of a host,
-# not the IP address of the host.
+# not the IP address of the host
+#
+# If [host] is not supplied, every host in the client's hosts.tab
+# table is iterated through and procesed..
#
# $Log: lonManage,v $
+# Revision 1.16 2003/10/21 09:44:04 foxr
+# Add ability to manage entire cluster in hosts table.
+#
+# Revision 1.15 2003/09/16 09:49:54 foxr
+# Adjust the usage message to reflect what actually will happen on
+# --reinit={lond|lonc}
+#
+# Revision 1.14 2003/09/08 09:45:20 foxr
+# Remove BUGBUG about comment about authentication as we'll be doing
+# host based authentication initially (no need for lonManage to do anything),
+# and certificate based later (need at that time).
+#
+# Revision 1.13 2003/08/19 10:26:24 foxr
+# Initial working version... tested against an unmodified lond this
+# produces an unknown_cmd response which is about what I'd expect.
+#
+# Revision 1.12 2003/08/18 11:08:07 foxr
+# Debug request building in Transact.
+#
+# Revision 1.11 2003/08/18 10:45:32 foxr
+# Felt strongly enough about hoisting ReadConfiguration into a separate sub
+# that I did it now before I forgot.
+#
+# Revision 1.10 2003/08/18 10:43:31 foxr
+# Code/test ValidHost. The hosts.tab and the perl variables are read in as
+# global hashes as a side effect. May later want to clean this up by making
+# a separate getconfig function and hoisting the config reads into that.
+#
# Revision 1.9 2003/08/18 10:25:46 foxr
# Write ReinitProcess function in terms of ValidHost and Transact.
#
@@ -80,33 +111,78 @@
# Add usage and skeleton documentation.
#
#
+
+
+
+# Modules required:
+
use strict; # Because it's good practice.
use English; # Cause I like meaningful names.
use Getopt::Long;
+use LONCAPA::Configuration; # To handle configuration I/O.
+use IO::Socket::UNIX; # To communicate with lonc.
+
+# File scoped variables:
+
+my %perlvar; # Perl variable defs from apache config.
+my %hostshash; # Host table as a host indexed hash.
+#
+# prints out utility's command usage info.
+#
sub Usage {
print "Usage:";
print <<USAGE;
- lonManage --push=<tablename> newfile host
+ lonManage --push=<tablename> newfile [host]
Push <tablename> to the lonTabs directory. Note that
<tablename> must be one of:
- hosts (hosts.tab)
+ host (hosts.tab)
domain (domain.tab)
- lonManage --reinit=lonc host
- Sends a HUP signal to the remote systems's lond.
-
- lonManage --reinit=lond host
- Requests the remote system's lond perform the same action as if
- it had received a HUP signal.
+ lonManage --reinit=lonc [host]
+ Causes lonc in the remote system to reread hosts.tab and
+ adjust the set of clients that are being maintained to match
+ the new file.
+
+
+ lonManage --reinit=lond [host]
+ Causes lond in the remote system to reread the hosts.tab file
+ and adjust the set of servers to match changes in that file.
In the above syntax, the host above is the hosts.tab name of a host,
not the IP address of the host.
+
+ If [host] is omitted, all hosts in the hosts.tab file are iterated
+ over.
+
USAGE
}
-
+#
+# Lifted from lonnet.pm - and we need to figure out a way to get it back in.
+# Performas a transaction with lond via the lonc proxy server.
+# Parameter:
+# cmd - The text of the request.
+# host - The host to which the request ultimately goes.
+# Returns:
+# The text of the reply from the lond or con_lost if not able to contact
+# lond/lonc etc.
+#
+sub subreply {
+ my ($cmd,$server)=@_;
+ my $peerfile="$perlvar{'lonSockDir'}/$server";
+ my $client=IO::Socket::UNIX->new(Peer =>"$peerfile",
+ Type => SOCK_STREAM,
+ Timeout => 10)
+ or return "con_lost";
+ print $client "$cmd\n";
+ my $answer=<$client>;
+ if (!$answer) { $answer="con_lost"; }
+ chomp($answer);
+ return $answer;
+}
+# >>> BUGBUG <<<
#
# Use Getopt::Long to parse the parameters of the program.
#
@@ -148,9 +224,9 @@ sub ParseArgs {
if($pushing ne '') {
- # --push takes in addition a table, and a host:
+ # --push takes in addition a table, and an optional host:
#
- if($paramcount != 2) {
+ if(($paramcount != 2) && ($paramcount != 1)) {
return (); # Invalid parameter count.
}
if($command ne '') {
@@ -164,9 +240,9 @@ sub ParseArgs {
if ($reinitting ne '') {
- # --reinit takes in addition just a host name
+ # --reinit takes in addition just an optional host name
- if($paramcount != 1) {
+ if($paramcount > 1) {
return ();
}
if($command ne '') {
@@ -187,10 +263,84 @@ sub ParseArgs {
return @result;
}
+#
+# Read the loncapa configuration stuff.
+#
+sub ReadConfig {
+ my $perlvarref = LONCAPA::Configuration::read_conf('loncapa.conf');
+ %perlvar = %{$perlvarref};
+ my $hoststab = LONCAPA::Configuration::read_hosts(
+ "$perlvar{'lonTabDir'}/hosts.tab");
+ %hostshash = %{$hoststab};
+
+}
+#
+# Determine if the target host is valid.
+# This is done by reading the current hosts.tab file.
+# For the host to be valid, it must be inthe file.
+#
+# Parameters:
+# host - Name of host to check on.
+# Returns:
+# true if host is valid.
+# false if host is invalid.
+#
sub ValidHost {
- return 1;
+ my $host = shift;
+
+
+ return defined $hostshash{$host};
+
}
+
+
+
+#
+# Performs a transaction with lonc.
+# By the time this is called, the transaction has already been
+# validated by the caller.
+#
+# Parameters:
+#
+# host - hosts.tab name of the host whose lonc we'll be talking to.
+# command - The base command we'll be asking lond to execute.
+# body - [optional] If supplied, this is a command body that is a ref.
+# to an array of lines that will be appended to the
+# command.
+#
+# NOTE:
+# The command will be done as an encrypted operation.
+#
sub Transact {
+ my $host = shift;
+ my $command = shift;
+ my $haveBody= 0;
+ my $body;
+ my $i;
+
+ if(scalar @ARG) {
+ $body = shift;
+ $haveBody = 1;
+ }
+ # Construct the command to send to the server:
+
+ my $request = "encrypt\:"; # All requests are encrypted.
+ $request .= $command;
+ if($haveBody) {
+ $request .= "\:";
+ my $bodylines = scalar @$body;
+ for($i = 0; $i < $bodylines; $i++) {
+ $request .= $$body[$i];
+ }
+ } else {
+ $request .= "\n";
+ }
+ # Body is now built... transact with lond..
+
+ my $answer = subreply($request, $host);
+
+ print "$answer\n";
+
}
#
# Called to push a file to the remote system.
@@ -208,6 +358,8 @@ sub Transact {
# tablefile - name of the file containing the table to push.
# host - name of the host to push this file to.
#
+# >>>BUGBUG<<< This belongs in lonnet.pm.
+#
sub PushFile {
my $tablename = shift;
my $tablefile = shift;
@@ -231,7 +383,8 @@ sub PushFile {
if( ($tablename eq "host") ||
($tablename eq "domain")) {
- Transact($host, "pushfile:$tablename:",\@table);
+ print("Pushing $tablename to $host\n");
+ Transact($host, "pushfile:$tablename",\@table);
} else {
die "EINVAL - Invalid parameter. tablename: $tablename must be host or domain";
}
@@ -249,6 +402,8 @@ sub PushFile {
# process - The name of the process to reinit (lonc or lond).
# host - The host in which this reinit will happen.
#
+# >>>BUGBUG<<<< This belongs in lonnet.pm
+#
sub ReinitProcess {
my $process = shift;
my $host = shift;
@@ -262,6 +417,7 @@ sub ReinitProcess {
if(($process eq "lonc") ||
($process eq "lond")) {
+ print("Reinitializing $process in $host\n");
Transact($host, "reinit:$process");
} else {
die "EINVAL -Invalid parameter. Process $process must be lonc or lond";
@@ -269,6 +425,9 @@ sub ReinitProcess {
}
#--------------------------- Entry point: --------------------------
+ReadConfig; # Read the configuration info (incl.hosts).
+
+
# Parse the parameters
# If command parsing failed, then print usage:
@@ -295,13 +454,25 @@ if($operation eq "push") { # push table
my $tablename = shift @params;
my $tablefile = shift @params;
my $host = shift @params;
- PushFile($tablename, $tablefile, $host);
+ if($host) {
+ PushFile($tablename, $tablefile, $host);
+ } else { # Push to whole cluster.
+ foreach my $host (keys %hostshash) {
+ PushFile($tablename, $tablefile, $host);
+ }
+ }
} elsif($operation eq "reinit") { # reinit processname host.
my $process = shift @params;
my $host = shift @params;
- ReinitProcess($process, $host);
-}
+ if ($host) {
+ ReinitProcess($process, $host);
+ } else { # Reinit whole cluster.
+ foreach my $host (keys %hostshash) {
+ ReinitProcess($process,$host);
+ }
+ }
+}
else {
Usage;
}
@@ -338,6 +509,9 @@ Usage:
=item strict
=item Getopt::Long
=item English
+=item IO::Socket::UNIX
+
+=head1 KEY Subroutines.
=head1 CATEGORIES
Command line utility