From 8b00e4fed886b2f358a1c00494f4487e1a6cb20d Mon Sep 17 00:00:00 2001 From: Jonathan Rouzaud-Cornabas Date: Wed, 30 Jan 2013 12:29:58 +0100 Subject: [PATCH] Add MSG_task_set_data_size function --- include/msg/msg.h | 3 +++ src/msg/msg_task.c | 17 +++++++++++++++++ 2 files changed, 20 insertions(+) diff --git a/include/msg/msg.h b/include/msg/msg.h index 5f0077ed1a..330ed564c4 100644 --- a/include/msg/msg.h +++ b/include/msg/msg.h @@ -205,6 +205,9 @@ XBT_PUBLIC(msg_error_t) MSG_process_sleep(double nb_sec); XBT_PUBLIC(double) MSG_task_get_compute_duration(msg_task_t task); XBT_PUBLIC(void) MSG_task_set_compute_duration(msg_task_t task, double compute_duration); +XBT_PUBLIC(void) MSG_task_set_data_size(msg_task_t task, + double data_size); + XBT_PUBLIC(double) MSG_task_get_remaining_computation(msg_task_t task); XBT_PUBLIC(double) MSG_task_get_remaining_communication(msg_task_t task); XBT_PUBLIC(int) MSG_task_is_latency_bounded(msg_task_t task); diff --git a/src/msg/msg_task.c b/src/msg/msg_task.c index 101689c4d4..a32e0d81a5 100644 --- a/src/msg/msg_task.c +++ b/src/msg/msg_task.c @@ -342,6 +342,23 @@ void MSG_task_set_compute_duration(msg_task_t task, } +/** \ingroup m_task_management + * \brief set the amount data attached with a task #msg_task_t. + * + * \warning If the transfer is ongoing (already started and not finished), + * it is not modified by this call. + */ + +void MSG_task_set_data_size(msg_task_t task, + double data_size) +{ + xbt_assert(task, "Invalid parameter"); + task->simdata->message_size = data_size; + +} + + + /** \ingroup m_task_management * \brief Returns the remaining computation amount of a task #msg_task_t. * -- 2.20.1