import org.simgrid.msg.Msg;
import org.simgrid.msg.MsgException;
import org.simgrid.msg.Task;
-import org.simgrid.msg.Process;;
+import org.simgrid.msg.Process;
public class Master extends Process {
public Master(Host host, String name, String[]args) {
System.exit(1);
}
- int tasksCount = Integer.valueOf(args[0]).intValue();
- double taskComputeSize = Double.valueOf(args[1]).doubleValue();
- double taskCommunicateSize = Double.valueOf(args[2]).doubleValue();
+ int tasksCount = Integer.parseInt(args[0]);
+ double taskComputeSize = Double.parseDouble(args[1]);
+ double taskCommunicateSize = Double.parseDouble(args[2]);
- int workersCount = Integer.valueOf(args[3]).intValue();
+ int workersCount = Integer.parseInt(args[3]);
Msg.info("Hello! Got "+ workersCount + " workers and "+tasksCount+" tasks to process");
for (int i = 0; i < tasksCount; i++) {
Task task = new Task("Task_" + i, taskComputeSize, taskCommunicateSize);
- //Msg.info("Sending \"" + task.getName()+ "\" to \"worker_" + i % workersCount + "\"");
+ Msg.debug("Sending \"" + task.getName()+ "\" to \"worker_" + i % workersCount + "\"");
task.send("worker_"+(i%workersCount));
}