// ---------------------------------------------------------------------------- // Copyright 2007-2013, GeoTelematic Solutions, Inc. // All rights reserved // ---------------------------------------------------------------------------- // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // // ---------------------------------------------------------------------------- // Change History: // 2006/03/26 Martin D. Flynn // -Initial release // 2006/04/23 Martin D. Flynn // -Integrated logging changes made to Print // 2007/01/25 Martin D. Flynn // -Moved to "OpenGTS" // 2007/02/18 Martin D. Flynn // -Added support for listening on multiple ports // -Added command-line option to display help // 2007/02/26 Martin D. Flynn // -No longer maintains a 'static final' copy of the OpenDMTP version. // This allows the OpenDMTP version display to properly reflect the version // of the loaded 'dmtpserv.jar' file. // 2007/06/30 Martin D. Flynn // -Added ability to set tcp/udp timeouts from the config file. // 2007/07/27 Martin D. Flynn // -Repackaged to "org.opengts.servers.gtsdmtp" // ---------------------------------------------------------------------------- package org.opengts.servers.gtsdmtp; import java.lang.*; import java.util.*; import java.io.*; import org.opengts.util.*; import org.opengts.dbtools.*; import org.opengts.dbtypes.*; import org.opengts.db.*; import org.opengts.db.dmtp.*; import org.opengts.db.tables.*; import org.opendmtp.server.base.DMTPServer; import org.opendmtp.server.base.DMTPClientPacketHandler; public class Main { // ---------------------------------------------------------------------------- /* command-line argument keys */ public static final String ARG_HELP[] = new String[] { "h", "help" }; public static final String ARG_PORT[] = new String[] { "p", "port" }; public static final String ARG_START[] = new String[] { "start" }; // ------------------------------------------------------------------------ public static final String COPYRIGHT = org.opengts.Version.COPYRIGHT; public static final String VERSION = "1.2.3"; // ------------------------------------------------------------------------ public static final String DEVICE_CODE = DCServerFactory.OPENDMTP_NAME; /* runtime config file key */ public static final String CFG_firstSessionNegotiation = DEVICE_CODE + ".firstSessionNegotiation"; public static final String CFG_udpReturnResponse = DEVICE_CODE + ".udpReturnResponse"; // ------------------------------------------------------------------------ // ------------------------------------------------------------------------ public static String DCServerFactory_LoadName() { return Main.getServerContextName(); } /* return server config */ public static String getServerName() { return DCServerFactory.OPENDMTP_NAME; } public static String getServerContextName() { return RTConfig.getContextName(Main.getServerName()); } /* return server config */ private static DCServerConfig dcServerCfg = null; public static DCServerConfig getServerConfig() { if (dcServerCfg == null) { dcServerCfg = DCServerFactory.getServerConfig(Main.getServerContextName()); DCServerConfig.startRemoteLogging(dcServerCfg); } return dcServerCfg; } // ------------------------------------------------------------------------ /* get server TCP ports (first check command-line, then config file) */ public static int[] getTcpPorts() { DCServerConfig dcs = Main.getServerConfig(); if (dcs != null) { return dcs.getTcpPorts(); } else { Print.logError("DCServerConfig not found for server: " + Main.getServerName()); return null; } } /* get server UDP ports (first check command-line, then config file) */ public static int[] getUdpPorts() { DCServerConfig dcs = Main.getServerConfig(); if (dcs != null) { return dcs.getUdpPorts(); } else { Print.logError("DCServerConfig not found for server: " + Main.getServerName()); return null; } } /* get server UDP ports (first check command-line, then config file) */ public static int[] getListenPorts() { java.util.List portList = new Vector(); // TCP ports int tcpPorts[] = Main.getTcpPorts(); for (int t = 0; t < tcpPorts.length; t++) { Integer tcp = new Integer(tcpPorts[t]); portList.add(tcp); } // UDP ports int udpPorts[] = Main.getUdpPorts(); for (int u = 0; u < udpPorts.length; u++) { Integer udp = new Integer(udpPorts[u]); if (!portList.contains(udp)) { portList.add(udp); } } // convert to array, return int ports[] = new int[portList.size()]; for (int p = 0; p < portList.size(); p++) { ports[p] = portList.get(p).intValue(); } return ports; } // ------------------------------------------------------------------------ // ------------------------------------------------------------------------ /* display usage and exit */ private static void usage(String msg) { /* print message */ if (msg != null) { Print.logInfo(msg); } /* print usage */ Print.logInfo(""); Print.logInfo("Usage:"); Print.logInfo(" java ... " + Main.class.getName() + " {options}"); Print.logInfo("Options:"); Print.logInfo(" [-h[elp]] Print this help"); Print.logInfo(" [-port=

