X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/24dbcb1a8071fe684d776063f04b314d92094e8d..23da67335f942457b0d8b1f10e9849eba0eee9f7:/contrib/psg/src/example/bittorrent/BTObserver.java

diff --git a/contrib/psg/src/example/bittorrent/BTObserver.java b/contrib/psg/src/example/bittorrent/BTObserver.java
deleted file mode 100644
index ddd38dab2b..0000000000
--- a/contrib/psg/src/example/bittorrent/BTObserver.java
+++ /dev/null
@@ -1,132 +0,0 @@
-/*
- * 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.config.*;
-import peersim.core.*;
-import peersim.util.*;
-
-/**
- * This {@link Control} provides a way to keep track of some
- * parameters of the BitTorrent network.
- */
- public class BTObserver implements Control {
-	 
-	/**
-	 *	The protocol to operate on.
-	 *	@config
-	 */
-	private static final String PAR_PROT="protocol";
-	
-	/**
-	 *	Protocol identifier, obtained from config property
-	 */
-	private final int pid;
-	
-	/**
-	 *	The basic constructor that reads the configuration file.
-	 *	@param prefix the configuration prefix for this class
-	 */
-	public BTObserver(String prefix) {
-		pid = Configuration.getPid(prefix + "." + PAR_PROT);
-	}
-	
-	/**
-	 * Prints information about the BitTorrent network
-	 * and the number of leechers and seeders.
-	 * Please refer to the code comments for more details.
-	 * @return always false
-	 */
-	public boolean execute() {
-		IncrementalFreq nodeStatusStats = new IncrementalFreq();
-		IncrementalStats neighborStats = new IncrementalStats();
-		
-		int numberOfNodes = Network.size();
-		int numberOfCompletedPieces = 0;
-		
-		// cycles from 1, since the node 0 is the tracker
-		for (int i=1; i<numberOfNodes; ++i) {
-			
-			// stats on number of leechers and seeders in the network
-			// and consequently also on number of completed files in the network
-			nodeStatusStats.add(((BitTorrent)(Network.get(i).getProtocol(pid))).getPeerStatus());
-			
-			// stats on number of neighbors per peer
-			neighborStats.add(((BitTorrent)(Network.get(i).getProtocol(pid))).getNNodes());
-		}
-		
-		// number of the pieces of the file, equal for every node, here 1 is chosen,
-		// since 1 is the first "normal" node (0 is the tracker)
-		int numberOfPieces = ((BitTorrent)(Network.get(1).getProtocol(pid))).nPieces;
-	
-		for (int i=1; i<numberOfNodes; ++i) {
-			numberOfCompletedPieces = 0;
-			
-			// discovers the status of the current peer (leecher or seeder)
-			int ps = ((BitTorrent)(Network.get(i).getProtocol(pid))).getPeerStatus();
-			String peerStatus;
-			if (ps==0) {
-				peerStatus = "L"; //leecher
-			}
-			else {
-				peerStatus = "S"; //seeder
-			}
-			
-			
-			if (Network.get(i)!=null) {
-				
-				// counts the number of completed pieces for the i-th node
-				for (int j=0; j<numberOfPieces; j++) {
-					if ( ((BitTorrent)(Network.get(i).getProtocol(pid))).getFileStatus()[j] == 16) {
-						numberOfCompletedPieces++;
-					}
-				}
-				
-				/*
-				 * Put here the output lines of the Observer. An example is provided with
-				 * basic information and stats.
-				 * CommonState.getTime() is used to print out time references
-				 * (useful for graph plotting).
-				 */
-				
-				System.out.println("OBS: node " + ((BitTorrent)(Network.get(i).getProtocol(pid))).getThisNodeID() + "(" + peerStatus + ")" + "\t pieces completed: " + numberOfCompletedPieces + "\t \t down: " + ((BitTorrent)(Network.get(i).getProtocol(pid))).nPiecesDown + "\t up: " + ((BitTorrent)(Network.get(i).getProtocol(pid))).nPiecesUp + " time: " + CommonState.getTime());
-				//System.out.println("[OBS] t " + CommonState.getTime() + "\t pc " + numberOfCompletedPieces + "\t n " + ((BitTorrent)(Network.get(i).getProtocol(pid))).getThisNodeID());
-				//System.out.println( CommonState.getTime() + "\t" + numberOfCompletedPieces + "\t" + ((BitTorrent)(Network.get(i).getProtocol(pid))).getThisNodeID());
-
-			}
-			else {
-				//System.out.println("[OBS] t " + CommonState.getTime() + "\t pc " + "0" + "\t n " + "0");
-			}
-		
-		}
-		
-		// prints the frequency of 0 (leechers) and 1 (seeders)
-		nodeStatusStats.printAll(System.out);
-		
-		// prints the average number of neighbors per peer
-		System.out.println("Avg number of neighbors per peer: " + neighborStats.getAverage());
-		
-		return false;
-	}
-}
\ No newline at end of file