+++ /dev/null
-/*
- * 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;
-}
-
-}
