--- /dev/null
+/*
+ * Copyright (c) 2007-2008 Fabrizio Frioli, Michele Pedrolli
+ *
+ * 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.
+ *
+ * --
+ *
+ * Please send your questions/suggestions to:
+ * {fabrizio.frioli, michele.pedrolli} at studenti dot unitn dot it
+ *
+ */
+
+package example.bittorrent;
+
+import peersim.core.*;
+import peersim.config.Configuration;
+import peersim.edsim.EDSimulator;
+import peersim.transport.Transport;
+import java.util.Random;
+
+/**
+ * This {@link Control} ...
+ */
+public class NetworkInitializer implements Control {
+ /**
+ * The protocol to operate on.
+ *
+ * @config
+ */
+ private static final String PAR_PROT="protocol";
+
+ private static final String PAR_TRANSPORT="transport";
+
+ private static final int TRACKER = 11;
+
+ private static final int CHOKE_TIME = 13;
+
+ private static final int OPTUNCHK_TIME = 14;
+
+ private static final int ANTISNUB_TIME = 15;
+
+ private static final int CHECKALIVE_TIME = 16;
+
+ private static final int TRACKERALIVE_TIME = 17;
+
+ /** Protocol identifier, obtained from config property */
+ private final int pid;
+ private final int tid;
+ private NodeInitializer init;
+
+ private Random rnd;
+
+ public NetworkInitializer(String prefix) {
+ pid = Configuration.getPid(prefix+"."+PAR_PROT);
+ tid = Configuration.getPid(prefix+"."+PAR_TRANSPORT);
+ init = new NodeInitializer(prefix);
+ }
+
+ public boolean execute() {
+ int completed;
+ Node tracker = Network.get(0);
+
+ // manca l'inizializzazione del tracker;
+
+ ((BitTorrent)Network.get(0).getProtocol(pid)).initializeTracker();
+
+ for(int i=1; i<Network.size(); i++){
+ System.err.println("chiamate ad addNeighbor " + i);
+ ((BitTorrent)Network.get(0).getProtocol(pid)).addNeighbor(Network.get(i));
+ init.initialize(Network.get(i));
+ }
+ for(int i=1; i< Network.size(); i++){
+ Node n = Network.get(i);
+
+ Object ev = new SimpleMsg(TRACKER, n);
+ long latency = ((Transport)n.getProtocol(tid)).getLatency(n,tracker);
+ EDSimulator.add(latency,ev,tracker,pid);
+// ((Transport) n.getProtocol(tid)).send(n,tracker, ev, pid);
+
+ ev = new SimpleEvent(CHOKE_TIME);
+ EDSimulator.add(10000,ev,n,pid);
+ ev = new SimpleEvent(OPTUNCHK_TIME);
+ EDSimulator.add(30000,ev,n,pid);
+ ev = new SimpleEvent(ANTISNUB_TIME);
+ EDSimulator.add(60000,ev,n,pid);
+ ev = new SimpleEvent(CHECKALIVE_TIME);
+ EDSimulator.add(120000,ev,n,pid);
+ ev = new SimpleEvent(TRACKERALIVE_TIME);
+ EDSimulator.add(1800000,ev,n,pid);
+ }
+ return true;
+ }
+
+ }
