--- /dev/null
+package psgsim;
+
+import org.simgrid.msg.Host;
+import org.simgrid.msg.MsgException;
+
+import peersim.core.Node;
+import peersim.edsim.EDProtocol;
+
+/**
+ * This class extends {@link org.simgrid.msg.Process} which creates a process
+ * for each host (corresponding to node in peersim) in the system.
+ * <p>
+ * The main method of this class is to handle events received, by calling the
+ * processEvent method on the corresponding node and pid.
+ * <p>
+ * See {@link peersim.edsim.EDProtocol#processEvent}
+ *
+ * @author Khaled Baati 28/10/2014
+ * @version version 1.1
+ */
+public class PSGProcessEvent extends org.simgrid.msg.Process {
+ /** The delivered event **/
+ private PSGTask task;
+ /** The current protocol **/
+ private EDProtocol prot;
+ /** The identifier of the current protocol **/
+ private int pid;
+
+ /**
+ * Constructs a new process from the name of a host.
+ *
+ * @param host
+ * the local host to create according to the active node in
+ * peersim
+ * @param name
+ * the host's name
+ * @param args
+ * The arguments of main method of the process.
+ */
+ public PSGProcessEvent(Host host, String name, String[] args) {
+ super(host, name, args);
+ }
+
+ @Override
+ public void main(String[] args) throws MsgException {
+ Node node = NodeHost.getNode(getHost());
+ Host.setAsyncMailbox(getHost().getName());
+ while (PSGPlatform.getTime() < PSGPlatform.getDuration()) {
+ task = null;
+ task = (PSGTask) PSGTask.receive(Host.currentHost().getName(),
+ PSGPlatform.psToSgTime(PSGPlatform.getDuration() - PSGPlatform.getTime()-1));
+ if (task != null && PSGPlatform.getTime() < PSGPlatform.getDuration()) {
+ pid = task.getPid();
+ prot = (EDProtocol) node.getProtocol(pid);
+ prot.processEvent(node, pid, task.getEvent());
+ PSGTransport.flush();
+ } else
+ break;
+ }
+ }
+
+}
