--- /dev/null
+package psgsim;
+
+import java.io.*;
+import java.util.Comparator;
+import java.util.LinkedHashMap;
+import java.util.Map;
+import java.util.TreeMap;
+
+import org.jdom2.*;
+import org.jdom2.output.*;
+import org.simgrid.msg.Host;
+import org.simgrid.msg.Msg;
+
+import peersim.config.Configuration;
+import peersim.core.Control;
+import peersim.core.Protocol;
+
+/**
+ * A class store different configuration information for simulation. It creates
+ * the deployment file according to this informations.
+ *
+ * @author Khaled Baati 26/10/2014
+ * @version version 1.1
+ */
+
+public class PSGPlatform {
+
+ enum timeUnit {
+ us, ms, sec;
+ }
+
+ /** unit of measure. **/
+ static int unit;
+
+ /** the clock. **/
+ static double time;
+
+ /** the default unit of measure **/
+ static final String sec = "sec";
+
+ /** All protocols defined in the configuration file. **/
+ static Protocol[] protocolsName;
+
+ /** A numeric identifier associated for each protocol. **/
+ static int[] pid;
+
+ /** List of hos.t **/
+ static Host[] hostList;
+
+ /** A collection map represents the Control and its associated step. **/
+ static Map<Control, Double> controlStepMap = new LinkedHashMap<Control, Double>();
+
+ /** A collection map represents the protocol and its associated pid. **/
+ static TreeMap<Protocol, Integer> protocolsPidsMap = new TreeMap<Protocol, Integer>(
+ new Comparator<Protocol>() {
+ public int compare(Protocol p1, Protocol p2) {
+ return p1.toString().compareTo(p2.toString());
+ }
+ });
+
+ /** A collection map represents all CDProtocol and its associated step **/
+ static TreeMap<Protocol, Double> cdProtocolsStepMap = new TreeMap<Protocol, Double>(
+ new Comparator<Protocol>() {
+ public int compare(Protocol p1, Protocol p2) {
+ return p1.toString().compareTo(p2.toString());
+ }
+ });
+ /** the default platform file **/
+ static final String platformFile = "platforms/psg.xml";
+
+ /** the deployment file **/
+ static final String deploymentFile = "deployment.xml";
+
+ static Element racine;
+ static Document document;
+ static boolean interfED = false;
+ static boolean interfCD = false;
+
+ /** Prepare the deployment file **/
+ static {
+ DocType dtype = new DocType("platform",
+ "http://simgrid.gforge.inria.fr/simgrid.dtd");
+ racine = new Element("platform");
+ document = new Document(racine, dtype);
+ Attribute version = new Attribute("version", "3");
+ racine.setAttribute(version);
+ }
+
+ // ========================== methods ==================================
+ // =====================================================================
+
+ /**
+ * Convert PS unit time to Simgrid unit time
+ *
+ * @param valeur
+ * the value to convert
+ * @return time converted
+ */
+ public static double psToSgTime(long valeur) {
+ timeUnit unit = unit();
+ switch (unit) {
+ case us:
+ return ((double) valeur) / 1000000;
+ case ms:
+ return ((double) valeur) / 1000;
+ default:
+ return (double) valeur;
+
+ }
+ }
+
+ /**
+ * Convert Simgrid unit time to PS unit time
+ *
+ * @param valeur
+ * the value to convert
+ * @return time converted
+ */
+ public static long sgToPsTime(double valeur) {
+ timeUnit unit = unit();
+ switch (unit) {
+ case us:
+ return (long) valeur * 1000000;
+ case ms:
+ return (long) valeur * 1000;
+ default:
+ return (long) valeur;
+
+ }
+ }
+
+ /**
+ *
+ * @return the duration of simulation.
+ */
+ public static long getDuration() {
+ return Configuration.getLong("simulation.duration");
+ }
+
+ /**
+ *
+ * @return PeerSim Time
+ */
+ public static long getTime() {
+ return sgToPsTime(Msg.getClock());
+ }
+
+ /**
+ *
+ * @return the Simgrid Clock
+ */
+ public static double getClock() {
+ return Msg.getClock();
+ }
+
+ /**
+ * Load and run initializers.
+ */
+ public static void init() {
+ Object[] inits = Configuration.getInstanceArray("init");
+ String names[] = Configuration.getNames("init");
+ for (int i = 0; i < inits.length; ++i) {
+ System.err.println("- Running initializer " + names[i] + ": "
+ + inits[i].getClass().toString());
+ ((Control) inits[i]).execute();
+ }
+ }
+
+ /**
+ * Load all controls and stores them in {@link #controlStepMap} collection
+ * to be scheduled, and executed in {@link psgsim.PSGProcessController}.
+ */
+ public static void control() {
+ // load controls
+ String[] names = Configuration.getNames("control");
+ Control control;
+ for (int i = 0; i < names.length; ++i) {
+ control = (Control) Configuration.getInstance(names[i]);
+ Long stepControl = Configuration.getLong(names[i] + "." + "step");
+ controlStepMap.put(control, psToSgTime(stepControl));
+ }
+ }
+
+ /**
+ * Lookup all protocols in the configuration file
+ */
+ public static void protocols() {
+ String[] names = Configuration.getNames("protocol");
+ Class[] interfaces;
+ protocolsName = new Protocol[names.length];
+ pid = new int[names.length];
+ boolean save = false;
+ for (int i = 0; i < names.length; i++) {
+ protocolsName[i] = (Protocol) Configuration.getInstance(names[i]);
+ if (i == names.length - 1)
+ save = true;
+ userProtocol(protocolsName[i], names[i], save);
+ pid[i] = i;
+ protocolsPidsMap.put(protocolsName[i], pid[i]);
+ }
+
+ }
+
+ /**
+ * Lookup CDProtocol and EDProtocol among all protocols
+ *
+ * @param prot
+ * the protocol class
+ * @param names
+ * the protocol name
+ * @param save
+ * parameter equal true when parsing all protocols
+ */
+ public static void userProtocol(Protocol prot, String names, boolean save) {
+ Class[] interfaces = prot.getClass().getInterfaces();
+ for (int j = 0; j < interfaces.length; j++) {
+ if (interfaces[j].getName().endsWith("EDProtocol")) {
+ interfED = true;
+ }
+ if (interfaces[j].getName().endsWith("CDProtocol")) {
+ String protName = names.substring("protocol".length() + 1);
+ long step = Configuration.getLong("protocol" + "." + protName
+ + "." + "step");
+ cdProtocolsStepMap.put(prot, psToSgTime(step));
+ }
+ }
+ if (save) {
+ edProt();
+ }
+ }
+
+ /**
+ *
+ */
+ private static void edProt() {
+ Host hostVal;
+ hostList = Host.all();
+ for (int i = 0; i < PSGSimulator.size; i++) {
+ hostVal = hostList[i];
+ Element process = new Element("process");
+ racine.addContent(process);
+ Attribute host = new Attribute("host", hostVal.getName());
+ Attribute function = new Attribute("function",
+ "psgsim.PSGProcessEvent");
+ process.setAttribute(host);
+ process.setAttribute(function);
+ }
+ save(deploymentFile);
+
+ }
+
+ /**
+ *
+ */
+ @Deprecated
+ private static void cdProt() {
+ for (int i = 0; i < PSGSimulator.size; i++) {
+ Element process = new Element("process");
+ racine.addContent(process);
+ Attribute host = new Attribute("host", String.valueOf(i));
+ Attribute function = new Attribute("function",
+ "psgsim.PSGProcessCycle");
+ process.setAttribute(host);
+ process.setAttribute(function);
+
+ }
+ save("deployment.xml");
+
+ }
+
+ /**
+ * Reads given configuration property: "platform". If not found, returns the
+ * default value.
+ *
+ * @return the platform file
+ */
+ public static String platformFile() {
+ String defFile = platformFile;
+ String file = Configuration.getString("platform", defFile);
+ return file;
+ }
+
+ /**
+ * Reads given configuration property: "unit". If not found, returns the
+ * default value (ms).
+ *
+ * @return the unit of measure
+ */
+ public static timeUnit unit() {
+ String defUnit = sec;
+ String unit = Configuration.getString("unit", defUnit);
+ timeUnit t = timeUnit.valueOf(unit);
+ return t;
+ }
+
+ /**
+ * Create the deployment file
+ *
+ * @param file
+ * the name of the deployment file
+ */
+ public static void save(String file) {
+ try {
+ // On utilise ici un affichage classique avec getPrettyFormat()
+ XMLOutputter out = new XMLOutputter(Format.getPrettyFormat());
+ out.output(document, new FileOutputStream(file));
+ } catch (java.io.IOException e) {
+ }
+ }
+
+ /**
+ * Delete the deployment file
+ *
+ * @param path
+ * the path of the deployment file
+ */
+ public static void delete(String path) {
+ File file = new File(path);
+ try {
+ file.delete();
+ } catch (Exception e) {
+ System.err.println("deployment file not found");
+
+ }
+ System.err.println(path + "file deleted");
+
+ }
+
+}
