+ for (int i = 0; i < args.length; i++) {
+ if (args[i].equals("-no-gui") && renderer == null) {
+ renderer = new SFConsoleRenderer();
+
+ } else if(args[i].equals("-no-output") && renderer == null) {
+ renderer = new SFNullRenderer();
+
+ } else if (args[i].equals("-comm")) {
+ i++;
+ if (i < args.length) {
+ motecom = args[i];
+ } else {
+ displayHelp = true;
+ }
+
+ } else if (args[i].equals("-port")) {
+ i++;
+ if (i < args.length) {
+ serverPort = Integer.parseInt(args[i]);
+ } else {
+ displayHelp = true;
+ }
+ } else if (args[i].equals("-log")) {
+ logDB = true;
+ } else if (args[i].equals("-quiet")) {
+ verbose.on = false;
+ } else if (args[i].equals("-debug")) {
+ debug.on = true;
+ } else {
+ displayHelp = true;
+ }
+ }
+ }
+
+ private static void printHelp() {
+ System.err.println("optional arguments:");
+ System.err.println("-port [server port] (default " + DEFAULT_PORT + ")");
+ System.err.println("-comm [motecom spec] (default serial@com1:57600)");
+ System.err.println("-packetsize [size] (default 36)");
+ System.err.println("-no-gui = do not display graphic interface");
+ System.err.println("-no-output");
+ System.err.println("-quiet = non-verbose mode");
+ System.err.println("-debug = display debug messages");
+ System.err.println("-log = log to database");
+ }
+
+ private void createGui() {
+ renderer = SFWindow.createGui(this, "SerialForwarder");
+ }
+
+ public void message(String msg) {
+ renderer.message(msg);
+ }
+
+ synchronized public void incrementPacketsRead() {
+ nPacketsRead++;
+ renderer.updatePacketsRead(nPacketsRead);
+ }
+
+ synchronized public void incrementPacketsWritten() {
+ nPacketsWritten++;
+ renderer.updatePacketsWritten(nPacketsWritten);
+ }
+
+ synchronized public void incrementClients() {
+ nClients++;
+ renderer.updateNumClients(nClients);
+ }
+
+ synchronized public void decrementClients() {
+ nClients--;
+ renderer.updateNumClients(nClients);
+ }
+
+ public synchronized void clearCounts() {
+ nPacketsRead = nPacketsWritten = 0;
+ renderer.updatePacketsWritten(nPacketsWritten);
+ renderer.updatePacketsRead(nPacketsRead);
+ }
+
+ public synchronized void startListenServer() {
+ if (listenServer == null) {
+ nClients = 0;
+ listenServer = new SFListen(this);
+ listenServer.start();
+ }
+ renderer.updateListenServerStatus(true);
+ renderer.updateNumClients(nClients);
+ clearCounts();
+ }
+
+ public void stopListenServer() {
+ SFListen lserver;
+
+ // We can't just make stopSFListen synchronized because
+ // listenServerStopped must be synchronized too
+ synchronized (this) {
+ lserver = listenServer;
+ if (lserver != null)
+ listenServer.shutdown();
+ }
+ if (lserver != null) {
+ try {
+ lserver.join(2000);
+ } catch (InterruptedException ex) {
+ }
+ }
+ }
+
+ public synchronized void listenServerStopped() {
+ listenServer = null;
+ renderer.updateListenServerStatus(false);
+ }