osoperationswindowsipv4.java

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

/*

QosAodv ver 0.2 - Java AODV (RFC 3561) Protocol Handler
Copyright 2003-2004 ComNets, University of Bremen

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

*/

package qosaodv.os;

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

import qosaodv.conf.*;
import qosaodv.net.*;
import qosaodv.other.*;

/**
* This class defines all the functions related to manipulating
* the routing environment of a Windows/IPv4 environment. Implements
* the OSOperationsInterface to provide a consistent interface
* to the route manager.
*
* @author : Koojana Kuladinithi
* @date : 06-oct-2003
* @email : [e-mail]
*
*/
public class OSOperationsWindowsIPv4 implements OSOperationsInterface {
	public ConfigInfo cfgInfo;
	public CurrentInfo curInfo;

	private Process proc;
	private String cmd, str, s;
	private BufferedReader stdInput, stdError;


	/**
	* Constructs the object
	*/
	public OSOperationsWindowsIPv4(ConfigInfo cfg, CurrentInfo cur) {
		cfgInfo = cfg;
		curInfo = cur;
	}

	/**
	* Method to initialize the routing environment
	* in a Windows IPv4 environment to perform AODV protocol
	* handling
	* @param int level - The initialization level
	*			0 = full initialization level
	*			1 - 100 = other init levels
	* @return int - returns the success or failure
	*/
	public int initializeRouteEnvironment(int level) {

                try {

			switch(level) {
				case 0:
					fullInit();
					break;
				case 1: 
					arpInit();
					break;
				default: // do nothing
					break;
			}

                } catch(Exception e) {
			// log
			curInfo.log.write(Logging.CRITICAL_LOGGING, "OS Ops IPv4 - Init failed");

			return 1;
                }
                return 0;
	}


	private void fullInit() throws Exception {

		curInfo.log.write(Logging.INFO_LOGGING, "OS Ops IPv4 - Init started");

		// set gateway MAC address to 00:00:00:00:00:00
		cmd = cfgInfo.pathToSystemCmdsVal + "\\arp -s "
				+ cfgInfo.ipAddressGatewayVal.getHostAddress()
				+ " 00-00-00-00-00-00 "
				+ cfgInfo.ipAddressVal.getHostAddress();


		curInfo.log.write(Logging.INFO_LOGGING, "OS Ops IPv4 - " + cmd);
                       proc = Runtime.getRuntime().exec(cmd);
		proc.waitFor();

		stdError = new BufferedReader(new InputStreamReader(proc.getErrorStream()));

		str = new String();
                while((s = stdError.readLine()) != null) {
                	str += s;
		}
		if(str.trim().length() > 0) {
			throw new Exception(str);
		}

		// set machine to act as router , has to be run in the background
		cmd = cfgInfo.pathToSystemCmdsVal + "\\EnableRouter ";

		curInfo.log.write(Logging.INFO_LOGGING, "OS Ops IPv4 - " + cmd);
                proc = Runtime.getRuntime().exec(cmd);

		// log
		curInfo.log.write(Logging.INFO_LOGGING, "OS Ops IPv4 - Init completed");
	}

	private void arpInit() throws Exception {
		// set gateway MAC address to 00:00:00:00:00:00
		cmd = cfgInfo.pathToSystemCmdsVal + "\\arp -s "
				+ cfgInfo.ipAddressGatewayVal.getHostAddress()
				+ " 00-00-00-00-00-00 "
				+ cfgInfo.ipAddressVal.getHostAddress();

		proc = Runtime.getRuntime().exec(cmd);
		proc.waitFor();
	}

	/**
	* Method to add a route entry in the routing environment
	* of a Windows/IPv4 environment.
	* @param RouteEntry rtEntry - the route entry from which to get
	*				information
	* @return int - returns the success or failure
	*/
	public int addRoute(RouteEntry rtEntry) {

                try {


			// the "nexthop via" clause is required only if the destination is
			// not in link local network (i.e. if only hop count > 1)
			if(rtEntry.destIPAddr.equals(rtEntry.nextHopIPAddr)) {
				cmd = cfgInfo.pathToSystemCmdsVal + "\\IpRoute -a "
					+ rtEntry.destIPAddr.getHostAddress()
					+ " 255.255.255.255 "
					+ rtEntry.destIPAddr.getHostAddress() + " "
					+ cfgInfo.ipAddressVal.getHostAddress();
			} else {
				cmd = cfgInfo.pathToSystemCmdsVal + "\\IpRoute -a "
					+ rtEntry.destIPAddr.getHostAddress()
					+ " 255.255.255.255 "
					+ rtEntry.nextHopIPAddr.getHostAddress() + " "
					+ cfgInfo.ipAddressVal.getHostAddress();
			}
			curInfo.log.write(Logging.INFO_LOGGING, "OS Ops IPv4 - Route add  " + cmd);
                        proc = Runtime.getRuntime().exec(cmd);
			proc.waitFor();

			// TODO : check for errors

		} catch(Exception e) {
			// log
			curInfo.log.write(Logging.CRITICAL_LOGGING, "OS Ops IPv4 - Route add failed");
                        return 1;
                }
                return 0;
	}

	/**
	* Method to remove a route entry in the routing environment of
	* a Windows/IPv4 environment
	* @param RouteEntry rtEntry - the route entry from which to get
	*				information
	* @return int - returns the success or failure
	*/
	public int deleteRoute(RouteEntry rtEntry) {

                try {

			cmd = cfgInfo.pathToSystemCmdsVal + "\\IpRoute -d "
				+ rtEntry.destIPAddr.getHostAddress();
			curInfo.log.write(Logging.INFO_LOGGING, "OS Ops IPv4 - Route delete " + cmd);
                        proc = Runtime.getRuntime().exec(cmd);

			// remove entry from ARP cache; only for routes in the link
			// network
			if(rtEntry.destIPAddr.equals(rtEntry.nextHopIPAddr)) {
				cmd = cfgInfo.pathToSystemCmdsVal + "\\arp -d "
					+ rtEntry.destIPAddr.getHostAddress();
			}

			// TODO : check for errors

                } catch(Exception e) {
			curInfo.log.write(Logging.CRITICAL_LOGGING, "OS Ops IPv4 - Route delete failed");
                        return 1;
                }
                return 0;
	}

	/**
	* Method to put the route environment to the original state
	* before terminating the protocol handler in Windows/IPv4
	* environment.
	* @return int - returns the success or failure
	*/
	public int finalizeRouteEnvironment() {

		try {

			curInfo.log.write(Logging.INFO_LOGGING, "OS Ops IPv4 - Termination started");
			cmd = cfgInfo.pathToSystemCmdsVal + "\\arp -d "
				+ cfgInfo.ipAddressGatewayVal.getHostAddress();
			curInfo.log.write(Logging.INFO_LOGGING, "OS Ops IPv4 - " + cmd);
                        proc = Runtime.getRuntime().exec(cmd);

                        stdError = new BufferedReader(new InputStreamReader(proc.getErrorStream()));

			str = new String();
                        while((s = stdError.readLine()) != null) {
                                str += s;
			}
			if(str.trim().length() > 0) {
				throw new Exception(str);
			}

			curInfo.log.write(Logging.INFO_LOGGING, "OS Ops IPv4 - Termination completed");

                } catch(Exception e) {
			curInfo.log.write(Logging.CRITICAL_LOGGING, "OS Ops IPv4 - Termination failed");
                        return 1;
                }
                return 0;
	}
}