X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/18c57b27dd71ee7839c6a90368c845886a87d638..6de9090dd8692387ae343c587b26915f9922d7bd:/src/msg/msg_task.c diff --git a/src/msg/msg_task.c b/src/msg/msg_task.c index 6698d82373..a833cf50f9 100644 --- a/src/msg/msg_task.c +++ b/src/msg/msg_task.c @@ -8,12 +8,8 @@ #include "xbt/sysdep.h" #include "xbt/log.h" -/** \defgroup m_task_management Managing functions of Tasks - * \brief This section describes the task structure of MSG - * (#m_task_t) and the functions for managing it. - */ /** @addtogroup m_task_management - * \htmlonly \endhtmlonly + * * * Since most scheduling algorithms rely on a concept of task * that can be either computed locally or @@ -39,7 +35,7 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(msg_task, msg, MSG_task_execute(). This value has to be >=0. * \param message_size a value of the amount of data (in bytes) needed to transfer this new task. If 0, then it cannot be transfered with - MSG_task_get() and MSG_task_put(). This value has to be >=0. + MSG_task_send() and MSG_task_recv(). This value has to be >=0. * \param data a pointer to any data may want to attach to the new object. It is for user-level information and can be NULL. It can be retrieved with the function \ref MSG_task_get_data. @@ -78,6 +74,51 @@ m_task_t MSG_task_create(const char *name, double compute_duration, return task; } +/*************** Begin GPU ***************/ +/** \ingroup m_task_management + * \brief Creates a new #m_gpu_task_t. + + * A constructor for #m_gpu_task_t taking four arguments and returning + a pointer to the new created GPU task. + + * \param name a name for the object. It is for user-level information + and can be NULL. + + * \param compute_duration a value of the processing amount (in flop) + needed to process this new task. If 0, then it cannot be executed with + MSG_gpu_task_execute(). This value has to be >=0. + + * \param dispatch_latency time in seconds to load this task on the GPU + + * \param collect_latency time in seconds to transfer result from the GPU + back to the CPU (host) when done + + * \see m_gpu_task_t + * \return The new corresponding object. + */ +m_gpu_task_t MSG_gpu_task_create(const char *name, double compute_duration, + double dispatch_latency, double collect_latency) +{ + m_gpu_task_t task = xbt_new(s_m_gpu_task_t, 1); + simdata_gpu_task_t simdata = xbt_new(s_simdata_gpu_task_t, 1); + task->simdata = simdata; + /* Task structure */ + task->name = xbt_strdup(name); + + /* Simulator Data */ + simdata->computation_amount = compute_duration; + simdata->dispatch_latency = dispatch_latency; + simdata->collect_latency = collect_latency; + +#ifdef HAVE_TRACING + //FIXME + /* TRACE_msg_gpu_task_create(task); */ +#endif + + return task; +} +/*************** End GPU ***************/ + /** \ingroup m_task_management * \brief Return the user data of a #m_task_t. * @@ -155,7 +196,7 @@ const char *MSG_task_get_name(m_task_t task) } /** \ingroup m_task_management - * \brief Return the name of a #m_task_t. + * \brief Sets the name of a #m_task_t. * * This functions allows to associate a name to a task */ @@ -207,7 +248,7 @@ MSG_error_t MSG_task_destroy(m_task_t task) } -/** \ingroup m_task_management +/** \ingroup m_task_usage * \brief Cancel a #m_task_t. * \param task the task to cancel. If it was executed or transfered, it stops the process that were working on it.