Changeset 18969 for greenstone3/trunk/src/java/org/greenstone/server/Server2.java

Timestamp:

2009-04-15T14:53:44+12:00 (15 years ago)

Author:

ak19

Message:

Updated several files so that the Server2 code in server.jar interacts with GLI code so that the local GS2 server for Linux works the same way as the GS2 Local Library Server on windows

File:

• greenstone3/trunk/src/java/org/greenstone/server/Server2.java (modified) (8 diffs)

greenstone3/trunk/src/java/org/greenstone/server/Server2.java

@@ -2 +2 @@
 package org.greenstone.server;
 
+import java.io.BufferedReader;
 import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileOutputStream;
+import java.io.InputStreamReader;
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.net.URL;
+//import java.net.URLConnection;
 import java.util.Properties;
 import java.util.ArrayList;
@@ -17 +24 @@
     protected String libraryURL;
 
-    public Server2(String gsdl2_home, String lang, String configfile)
+    private class QuitListener extends Thread 
+    {
+    int quitPort = -1;
+    ServerSocket serverSocket = null;
+
+    public QuitListener(int quitport) throws Exception {
+        ///Server2.this.recordSuccess("In QuitListener constructor");
+        this.quitPort = quitport;
+        serverSocket = new ServerSocket(quitPort);
+    }
+
+    public void run() {
+        // Server2.this.recordSuccess("In QuitListener.run()");
+
+        Socket connection = null;
+
+        try {
+        // wait for a connection
+        connection = serverSocket.accept();
+
+        ///Server2.this.recordSuccess("In QuitListener - accepted connection");
+
+        // read input
+        try {
+            BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
+            String line = null;
+            if((line = reader.readLine()) != null) {
+            // Server2.this.recordSuccess("In QuitListener - Got a line");
+            if(line.equals("QUIT")) {
+                // Server2.this.recordSuccess("In QuitListener - line is QUIT");
+                reader.close();
+                reader = null;
+                serverSocket.close();
+                serverSocket = null;
+            }
+            }
+        } catch(Exception e) {
+            Server2.this.recordError("Exception in QuitListener thread.");
+        } finally {
+            Server2.this.stop();
+            System.exit(0);
+        }
+        } catch(IOException ioe) {
+        Server2.this.recordError("Server2.QuitListener: Unable to make the connection with the client socket." + ioe);
+        }
+    }
+    }
+
+
+    public Server2(String gsdl2_home, String lang, String configfile, int quitPort)
     {
     super(gsdl2_home, lang, configfile, "etc"+File.separator+"logs-gsi");   
                    // configfile can be either glisite.cfg or llssite.cfg
 
-
     Property = new Server2Property();
-
+    
     String frame_title = dictionary.get("ServerControl.Frame_Title");
     server_control_ = new Server2Control(this,frame_title);
 
-    /** Make command tagets for managing Web server */
+    /* Make command tagets for managing Web server */
     START_CMD     = "web-start";
     RESTART_CMD   = "web-restart";
@@ -34 +89 @@
     STOP_CMD      = "web-stop";
 
+    // now we can monitor for the quit command if applicable
+    // First check if given port is within the range of allowed ports
+    if(!PortFinder.isAssignablePortNumber(quitPort)) {
+        recordError("QuitPort provided is not within acceptable range: ("
+                   + PortFinder.PORTS_RESERVED + " - " + PortFinder.MAX_PORT + "]" );
+        quitPort = -1;
+    }
+    
+    if(quitPort != -1) {
+        try {
+        new QuitListener(quitPort).start();
+        } catch(Exception e) {
+        Server2.this.recordError("Exception constructing the QuitListener thread.");
+        }
+    }
+    
     autoStart();
     }
@@ -98 +169 @@
     // default values, to be replaced with what's in gsdlsite.cfg
     String host = "localhost";
-    String port = "8080";
+    String port = "80";
     String gwcgi;
     String httpprefix = "greenstone";
@@ -123 +194 @@
         recordError("Could not open gsdlsite_cfg for reading, using default library prefix.");
         }
-        reloadConfigProperties();
+        //reloadConfigProperties();
         port = config_properties.getProperty("portnumber", port);
-
     } catch(Exception e) {
         recordError("Exception trying to load properties from gsdlsite_cfg. Using default library prefix.", e);
         suffix = httpprefix + suffix;
     }
-
+    
     libraryURL = "http://" + host + ":" + port + suffix;
