server/client/ClientMain.java

//---PACKAGE DECLARATION---
package uk.org.iscream.client;

//---IMPORTS---
import uk.org.iscream.clientinterface.*;
import uk.org.iscream.componentmanager.*;
import uk.org.iscream.core.*;
import uk.org.iscream.util.*;

/**
 * A startup component for the Local Clients.
 *
 * @author  $Author: tdb1 $
 * @version $Id: ClientMain.java,v 1.16 2001/03/15 22:12:22 tdb1 Exp $
 */
public class ClientMain implements Component {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public static final String REVISION = "$Revision: 1.16 $";
    
    /**
     * The friendly name for this component, used by
     * all related classes.
     */
    public static final String NAME = "LocalClient";
    
//---STATIC METHODS---

//---CONSTRUCTORS---

//---PUBLIC METHODS---

    /**
     * This starts the Local Client component
     */
    public void start() throws ComponentStartException {
        // get references to key objects
        _logger = _refman.getLogger();

        _logger.write(toString(), Logger.SYSINIT, "coming up");
        
        // get a reference to the configuration proxy
        ConfigurationProxy cp = ConfigurationProxy.getInstance();
        
        // see if these Queue's need a size limit
        try {
            int queueSizeLimit = Integer.parseInt(cp.getProperty(NAME, "Queue.SizeLimit"));
            String queueRemoveAlgorithm = cp.getProperty(NAME, "Queue.RemoveAlgorithm");
            int algorithm = StringUtils.getStringPos(queueRemoveAlgorithm, Queue.algorithms);
            if(algorithm != -1) {
                _logger.write(toString(), Logger.DEBUG, "Starting 2 Queues with size limit of "+queueSizeLimit+", using remove algorithm "+queueRemoveAlgorithm);
                // we have valid values, so lets start it.
                _alerterQueue = new Queue(queueSizeLimit, algorithm);
                _monitorQueue = new Queue(queueSizeLimit, algorithm);
            }
            else {
                _logger.write(toString(), Logger.WARNING, "Bad Queue Algorithm configuration, not known: "+queueRemoveAlgorithm);
                // just don't activate a limit
                _alerterQueue = new Queue();
                _monitorQueue = new Queue();
            }
        } catch (PropertyNotFoundException e) {
            _logger.write(toString(), Logger.DEBUG, "Optional config not set: "+e);
            // just don't activate a limit
            _alerterQueue = new Queue();
            _monitorQueue = new Queue();
        } catch (NumberFormatException e) {
            _logger.write(toString(), Logger.WARNING, "Bad Queue SizeLimit configuration: "+e);
            // just don't activate a limit
            _alerterQueue = new Queue();
            _monitorQueue = new Queue();
        }
        
        // startup monitors on these queues
        try {
            // try to get the interval, if this fails, we won't start up the monitor
            int queueMonitorInterval = Integer.parseInt(cp.getProperty(NAME, "Queue.MonitorInterval"));
            _alerterQueue.startMonitor(queueMonitorInterval*1000, _monitorQueue, NAME + " DataQueue");
            _monitorQueue.startMonitor(queueMonitorInterval*1000, _monitorQueue, NAME + " HeartbeatQueue");
        } catch (PropertyNotFoundException e) {
            _logger.write(toString(), Logger.WARNING, "failed to find queue monitor config, disabling. " + e);
        }        
        
        // setup the servant and connect
        _logger.write(toString(), Logger.SYSINIT, "starting servant and connecting");           
        try {
            ClientServant ref = new ClientServant(_monitorQueue);
            org.omg.CORBA.Object objRef = _refman.getRootPOA().servant_to_reference(ref);
            Client client = ClientHelper.narrow(objRef);
            
            // this name maybe shouldn't be static
            objRef = _refman.getCORBARef("iscream.ClientInterface.CorbaListener");
            CorbaClientListener listener = CorbaClientListenerHelper.narrow(objRef);
            
            _logger.write(toString(), Logger.SYSINIT, "connecting");
            CorbaControlHandler handler = listener.connect(client, NAME);
            handler.startData();
        }
        catch(Exception e) {
            // not sure what to do here
            // so we just log the error
            _logger.write(toString(), Logger.ERROR, "ERROR - " + e.getMessage());
        }
        
        // setup the MonitorManager
        MonitorManager monMan = MonitorManager.getInstance();
        monMan.start();
        
        // setup the AlerterManager
        AlerterManager alertMan = AlerterManager.getInstance();
        alertMan.start();
       
        _logger.write(toString(), Logger.SYSINIT, "started");
        
    }
    
