sender.java

使用J2ME MIDP2.0實做AODV協定(RFC3561),測試平台為兩種PDA:PalmOS和PacketPC2003

/*
 * @(#)Sender.java	1.4 03/03/02
 *
 * Copyright (c) 2000-2003 Sun Microsystems, Inc. All rights reserved. 
 * PROPRIETARY/CONFIDENTIAL
 * Use is subject to license terms
 */
package TestDataPacket;

import qosaodv.itface.*;
import qosaodv.net.*;

import javax.microedition.midlet.*;
import javax.microedition.io.*;
import javax.microedition.lcdui.*;
import java.io.*;

public class Sender extends Thread {
	private UDPDatagramConnection dgc;    
	private boolean runFlag= true;
    private String addr;
	private byte[] bytes;

    public Sender(UDPDatagramConnection dgc2) {
        dgc= dgc2;
		bytes= null;
        addr= null;
        start();
    }

    public Sender() {
	    dgc= null; 
		bytes= null;
        addr= null;
        start();
    }

    public synchronized  void terminate() {
        runFlag= false;
        notify();
    }

    public synchronized void send(byte bytes2[], String addr2) {
        bytes= bytes2;
		addr= addr2;
		notify();
    }

    public synchronized void run() {

		try {
			if( dgc==null )
                dgc= (UDPDatagramConnection)Connector.open("datagram://127.0.0.1:1234");
    		Datagram dg= dgc.newDatagram( dgc.getMaximumLength() );

			while(runFlag) {

				// If no client to deal, wait until one connects
				if (bytes == null || addr==null) {
					try {
						wait();
					} catch (InterruptedException e) { }
				}

                if(!runFlag)
                    return;

				try {
                    dg.reset();
                    dg.setData(bytes, 0, bytes.length);
                    dg.setAddress(addr);
					dgc.send(dg);
	//				QDatagramControlor.send(dgc,dg,address);	//AODV 盡ノ send
					System.out.println("[Sender] Send complete.");
				} catch (Exception ioe) {
					ioe.printStackTrace();
				}

				// Completed client handling, return handler to pool and
				// mark for wait
				bytes= null;
				addr= null;
			}

///			dgc.close();
		} catch (Exception e) {
			e.printStackTrace();
		}


    }

}