X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1282bea34802164b8173a518bcd379fd845bb684..04c44fbe77163cca75366d10e35ba400b804eaef:/examples/cxx/autoDestination/Forwarder.cxx diff --git a/examples/cxx/autoDestination/Forwarder.cxx b/examples/cxx/autoDestination/Forwarder.cxx index 7953686088..052bf87ef3 100644 --- a/examples/cxx/autoDestination/Forwarder.cxx +++ b/examples/cxx/autoDestination/Forwarder.cxx @@ -1,60 +1,60 @@ -#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(); - - 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])); - - 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(); + + 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])); + + basicTask->send(argv[taskCount % aliasCount]); + + taskCount++; + } + + + info("I'm done. See you!"); + + delete this; + + return 0; +}