server/core/Core.java

//---PACKAGE DECLARATION---

//---IMPORTS---
import uk.ac.ukc.iscream.core.*;
import org.omg.CORBA.*;
import org.omg.CosNaming.*;
import org.omg.PortableServer.*;
import java.util.*;
import java.io.*;

/**
 * The main class for the CORE of the I-Scream system.
 * The main method of this class initialises the ORB
 * and then starts and registers CORE I-Scream services
 * with the name service.  At which point it essentially
 * finishs its role and the started services continue to
 * serve requests from the I-Scream system.
 *
 * @author  $Author: tdb1 $
 * @version $Id: Core.java,v 1.11 2000/11/17 16:25:18 tdb1 Exp $
 */
class Core {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public static final String REVISION = "$Revision: 1.11 $";
    
    /**
     * The toString() of this class
     * As it won't be instatiated, this is needed.
     */
    public static final String toString = "CORE(" + REVISION.substring(11, REVISION.length() - 2) + ")";
    
    /**
     * The default location of the properties file for the system
     */
    public static final String DEFAULTPROPERTIES = "default.properties";
    
//---STATIC METHODS---

    /**
     * The main method which starts the CORE
     * Currently the args are passed direct to the ORB,
     * so any ORB paramaters could go there.
     *
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        System.out.println("--- I-Scream ---");
                
        // get the command line args
        String defaultProperties = DEFAULTPROPERTIES;
        if (args.length > 0) {
            if (args[0].equals("-l")) {
                defaultProperties = args[1];
            } else if (args[0].equals("-h")) {
                usage();
            } else {
                usage();
            }            
        }

        // load the default properties file into the system properties
        System.out.println(toString + ": initialising - using " + defaultProperties);
        try {
            Properties initProperties = new Properties(System.getProperties());
            initProperties.load(new FileInputStream(new File(defaultProperties)));
            System.setProperties(initProperties);


        } catch (Exception e) {
            System.err.println(toString + ": ERROR " + e.getMessage());
            usage();
        }

        // continue to bring the system up
        System.out.println(toString + ": coming up");        
        try {
            // start the ORB
            ORB orb = ORB.init(args, null);
            
            // get the Root POA
            org.omg.CORBA.Object objRef = orb.resolve_initial_references("RootPOA");
            POA poa = POAHelper.narrow(objRef);
            
            // get a hook to the name service
            objRef = orb.resolve_initial_references("NameService");
            NamingContextExt ncRef = NamingContextExtHelper.narrow(objRef);
            
            // start and bind each server in turn
            
            // work out the verbosity setting & which logger to use
            int verbosity = Integer.parseInt(System.getProperty("uk.ac.ukc.iscream.Verbosity", defaultVerbosity));
            String whichLogger = System.getProperty("uk.ac.ukc.iscream.LoggerClass", defaultLogger);
            String loggerParams = System.getProperty("uk.ac.ukc.iscream.LoggerClassParams");
            
            Logger logRef = null;
            // create the logger (either Screen or File), and bind it
            if(whichLogger.equals("ScreenLogger")){
                ScreenLoggerServant loggerRef = new ScreenLoggerServant(verbosity);
                objRef = poa.servant_to_reference(loggerRef);
                ncRef.bind(ncRef.to_name("iscream.Logger"), objRef);
                logRef = LoggerHelper.narrow(objRef);
            }
            else if(whichLogger.equals("FileLogger")){
                FileLoggerServant loggerRef = new FileLoggerServant(loggerParams, verbosity);
                objRef = poa.servant_to_reference(loggerRef);
                ncRef.bind(ncRef.to_name("iscream.Logger"), objRef);
                logRef = LoggerHelper.narrow(objRef);
            }
            else {
                //need to deal with this
            }
            
            // and advertise it to the naming context
            //objRef = poa.servant_to_reference(loggerRef);
            //ncRef.bind(ncRef.to_name("iscream.Logger"), objRef);
            
            // get a ref to the logger servant as a Logger reference
            //Logger logRef = LoggerHelper.narrow(objRef);
            
            // create the Configurator
            String configLocation = System.getProperty("uk.ac.ukc.iscream.ConfigurationLocation", defaultConfigPath);
            ConfigurationManagerServant configManRef = new ConfigurationManagerServant(poa, logRef);
            
            // and advertise it to the naming context
            objRef = poa.servant_to_reference(configManRef);
            ncRef.bind(ncRef.to_name("iscream.ConfigurationManager"), objRef);
            
            // start the POA off
            poa.the_POAManager().activate();
                        
            logRef.write(toString, Logger.SYSINIT, "started");
            
            // now we are running, we just need to serve
            // so we ask the orb to block for us until it has finished
            orb.run();
            
        // if there was a problem then we'll get to here    
        } catch (Exception e) {
            
            // there is already another CORE of the same name registered
            if ( e instanceof org.omg.CosNaming.NamingContextPackage.AlreadyBound) {
                System.err.println("ERROR: Another I-Scream CORE is already registered under the same name.");
            
            // otherwise we don't know what happened
            // so print the error and do a stack trace
            } else {
                System.err.println("CORE ERROR: " + e);
                e.printStackTrace(System.out);
            }
        }
    }
    
    /** 
     * A simple method to print the usage of this class.
     * It never returns, but instead exits to the system
     * with a value 1, to indicate the system did not start
     * properly.
     */
    public static void usage() {
        System.out.println("USAGE: java Core.java <option>");
        System.out.println("WHERE <option>:");
        System.out.println("      -l <filename> - the location of initial system properties");
        System.out.println("      -h            - this help screen");
        System.exit(1);
    }

//---CONSTRUCTORS---

//---PUBLIC METHODS---

//---PRIVATE METHODS---

//---ACCESSOR/MUTATOR METHODS---

//---ATTRIBUTES---
    
//---STATIC ATTRIBUTES---