-    
-    // the URL has been changed
-    // write the URL to the file since this should work like GS2's Local Lib Server for Windows
-    ScriptReadWrite scriptReadWrite = new ScriptReadWrite();
-    ArrayList fileLines = scriptReadWrite.readInFile(BaseServer.config_properties_file);
-    scriptReadWrite.replaceOrAddLine(fileLines, "url", libraryURL, true);
-    scriptReadWrite.writeOutFile(config_properties_file, fileLines);
-    }
+    }
+
+    public void reloadConfigProperties() {
+    super.reloadConfigProperties();
+
+    // make sure the port is okay, otherwise find another port
+    // first choice is port 80, second choice starts at 8282
+    String port = config_properties.getProperty("portnumber", "80");
+    int portDefault = 8282;
+    try {
+        int portNum = Integer.parseInt(port);
+        
+        if(!PortFinder.isPortAvailable(portNum)) {
+        
+        PortFinder portFinder = new PortFinder(portDefault, 101);
+        portNum = portFinder.findPortInRange();
+        port = (portNum == -1) ? Integer.toString(portDefault) : Integer.toString(portNum);
+        config_properties.setProperty("portnumber", port); // store the correct port
+
+        // write this updated port to the config file, since the configure target uses the file to run
+        ScriptReadWrite scriptReadWrite = new ScriptReadWrite();
+        ArrayList fileLines = scriptReadWrite.readInFile(BaseServer.config_properties_file);
+        scriptReadWrite.replaceOrAddLine(fileLines, "portnumber", port, false); // write the correct port
+        scriptReadWrite.writeOutFile(config_properties_file, fileLines);
+
+        configure_required_ = true;
+        }    
+    } catch (Exception e) {
+        recordError("Exception in Server2.reload(): " + e.getMessage());
+        port = Integer.toString(portDefault);
+    }
+    
+    }
+
     
     // About to stop the webserver
@@ -153 +249 @@
     }
 
+    // Called when the URL has been changed (called after a reload() and starting the server).
+    // By the time we get here, reload() would already have been called and have set
+    // both the port and worked out libraryURL
+    // This method needs to write the URL to the configfile since things should work
+    // like GS2's Local Lib Server for Windows
+    protected void postStart() {
+
+    URL libURL = null;
+    try {
+        libURL = new URL(libraryURL);
+    } catch (Exception e) {
+        recordError("Unable to convert library URL string into a valid URL, Server2.java." + e);
+    }
+    
+    // 1. Test that the server is running at the libraryURL before writing it out to glisite.cfg/configfile 
+    // A quick test involves opening a connection to get the home page for this collection
+    if(libURL != null) {
+
+        boolean ready = false; 
+        for(int i = 0; i < 60 && !ready; i++) {
+        try {
+            libURL.openConnection();
+            //URLConnection connection = new URL(libraryURL).openConnection();
+            //connection.getContent();
+            ready = true;
+            recordSuccess("Try connecting to server on url: '" + libraryURL + "'");
+        } catch (IOException bad_url_connection) {
+            // keep looping
+            recordSuccess("NOT YET CONNECTED. Waiting to try again...");
+            try {
+            Thread.sleep(1000);
+            } catch (InterruptedException ie) {
+            ready = true;
+            recordError("Unexpected: got an InterruptedException in sleeping thread, Server2.java." + ie);
+            }
+        } catch (Exception e) {
+            ready = true;
+            recordError("Got an Exception while waiting for the connection to become live, Server2.java." + e);
+        }
+        }
+    }
+
+    // 2. Now write the URL to the config file
+    String port = config_properties.getProperty("portnumber");
+
+    ScriptReadWrite scriptReadWrite = new ScriptReadWrite();
+    ArrayList fileLines = scriptReadWrite.readInFile(BaseServer.config_properties_file);
+    scriptReadWrite.replaceOrAddLine(fileLines, "url", libraryURL, true);
+    scriptReadWrite.replaceOrAddLine(fileLines, "portnumber", port, false); // write the correct port
+    scriptReadWrite.writeOutFile(config_properties_file, fileLines);
+    }
+
+
     public static void main (String[] args)
     {
-        if ((args.length < 1) || (args.length > 3)) {
-        System.err.println("Usage: java org.greenstone.server.Server2 <gsdl2-home-dir> [lang] [--config=configfile]");
+        if ((args.length < 1) || (args.length > 4)) {
+        System.err.println(
+           "Usage: java org.greenstone.server.Server2 <gsdl2-home-dir> [lang] [--config=configfile] [--quitport=portNum]");
         System.exit(1);
     }
@@ -170 +320 @@
     
     // if no config file is given, then the following defaults to llssite.cfg
-    String configfile = (args.length==3 && args[2].startsWith("--config=")) ? args[2] : gsdl2_home+File.separator+"llssite.cfg";
+    String configfile = (args.length>=3 && args[2].startsWith("--config=")) ? args[2] : gsdl2_home+File.separator+"llssite.cfg";
     int equalSign = configfile.indexOf('=');
     if(equalSign != -1) {
@@ -176 +326 @@
     }
 
-    new Server2(gsdl2_home,lang,configfile);
+    String quitport = (args.length == 4 && args[3].startsWith("--quitport=")) ? args[3] : "";
+    equalSign = quitport.indexOf('=');
+    int port = -1;
+    if(equalSign != -1) {
+        try {
+        quitport = quitport.substring(equalSign+1);
+        port = Integer.parseInt(quitport);
+        } catch(Exception e) { // parse fails
+        System.err.println("Port must be numeric. Continuing without it.");
+        }
+    }
+
+    //System.err.println("Running server with config file: " + configfile);
+    
+    new Server2(gsdl2_home, lang, configfile, port);
     }
 }