    /**
     * Does a dependency check. Used mainly at startup to
     * see if the required dependencies (components) are up
     * and running.
     *
     * @return a boolean value, true if the depdencies are satisfied
     */
    public boolean depCheck() {
        try {
            org.omg.CORBA.Object obj;
            // first check the ConfigurationManager is alive
            obj = _refman.getCORBARef("iscream.ConfigurationManager");
            // then get some info on the CLI
            ConfigurationProxy cp = ConfigurationProxy.getInstance();
            String cli = cp.getProperty("RootFilter", "RootFilter.realtimeInterfaceName");
            // finally check the CLI is alive
            obj = _refman.getCORBARef("iscream.ClientInterface." + cli);
        } catch(ComponentCORBAException e) {
            System.err.println(toString() + ": Dependency Failure: "+e);
            return false;
        } catch(PropertyNotFoundException e) {
            System.err.println(toString() + ": Unable to obtain configuration: "+e);
            return false;
        }
        // dependency check suceeded
        return true;
    }
    
    /**
     * Overrides the {@link java.lang.Object#toString() Object.toString()}
     * method to provide clean logging (every class should have this).
     *
     * This uses the uk.org.iscream.util.FormatName class
     * to format the toString()
     *
     * @return the name of this class and its CVS revision
     */
    public String toString() {
        return FormatName.getName(
            NAME,
            getClass().getName(),
            REVISION);
    }

//---PRIVATE METHODS---

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

//---ATTRIBUTES---

    /**
     * This holds a reference to the
     * system logger that is being used.
     */
    private Logger _logger;

    /**
     * A reference to the reference manager in use
     */
    private ReferenceManager _refman = ReferenceManager.getInstance();

//---STATIC ATTRIBUTES---

    /**
     * A queue for the alerter manager
     */
    public static Queue _alerterQueue;
    
