serialportstub.java

无线传感器网络操作系统源代码

/* 
 * Author: Mike Chen <[e-mail]>
 * Inception Date: October 22th, 2000
 *
 * This software is copyrighted by Mike Chen and the Regents of
 * the University of California.  The following terms apply to all
 * files associated with the software unless explicitly disclaimed in
 * individual files.
 * 
 * The authors hereby grant permission to use this software without
 * fee or royalty for any non-commercial purpose.  The authors also
 * grant permission to redistribute this software, provided this
 * copyright and a copy of this license (for reference) are retained
 * in all distributed copies.
 *
 * For commercial use of this software, contact the authors.
 * 
 * IN NO EVENT SHALL THE AUTHORS OR DISTRIBUTORS BE LIABLE TO ANY PARTY
 * FOR DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES
 * ARISING OUT OF THE USE OF THIS SOFTWARE, ITS DOCUMENTATION, OR ANY
 * DERIVATIVES THEREOF, EVEN IF THE AUTHORS HAVE BEEN ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 *
 * THE AUTHORS AND DISTRIBUTORS SPECIFICALLY DISCLAIM ANY WARRANTIES,
 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE, AND NON-INFRINGEMENT.  THIS SOFTWARE
 * IS PROVIDED ON AN "AS IS" BASIS, AND THE AUTHORS AND DISTRIBUTORS HAVE
 * NO OBLIGATION TO PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR
 * MODIFICATIONS.
 */

//==============================================================================
//===   SerialPortStub.java   ==============================================


package net.tinyos.util;

import java.util.*;
import java.io.*;
import javax.comm.*;

/**
 * 
 * Init the serial port and reads data from it.
 *
 * @author  <A HREF="http://www.cs.berkeley.edu/~mikechen/">Mike Chen</A> 
 *		(<A HREF="mailto:[e-mail]">[e-mail]</A>)
 * @since   1.1.6
 */


public class SerialPortStub implements SerialStub{

    //=========================================================================
    //=   CONSTANTS   =========================================================
  
    private static final String  CLASS_NAME                  = "SerialPortStub";
    private static final String  VERSION     	         = "v0.1";


    //size of a message, in bytes
    private static final int MSG_SIZE = 36;

    //=   CONSTANTS   =========================================================
    //===========================================================================
  
    //=========================================================================
    //=   PRIVATE VARIABLES   =================================================

    CommPortIdentifier portId;
    SerialPort port;
    String portName;
    InputStream in;
    OutputStream out;
    PacketListenerIF listener;
    public static int debug = 0;


    //=   PRIVATE VARIABLES   =================================================
    //=========================================================================
  
  
    //=========================================================================
    //=   NONLOCAL INSTANCE VARIABLES   =======================================
      
    //=   NONLOCAL INSTANCE VARIABLES   =======================================
    //=========================================================================
      
    //=========================================================================
    //=   CONSTRUCTORS   ======================================================
  
    /**
     * Default constructor.
     */

    //=   CONSTRUCTORS   ======================================================
    //=========================================================================
      
    //=========================================================================
  

    /**
     *  .
     */

    public SerialPortStub(String portName) {
	this.portName = portName;
    }


    //=========================================================================

    public void Open() throws NoSuchPortException, PortInUseException, IOException, UnsupportedCommOperationException {
	portId = CommPortIdentifier.getPortIdentifier(portName);
	port = (SerialPort)portId.open(CLASS_NAME, 0);
	in = port.getInputStream();
	out = port.getOutputStream();
  port.setFlowControlMode(SerialPort.FLOWCONTROL_NONE);

  //	port.setFlowControlMode(SerialPort.FLOWCONTROL_RTSCTS_IN);
  //	port.setFlowControlMode(SerialPort.FLOWCONTROL_RTSCTS_OUT);

	printPortStatus();
	port.setSerialPortParams(19200, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
	printPortStatus();
    }

    private void printPortStatus() {
	System.out.println("baud rate: " + port.getBaudRate());
	System.out.println("data bits: " + port.getDataBits());
	System.out.println("stop bits: " + port.getStopBits());
	System.out.println("parity:    " + port.getParity());
    }

    //=========================================================================

    /*
     *  Get an enumeration of all of the comm ports 
     *  on the machine
     */
  
    public void printAllPorts() {
	Enumeration ports = CommPortIdentifier.getPortIdentifiers();
  
	if (ports == null) {
	    System.out.println("No comm ports found!");
	    return;
	}
  
	// print out all ports
	System.out.println("printing all ports...");
	while (ports.hasMoreElements()) {
	    System.out.println("-  " + ((CommPortIdentifier)ports.nextElement()).getName());
	}
	System.out.println("done.");
    }

  
    //=======================================================================  

    public void registerPacketListener(PacketListenerIF listener) {
	this.listener = listener;
    }


    //=======================================================================  

    public synchronized void Read() throws IOException {
	int i; 
	int count = 0;
	byte[] packet = new byte[MSG_SIZE];
	if (debug > 0)
	    System.out.print("!");

	while ((i = in.read()) != -1) {
	    if (debug > 0)
		System.out.print("!");
	    packet[count] = (byte)i;
	    count++;
	    if (count == MSG_SIZE) {
		count = 0;
		listener.packetReceived(packet);
	    }else if(count == 1 && i != 0x7e){
		count = 0;
		if (debug > 0)
		    System.out.print("?");
	    }
	}
    }

    public  void Write(byte [] packet ) throws IOException {
	int i; 
	if (debug > 0)
	    System.out.print("-");
	out.write(packet);
	out.flush();
    }


    public static void main(String args[]) {
	if (args.length != 1) {
	    System.err.println("usage: java SerialPortStub [port]");
	    System.exit(-1);
	}

	System.out.println("\nSerialPortStub started");
	SerialPortStub reader = new SerialPortStub(args[0]);
	try {
	    reader.printAllPorts();
	    reader.Open();
	}
	catch (Exception e) {
	    e.printStackTrace();
	}

	try {
	    reader.Read();
	}
	catch (Exception e) {
	    e.printStackTrace();
	}
    }

}
//===   MAIN    =============================================================
//===========================================================================



// of Class SerialPortStub

//===   SerialPortStub.java   =============================================
//=============================================================================



//////////////////////////////////////////////////
// Fix the emacs editing mode
// Local Variables: ***
// c-basic-offset:4 ***
// End: ***
//////////////////////////////////////////////////