git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@5858
48e7efb5-ca39-0410-a469-
dd3cf9ba447f
16 files changed:
\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "I'm done. See you!" << endl;\r
\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "I'm done. See you!" << endl;\r
\r
return 0;\r
}
\ No newline at end of file
\r
return 0;\r
}
\ No newline at end of file
\r
cout << "Hello I'm " << getName() << " on " << getHost().getName() << "!" << endl;\r
\r
\r
cout << "Hello I'm " << getName() << " on " << getHost().getName() << "!" << endl;\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "argc=" << argc << endl;\r
\r
for (int i = 0; i< argc; i++) \r
cout << "argv:" << argv[i] << endl;\r
\r
sscanf(argv[0],"%d", &taskCount);\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "argc=" << argc << endl;\r
\r
for (int i = 0; i< argc; i++) \r
cout << "argv:" << argv[i] << endl;\r
\r
sscanf(argv[0],"%d", &taskCount);\r
sscanf(argv[1],"%lg", &taskComputeSize);\r
sscanf(argv[1],"%lg", &taskComputeSize);\r
sscanf(argv[2],"%lg", &taskCommunicateSize);\r
\r
BasicTaskPtr* basicTasks = new BasicTaskPtr[taskCount];\r
sscanf(argv[2],"%lg", &taskCommunicateSize);\r
\r
BasicTaskPtr* basicTasks = new BasicTaskPtr[taskCount];\r
} \r
\r
int aliasCount = argc - 3;\r
} \r
\r
int aliasCount = argc - 3;\r
\r
char** aliases = (char**) calloc(aliasCount, sizeof(char*));\r
\r
\r
char** aliases = (char**) calloc(aliasCount, sizeof(char*));\r
\r
delete[] basicTasks;\r
delete[] aliases;\r
\r
delete[] basicTasks;\r
delete[] aliases;\r
\r
return 0;\r
}
\ No newline at end of file
return 0;\r
}
\ No newline at end of file
\r
int Slave::main(int argc, char** argv)\r
{\r
\r
int Slave::main(int argc, char** argv)\r
{\r
- cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Hello I'm " << getName() << " on " << getHost().getName() << "!" << endl;\r
+ cout <<"[" << getName() << ":" << getHost().getName() << ": PID " << getPID() << "] " << "Hello I'm " << getName() << " on " << getHost().getName() << "!" << endl;\r
Task* receivedTask;\r
BasicTask* basicTask;\r
\r
Task* receivedTask;\r
BasicTask* basicTask;\r
\r
\r
basicTask = reinterpret_cast<BasicTask*>(receivedTask);\r
\r
\r
basicTask = reinterpret_cast<BasicTask*>(receivedTask);\r
\r
- cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Received \"" << basicTask->getName() << "\" " << endl;\r
+ cout <<"[" << getName() << ":" << getHost().getName() << ": PID " << getPID() << "] " << "Received \"" << basicTask->getName() << "\" " << endl;\r
- cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Processing \"" << basicTask->getName() << "\" " << endl; \r
+ cout <<"[" << getName() << ":" << getHost().getName() << ": PID " << getPID() << "] " << "Processing \"" << basicTask->getName() << "\" " << endl; \r
+ \r
- cout <<"[" << getName() << ":" << getHost().getName() << "] " << "\"" << basicTask->getName() << "\" done " << endl;\r
+ \r
+ cout <<"[" << getName() << ":" << getHost().getName() << ": PID " << getPID() << "] " << "\"" << basicTask->getName() << "\" done " << endl;\r
\r
delete basicTask;\r
}\r
\r
\r
delete basicTask;\r
}\r
\r
- cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Received Finalize. I'm done. See you!" << endl;\r
+ cout <<"[" << getName() << ":" << getHost().getName() << ": PID " << getPID() << "] " << "Received Finalize. I'm done. See you!" << endl;\r
+ \r
+ delete this;\r
\r
return 0;\r
}
\ No newline at end of file
\r
return 0;\r
}
\ No newline at end of file
BasicTask(const char* name, double computeDuration, double messageSize)\r
throw (InvalidArgumentException, NullPointerException)\r
:Task(name, computeDuration, messageSize){}\r
BasicTask(const char* name, double computeDuration, double messageSize)\r
throw (InvalidArgumentException, NullPointerException)\r
:Task(name, computeDuration, messageSize){}\r
-\r
- /*virtual const BasicTask& operator = (const BasicTask& rTask) {\r
- Task::operator=(rTask);\r
- return *this;\r
- }*/\r
};\r
\r
typedef BasicTask* BasicTaskPtr;\r
};\r
\r
typedef BasicTask* BasicTaskPtr;\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "I'm done. See you!" << endl;\r
\r
delete[] slaves;\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "I'm done. See you!" << endl;\r
\r
delete[] slaves;\r
\r
return 0;\r
}
\ No newline at end of file
\r
return 0;\r
}
\ No newline at end of file
#include <Host.hpp>\r
#include <HostNotFoundException.hpp>\r
\r
#include <Host.hpp>\r
#include <HostNotFoundException.hpp>\r
\r
+#include <Msg.hpp>\r
+\r
#include <iostream>\r
using namespace std;\r
\r
#include <iostream>\r
using namespace std;\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Sending \"" << todo[i]->getName() << "\" to \"" << slaves[i % slaveCount].getName() << "\"" << endl;\r
\r
if(!strcmp(Host::currentHost().getName(), slaves[i % slaveCount].getName())) \r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Sending \"" << todo[i]->getName() << "\" to \"" << slaves[i % slaveCount].getName() << "\"" << endl;\r
\r
if(!strcmp(Host::currentHost().getName(), slaves[i % slaveCount].getName())) \r
- cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Hey ! It's me ! ";\r
- \r
+ cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Hey ! It's me ! ";\r
+\r
slaves[i % slaveCount].put(channel, todo[i]);\r
}\r
\r
slaves[i % slaveCount].put(channel, todo[i]);\r
}\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "All tasks have been dispatched. Let's tell everybody the computation is over." << endl;\r
\r
for (int i = 0; i < slaveCount; i++) \r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "All tasks have been dispatched. Let's tell everybody the computation is over." << endl;\r
\r
for (int i = 0; i < slaveCount; i++) \r
- {\r
- slaves[i].put(channel, new FinalizeTask());\r
- }\r
- \r
-\r
- for(int i = 0; i < numberOfTasks; i++)\r
- delete todo[i];\r
+ slaves[i].put(channel, new FinalizeTask());\r
delete[] slaves;\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Goodbye now!" << endl;\r
\r
delete[] slaves;\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Goodbye now!" << endl;\r
\r
return 0;\r
}
\ No newline at end of file
return 0;\r
}
\ No newline at end of file
t->execute();\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "\"" << t->getName() << "\" done " << endl;\r
t->execute();\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "\"" << t->getName() << "\" done " << endl;\r
}\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Received Finalize. I'm done. See you!" << endl;\r
}\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Received Finalize. I'm done. See you!" << endl;\r
\r
return 0;\r
}
\ No newline at end of file
\r
return 0;\r
}
\ No newline at end of file
Simulation s;\r
\r
return s.execute(argc, argv);\r
Simulation s;\r
\r
return s.execute(argc, argv);\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "All finalize messages have been dispatched. Goodbye now!" << endl;\r
\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "All finalize messages have been dispatched. Goodbye now!" << endl;\r
\r
+\r
+ delete[] slaves;\r
+ delete this;\r
return 0;\r
}
\ No newline at end of file
return 0;\r
}
\ No newline at end of file
}\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Received Finalize. I'm done. See you!" << endl;\r
}\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Received Finalize. I'm done. See you!" << endl;\r
return 0;\r
\r
}
\ No newline at end of file
return 0;\r
\r
}
\ No newline at end of file
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "I'm done. See you!" << endl;\r
\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "I'm done. See you!" << endl;\r
\r
return 0;\r
}
\ No newline at end of file
return 0;\r
}
\ No newline at end of file
delete[] basicTasks;\r
delete[] aliases;\r
\r
delete[] basicTasks;\r
delete[] aliases;\r
\r
return 0;\r
}
\ No newline at end of file
return 0;\r
}
\ No newline at end of file
}\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Received Finalize. I'm done. See you!" << endl;\r
}\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "Received Finalize. I'm done. See you!" << endl;\r
return 0;\r
}
\ No newline at end of file
return 0;\r
}
\ No newline at end of file
cout <<"[" << getName() << ":" << getHost().getName() << "] " << " --- bw " << commSizeBw/communicationTime << " ----" << endl;\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "goodbye!" << endl;\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << " --- bw " << commSizeBw/communicationTime << " ----" << endl;\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "goodbye!" << endl;\r
\r
return 0;\r
}
\ No newline at end of file
\r
return 0;\r
}
\ No newline at end of file
\r
delete[] hostTable;\r
\r
\r
delete[] hostTable;\r
\r
return 0;\r
\r
}
\ No newline at end of file
return 0;\r
\r
}
\ No newline at end of file
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "OK, goodbye now." << endl;\r
\r
\r
cout <<"[" << getName() << ":" << getHost().getName() << "] " << "OK, goodbye now." << endl;\r
\r
return 0;\r
\r
}
\ No newline at end of file
return 0;\r
\r
}
\ No newline at end of file