*/
package async;
+import org.simgrid.msg.Host;
import org.simgrid.msg.Msg;
import org.simgrid.msg.MsgException;
import org.simgrid.msg.Task;
public class Forwarder extends Process {
-
+ public Forwarder(Host host, String name, String[]args) {
+ super(host,name,args);
+ }
public void main(String[] args) throws MsgException {
if (args.length < 3) {
Msg.info("Forwarder needs 3 arguments (input mailbox, first output mailbox, last one)");
Task tf = new FinalizeTask();
tf.dsend("slave_"+cpt);
}
- simulatedSleep(20);
+ waitFor(20);
break;
}
int dest = firstOutput + (taskCount % slavesCount);