git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@5195
48e7efb5-ca39-0410-a469-
dd3cf9ba447f
16 files changed:
\r
import simgrid.msg.*;\r
\r
\r
import simgrid.msg.*;\r
\r
-public class Alias0Test {\r
+public class AutoDestinationTest {\r
\r
/* This only contains the launcher. If you do nothing more than than you can run \r
* java simgrid.msg.Msg\r
\r
/* This only contains the launcher. If you do nothing more than than you can run \r
* java simgrid.msg.Msg\r
Msg.info("hello!");\r
\r
int aliasCount = args.length;\r
Msg.info("hello!");\r
\r
int aliasCount = args.length;\r
+ \r
+ int taskCount = 0;\r
+ \r
Task taskReceived;\r
Task finalizeTask;\r
BasicTask basicTask;\r
\r
Task taskReceived;\r
Task finalizeTask;\r
BasicTask basicTask;\r
\r
- int taskCount = 0;\r
- \r
while(true) \r
{\r
taskReceived = Task.receive();\r
\r
while(true) \r
{\r
taskReceived = Task.receive();\r
\r
if(taskReceived instanceof FinalizeTask) \r
{\r
Msg.info("All tasks have been dispatched. Let's tell everybody the computation is over.");\r
if(taskReceived instanceof FinalizeTask) \r
{\r
Msg.info("All tasks have been dispatched. Let's tell everybody the computation is over.");\r
\r
for (int i = 0; i < taskCount; i++) \r
{ \r
\r
for (int i = 0; i < taskCount; i++) \r
{ \r
- Msg.info("current host name : " + (aliases[i % aliasCount].split(":"))[0]);\r
+ Msg.info("Sending \"" + basicTasks[i].getName()+ "\" to \"" + aliases[i % aliasCount] + "\"");\r
\r
if((Host.currentHost().getName()).equals((aliases[i % aliasCount].split(":"))[0]))\r
Msg.info("Hey ! It's me ! ");\r
\r
if((Host.currentHost().getName()).equals((aliases[i % aliasCount].split(":"))[0]))\r
Msg.info("Hey ! It's me ! ");\r
{\r
Msg.info("Hello !");\r
\r
{\r
Msg.info("Hello !");\r
\r
+ Task receivedTask;\r
+ BasicTask basicTask;\r
+ \r
- Task received = Task.receive(); \r
+ receivedTask = Task.receive(); \r
- if (received instanceof FinalizeTask) \r
+ if (receivedTask instanceof FinalizeTask) \r
- BasicTask basicTask = (BasicTask)received;\r
+ basicTask = (BasicTask)receivedTask;\r
\r
Msg.info("Received \"" + basicTask.getName() + "\" ");\r
\r
\r
Msg.info("Received \"" + basicTask.getName() + "\" ");\r
\r
\r
import simgrid.msg.*;\r
\r
\r
import simgrid.msg.*;\r
\r
-public class Alias1Test {\r
+public class ExplicitDestinationTest {\r
\r
/* This only contains the launcher. If you do nothing more than than you can run \r
* java simgrid.msg.Msg\r
\r
/* This only contains the launcher. If you do nothing more than than you can run \r
* java simgrid.msg.Msg\r
\r
Task receivedTask;\r
FinalizeTask finalizeTask;\r
\r
Task receivedTask;\r
FinalizeTask finalizeTask;\r
- task = (BasicTask)receivedTask;\r
+ basicTask = (BasicTask)receivedTask;\r
- Msg.info("Received \"" + task.getName() + "\" ");\r
+ Msg.info("Received \"" + basicTask.getName() + "\" ");\r
- Msg.info("Sending \"" + task.getName() + "\" to \"" + aliases[taskCount % aliasCount] + "\"");\r
+ Msg.info("Sending \"" + basicTask.getName() + "\" to \"" + aliases[taskCount % aliasCount] + "\"");\r
- task.send(aliases[taskCount % aliasCount]);\r
+ basicTask.send(aliases[taskCount % aliasCount]);\r
- int numberOfTasks = Integer.valueOf(args[0]).intValue(); \r
- double taskComputeSize = Double.valueOf(args[1]).doubleValue(); \r
+ int numberOfTasks = Integer.valueOf(args[0]).intValue(); \r
+ \r
+ double taskComputeSize = Double.valueOf(args[1]).doubleValue(); \r
+ \r
double taskCommunicateSize = Double.valueOf(args[2]).doubleValue();\r
double taskCommunicateSize = Double.valueOf(args[2]).doubleValue();\r
- BasicTask[] todo = new BasicTask[numberOfTasks];\r
+ \r
+ BasicTask[] basicTasks = new BasicTask[numberOfTasks];\r
\r
for (int i = 0; i < numberOfTasks; i++) \r
{\r
\r
for (int i = 0; i < numberOfTasks; i++) \r
{\r
- todo[i] = new BasicTask("Task_" + i, taskComputeSize, taskCommunicateSize); \r
+ basicTasks[i] = new BasicTask("Task_" + i, taskComputeSize, taskCommunicateSize); \r
}\r
\r
int aliasCount = args.length - 3;\r
}\r
\r
int aliasCount = args.length - 3;\r
String[] aliases = new String[aliasCount];\r
\r
for(int i = 3; i < args.length ; i++) \r
String[] aliases = new String[aliasCount];\r
\r
for(int i = 3; i < args.length ; i++) \r
\r
for (int i = 0; i < numberOfTasks; i++) \r
{\r
\r
for (int i = 0; i < numberOfTasks; i++) \r
{\r
- Msg.info("Sending \"" + todo[i].getName()+ "\" to \"" + aliases[i % aliasCount] + "\"");\r
+ Msg.info("Sending \"" + basicTasks[i].getName()+ "\" to \"" + aliases[i % aliasCount] + "\"");\r
\r
if((Host.currentHost()).getName().equals(aliases[i % aliasCount])) \r
Msg.info("Hey ! It's me ! ");\r
\r
\r
if((Host.currentHost()).getName().equals(aliases[i % aliasCount])) \r
Msg.info("Hey ! It's me ! ");\r
\r
- todo[i].send(aliases[i % aliasCount]);\r
+ basicTasks[i].send(aliases[i % aliasCount]);\r
}\r
\r
Msg.info("Send completed");\r
}\r
\r
Msg.info("Send completed");\r
Msg.info("All tasks have been dispatched. Let's tell everybody the computation is over.");\r
\r
FinalizeTask finalizeTask;\r
Msg.info("All tasks have been dispatched. Let's tell everybody the computation is over.");\r
\r
FinalizeTask finalizeTask;\r
for (int i = 0; i < aliasCount; i++) \r
{\r
finalizeTask = new FinalizeTask();\r
for (int i = 0; i < aliasCount; i++) \r
{\r
finalizeTask = new FinalizeTask();\r
{\r
Msg.info("Hello !");\r
\r
{\r
Msg.info("Hello !");\r
\r
+ BasicTask basicTask;\r
+ Task receivedTask;\r
+ \r
- Task t = Task.receive(Host.currentHost().getName()); \r
+ receivedTask = Task.receive(Host.currentHost().getName()); \r
- if (t instanceof FinalizeTask) \r
+ if (receivedTask instanceof FinalizeTask) \r
- BasicTask task = (BasicTask)t;\r
- Msg.info("Received \"" + task.getName() + "\" ");\r
+ basicTask = (BasicTask)receivedTask;\r
+ Msg.info("Received \"" + basicTask.getName() + "\" ");\r
- Msg.info("Processing \"" + task.getName() + "\" "); \r
- task.execute();\r
- Msg.info("\"" + task.getName() + "\" done ");\r
+ Msg.info("Processing \"" + basicTask.getName() + "\" "); \r
+ basicTask.execute();\r
+ Msg.info("\"" + basicTask.getName() + "\" done ");\r
}\r
\r
Msg.info("Received Finalize. I'm done. See you!");\r
}\r
\r
Msg.info("Received Finalize. I'm done. See you!");\r