    /**
     * A queue for the monitor manager
     */
    public static Queue _monitorQueue;

}
Revision:	1.17
Committed:	Thu Mar 22 17:31:43 2001 UTC (23 years, 2 months ago) by tdb
Branch:	MAIN
Changes since 1.16:	+43 -7 lines
Log Message:	Radically changed the way data is passed around. Monitor's are now required to get data from the MonitorManager queue's, rather than being passed it. This allows them to run in parallel, rather than the serial setup we had before.
#	Content
1	//---PACKAGE DECLARATION---
2	package uk.org.iscream.client;
3
4	//---IMPORTS---
5	import uk.org.iscream.clientinterface.*;
6	import uk.org.iscream.componentmanager.*;
7	import uk.org.iscream.core.*;
8	import uk.org.iscream.util.*;
9
10	/**
11	* A startup component for the Local Clients.
12	*
13	* @author $Author: tdb1 $
14	* @version $Id: ClientMain.java,v 1.16 2001/03/15 22:12:22 tdb1 Exp $
15	*/
16	public class ClientMain implements Component {
17
18	//---FINAL ATTRIBUTES---
19
20	/**
21	* The current CVS revision of this class
22	*/
23	public static final String REVISION = "$Revision: 1.16 $";
24
25	/**
26	* The friendly name for this component, used by
27	* all related classes.
28	*/
29	public static final String NAME = "LocalClient";
30
31	//---STATIC METHODS---
32
33	//---CONSTRUCTORS---
34
35	//---PUBLIC METHODS---
36
37	/**
38	* This starts the Local Client component
39	*/
40	public void start() throws ComponentStartException {
41	// get references to key objects
42	_logger = _refman.getLogger();
43
44	_logger.write(toString(), Logger.SYSINIT, "coming up");
45
46	// get a reference to the configuration proxy
47	ConfigurationProxy cp = ConfigurationProxy.getInstance();
48
49	// see if these Queue's need a size limit
50	try {
51	int queueSizeLimit = Integer.parseInt(cp.getProperty(NAME, "Queue.SizeLimit"));
52	String queueRemoveAlgorithm = cp.getProperty(NAME, "Queue.RemoveAlgorithm");
53	int algorithm = StringUtils.getStringPos(queueRemoveAlgorithm, Queue.algorithms);
54	if(algorithm != -1) {
55	_logger.write(toString(), Logger.DEBUG, "Starting 2 Queues with size limit of "+queueSizeLimit+", using remove algorithm "+queueRemoveAlgorithm);
56	// we have valid values, so lets start it.
57	_alerterQueue = new Queue(queueSizeLimit, algorithm);
58	_monitorQueue = new Queue(queueSizeLimit, algorithm);
59	}
60	else {
61	_logger.write(toString(), Logger.WARNING, "Bad Queue Algorithm configuration, not known: "+queueRemoveAlgorithm);
62	// just don't activate a limit
63	_alerterQueue = new Queue();
64	_monitorQueue = new Queue();
65	}
66	} catch (PropertyNotFoundException e) {
67	_logger.write(toString(), Logger.DEBUG, "Optional config not set: "+e);
68	// just don't activate a limit
69	_alerterQueue = new Queue();
70	_monitorQueue = new Queue();
71	} catch (NumberFormatException e) {
72	_logger.write(toString(), Logger.WARNING, "Bad Queue SizeLimit configuration: "+e);
73	// just don't activate a limit
74	_alerterQueue = new Queue();
75	_monitorQueue = new Queue();
76	}
77
78	// startup monitors on these queues
79	try {
80	// try to get the interval, if this fails, we won't start up the monitor
81	int queueMonitorInterval = Integer.parseInt(cp.getProperty(NAME, "Queue.MonitorInterval"));
82	_alerterQueue.startMonitor(queueMonitorInterval*1000, _monitorQueue, NAME + " DataQueue");
83	_monitorQueue.startMonitor(queueMonitorInterval*1000, _monitorQueue, NAME + " HeartbeatQueue");
84	} catch (PropertyNotFoundException e) {
85	_logger.write(toString(), Logger.WARNING, "failed to find queue monitor config, disabling. " + e);
86	}
87
88	// setup the servant and connect
89	_logger.write(toString(), Logger.SYSINIT, "starting servant and connecting");
90	try {
91	ClientServant ref = new ClientServant(_monitorQueue);
92	org.omg.CORBA.Object objRef = _refman.getRootPOA().servant_to_reference(ref);
93	Client client = ClientHelper.narrow(objRef);
94
95	// this name maybe shouldn't be static
96	objRef = _refman.getCORBARef("iscream.ClientInterface.CorbaListener");
97	CorbaClientListener listener = CorbaClientListenerHelper.narrow(objRef);
98
99	_logger.write(toString(), Logger.SYSINIT, "connecting");
100	CorbaControlHandler handler = listener.connect(client, NAME);
101	handler.startData();
102	}
103	catch(Exception e) {
104	// not sure what to do here
105	// so we just log the error
106	_logger.write(toString(), Logger.ERROR, "ERROR - " + e.getMessage());
107	}
108
109	// setup the MonitorManager
110	MonitorManager monMan = MonitorManager.getInstance();
111	monMan.start();
112
113	// setup the AlerterManager
114	AlerterManager alertMan = AlerterManager.getInstance();
115	alertMan.start();
116
117	_logger.write(toString(), Logger.SYSINIT, "started");
118
119	}
120
121	/**
122	* Does a dependency check. Used mainly at startup to
123	* see if the required dependencies (components) are up
124	* and running.
125	*
126	* @return a boolean value, true if the depdencies are satisfied
127	*/
128	public boolean depCheck() {
129	try {
130	org.omg.CORBA.Object obj;
131	// first check the ConfigurationManager is alive
132	obj = _refman.getCORBARef("iscream.ConfigurationManager");
133	// then get some info on the CLI
134	ConfigurationProxy cp = ConfigurationProxy.getInstance();
135	String cli = cp.getProperty("RootFilter", "RootFilter.realtimeInterfaceName");
136	// finally check the CLI is alive
137	obj = _refman.getCORBARef("iscream.ClientInterface." + cli);
138	} catch(ComponentCORBAException e) {
139	System.err.println(toString() + ": Dependency Failure: "+e);
140	return false;
141	} catch(PropertyNotFoundException e) {
142	System.err.println(toString() + ": Unable to obtain configuration: "+e);
143	return false;
144	}
145	// dependency check suceeded
146	return true;
147	}
148
149	/**
150	* Overrides the {@link java.lang.Object#toString() Object.toString()}
151	* method to provide clean logging (every class should have this).
152	*
153	* This uses the uk.org.iscream.util.FormatName class
154	* to format the toString()
155	*
156	* @return the name of this class and its CVS revision
157	*/
158	public String toString() {
159	return FormatName.getName(
160	NAME,
161	getClass().getName(),
162	REVISION);
163	}
164
165	//---PRIVATE METHODS---
166
167	//---ACCESSOR/MUTATOR METHODS---
168
169	//---ATTRIBUTES---
170
171	/**
172	* This holds a reference to the
173	* system logger that is being used.
174	*/
175	private Logger _logger;
176
177	/**
178	* A reference to the reference manager in use
179	*/
180	private ReferenceManager _refman = ReferenceManager.getInstance();
181
182	//---STATIC ATTRIBUTES---
183
184	/**
185	* A queue for the alerter manager
186	*/
187	public static Queue _alerterQueue;
188
189	/**
190	* A queue for the monitor manager
191	*/
192	public static Queue _monitorQueue;
193
194	}