Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
New platform files (just add AS tag)
[simgrid.git] / examples / cxx / comm_time / Slave.cxx
index e1b41e8..c604f41 100644 (file)
@@ -1,45 +1,45 @@
-#include "Slave.hpp"\r
-#include "FinalizeTask.hpp"\r
-#include "CommTimeTask.hpp"\r
-#include <Host.hpp>\r
-#include <HostNotFoundException.hpp>\r
-#include <Msg.hpp>\r
-\r
-#include <Msg.hpp>\r
-\r
-MSG_IMPLEMENT_DYNAMIC(Slave, Process);\r
-\r
-int Slave::main(int argc, char** argv)\r
-{\r
-       info("Hello");\r
-       \r
-       while(true) \r
-       {\r
-               double time1 = getClock();       \r
-               Task* t = Task::get(0); \r
-               double time2 = getClock();\r
-       \r
-               if(t->isInstanceOf("FinalizeTask")) \r
-               {\r
-                       delete t;\r
-                       break;\r
-               }\r
-               \r
-               CommTimeTask* task = reinterpret_cast<CommTimeTask*>(t);\r
-       \r
-               if(time1 < task->getTime())\r
-                       time1 = task->getTime();\r
-                       \r
-               //info(TEXT_("Processing \"") + TEXT_(task->getName()) + TEXT_("\" ") + TEXT_(getHost().getName()) + TEXT_(" (Communication time : ") + TEXT_((time2 - time1)) + TEXT_(")"));\r
-        \r
-               task->execute();\r
-               \r
-               delete task;\r
-       }\r
-       \r
-       info(TEXT_("Received Finalize. I'm done. See you!"));\r
-       \r
-       delete this;\r
-       return 0;\r
-       \r
-}
\ No newline at end of file
+#include "Slave.hpp"
+#include "FinalizeTask.hpp"
+#include "CommTimeTask.hpp"
+#include <MsgHost.hpp>
+#include <HostNotFoundException.hpp>
+#include <Msg.hpp>
+
+#include <Msg.hpp>
+
+MSG_IMPLEMENT_DYNAMIC(Slave, Process)
+
+int Slave::main(int argc, char** argv)
+{
+       info("Hello");
+       
+       while(true) 
+       {
+               double time1 = getClock();       
+               Task* t = Task::get(0); 
+               double time2 = getClock();
+       
+               if(t->isInstanceOf("FinalizeTask")) 
+               {
+                       delete t;
+                       break;
+               }
+               
+               CommTimeTask* task = reinterpret_cast<CommTimeTask*>(t);
+       
+               if(time1 < task->getTime())
+                       time1 = task->getTime();
+                       
+               //info(TEXT_("Processing \"") + TEXT_(task->getName()) + TEXT_("\" ") + TEXT_(getHost().getName()) + TEXT_(" (Communication time : ") + TEXT_((time2 - time1)) + TEXT_(")"));
+        
+               task->execute();
+               
+               delete task;
+       }
+       
+       info(TEXT_("Received Finalize. I'm done. See you!"));
+       
+       delete this;
+       return 0;
+       
+}