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

diff --git a/contrib/psg/src/example/edaggregation/AverageED.java b/contrib/psg/src/example/edaggregation/AverageED.java
deleted file mode 100644
index c5f335831a..0000000000
--- a/contrib/psg/src/example/edaggregation/AverageED.java
+++ /dev/null
@@ -1,116 +0,0 @@
-/*
- * Copyright (c) 2003 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 example.edaggregation;
-
-import peersim.vector.SingleValueHolder;
-import peersim.config.*;
-import peersim.core.*;
-import peersim.transport.Transport;
-import peersim.cdsim.CDProtocol;
-import peersim.edsim.EDProtocol;
-
-/**
- * Event driven version of epidemic averaging.
- */
-public class AverageED extends SingleValueHolder implements CDProtocol,
-		EDProtocol {
-
-	// --------------------------------------------------------------------------
-	// Initialization
-	// --------------------------------------------------------------------------
-
-	/**
-	 * @param prefix
-	 *            string prefix for config properties
-	 */
-	public AverageED(String prefix) {
-		super(prefix);
-	}
-
-	// --------------------------------------------------------------------------
-	// methods
-	// --------------------------------------------------------------------------
-
-	/**
-	 * This is the standard method the define periodic activity. The frequency
-	 * of execution of this method is defined by a
-	 * {@link peersim.edsim.CDScheduler} component in the configuration.
-	 */
-	public void nextCycle(Node node, int pid) {
-		Linkable linkable = (Linkable) node.getProtocol(FastConfig
-				.getLinkable(pid));
-		if (linkable.degree() > 0) {
-			int degree=linkable.degree();
-			int i=CommonState.r.nextInt(degree);		
-			Node peern = linkable.getNeighbor(i);
-			System.out.println("Pid of the protocol: "+pid);
-			System.out.println("Time="+CommonState.getTime()+" degree="+degree+" i="+i+" peernID="+peern.getID()+" peernIndex="+peern.getIndex());
-			if (!peern.isUp())
-				return;
-			AverageMessage ob=new AverageMessage(value, node);
-			System.out.println("NextCycle\t"+"\t Time: " + CommonState.getTime()+ "\t src: " + node.getID() + "\t dst: " + peern.getID()+"\t msg:"+ob.value);
-			((Transport) node.getProtocol(FastConfig.getTransport(pid))).send(
-					node, peern, ob, pid);
-		}
-	}
-
-	// --------------------------------------------------------------------------
-
-	/**
-	 * This is the standard method to define to process incoming messages.
-	 */
-	public void processEvent(Node node, int pid, Object event) {
-
-		AverageMessage aem = (AverageMessage) event;
-
-		AverageMessage ob=null;
-		if (aem.sender != null){
-			System.out.println("ProcessEventR\t"+"\t Time: " + CommonState.getTime() + "\t src: " + aem.sender.getID() + "\t dst: " + node.getID()+"\t msg:"+aem.value);
-			ob=new AverageMessage(value, null);
-			System.out.println("ProcessEventS\t"+"\t Time: " + CommonState.getTime()+ "\t src: " + node.getID() + "\t dst: " + aem.sender.getID()+"\t msg:"+ob.value);
-			((Transport) node.getProtocol(FastConfig.getTransport(pid))).send(
-					node, aem.sender, ob, pid);
-	} else {
-		System.out.println("ProcessEventR\t"+"\t Time: " +CommonState.getTime() + "\t src: " + "NULL" + "\t dst: " + node.getID()+"\t msg:"+aem.value);
-	}
-		value = (value + aem.value) / 2;
-	}
-
-}
-
-// --------------------------------------------------------------------------
-// --------------------------------------------------------------------------
-
-/**
- * The type of a message. It contains a value of type double and the sender node
- * of type {@link peersim.core.Node}.
- */
-class AverageMessage {
-
-	final double value;
-	/**
-	 * If not null, this has to be answered, otherwise this is the answer.
-	 */
-	final Node sender;
-
-	public AverageMessage(double value, Node sender) {
-		this.value = value;
-		this.sender = sender;
-	}
-}
\ No newline at end of file