listenserver.java

无线通信的主要编程软件,是无线通信工作人员的必备工具,关天相关教程我会在后续传上.

// $Id: ListenServer.java,v 1.2 2003/10/07 21:46:03 idgay 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: ListenServer.java
 *
 * Description:
 * The Listen Server is the heart of the serial forwarder.  Upon
 * instantiation, this class spawns the SerialPortReader and the
 * Multicast threads.  As clients connect, this class spawns
 * ServerReceivingThreads as wells as registers the new connection
 * SerialPortReader.  This class also provides the central
 * point of contact for the GUI, allowing the server to easily
 * be shut down
 *
 * @author <a href="mailto:[e-mail]">Bret Hull</a>
 */
package net.tinyos.sf.old;

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

public class ListenServer extends Thread {

    private static final String CLASS_NAME    = "Listen Server";
    private int                 m_nPort         = 0;
    private boolean             m_bShutdown     = false;
    private ServerSocket        m_serverSocket  = null;
    private Vector              vctServicers  = new Vector();
    private SerialForward sf;
    public ListenServer (SerialForward SF) {
        sf=SF;
        m_nPort       = sf.serverPort;
    }

    public void run () {
        boolean status;
	sf.DEBUG("Listen server running.");
        // open up our server socket
        try {m_serverSocket = new ServerSocket(m_nPort);}
        catch (IOException e) {
            sf.VERBOSE ("Could not listen on port: " + m_nPort);
            if (sf.cntrlWndw != null) {
                sf.cntrlWndw.ClearListenServer ();
            }
            return;
        }
        sf.VERBOSE ("Listening for client connections on port " + m_nPort);
        //if (SerialForward.bSourceSim)
        //{
	SetDataSource();
	sf.InitSerialPortIO();
        //}
        // start listening for connections
        try {
	    ClientServicer rcv;
            Socket currentSocket;
            while (!m_bShutdown) {
                currentSocket = m_serverSocket.accept();
                   ClientServicer newServicer = new ClientServicer (currentSocket, sf, this);
                   newServicer.start();
                   vctServicers.add (newServicer);
            }
            m_serverSocket.close();
        }
        catch (IOException e) {
            /*try { this.sleep(500); }
            catch (Exception e2) { }*/
            sf.VERBOSE ("Server Socket closed");
        }
        finally {
            ShutdownAllClientServicers();
            if(sf.serialPortIO!=null) sf.serialPortIO.Shutdown();
            sf.VERBOSE("--------------------------");
            if (sf.cntrlWndw != null) {
                sf.cntrlWndw.ClearListenServer ();
            }
        }
    }

    private void SetDataSource ()    {
        if (sf.useDummyData) {
            sf.dataSource = new DummySource (sf);
        }
        else if (sf.bSourceSim) {
	    try {
		sf.dataSource = (DataSource)(Class.forName("net.tinyos.sf.old.nido.SimNetworkDataSource").newInstance());
		sf.dataSource.setSerialForward(sf);
	    }
	    catch (Exception e) {
		System.err.println("Cannot instantiate SimNetworkDataSource - did you compile it? "+e);
      	    return;
	  }
        }
	else if (sf.bNidoSerialData) {
	  // Doing it this way to avoid having to compile NidoSerialDataSource
	  // which requires all of the TOSSIM event classes
	  //sf.dataSource = new NidoSerialDataSource(sf);
	  try {
	    sf.dataSource = (DataSource)(Class.forName("net.tinyos.sf.old.nido.NidoSerialDataSource").newInstance());
	    sf.dataSource.setSerialForward(sf);
	  } catch (Exception e) {
	    System.err.println("Cannot instantiate NidoSerialDataSource - did you compile it? "+e);
      	    return;
	  }
	}
        else if (sf.bSourceDB) {
            sf.dataSource = new DBSource (sf);
        } else if (sf.bQueuedSerial) {
	    System.out.println("USING QUEUED SERIAL SOURCE");
	    sf.dataSource = new QueuedSerialSource(sf);
	} else if (sf.commPort_is_socket) {
	    sf.dataSource = new NetworkSource(sf);
	} else {
            sf.dataSource = new SerialSource (sf);
        }
    }

    public void RestartDataSource () {
      SetDataSource();
      sf.InitSerialPortIO();
    }

    public void Shutdown () {
        if (!m_bShutdown) {
            m_bShutdown = true;

	    try {sf.dataSource.CloseSource();}
	    catch (Exception e) {}
	    
            try { if (m_serverSocket != null) m_serverSocket.close(); }
            catch (IOException e) { e.printStackTrace(); }
            this.interrupt();
        }
    }

    public void ShutdownAllClientServicers ( )
    {
        sf.VERBOSE( "CLIENTSERVICER: Shutting down all client connections" );
        ClientServicer crrntServicer;
        while ( vctServicers.size() != 0 )
        {
            crrntServicer = (ClientServicer) vctServicers.firstElement();
            crrntServicer.Shutdown();
            try {  crrntServicer.join(1000); }
            catch (InterruptedException e) { e.printStackTrace(); };
        }
    }

    public void RemoveClientServicer(ClientServicer clientS)
    {
        vctServicers.remove(clientS);
    }

}