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