serialforwarder.java

传感器网络中的嵌入式操作系统源代码

// $Id: SerialForwarder.java,v 1.2.2.4 2003/09/12 15:00:41 mdwelsh Exp $

/*									tab:4
 * "Copyright (c) 2000-2003 The Regents of the University  of California.  
 * All rights reserved.
 *
 * Permission to use, copy, modify, and distribute this software and its
 * documentation for any purpose, without fee, and without written agreement is
 * hereby granted, provided that the above copyright notice, the following
 * two paragraphs and the author appear in all copies of this software.
 * 
 * IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY PARTY FOR
 * DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES ARISING OUT
 * OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN IF THE UNIVERSITY OF
 * CALIFORNIA HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 * 
 * THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,
 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
 * AND FITNESS FOR A PARTICULAR PURPOSE.  THE SOFTWARE PROVIDED HEREUNDER IS
 * ON AN "AS IS" BASIS, AND THE UNIVERSITY OF CALIFORNIA HAS NO OBLIGATION TO
 * PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS."
 *
 * Copyright (c) 2002-2003 Intel Corporation
 * All rights reserved.
 *
 * This file is distributed under the terms in the attached INTEL-LICENSE     
 * file. If you do not find these files, copies can be found by writing to
 * Intel Research Berkeley, 2150 Shattuck Avenue, Suite 1300, Berkeley, CA, 
 * 94704.  Attention:  Intel License Inquiry.
 */


/**
 * File: SerialForwarder.java
 *
 * Description:
 * The SerialForwarder class provides many static functions
 * that handle the initialization of the serialforwarder
 * and/or the associated gui.
 *
 * @author <a href="mailto:[e-mail]">Bret Hull</a>
 * @author <a href="mailto:[e-mail]">David Gay</a>
 */
package net.tinyos.sf;

import java.io.*;
import javax.swing.*;
import java.awt.event.*;
import net.tinyos.packet.*;
import net.tinyos.util.*;

public class SerialForwarder implements Messenger {
    // appication defaults
    public SFWindow cntrlWndw;
    public SFListen listenServer;
    public String motecom = "serial@COM1";
    public boolean logDB;

    public int serverPort = 9001;

    private boolean guiMode = true;
    private boolean displayHelp = false;
    private int nClients = 0;
    private int nPacketsRead = 0;
    private int nPacketsWritten = 0;
    private SFListen listener = null;
    SFMessenger verbose = new SFMessenger(true);
    SFMessenger debug = new SFMessenger(false);

    class SFMessenger implements Messenger {
	boolean on;

	SFMessenger(boolean on) {
	    this.on = on;
	}

	public void message(String message) {
	    if (on) {
		SerialForwarder.this.message(message);
	    }
	}
    }

    public static void main(String[] args) throws IOException {
	new SerialForwarder(args);
    }

    public SerialForwarder(String[] args) throws IOException {
        ProcessCommandLineArgs (args);

	if (displayHelp) {
	    printHelp();
	    System.exit(2);
	}
	if (guiMode) {
	    createGui();
	}
	startListenServer();
    }

    private void ProcessCommandLineArgs(String[] args) {
	for (int i = 0; i < args.length; i++) {
	    debug.message(args[i]);
	}
	for (int i = 0; i < args.length; i++) {
	    if (args[i].equals ("-no-gui")) {
		guiMode = false;
	    }
	    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 9000)");
	System.err.println ("-comm [motecom spec] (default serial@COM1)");
	System.err.println ("-packetsize [size] (default 36)");
	System.err.println ("-no-gui      = do not display graphic interface");
	System.err.println ("-quiet       = non-verbose mode");
	System.err.println ("-debug       = display debug messages");
	System.err.println ("-log         = log to database");
    }

    private void createGui() {
	JFrame mainFrame = new JFrame("SerialForwarder");
	cntrlWndw = new SFWindow(this);
	mainFrame.setSize(cntrlWndw.getPreferredSize());
	mainFrame.getContentPane().add("Center", cntrlWndw);
	mainFrame.show();
	mainFrame.addWindowListener(cntrlWndw);
    }

    public void message(String msg) {
	if (cntrlWndw != null) {
	    cntrlWndw.message(msg);
	}
	else {
	    System.err.println(msg);
	}
    }

    synchronized public void incrementPacketsRead() {
        nPacketsRead++;
        if (cntrlWndw != null) {
	    cntrlWndw.updatePacketsRead(nPacketsRead);
	}
    }

    synchronized public void incrementPacketsWritten() {
        nPacketsWritten++;
        if (cntrlWndw != null) {
	    cntrlWndw.updatePacketsWritten(nPacketsWritten);
	}
    }

    synchronized public void incrementClients() {
        nClients++;
        if (cntrlWndw != null) {
	    cntrlWndw.updateNumClients(nClients);
	}
    }

    synchronized public void decrementClients() {
        nClients--;
        if (cntrlWndw != null) {
	    cntrlWndw.updateNumClients(nClients);
	}
    }

    public synchronized void startListenServer() {
	if (listenServer == null) {
	    nClients = nPacketsRead = nPacketsWritten = 0;
	    listenServer = new SFListen(this);
	    listenServer.start();
	}
	if (cntrlWndw != null) {
	    cntrlWndw.updateListenServerStatus(true);
	    cntrlWndw.updateNumClients(nClients);
	    cntrlWndw.updatePacketsWritten(nPacketsWritten);
	    cntrlWndw.updatePacketsRead(nPacketsRead);
	}
    }

    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;
	if (cntrlWndw != null) {
	    cntrlWndw.updateListenServerStatus(false);
	}
    }
}