X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0844c6822ce0a2844a0500dafc4e5bc5d37f01bb..ed5b6e45b9957b00a2c41f01ce9da418da78cecb:/examples/cxx/explicitDestination/Forwarder.cxx diff --git a/examples/cxx/explicitDestination/Forwarder.cxx b/examples/cxx/explicitDestination/Forwarder.cxx index f7220cd970..651533a11b 100644 --- a/examples/cxx/explicitDestination/Forwarder.cxx +++ b/examples/cxx/explicitDestination/Forwarder.cxx @@ -1,61 +1,61 @@ -#include "Forwarder.hpp" -#include "BasicTask.hpp" -#include "FinalizeTask.hpp" - -#include -#include - -#include - - -MSG_IMPLEMENT_DYNAMIC(Forwarder, Process); - - -int Forwarder::main(int argc, char** argv) -{ - info("Hello"); - - int aliasCount = argc; - - int taskCount = 0; - - Task* taskReceived; - Task* finalizeTask; - BasicTask* basicTask; - - while(true) - { - taskReceived = Task::receive(Host::currentHost().getName()); - - if(taskReceived->isInstanceOf("FinalizeTask")) - { - info("All tasks have been dispatched. Let's tell everybody the computation is over."); - - for (int i = 0; i < aliasCount; i++) - { - finalizeTask = new FinalizeTask(); - finalizeTask->send(argv[i]); - } - - delete taskReceived; - - break; - } - - basicTask = reinterpret_cast(taskReceived); - - info(TEXT_("Received \"") + TEXT_(basicTask->getName()) + TEXT_("\" ")); - - info(TEXT_("Sending \"") + TEXT_(basicTask->getName()) + TEXT_("\" to \"") + TEXT_(argv[taskCount % aliasCount]) + TEXT_("\"")); - - basicTask->send(argv[taskCount % aliasCount]); - - taskCount++; - } - - - info("I'm done. See you!"); - - delete this; - return 0; -} \ No newline at end of file +#include "Forwarder.hpp" +#include "BasicTask.hpp" +#include "FinalizeTask.hpp" + +#include +#include + +#include + + +MSG_IMPLEMENT_DYNAMIC(Forwarder, Process) + + +int Forwarder::main(int argc, char** argv) +{ + info("Hello"); + + int aliasCount = argc; + + int taskCount = 0; + + Task* taskReceived; + Task* finalizeTask; + BasicTask* basicTask; + + while(true) + { + taskReceived = Task::receive(Host::currentHost().getName()); + + if(taskReceived->isInstanceOf("FinalizeTask")) + { + info("All tasks have been dispatched. Let's tell everybody the computation is over."); + + for (int i = 0; i < aliasCount; i++) + { + finalizeTask = new FinalizeTask(); + finalizeTask->send(argv[i]); + } + + delete taskReceived; + + break; + } + + basicTask = reinterpret_cast(taskReceived); + + info(TEXT_("Received \"") + TEXT_(basicTask->getName()) + TEXT_("\" ")); + + info(TEXT_("Sending \"") + TEXT_(basicTask->getName()) + TEXT_("\" to \"") + TEXT_(argv[taskCount % aliasCount]) + TEXT_("\"")); + + basicTask->send(argv[taskCount % aliasCount]); + + taskCount++; + } + + + info("I'm done. See you!"); + + delete this; + return 0; +}