OGAgent.java revision 368
1170N/A/*
1170N/A * CDDL HEADER START
1170N/A *
1170N/A * The contents of this file are subject to the terms of the
1170N/A * Common Development and Distribution License (the "License").
1172N/A * You may not use this file except in compliance with the License.
1170N/A *
1170N/A * See LICENSE.txt included in this distribution for the specific
1170N/A * language governing permissions and limitations under the License.
1170N/A *
1170N/A * When distributing Covered Code, include this CDDL HEADER in each
1170N/A * file and include the License file at LICENSE.txt.
1170N/A * If applicable, add the following below this CDDL HEADER, with the
1170N/A * fields enclosed by brackets "[]" replaced with your own identifying
1170N/A * information: Portions Copyright [yyyy] [name of copyright owner]
1170N/A *
1170N/A * CDDL HEADER END
1170N/A */
1170N/A
1170N/A/*
1170N/A * Copyright 2008 Sun Microsystems, Inc. All rights reserved.
1170N/A * Use is subject to license terms.
1170N/A */
1170N/Apackage org.opensolaris.opengrok.management;
1170N/A
1170N/Aimport javax.management.MBeanServer;
1170N/Aimport javax.management.MBeanServerFactory;
1170N/Aimport javax.management.ObjectName;
1170N/Aimport javax.management.remote.JMXServiceURL;
1170N/Aimport javax.management.remote.JMXConnectorServer;
1170N/Aimport javax.management.remote.jmxmp.JMXMPConnectorServer;
1170N/Aimport javax.management.remote.rmi.RMIConnectorServer;
1170N/Aimport java.util.HashMap;
1170N/Aimport java.util.logging.Logger;
1170N/Aimport java.util.logging.Level;
1170N/Aimport java.io.FileInputStream;
1170N/Aimport java.io.IOException;
1170N/Aimport java.io.InputStream;
1170N/Aimport java.util.Properties;
1170N/Aimport java.util.ArrayList;
1170N/Aimport java.util.Date;
1170N/Aimport javax.management.NotificationFilter;
1170N/Aimport javax.management.timer.Timer;
1170N/Aimport org.opensolaris.opengrok.Info;
1170N/Aimport org.opensolaris.opengrok.OpenGrokLogger;
1170N/A
1170N/A/**
1170N/A * OG Agent main class.
1170N/A * Class for starting the basic components:
1170N/A * Monitor and JMX and HTTP Connectors.
1170N/A * @author Jan S Berg
1170N/A */
1170N/Apublic class OGAgent {
1170N/A
1170N/A private int connectorport = 9292;
1170N/A private final static Logger log = Logger.getLogger("org.opensolaris.opengrok");
1170N/A private static String cfgfile = null;
1170N/A private MBeanServer server = null;
1170N/A private static OGAgent oga = null;
1170N/A
1170N/A public static void main(final String args[]) {
1170N/A
1170N/A for (int i = 0; i < args.length; i++) {
1170N/A if (args[i].equals("-config")) {
1170N/A if (++i < args.length) {
1170N/A cfgfile = args[i];
1170N/A } else {
1170N/A System.err.println("-config, argument missing: config file");
1170N/A System.exit(1);
1170N/A }
1170N/A }
1170N/A }
1170N/A
1170N/A oga = new OGAgent();
1170N/A try {
1170N/A oga.runOGA();
1170N/A } catch (Exception ex) {
1170N/A Logger.getLogger(OGAgent.class.getName()).log(Level.SEVERE, null, ex);
1170N/A System.exit(1);
1170N/A }
1170N/A }
1170N/A
1170N/A public OGAgent() {
1170N/A }
1170N/A
1170N/A public final void runOGA() throws Exception {
1170N/A String machinename = java.net.InetAddress.getLocalHost().getHostName();
1170N/A String javaver = System.getProperty("java.version");
1170N/A
1170N/A Properties props = new Properties(System.getProperties());
1170N/A // Load default values
1170N/A InputStream in = Info.class.getResourceAsStream("oga.properties");
1170N/A if (in != null) {
1170N/A props.load(in);
1170N/A in.close();
1170N/A }
1170N/A
1170N/A if (cfgfile != null) {
1170N/A FileInputStream is = new FileInputStream(cfgfile);
1170N/A props.load(is);
1170N/A is.close();
1170N/A }
1170N/A
1170N/A createLogger(props);
1170N/A
1170N/A log.info("Starting " + Info.getFullVersion() +
1170N/A " JMX Agent, with java version " + javaver);
1170N/A //create mbeanserver
1170N/A
1170N/A String connprotocol = props.getProperty("oga.connection.protocol", "jmxmp");
1170N/A connectorport = Integer.parseInt(props.getProperty("oga.connection." + connprotocol + ".port", Integer.toString(connectorport)));
1170N/A log.fine("Using protocol " + connprotocol + ", port: " + connectorport);
1170N/A
1170N/A try {
1170N/A ArrayList mbservs = MBeanServerFactory.findMBeanServer(null);
1170N/A log.fine("Finding MBeanservers, size " + mbservs.size());
1170N/A if (mbservs.size() > 0) {
1170N/A server = (MBeanServer) mbservs.get(0);
1170N/A } else {
1170N/A server = MBeanServerFactory.createMBeanServer();
1170N/A }
1170N/A
1170N/A //instantiate and register OGAManagement
1170N/A ObjectName manager = new ObjectName("OGA:name=Management");
1170N/A server.registerMBean(Management.getInstance(props), manager);
1170N/A
1170N/A //instantiate and register Timer service and resource purger
1170N/A createIndexTimer(props);
1170N/A log.info("MBeans registered");
1170N/A } catch (Exception ex) {
1170N/A log.log(Level.SEVERE, "ERR " + ex.getMessage(), ex);
1172N/A throw ex;
1170N/A }
1170N/A
1170N/A // Create and start connector server
1170N/A log.fine("Starting JMX connector");
1170N/A try {
HashMap<String, Object> env = new HashMap<String, Object>();
JMXServiceURL url = new JMXServiceURL(connprotocol, machinename, connectorport);
JMXConnectorServer connectorServer = null;
if ("jmxmp".equals(connprotocol)) {
connectorServer = new JMXMPConnectorServer(url, env, server);
} else if ("rmi".equals(connprotocol) || "iiop".equals(connprotocol)) {
connectorServer = new RMIConnectorServer(url, env, server);
} else {
throw new IOException("Unknown connector protocol");
}
connectorServer.start();
} catch (java.net.MalformedURLException e) {
log.log(Level.SEVERE, "Could not create connector server: " + e, e);
System.exit(1);
} catch (java.io.IOException e) {
log.log(Level.SEVERE, "Could not start connector server: " + e, e);
System.exit(2);
}
log.info("OGA is ready and running...");
}
private void createIndexTimer(Properties properties) throws Exception {
//instantiate, register and start the Timer service
ObjectName timer = new ObjectName("service:name=timer");
server.registerMBean(new Timer(), timer);
server.invoke(timer, "start", null, null);
log.info("Started timer service");
boolean enabled = Boolean.valueOf(properties.getProperty("oga.indexer.enabled")).booleanValue();
int period = Integer.parseInt(properties.getProperty("oga.indexer.sleeptime"));
log.fine("Indexer enabled: " + enabled);
log.fine("Indexer period: " + period + " seconds");
//instantiate and register resource purger
ObjectName indexRunner = new ObjectName("OGA:name=AgentIndexRunner," + "source=timer");
server.registerMBean(AgentIndexRunner.getInstance(enabled), indexRunner);
// Add index notification to timer (read from oga.indexer.sleeptime property).
Date date = new Date(System.currentTimeMillis() + Timer.ONE_SECOND * 5);
Long longPeriod = Long.valueOf(period * Timer.ONE_SECOND);
Integer id = (Integer) server.invoke(timer, "addNotification",
new Object[]{"timer.notification", // Type
"Time to index again", // Message
null, // user data
date, // Start time
longPeriod, // Period
},
new String[]{String.class.getName(),
String.class.getName(),
Object.class.getName(),
Date.class.getName(),
"long",
});
// Add indexer as listener to index notifications
NotificationFilter filter = new TimerFilter(id);
server.addNotificationListener(timer, indexRunner, filter, null);
}
private void createLogger(Properties props) {
String OGAlogpath = props.getProperty("oga.logging.path");
Level loglevel = null;
try {
loglevel = Level.parse(props.getProperty("oga.logging.filelevel"));
} catch (Exception exll) {
loglevel = Level.FINE;
}
Level consoleloglevel = null;
try {
consoleloglevel = Level.parse(props.getProperty("oga.logging.consolelevel"));
} catch (Exception excl) {
consoleloglevel = Level.INFO;
}
OpenGrokLogger.setupLogger(OGAlogpath, loglevel, consoleloglevel);
}
}