    /**
     * Default verbosity setting, to be used when one is
     * not provided in the configuration.
     */
    private static final String defaultVerbosity = "3";
    
    /**
     * Default logger, to be used when one is not provided
     * in the configuration.
     */
    private static final String defaultLogger = "ScreenLogger";
    
    /**
     * Default configPath, to be used when one is not provided
     * in the configuration.
     */
    private static final String defaultConfigPath = ".";

}
Revision:	1.12
Committed:	Mon Nov 20 17:11:44 2000 UTC (23 years, 6 months ago) by ajm
Branch:	MAIN
Changes since 1.11:	+202 -202 lines
Log Message:	Modified to change the name of the Configurator -> ConfigurationManager Added initial work for multiple configurations
#	User	Rev	Content
1	ajm	1.12	//---PACKAGE DECLARATION---
2
3			//---IMPORTS---
4			import uk.ac.ukc.iscream.core.*;
5			import org.omg.CORBA.*;
6			import org.omg.CosNaming.*;
7			import org.omg.PortableServer.*;
8			import java.util.*;
9			import java.io.*;
10
11			/**
12			* The main class for the CORE of the I-Scream system.
13			* The main method of this class initialises the ORB
14			* and then starts and registers CORE I-Scream services
15			* with the name service. At which point it essentially
16			* finishs its role and the started services continue to
17			* serve requests from the I-Scream system.
18			*
19			* @author $Author: tdb1 $
20			* @version $Id: Core.java,v 1.11 2000/11/17 16:25:18 tdb1 Exp $
21			*/
22			class Core {
23
24			//---FINAL ATTRIBUTES---
25
26			/**
27			* The current CVS revision of this class
28			*/
29			public static final String REVISION = "$Revision: 1.11 $";
30
31			/**
32			* The toString() of this class
33			* As it won't be instatiated, this is needed.
34			*/
35			public static final String toString = "CORE(" + REVISION.substring(11, REVISION.length() - 2) + ")";
36
37			/**
38			* The default location of the properties file for the system
39			*/
40			public static final String DEFAULTPROPERTIES = "default.properties";
41
42			//---STATIC METHODS---
43
44			/**
45			* The main method which starts the CORE
46			* Currently the args are passed direct to the ORB,
47			* so any ORB paramaters could go there.
48			*
49			* @param args the command line arguments
50			*/
51			public static void main(String[] args) {
52			System.out.println("--- I-Scream ---");
53
54			// get the command line args
55			String defaultProperties = DEFAULTPROPERTIES;
56			if (args.length > 0) {
57			if (args[0].equals("-l")) {
58			defaultProperties = args[1];
59			} else if (args[0].equals("-h")) {
60			usage();
61			} else {
62			usage();
63			}
64			}
65
66			// load the default properties file into the system properties
67			System.out.println(toString + ": initialising - using " + defaultProperties);
68			try {
69			Properties initProperties = new Properties(System.getProperties());
70			initProperties.load(new FileInputStream(new File(defaultProperties)));
71			System.setProperties(initProperties);
72
73
74			} catch (Exception e) {
75			System.err.println(toString + ": ERROR " + e.getMessage());
76			usage();
77			}
78
79			// continue to bring the system up
80			System.out.println(toString + ": coming up");
81			try {
82			// start the ORB
83			ORB orb = ORB.init(args, null);
84
85			// get the Root POA
86			org.omg.CORBA.Object objRef = orb.resolve_initial_references("RootPOA");
87			POA poa = POAHelper.narrow(objRef);
88
89			// get a hook to the name service
90			objRef = orb.resolve_initial_references("NameService");
91			NamingContextExt ncRef = NamingContextExtHelper.narrow(objRef);
92
93			// start and bind each server in turn
94
95			// work out the verbosity setting & which logger to use
96			int verbosity = Integer.parseInt(System.getProperty("uk.ac.ukc.iscream.Verbosity", defaultVerbosity));
97			String whichLogger = System.getProperty("uk.ac.ukc.iscream.LoggerClass", defaultLogger);
98			String loggerParams = System.getProperty("uk.ac.ukc.iscream.LoggerClassParams");
99
100			Logger logRef = null;
101			// create the logger (either Screen or File), and bind it
102			if(whichLogger.equals("ScreenLogger")){
103			ScreenLoggerServant loggerRef = new ScreenLoggerServant(verbosity);
104			objRef = poa.servant_to_reference(loggerRef);
105			ncRef.bind(ncRef.to_name("iscream.Logger"), objRef);
106			logRef = LoggerHelper.narrow(objRef);
107			}
108			else if(whichLogger.equals("FileLogger")){
109			FileLoggerServant loggerRef = new FileLoggerServant(loggerParams, verbosity);
110			objRef = poa.servant_to_reference(loggerRef);
111			ncRef.bind(ncRef.to_name("iscream.Logger"), objRef);
112			logRef = LoggerHelper.narrow(objRef);
113			}
114			else {
115			//need to deal with this
116			}
117
118			// and advertise it to the naming context
119			//objRef = poa.servant_to_reference(loggerRef);
120			//ncRef.bind(ncRef.to_name("iscream.Logger"), objRef);
121
122			// get a ref to the logger servant as a Logger reference
123			//Logger logRef = LoggerHelper.narrow(objRef);
124
125			// create the Configurator
126			String configLocation = System.getProperty("uk.ac.ukc.iscream.ConfigurationLocation", defaultConfigPath);
127			ConfigurationManagerServant configManRef = new ConfigurationManagerServant(poa, logRef);
128
129			// and advertise it to the naming context
130			objRef = poa.servant_to_reference(configManRef);
131			ncRef.bind(ncRef.to_name("iscream.ConfigurationManager"), objRef);
132
133			// start the POA off
134			poa.the_POAManager().activate();
135
136			logRef.write(toString, Logger.SYSINIT, "started");
137
138			// now we are running, we just need to serve
139			// so we ask the orb to block for us until it has finished
140			orb.run();
141
142			// if there was a problem then we'll get to here
143			} catch (Exception e) {
144
145			// there is already another CORE of the same name registered
146			if ( e instanceof org.omg.CosNaming.NamingContextPackage.AlreadyBound) {
147			System.err.println("ERROR: Another I-Scream CORE is already registered under the same name.");
148
149			// otherwise we don't know what happened
150			// so print the error and do a stack trace
151			} else {
152			System.err.println("CORE ERROR: " + e);
153			e.printStackTrace(System.out);
154			}
155			}
156			}
157
158			/**
159			* A simple method to print the usage of this class.
160			* It never returns, but instead exits to the system
161			* with a value 1, to indicate the system did not start
162			* properly.
163			*/
164			public static void usage() {
165			System.out.println("USAGE: java Core.java <option>");
166			System.out.println("WHERE <option>:");
167			System.out.println(" -l <filename> - the location of initial system properties");
168			System.out.println(" -h - this help screen");
169			System.exit(1);
170			}
171
172			//---CONSTRUCTORS---
173
174			//---PUBLIC METHODS---
175
176			//---PRIVATE METHODS---
177
178			//---ACCESSOR/MUTATOR METHODS---
179
180			//---ATTRIBUTES---
181
182			//---STATIC ATTRIBUTES---
183
184			/**
185			* Default verbosity setting, to be used when one is
186			* not provided in the configuration.
187			*/
188			private static final String defaultVerbosity = "3";
189
190			/**
191			* Default logger, to be used when one is not provided
192			* in the configuration.
193			*/
194			private static final String defaultLogger = "ScreenLogger";
195
196			/**
197			* Default configPath, to be used when one is not provided
198			* in the configuration.
199			*/
200			private static final String defaultConfigPath = ".";
201
202			}