summaryrefslogtreecommitdiff
path: root/java/src
diff options
context:
space:
mode:
Diffstat (limited to 'java/src')
-rw-r--r--java/src/IceBox/Admin.java107
-rw-r--r--java/src/IceBox/Server.java51
-rw-r--r--java/src/IceBox/ServiceManagerI.java334
3 files changed, 492 insertions, 0 deletions
diff --git a/java/src/IceBox/Admin.java b/java/src/IceBox/Admin.java
new file mode 100644
index 00000000000..4baf40b750b
--- /dev/null
+++ b/java/src/IceBox/Admin.java
@@ -0,0 +1,107 @@
+// **********************************************************************
+//
+// Copyright (c) 2001
+// MutableRealms, Inc.
+// Huntsville, AL, USA
+//
+// All Rights Reserved
+//
+// **********************************************************************
+
+package IceBox;
+
+public final class Admin
+{
+ private static class Client extends Ice.Application
+ {
+ private void
+ usage()
+ {
+ System.err.println(
+ "Usage: " + appName() + " [options] [command...]\n" +
+ "Options:\n" +
+ "-h, --help Show this message.\n" +
+ "\n" +
+ "Commands:\n" +
+ "shutdown Shutdown the server.");
+ }
+
+ public int
+ run(String[] args)
+ {
+ java.util.ArrayList commands = new java.util.ArrayList();
+
+ int idx = 0;
+ while (idx < args.length)
+ {
+ if (args[idx].equals("-h") || args[idx].equals("--help"))
+ {
+ usage();
+ return 1;
+ }
+ else if (args[idx].charAt(0) == '-')
+ {
+ System.err.println(appName() + ": unknown option `" + args[idx] + "'");
+ usage();
+ return 1;
+ }
+ else
+ {
+ commands.add(args[idx]);
+ ++idx;
+ }
+ }
+
+ if (commands.isEmpty())
+ {
+ usage();
+ return 0;
+ }
+
+ Ice.Properties properties = communicator().getProperties();
+ final String managerEndpointsProperty = "IceBox.ServiceManager.Endpoints";
+ String managerEndpoints = properties.getProperty(managerEndpointsProperty);
+ if (managerEndpoints.length() == 0)
+ {
+ System.err.println(appName() + ": property `" + managerEndpointsProperty + "' is not set");
+ return 1;
+ }
+
+ Ice.ObjectPrx base = communicator().stringToProxy("ServiceManager:" + managerEndpoints);
+ IceBox.ServiceManagerPrx manager = IceBox.ServiceManagerPrxHelper.checkedCast(base);
+ if (manager == null)
+ {
+ System.err.println(appName() + ": `" + managerEndpoints + "' is not running");
+ return 1;
+ }
+
+ for (int i = 0; i < commands.size(); i++)
+ {
+ String command = (String)commands.get(i);
+ if (command.equals("shutdown"))
+ {
+ manager.shutdown();
+ }
+ else
+ {
+ System.err.println(appName() + ": unknown command `" + command + "'");
+ usage();
+ return 1;
+ }
+ }
+
+ return 0;
+ }
+ }
+
+ public static void
+ main(String[] args)
+ {
+ Ice.Util.addArgumentPrefix("IceBox");
+
+ Client app = new Client();
+ int rc = app.main("IceBox.Admin", args);
+
+ System.exit(rc);
+ }
+}
diff --git a/java/src/IceBox/Server.java b/java/src/IceBox/Server.java
new file mode 100644
index 00000000000..1958efdbf0e
--- /dev/null
+++ b/java/src/IceBox/Server.java
@@ -0,0 +1,51 @@
+// **********************************************************************
+//
+// Copyright (c) 2002
+// MutableRealms, Inc.
+// Huntsville, AL, USA
+//
+// All Rights Reserved
+//
+// **********************************************************************
+
+package IceBox;
+
+public final class Server
+{
+ public static void
+ main(String[] args)
+ {
+ Ice.Communicator communicator = null;
+ int status = 0;
+
+ Ice.Util.addArgumentPrefix("IceBox");
+
+ try
+ {
+ Ice.StringSeqHolder argsH = new Ice.StringSeqHolder(args);
+ communicator = Ice.Util.initialize(argsH);
+ ServiceManagerI serviceManagerImpl = new ServiceManagerI(communicator, argsH.value);
+ status = serviceManagerImpl.run();
+ }
+ catch (Ice.LocalException ex)
+ {
+ ex.printStackTrace();
+ status = 1;
+ }
+
+ if (communicator != null)
+ {
+ try
+ {
+ communicator.destroy();
+ }
+ catch (Ice.LocalException ex)
+ {
+ ex.printStackTrace();
+ status = 1;
+ }
+ }
+
+ System.exit(status);
+ }
+}
diff --git a/java/src/IceBox/ServiceManagerI.java b/java/src/IceBox/ServiceManagerI.java
new file mode 100644
index 00000000000..60e2829a77e
--- /dev/null
+++ b/java/src/IceBox/ServiceManagerI.java
@@ -0,0 +1,334 @@
+// **********************************************************************
+//
+// Copyright (c) 2002
+// MutableRealms, Inc.
+// Huntsville, AL, USA
+//
+// All Rights Reserved
+//
+// **********************************************************************
+
+package IceBox;
+
+public final class ServiceManagerI extends _ServiceManagerDisp
+{
+ public
+ ServiceManagerI(Ice.Communicator communicator, String[] args)
+ {
+ _communicator = communicator;
+ _logger = _communicator.getLogger();
+ _argv = args;
+
+ Ice.Properties properties = communicator.getProperties();
+ _options = properties.getCommandLineOptions();
+ }
+
+ public void
+ shutdown(Ice.Current current)
+ {
+ _communicator.shutdown();
+ }
+
+ int
+ run()
+ {
+ try
+ {
+ //
+ // Create an object adapter. Services probably should NOT share
+ // this object adapter, as the endpoint(s) for this object adapter
+ // will most likely need to be firewalled for security reasons.
+ //
+ Ice.ObjectAdapter adapter =
+ _communicator.createObjectAdapterFromProperty("ServiceManagerAdapter",
+ "IceBox.ServiceManager.Endpoints");
+ adapter.add(this, Ice.Util.stringToIdentity("ServiceManager"));
+
+ //
+ // Load and initialize the services defined in the property set
+ // with the prefix "IceBox.Service.". These properties should
+ // have the following format:
+ //
+ // IceBox.Service.Foo=Package.Foo [args]
+ //
+ final String prefix = "IceBox.Service.";
+ Ice.Properties properties = _communicator.getProperties();
+ String[] services = properties.getProperties(prefix);
+ for (int i = 0; i < services.length; i += 2)
+ {
+ String name = services[i].substring(prefix.length());
+ String value = services[i + 1];
+
+ //
+ // Separate the entry point from the arguments.
+ //
+ String className;
+ String[] args;
+ int pos = value.indexOf(' ');
+ if (pos == -1)
+ {
+ pos = value.indexOf('\t');
+ }
+ if (pos == -1)
+ {
+ pos = value.indexOf('\n');
+ }
+ if (pos == -1)
+ {
+ className = value;
+ args = new String[0];
+ }
+ else
+ {
+ className = value.substring(0, pos);
+ args = value.substring(pos).trim().split("[ \t\n]+", pos);
+ }
+
+ init(name, className, args);
+ }
+
+ //
+ // Invoke start() on the services.
+ //
+ java.util.Iterator r = _services.entrySet().iterator();
+ while (r.hasNext())
+ {
+ java.util.Map.Entry entry = (java.util.Map.Entry)r.next();
+ String name = (String)entry.getKey();
+ Service svc = (Service)entry.getValue();
+ try
+ {
+ svc.start();
+ }
+ catch (FailureException ex)
+ {
+ throw ex;
+ }
+ catch (Exception ex)
+ {
+ FailureException e = new FailureException();
+ e.reason = "ServiceManager: exception in start for service " + name + ": " + ex;
+ e.initCause(ex);
+ throw e;
+ }
+ }
+
+ //
+ // We may want to notify external scripts that the services
+ // have started. This is done by defining the property:
+ //
+ // IceBox.PrintServicesReady=bundleName
+ //
+ // Where bundleName is whatever you choose to call this set of
+ // services. It will be echoed back as "bundleName ready".
+ //
+ // This must be done after start() has been invoked on the
+ // services.
+ //
+ String bundleName = properties.getProperty("IceBox.PrintServicesReady");
+ if (bundleName.length() > 0)
+ {
+ System.out.println(bundleName + " ready");
+ }
+
+ //
+ // Start request dispatching after we've started the services.
+ //
+ adapter.activate();
+
+ _communicator.waitForShutdown();
+
+ //
+ // Invoke stop() on the services.
+ //
+ stopAll();
+ }
+ catch (FailureException ex)
+ {
+ java.io.StringWriter sw = new java.io.StringWriter();
+ java.io.PrintWriter pw = new java.io.PrintWriter(sw);
+ pw.println(ex.reason);
+ ex.printStackTrace(pw);
+ pw.flush();
+ _logger.error(sw.toString());
+ stopAll();
+ return 1;
+ }
+ catch (Ice.LocalException ex)
+ {
+ java.io.StringWriter sw = new java.io.StringWriter();
+ java.io.PrintWriter pw = new java.io.PrintWriter(sw);
+ ex.printStackTrace(pw);
+ pw.flush();
+ _logger.error("ServiceManager: " + ex + "\n" + sw.toString());
+ stopAll();
+ return 1;
+ }
+ catch (Exception ex)
+ {
+ java.io.StringWriter sw = new java.io.StringWriter();
+ java.io.PrintWriter pw = new java.io.PrintWriter(sw);
+ ex.printStackTrace(pw);
+ pw.flush();
+ _logger.error("ServiceManager: unknown exception\n" + sw.toString());
+ stopAll();
+ return 1;
+ }
+
+ return 0;
+ }
+
+ private Service
+ init(String service, String className, String[] args)
+ throws FailureException
+ {
+ //
+ // We need to create a property set to pass to init().
+ // The property set is populated from a number of sources.
+ // The precedence order (from lowest to highest) is:
+ //
+ // 1. Properties defined in the server property set (e.g.,
+ // that were defined in the server's configuration file)
+ // 2. Service arguments
+ // 3. Server arguments
+ //
+ // We'll compose an array of arguments in the above order.
+ //
+ java.util.ArrayList l = new java.util.ArrayList();
+ for (int j = 0; j < _options.length; j++)
+ {
+ if (_options[j].startsWith("--" + service + "."))
+ {
+ l.add(_options[j]);
+ }
+ }
+ for (int j = 0; j < args.length; j++)
+ {
+ l.add(args[j]);
+ }
+ for (int j = 0; j < _argv.length; j++)
+ {
+ if (_argv[j].startsWith("--" + service + "."))
+ {
+ l.add(_argv[j]);
+ }
+ }
+
+ //
+ // Create the service property set.
+ //
+ Ice.Util.addArgumentPrefix(service);
+ Ice.StringSeqHolder argsH = new Ice.StringSeqHolder();
+ argsH.value = new String[l.size()];
+ l.toArray(argsH.value);
+ Ice.Properties serviceProperties = Ice.Util.createProperties(argsH);
+
+ //
+ // Instantiate the class.
+ //
+ Service svc = null;
+ try
+ {
+ Class c = Class.forName(className);
+ java.lang.Object obj = c.newInstance();
+ try
+ {
+ svc = (Service)obj;
+ }
+ catch (ClassCastException ex)
+ {
+ FailureException e = new FailureException();
+ e.reason = "ServiceManager: class " + className + " does not implement IceBox.Service";
+ throw e;
+ }
+ }
+ catch (ClassNotFoundException ex)
+ {
+ FailureException e = new FailureException();
+ e.reason = "ServiceManager: class " + className + " not found";
+ e.initCause(ex);
+ throw e;
+ }
+ catch (IllegalAccessException ex)
+ {
+ FailureException e = new FailureException();
+ e.reason = "ServiceManager: unable to access default constructor in class " + className;
+ e.initCause(ex);
+ throw e;
+ }
+ catch (InstantiationException ex)
+ {
+ FailureException e = new FailureException();
+ e.reason = "ServiceManager: unable to instantiate class " + className;
+ e.initCause(ex);
+ throw e;
+ }
+
+ //
+ // Invoke Service::init().
+ //
+ try
+ {
+ svc.init(service, _communicator, serviceProperties, argsH.value);
+ _services.put(service, svc);
+ }
+ catch (FailureException ex)
+ {
+ throw ex;
+ }
+ catch (Exception ex)
+ {
+ FailureException e = new FailureException();
+ e.reason = "ServiceManager: exception while initializing service " + service + ": " + ex;
+ e.initCause(ex);
+ throw e;
+ }
+
+ return svc;
+ }
+
+ private void
+ stop(String service)
+ throws FailureException
+ {
+ Service svc = (Service)_services.remove(service);
+ assert(svc != null);
+
+ try
+ {
+ svc.stop();
+ }
+ catch (Exception ex)
+ {
+ FailureException e = new FailureException();
+ e.reason = "ServiceManager: exception in stop for service " + service + ": " + ex;
+ e.initCause(ex);
+ throw e;
+ }
+ }
+
+ private void
+ stopAll()
+ {
+ java.util.Iterator r = _services.keySet().iterator();
+ while (r.hasNext())
+ {
+ String service = (String)r.next();
+ try
+ {
+ stop(service);
+ }
+ catch (FailureException ex)
+ {
+ _logger.error(ex.reason);
+ }
+ }
+ assert(_services.isEmpty());
+ }
+
+ private Ice.Communicator _communicator;
+ private Ice.Logger _logger;
+ private String[] _argv; // Filtered server argument vector
+ private String[] _options; // Server property set converted to command-line options
+ private java.util.HashMap _services = new java.util.HashMap();
+}
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-04 16:12:22 +0000