From 254ee6f47eebfc00462c10756a92066e82cc1a96 Mon Sep 17 00:00:00 2001 From: Andrew Branson Date: Tue, 21 Jun 2011 15:46:02 +0200 Subject: Initial commit --- source/com/c2kernel/process/StandardServer.java | 125 ++++++++++++++++++++++++ 1 file changed, 125 insertions(+) create mode 100755 source/com/c2kernel/process/StandardServer.java (limited to 'source/com/c2kernel/process/StandardServer.java') diff --git a/source/com/c2kernel/process/StandardServer.java b/source/com/c2kernel/process/StandardServer.java new file mode 100755 index 0000000..2c9bcaf --- /dev/null +++ b/source/com/c2kernel/process/StandardServer.java @@ -0,0 +1,125 @@ +/************************************************************************** + * StandardServer + * + * $Revision: 1.47 $ + * $Date: 2005/04/28 13:49:43 $ + * + * Copyright (C) 2001 CERN - European Organization for Nuclear Research + * All rights reserved. + **************************************************************************/ + +package com.c2kernel.process; + +import org.tanukisoftware.wrapper.WrapperListener; +import org.tanukisoftware.wrapper.WrapperManager; + +import com.c2kernel.utils.Logger; + +/************************************************************************** + * Base class for all servers i.e. c2k processes that serve Entities + * + * @author $Author: abranson $ $Date: 2005/04/28 13:49:43 $ + * @version $Revision: 1.47 $ + **************************************************************************/ +public class StandardServer extends AbstractMain implements WrapperListener +{ + protected static StandardServer server; + + + /************************************************************************** + * C2KRootPOA suitable for Factory objects + **************************************************************************/ + + + + + + /************************************************************************** + * void StandardInitalisation( String[] ) + * + * Set-up calls to ORB, POA and Factorys, both optional and required. + **************************************************************************/ + protected void standardInitialisation( String[] args ) + throws Exception + { + // read args and init Gateway + standardSetUp(args); + + // connect to LDAP as root + Gateway.connect(); + + //start console + Logger.initConsole("ItemServer"); + + //initialize the server objects + Gateway.startServer(); + + Logger.msg(5, "StandardServer::standardInitialisation - complete."); + + } + + + /************************************************************************** + * Sets up and runs and item server + **************************************************************************/ + public Integer start(String[] args) + { + try + { + //initialise everything + standardInitialisation( args ); + } + catch( Exception ex ) + { + Logger.error(ex); + Logger.die("Startup failed"); + } + return null; + } + + public static void main(String[] args) { + server = new StandardServer(); + AbstractMain.runningAsWrapper = true; + WrapperManager.start( server, args ); + } + + /** + * + */ + public void controlEvent(int event) { + if (WrapperManager.isControlledByNativeWrapper()) { + // The Wrapper will take care of this event + } else { + // We are not being controlled by the Wrapper, so + // handle the event ourselves. + if ((event == WrapperManager.WRAPPER_CTRL_C_EVENT) || + (event == WrapperManager.WRAPPER_CTRL_CLOSE_EVENT) || + (event == WrapperManager.WRAPPER_CTRL_SHUTDOWN_EVENT)){ + WrapperManager.stop(0); + } + } + + } + + /************************************************************************** + * Closes all listeners, quits the VM. + * This method should be called to kill the server process + * e.g. from the NT service wrapper + **************************************************************************/ + public int stop(int arg0) { + try + { + // close gateway + standardTearDown(); + } + catch( Exception ex ) + { + Logger.error(ex); + return 1; + } + + Logger.msg("StandardServer::shutdown - complete. "); + return 0; + } + +} -- cgit v1.2.3