X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2033091e2339a120d594b4cbf81a89d72faa0d05..986e097639af0e900f09bd3860dfdc2b4d1434f9:/examples/java/comm_time/Master.java diff --git a/examples/java/comm_time/Master.java b/examples/java/comm_time/Master.java index a9dad92f93..488dc3dece 100644 --- a/examples/java/comm_time/Master.java +++ b/examples/java/comm_time/Master.java @@ -39,12 +39,10 @@ public class Master extends simgrid.msg.Process { Msg.info("Got "+numberoftasks+" task(s) to process."); - Channel channel = new Channel(0); - for (int i = 0; i < numberoftasks; i++) { CommTimeTask task = new CommTimeTask("Task_" + i ,taskComputeSize,taskCommunicateSize); task.setTime(Msg.getClock()); - channel.put(task,slaves[i % slavecount]); + slaves[i % slavecount].put(0,task); // Msg.info("Send completed for the task " + task.getName() + " on the host " + slaves[i % slavecount].getName() + " [" + (i % slavecount) + "]"); } @@ -53,13 +51,8 @@ public class Master extends simgrid.msg.Process { for (int i = 0; i < slavecount; i++) { - CommTimeTask task = new CommTimeTask("finalize_" + i,0,0); - task.setData(221297); - - Msg.info("Send task to host : " + slaves[i].getName()); - channel.put(task,slaves[i]); - - Msg.info("Send completed " + slaves[i].getName() + " [" + i + "]"); + Msg.info("Finalize host " + slaves[i].getName() + " [" + i + "]"); + slaves[i].put(0, new FinalizeTask()); } Msg.info("All finalize messages have been dispatched. Goodbye now!");