[,

]] Server port(s) to listen on"); Print.logInfo(" -start Start server on the specified port"); Print.logInfo(""); /* exit */ System.exit(1); } /* main entry point */ public static void main(String argv[]) { /* runtime default properties */ RTKey.addRuntimeEntry(new RTKey.Entry(CFG_firstSessionNegotiation, true, "DMTP allow 1st session custom event negotiation")); RTKey.addRuntimeEntry(new RTKey.Entry(CFG_udpReturnResponse , true, "DMTP return UDP response/ack")); /* load runtime config */ DBConfig.cmdLineInit(argv,false); /* register OpenDMTP protocol DB interface */ DMTPServer.setDBFactory(new DMTPDBFactory()); /* header */ Print.logInfo("----------------------------------------------------------------"); Print.logInfo("OpenDMTP (GTS) Java Server"); Print.logInfo(COPYRIGHT); Print.logInfo("DMTP Version : " + org.opendmtp.server.Version.getVersion()); Print.logInfo("GTSDMTP Version : " + VERSION); Print.logInfo("GTS Version : " + org.opengts.Version.getVersion()); Print.logInfo("SQL Database Name: " + RTConfig.getString(RTKey.DB_NAME)); Print.logInfo("Transport Enabled: " + Transport.isTransportQueryEnabled()); Print.logInfo("Message Log Level: " + Print.getLogLevelString(Print.getLogLevel())); //Print.logInfo("Process ID : " + OSTools.getProcessID()); // useless on Windows Print.logInfo("----------------------------------------------------------------"); /* explicit help? */ if (RTConfig.getBoolean(ARG_HELP,false)) { Main.usage("Help ..."); // control doesn't reach here } /* validate ports here */ int listenPorts[] = Main.getListenPorts(); /* make sure the DB is properly initialized */ if (!DBAdmin.verifyTablesExist()) { Print.logFatal("MySQL database has not yet been properly initialized"); System.exit(1); } /* DCServerConfig */ DCServerConfig dcs = Main.getServerConfig(); /* alow first session custom event packet negotiation */ if (RTConfig.hasProperty(CFG_firstSessionNegotiation)) { // This section requires OpenDMTP v1.2.14.1+ // If you receive a compile error here, simply comment the following lines if (RTConfig.getBoolean(CFG_firstSessionNegotiation,true)) { DMTPServer.setAllowFirstSessionNegotiation(true); } else { Print.logInfo("First session custom event packet negotiation DISABLED ..."); DMTPServer.setAllowFirstSessionNegotiation(false); } } else { if (dcs.getBooleanProperty(CFG_firstSessionNegotiation,true)) { DMTPServer.setAllowFirstSessionNegotiation(true); } else { Print.logInfo("First session custom event packet negotiation DISABLED ..."); DMTPServer.setAllowFirstSessionNegotiation(false); } } /* return UDP response/ack */ if (RTConfig.hasProperty(CFG_udpReturnResponse)) { if (RTConfig.getBoolean(CFG_udpReturnResponse,true)) { Print.logInfo("UDP responses/acks will be returned to UDP packets ..."); DMTPClientPacketHandler.setUdpReturnResponse(true); } else { Print.logInfo("No UDP responses will be returned ..."); DMTPClientPacketHandler.setUdpReturnResponse(false); } } else { if (dcs.getBooleanProperty(CFG_udpReturnResponse,true)) { Print.logInfo("UDP responses/acks will be returned to UDP packets ..."); DMTPClientPacketHandler.setUdpReturnResponse(true); } else { Print.logInfo("No UDP responses will be returned ..."); DMTPClientPacketHandler.setUdpReturnResponse(false); } } /* init DeviceDMImpl */ DeviceDBImpl.configInit(); String dcsName = dcs.getName(); /* TCP timeouts */ long tcpIdleTimeout = dcs.getTcpIdleTimeoutMS(-1L); if (tcpIdleTimeout > 0L) { DMTPServer.setTcpIdleTimeout(tcpIdleTimeout); } long tcpPcktTimeout = dcs.getTcpPacketTimeoutMS(-1L); if (tcpPcktTimeout > 0L) { DMTPServer.setTcpPacketTimeout(tcpPcktTimeout); } long tcpSessTimeout = dcs.getTcpSessionTimeoutMS(-1L); if (tcpSessTimeout > 0L) { DMTPServer.setTcpSessionTimeout(tcpSessTimeout); } /* UDP timeouts */ long udpIdleTimeout = dcs.getUdpIdleTimeoutMS(-1L); if (udpIdleTimeout > 0L) { DMTPServer.setUdpIdleTimeout(udpIdleTimeout); } long udpPcktTimeout = dcs.getUdpPacketTimeoutMS(-1L); if (udpPcktTimeout > 0L) { DMTPServer.setUdpPacketTimeout(udpPcktTimeout); } long udpSessTimeout = dcs.getUdpSessionTimeoutMS(-1L); if (udpSessTimeout > 0L) { DMTPServer.setUdpSessionTimeout(udpSessTimeout); } /* start server */ if (RTConfig.getBoolean(ARG_START,false)) { /* start port listeners */ try { DMTPServer.createTrackSocketHandler(listenPorts); } catch (Throwable t) { // trap any server exception Print.logError("Error: " + t); } /* wait here forever while the server is running in a thread */ while (true) { try { Thread.sleep(60L * 60L * 1000L); } catch (Throwable t) {} } // control never reaches here } /* display usage */ Main.usage("Please specify an option ..."); } }