ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/client/ClientMain.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/client/ClientMain.java (file contents):
Revision 1.16 by tdb, Thu Mar 15 22:12:22 2001 UTC vs.
Revision 1.23 by tdb, Fri Sep 6 15:10:48 2002 UTC

# Line 1 | Line 1
1 + /*
2 + * i-scream central monitoring system
3 + * http://www.i-scream.org.uk
4 + * Copyright (C) 2000-2002 i-scream
5 + *
6 + * This program is free software; you can redistribute it and/or
7 + * modify it under the terms of the GNU General Public License
8 + * as published by the Free Software Foundation; either version 2
9 + * of the License, or (at your option) any later version.
10 + *
11 + * This program is distributed in the hope that it will be useful,
12 + * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14 + * GNU General Public License for more details.
15 + *
16 + * You should have received a copy of the GNU General Public License
17 + * along with this program; if not, write to the Free Software
18 + * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
19 + */
20 +
21   //---PACKAGE DECLARATION---
22 < package uk.org.iscream.client;
22 > package uk.org.iscream.cms.server.client;
23  
24   //---IMPORTS---
25 < import uk.org.iscream.clientinterface.*;
26 < import uk.org.iscream.componentmanager.*;
27 < import uk.org.iscream.core.*;
28 < import uk.org.iscream.util.*;
25 > import uk.org.iscream.cms.server.clientinterface.*;
26 > import uk.org.iscream.cms.server.componentmanager.*;
27 > import uk.org.iscream.cms.server.core.*;
28 > import uk.org.iscream.cms.server.util.*;
29  
30   /**
31   * A startup component for the Local Clients.
32 + * This class starts the CORBA client used for alerting
33 + * purposes.  It reads data using the ClientServant from CORBA
34 + * calls by the i-scream client interface.  This data is then
35 + * used by the MonitorManager to pass to Monitors.  Monitors then
36 + * analyse the data and raise alerts if needed, these are passed to
37 + * the Alerters, which send out alerts.  They are looked after by
38 + * the AlerterManager.
39   *
40   * @author  $Author$
41   * @version $Id$
# Line 35 | Line 62 | public class ClientMain implements Component {
62   //---PUBLIC METHODS---
63  
64      /**
65 <     * This starts the Local Client component
65 >     * This starts the Local Client component.
66 >     * This starts the ClientServant, the MonitorManager and
67 >     * the AlerterManager, aswell as initialising any queues
68 >     * and obtaining any initial configuration.
69 >     *
70 >     * @throws ComponentStartException if the component fails to start
71       */
72      public void start() throws ComponentStartException {
73          // get references to key objects
# Line 43 | Line 75 | public class ClientMain implements Component {
75  
76          _logger.write(toString(), Logger.SYSINIT, "coming up");
77          
78 <        // setup the queues, this must be done before both managers are setup
79 <        // setup a Queue for the servant -> monitor manager
48 <        _monitorQueue = new Queue();
49 <        // setup a Queue for the monitors -> alert manager
50 <        _alerterQueue = new Queue();
78 >        // get a reference to the configuration proxy
79 >        ConfigurationProxy cp = ConfigurationProxy.getInstance();
80          
81 +        // see if these Queue's need a size limit
82 +        try {
83 +            int queueSizeLimit = Integer.parseInt(cp.getProperty(NAME, "Queue.SizeLimit"));
84 +            String queueRemoveAlgorithm = cp.getProperty(NAME, "Queue.RemoveAlgorithm");
85 +            int algorithm = StringUtils.getStringPos(queueRemoveAlgorithm, Queue.algorithms);
86 +            if(algorithm != -1) {
87 +                _logger.write(toString(), Logger.DEBUG, "Starting 2 Queues with size limit of "+queueSizeLimit+", using remove algorithm "+queueRemoveAlgorithm);
88 +                // we have valid values, so lets start it.
89 +                _alerterQueue = new Queue(queueSizeLimit, algorithm);
90 +                _monitorQueue = new Queue(queueSizeLimit, algorithm);
91 +            }
92 +            else {
93 +                _logger.write(toString(), Logger.WARNING, "Bad Queue Algorithm configuration, not known: "+queueRemoveAlgorithm);
94 +                // just don't activate a limit
95 +                _alerterQueue = new Queue();
96 +                _monitorQueue = new Queue();
97 +            }
98 +        } catch (PropertyNotFoundException e) {
99 +            _logger.write(toString(), Logger.DEBUG, "Optional config not set: "+e);
100 +            // just don't activate a limit
101 +            _alerterQueue = new Queue();
102 +            _monitorQueue = new Queue();
103 +        } catch (NumberFormatException e) {
104 +            _logger.write(toString(), Logger.WARNING, "Bad Queue SizeLimit configuration: "+e);
105 +            // just don't activate a limit
106 +            _alerterQueue = new Queue();
107 +            _monitorQueue = new Queue();
108 +        }
109 +        
110 +        // startup monitors on these queues
111 +        try {
112 +            // try to get the interval, if this fails, we won't start up the monitor
113 +            int queueMonitorInterval = Integer.parseInt(cp.getProperty(NAME, "Queue.MonitorInterval"));
114 +            _alerterQueue.startMonitor(queueMonitorInterval*1000, _monitorQueue, NAME + " Alerter");
115 +            _monitorQueue.startMonitor(queueMonitorInterval*1000, _monitorQueue, NAME + " Monitor");
116 +        } catch (PropertyNotFoundException e) {
117 +            _logger.write(toString(), Logger.WARNING, "failed to find queue monitor config, disabling. " + e);
118 +        }        
119 +        
120          // setup the servant and connect
121          _logger.write(toString(), Logger.SYSINIT, "starting servant and connecting");          
122          try {
# Line 57 | Line 125 | public class ClientMain implements Component {
125              Client client = ClientHelper.narrow(objRef);
126              
127              // this name maybe shouldn't be static
128 <            objRef = _refman.getCORBARef("iscream.ClientInterface.CorbaListener");
128 >            objRef = _refman.getCORBARef("iscream.ClientInterface\\.CorbaListener");
129              CorbaClientListener listener = CorbaClientListenerHelper.narrow(objRef);
130              
131              _logger.write(toString(), Logger.SYSINIT, "connecting");
# Line 79 | Line 147 | public class ClientMain implements Component {
147          alertMan.start();
148        
149          _logger.write(toString(), Logger.SYSINIT, "started");
82 –        
150      }
151      
152      /**
# Line 98 | Line 165 | public class ClientMain implements Component {
165              ConfigurationProxy cp = ConfigurationProxy.getInstance();
166              String cli = cp.getProperty("RootFilter", "RootFilter.realtimeInterfaceName");
167              // finally check the CLI is alive
168 <            obj = _refman.getCORBARef("iscream.ClientInterface." + cli);
168 >            obj = _refman.getCORBARef("iscream.ClientInterface\\." + cli);
169          } catch(ComponentCORBAException e) {
170              System.err.println(toString() + ": Dependency Failure: "+e);
171              return false;
# Line 114 | Line 181 | public class ClientMain implements Component {
181       * Overrides the {@link java.lang.Object#toString() Object.toString()}
182       * method to provide clean logging (every class should have this).
183       *
184 <     * This uses the uk.org.iscream.util.FormatName class
184 >     * This uses the uk.org.iscream.cms.server.util.FormatName class
185       * to format the toString()
186       *
187       * @return the name of this class and its CVS revision

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines