kingparser.java

peersim仿真chord协议的测试过的环境

/*
 * Copyright (c) 2003-2005 The BISON Project
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License version 2 as
 * published by the Free Software Foundation.
 *
 * 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 Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 *
 */

package peersim.transport;

import java.io.*;
import java.util.*;
import peersim.config.*;
import peersim.core.Control;

/**
 * Initializes static singleton {@link E2ENetwork} by reading a king data set.
 * 
 * @author Alberto Montresor
 * @version $Revision: 1.9 $
 */
public class KingParser implements Control
{

// ---------------------------------------------------------------------
// Parameters
// ---------------------------------------------------------------------

/**
 * The file containing the King measurements.
 * @config
 */
private static final String PAR_FILE = "file";

/**
 * The ratio between the time units used in the configuration file and the
 * time units used in the Peersim simulator.
 * @config
 */
private static final String PAR_RATIO = "ratio";

// ---------------------------------------------------------------------
// Fields
// ---------------------------------------------------------------------

/** Name of the file containing the King measurements. */
private String filename;

/**
 * Ratio between the time units used in the configuration file and the time
 * units used in the Peersim simulator.
 */
private double ratio;

/** Prefix for reading parameters */
private String prefix;

// ---------------------------------------------------------------------
// Initialization
// ---------------------------------------------------------------------

/**
 * Read the configuration parameters.
 */
public KingParser(String prefix)
{
	this.prefix = prefix;
	ratio = Configuration.getDouble(prefix + "." + PAR_RATIO, 1);
	filename = Configuration.getString(prefix + "." + PAR_FILE, null);
}

// ---------------------------------------------------------------------
// Methods
// ---------------------------------------------------------------------

/**
 * Initializes static singleton {@link E2ENetwork} by reading a king data set.
* @return  always false
*/
public boolean execute()
{
	BufferedReader in = null;
	if (filename != null) {
		try {
			in = new BufferedReader(new FileReader(filename));
		} catch (FileNotFoundException e) {
			throw new IllegalParameterException(prefix + "." + PAR_FILE, filename
					+ " does not exist");
		}
	} else {
		in = new BufferedReader( new InputStreamReader(
						ClassLoader.getSystemResourceAsStream("t-king.map")
					)	);
	}
		
	// XXX If the file format is not correct, we will get quite obscure
	// exceptions. To be improved.

	String line = null;
	// Skip initial lines
	int size = 0;
	int lc = 1;
	try {
		while ((line = in.readLine()) != null && !line.startsWith("node")) lc++;
		while (line != null && line.startsWith("node")) {
			size++;
			lc++;
			line = in.readLine();
		}
	} catch (IOException e) {
		System.err.println("KingParser: " + filename + ", line " + lc + ":");
		e.printStackTrace();
		try { in.close(); } catch (IOException e1) { };
		System.exit(1);
	}
	E2ENetwork.reset(size, true);
	if (line == null) {
		System.err.println("KingParser: " + filename + ", line " + lc + ":");
		System.err.println("No latency matrix contained in the specified file");
		try { in.close(); } catch (IOException e1) { };
		System.exit(1);
	}
	
	System.err.println("KingParser: read " + size + " entries");
	
	try {
		do {
			StringTokenizer tok = new StringTokenizer(line, ", ");
			if (tok.countTokens() != 3) {
				System.err.println("KingParser: " + filename + ", line " + lc + ":");
				System.err.println("Specified line does not contain a <node1, node2, latency> triple");
				try { in.close(); } catch (IOException e1) { };
				System.exit(1);
			}
			int n1 = Integer.parseInt(tok.nextToken()) - 1;
			int n2 = Integer.parseInt(tok.nextToken()) - 1;
			int latency = (int) (Double.parseDouble(tok.nextToken()) * ratio);
			E2ENetwork.setLatency(n1, n2, latency);
			lc++;
			line = in.readLine();
		} while (line != null);
		
		in.close();
	
	} catch (IOException e) {
		System.err.println("KingParser: " + filename + ", line " + lc + ":");
		e.printStackTrace();
		try { in.close(); } catch (IOException e1) { };
		System.exit(1);
	}


	return false;
}

}