+/*\r
+ * Task.cxx\r
+ *\r
+ * Copyright 2006,2007 Martin Quinson, Malek Cherier \r
+ * All right reserved. \r
+ *\r
+ * This program is free software; you can redistribute \r
+ * it and/or modify it under the terms of the license \r
+ *(GNU LGPL) which comes with this package. \r
+ *\r
+ */\r
+ \r
+ /* Task member functions implementation.\r
+ */ \r
+\r
+#include <Process.hpp>\r
+#include <Host.hpp>\r
+\r
#include <Task.hpp>\r
\r
+#include <stdlib.h>\r
+#include <stdio.h>\r
+\r
+#include <msg/msg.h>\r
+\r
namespace SimGrid\r
{\r
namespace Msg\r
{\r
+\r
+ MSG_IMPLEMENT_DYNAMIC(Task, Object);\r
\r
Task::Task()\r
{\r
\r
Task::Task(const Task& rTask)\r
{\r
+ this->nativeTask = rTask.nativeTask;\r
}\r
\r
\r
Task::~Task()\r
- throw(NativeException)\r
+ throw(MsgException)\r
{\r
if(NULL != nativeTask)\r
if(MSG_OK != MSG_task_destroy(nativeTask))\r
Task::Task(const char* name, double computeDuration, double messageSize)\r
throw(InvalidArgumentException, NullPointerException)\r
{\r
- \r
+\r
if(computeDuration < 0) \r
throw InvalidArgumentException("computeDuration");\r
\r
Task::Task(const char* name, Host* hosts, double* computeDurations, double* messageSizes, int hostCount)\r
throw(NullPointerException, InvalidArgumentException)\r
{\r
- \r
// check the parameters\r
\r
if(!name) \r
\r
\r
\r
- task->data = (void*)this;\r
+ this->nativeTask->data = (void*)this;\r
\r
}\r
\r
\r
Process& Task::getSender(void) const\r
{\r
- m_proccess_t nativeProcess = MSG_task_get_sender(nativeTask);\r
+ m_process_t nativeProcess = MSG_task_get_sender(nativeTask);\r
\r
return (*((Process*)(nativeProcess->data)));\r
}\r
\r
MSG_task_set_priority(nativeTask, priority);\r
}\r
- \r
- Task& Task::get(int channel) \r
+\r
+ Task* Task::get(int channel) \r
throw(InvalidArgumentException, MsgException)\r
{\r
// check the parameters\r
if(MSG_OK != MSG_task_get_ext(&nativeTask, channel , -1.0, NULL)) \r
throw MsgException("MSG_task_get_ext() failed");\r
\r
- return (*((Task*)(nativeTask->data)));\r
+ return ((Task*)(nativeTask->data));\r
}\r
\r
- Task& Task::get(int channel, const Host& rHost) \r
+ Task* Task::get(int channel, const Host& rHost) \r
throw(InvalidArgumentException, MsgException)\r
{\r
// check the parameters\r
if(MSG_OK != MSG_task_get_ext(&nativeTask, channel , -1.0, rHost.nativeHost)) \r
throw MsgException("MSG_task_get_ext() failed");\r
\r
- return (*((Task*)(nativeTask->data)));\r
+ return (Task*)(nativeTask->data);\r
}\r
\r
- Task& Task::get(int channel, double timeout, const Host& rHost) \r
+ Task* Task::get(int channel, double timeout, const Host& rHost) \r
throw(InvalidArgumentException, MsgException)\r
{\r
// check the parameters\r
if(MSG_OK != MSG_task_get_ext(&nativeTask, channel , timeout, rHost.nativeHost)) \r
throw MsgException("MSG_task_get_ext() failed");\r
\r
- return (*((Task*)(nativeTask->data)));\r
+ return (Task*)(nativeTask->data);\r
}\r
\r
- bool static Task::probe(int channel)\r
+ int Task::probe(int channel)\r
throw(InvalidArgumentException)\r
{\r
// check the parameters\r
if(channel < 0)\r
throw InvalidArgumentException("channel (must not be negative)");\r
\r
- return (bool)MSG_task_Iprobe(channel);\r
+ return MSG_task_Iprobe(channel);\r
}\r
\r
int Task::probe(int channel, const Host& rHost)\r
if(channel < 0)\r
throw InvalidArgumentException("channel (must not be negative)");\r
\r
- return MSG_task_probe_from_host(chan_id,rHost.nativeHost);\r
+ return MSG_task_probe_from_host(channel,rHost.nativeHost);\r
}\r
\r
void Task::execute(void) \r
void Task::send(void) \r
throw(BadAllocException, MsgException)\r
{ \r
- char* alias = (char*)calloc(strlen(Process::currentProcess().getName() + strlen(Host::currentHost().getName()) + 2);\r
+ char* alias = (char*)calloc(strlen(Process::currentProcess().getName()) + strlen(Host::currentHost().getName()) + 2, sizeof(char));\r
\r
if(!alias)\r
throw BadAllocException("alias");\r
\r
- sprintf(alias,"%s:%s", Process::currentProcess().getName(),Host::currentHost().getName());\r
+ sprintf(alias,"%s:%s", Host::currentHost().getName(), Process::currentProcess().getName());\r
\r
MSG_error_t rv = MSG_task_send_with_timeout(nativeTask, alias, -1.0);\r
\r
- free(alias)\r
+ free(alias);\r
\r
if(MSG_OK != rv)\r
throw MsgException("MSG_task_send_with_timeout() failed");\r
}\r
\r
void Task::send(double timeout) \r
- throw(BadAllocationException, InvalidArgumentException, MsgException)\r
+ throw(BadAllocException, InvalidArgumentException, MsgException)\r
{\r
// check the parameters\r
\r
if(timeout < 0 && timeout != -1.0)\r
throw InvalidArgumentException("timeout (must not be negative and different than -1.0");\r
\r
- char* alias = (char*)calloc(strlen(Process::currentProcess().getName() + strlen(Host::currentHost().getName()) + 2);\r
+ char* alias = (char*)calloc(strlen(Process::currentProcess().getName()) + strlen(Host::currentHost().getName()) + 2, sizeof(char));\r
\r
if(!alias)\r
throw BadAllocException("alias");\r
\r
- sprintf(alias,"%s:%s", Process::currentProcess().getName(),Host::currentHost().getName());\r
+ sprintf(alias,"%s:%s", Host::currentHost().getName(), Process::currentProcess().getName());\r
\r
MSG_error_t rv = MSG_task_send_with_timeout(nativeTask, alias, timeout);\r
\r
- free(alias)\r
+ free(alias);\r
\r
if(MSG_OK != rv)\r
throw MsgException("MSG_task_send_with_timeout() failed");\r
if(maxRate < 0 && maxRate != -1.0)\r
throw InvalidArgumentException("maxRate (must not be negative and different than -1.0");\r
\r
- char* alias = (char*)calloc(strlen(Process::currentProcess().getName() + strlen(Host::currentHost().getName()) + 2);\r
+ char* alias = (char*)calloc(strlen(Process::currentProcess().getName()) + strlen(Host::currentHost().getName()) + 2, sizeof(char));\r
\r
if(!alias)\r
throw BadAllocException("alias");\r
\r
- sprintf(alias,"%s:%s", Process::currentProcess().getName(),Host::currentHost().getName());\r
+ sprintf(alias,"%s:%s", Host::currentHost().getName(), Process::currentProcess().getName());\r
\r
MSG_error_t rv = MSG_task_send_bounded(nativeTask, alias, maxRate);\r
\r
if(MSG_OK != MSG_task_send_bounded(nativeTask, alias, maxRate))\r
throw MsgException("MSG_task_send_bounded() failed");\r
}\r
- \r
- Task& Task::receive(void) \r
- throw(throw(BadAllocException, MsgException))\r
+\r
+ Task* Task::receive(void) \r
+ throw(BadAllocException, MsgException)\r
{\r
- char* alias = (char*)calloc(strlen(Process::currentProcess().getName() + strlen(Host::currentHost().getName()) + 2);\r
+ char* alias = (char*)calloc(strlen(Process::currentProcess().getName()) + strlen(Host::currentHost().getName()) + 2, sizeof(char));\r
\r
if(!alias)\r
throw BadAllocException("alias");\r
\r
- sprintf(alias,"%s:%s", Process::currentProcess().getName(),Host::currentHost().getName());\r
+ sprintf(alias,"%s:%s", Host::currentHost().getName(), Process::currentProcess().getName());\r
\r
m_task_t nativeTask = NULL;\r
\r
if(MSG_OK != rv) \r
throw MsgException("MSG_task_receive_ext() failed");\r
\r
- return (*((Task*)nativeTask->data));\r
+ return (Task*)(nativeTask->data);\r
}\r
- \r
- Task& Task::receive(const char* alias) \r
+\r
+ Task* Task::receive(const char* alias) \r
throw(NullPointerException, MsgException)\r
{\r
// check the parameters\r
if(MSG_OK != MSG_task_receive_ext(&nativeTask, alias, -1.0, NULL)) \r
throw MsgException("MSG_task_receive_ext() failed");\r
\r
- return (*((Task*)nativeTask->data));\r
+ return (Task*)(nativeTask->data);\r
}\r
\r
- Task& Task::receive(const char* alias, double timeout) \r
+ Task* Task::receive(const char* alias, double timeout) \r
throw(NullPointerException, InvalidArgumentException, MsgException)\r
{\r
// check the parameters\r
if(!alias)\r
throw NullPointerException("alias");\r
\r
- if(timeout < 0 && alias != -1.0)\r
+ if(timeout < 0 && timeout != -1.0)\r
throw InvalidArgumentException("timeout (must not be negative and differnt than -1.0)");\r
\r
m_task_t nativeTask = NULL;\r
if(MSG_OK != MSG_task_receive_ext(&nativeTask, alias, timeout, NULL)) \r
throw MsgException("MSG_task_receive_ext() failed");\r
\r
- return (*((Task*)nativeTask->data));\r
+ return (Task*)(nativeTask->data);\r
}\r
\r
- Task& Task::receive(const char* alias, const Host& rHost) \r
+ Task* Task::receive(const char* alias, const Host& rHost) \r
throw(NullPointerException, MsgException)\r
{\r
// check the parameters\r
if(MSG_OK != MSG_task_receive_ext(&nativeTask, alias, -1.0, rHost.nativeHost)) \r
throw MsgException("MSG_task_receive_ext() failed");\r
\r
- return (*((Task*)nativeTask->data));\r
+ return (Task*)(nativeTask->data);\r
} \r
\r
- Task& Task::receive(const char* alias, double timeout, const Host& rHost) \r
+ Task* Task::receive(const char* alias, double timeout, const Host& rHost) \r
throw(NullPointerException, InvalidArgumentException, MsgException)\r
{\r
// check the parameters\r
if(!alias)\r
throw NullPointerException("alias");\r
\r
- if(timeout < 0 && alias != -1.0)\r
+ if(timeout < 0 && timeout != -1.0)\r
throw InvalidArgumentException("timeout (must not be negative and differnt than -1.0)");\r
\r
m_task_t nativeTask = NULL;\r
if(MSG_OK != MSG_task_receive_ext(&nativeTask, alias, timeout, rHost.nativeHost)) \r
throw MsgException("MSG_task_receive_ext() failed");\r
\r
- return (*((Task*)nativeTask->data));\r
+ return (Task*)(nativeTask->data);\r
}\r
\r
- bool Task::listen(void) \r
+ int Task::listen(void) \r
throw(BadAllocException)\r
{\r
- char* alias = (char*)calloc(strlen(Process::currentProcess().getName() + strlen(Host::currentHost().getName()) + 2);\r
+ char* alias = (char*)calloc(strlen(Process::currentProcess().getName()) + strlen(Host::currentHost().getName()) + 2, sizeof(char));\r
\r
if(!alias)\r
throw BadAllocException("alias");\r
\r
- sprintf(alias,"%s:%s", Process::currentProcess().getName(),Host::currentHost().getName());\r
+ sprintf(alias,"%s:%s", Host::currentHost().getName(), Process::currentProcess().getName());\r
\r
int rv = MSG_task_listen(alias);\r
\r
free(alias);\r
\r
- return (bool)rv;\r
+ return rv;\r
} \r
\r
- bool Task::listen(const char* alias) \r
+ int Task::listen(const char* alias) \r
throw(NullPointerException)\r
{\r
// check the parameters\r
if(!alias)\r
throw NullPointerException("alias");\r
\r
- return (bool)MSG_task_listen(alias);\r
+ return MSG_task_listen(alias);\r
}\r
\r
int Task::listenFrom(void) \r
throw(BadAllocException)\r
{\r
- char* alias = (char*)calloc(strlen(Process::currentProcess().getName() + strlen(Host::currentHost().getName()) + 2);\r
+ char* alias = (char*)calloc(strlen(Process::currentProcess().getName()) + strlen(Host::currentHost().getName()) + 2, sizeof(char));\r
\r
if(!alias)\r
throw BadAllocException("alias");\r
\r
- sprintf(alias,"%s:%s", Process::currentProcess().getName(),Host::currentHost().getName());\r
+ sprintf(alias,"%s:%s", Host::currentHost().getName(), Process::currentProcess().getName());\r
\r
int rv = MSG_task_listen_from(alias);\r
\r
int Task::listenFromHost(const Host& rHost) \r
throw(BadAllocException)\r
{\r
- char* alias = (char*)calloc(strlen(Process::currentProcess().getName() + strlen(Host::currentHost().getName()) + 2);\r
+ char* alias = (char*)calloc(strlen(Process::currentProcess().getName()) + strlen(Host::currentHost().getName()) + 2, sizeof(char));\r
\r
if(!alias)\r
throw BadAllocException("alias");\r
\r
- sprintf(alias,"%s:%s", Process::currentProcess().getName(),Host::currentHost().getName());\r
+ sprintf(alias,"%s:%s", Host::currentHost().getName(), Process::currentProcess().getName());\r
\r
int rv = MSG_task_listen_from_host(alias, rHost.nativeHost);\r
\r
\r
return MSG_task_listen_from_host(alias, rHost.nativeHost);\r
} \r
+\r
+ const Task& Task::operator = (const Task& rTask)\r
+ {\r
+ this->nativeTask = rTask.nativeTask;\r
+ return *this;\r
+ }\r
} // namespace Msg \r
} // namespace SimGrid\r
\r
