This is the first version of the JACE Server Logging service. It

is based heavily on the example written by Chris Cleeland, and it
should be compatible with the C++ ACE version.

The Client Logging service isn't necessary in Java since applications
have to use sockets to communicate with the services anyway (the C++
version let apps communicate with the middle-man Client Logging Service
via named pipes).

1 files changed, 157 insertions, 0 deletions

diff --git a/java/netsvcs/Logger/ServerLoggingAcceptor.java b/java/netsvcs/Logger/ServerLoggingAcceptor.java
new file mode 100644
index 00000000000..c68c089a0f7
--- /dev/null
+++ b/java/netsvcs/Logger/ServerLoggingAcceptor.java
@@ -0,0 +1,157 @@
+/*************************************************
+ *
+ * = PACKAGE
+ *    netsvcs.Logger
+ *
+ * = FILENAME
+ *    ServerLoggingAcceptor.java
+ *
+ *@author Chris Cleeland, Everett Anderson
+ *
+ *************************************************/
+package netsvcs.Logger;
+
+import JACE.SOCK_SAP.*;
+import JACE.Connection.*;
+import netsvcs.Logger.*;
+import JACE.OS.*;
+import java.io.*;
+import java.net.*;
+import JACE.Misc.*;
+
+/**
+ *
+ * <p><h2>DESCRIPTION</h2>
+ *
+ * <blockquote>
+ * Acceptor:  Listens on a specified port and launches ServerLoggingHandlers
+ * in response to requests.  A LogMessageReceiver can be specified on the
+ * command line to change the way the logging service processes messages.
+ *
+ * @see netsvcs.Logger.ServerLoggingHandler, netsvcs.Logger.LogMessageReceiver
+ */
+public class ServerLoggingAcceptor extends Acceptor implements Runnable
+{
+  // Main function so the service can be started without the service
+  // configurator.
+  public static void main (String [] args)
+    {
+      ServerLoggingAcceptor sla = new ServerLoggingAcceptor();
+
+      sla.init(args);
+    }
+
+  // Called by the service configurator, receives the command line and
+  // launches its own thread.
+  public int init (String [] args)
+    {
+      this.parseArgs(args);
+
+      // *** should contain choices like what the default is
+      // in an options singleton?
+      if (this.receiver_ == null)
+	this.receiver_ = new DefaultLMR();
+
+      new Thread (this).start();
+      return 0;
+    }
+
+  // Specify what LogMessageReceiver to use 
+  public void setLMR(LogMessageReceiver receiver)
+    {
+      this.receiver_ = receiver;
+    }
+
+  // Accessor for the LogMessageReceiver
+  public LogMessageReceiver getLMR ()
+    {
+      return this.receiver_;
+    }
+
+  // Create a new ServerLoggingHandler 
+  protected SvcHandler makeSvcHandler ()
+    throws InstantiationException, IllegalAccessException
+    {
+      // ** could contain this choice in a singleton, too
+      return new netsvcs.Logger.ServerLoggingHandler (this.receiver_);
+    }
+
+  // Run forever accepting new connections
+  public void run ()
+    {
+      try {
+
+	this.open (this.port_);
+	while (true) 
+	  this.accept();  // blocks
+
+      } catch (SocketException e)
+	{
+	  ACE.ERROR ("Socket Exception: " + e);
+	}
+      catch (InstantiationException e)
+	{
+	  ACE.ERROR (e);
+	}
+      catch (IllegalAccessException e)
+	{
+	  ACE.ERROR (e);
+	}
+      catch (IOException e)
+	{
+	  ACE.ERROR (e);
+	}
+
+      ACE.ERROR("ServerLoggingAcceptor has exited");
+    }
+
+  // Process the command line
+  protected void parseArgs (String args[])
+  {
+    String s;
+    GetOpt opt = new GetOpt (args, "p:r:");
+    for (int c; (c = opt.next ()) != -1; )
+      {
+	switch (c)
+	  {
+	  case 'p':
+	    s = opt.optarg ();
+	    this.port_ = (new Integer (s)).intValue ();
+	    break;
+	  case 'r':
+	    // Load the LMR with the given name
+	    s = new String(opt.optarg ());
+	    Class LMRfactory;
+	    try {
+	      LMRfactory = Class.forName(s);
+
+	      receiver_ = (LogMessageReceiver)LMRfactory.newInstance();
+
+	    } catch (ClassNotFoundException e) {
+	      ACE.ERROR("Unable to find LMR factory: " + e);
+	    } catch (InstantiationException e) {
+	      ACE.ERROR("Creating LMR: " + e);
+	    } catch (IllegalAccessException e) {
+	      ACE.ERROR("Creating LMR: " + e);
+	    }
+	    // Any of the above exceptions will result in just using the
+	    // default LMR
+	    break;
+	  default:
+	    ACE.ERROR ("Unknown argument: " + c);
+	    ACE.ERROR ("Valid args: -p <port> -r <LogMessageReceiver name>");
+	    break;
+	  }
+      }
+  }
+
+  // port should be in options singleton **
+  private int port_ = ACE.DEFAULT_SERVER_PORT;
+  private LogMessageReceiver receiver_ = null;
+};
+
+
+
+
+
+