*/
void *SD_task_get_data(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
return task->data;
}
*/
void SD_task_set_data(SD_task_t task, void *data)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
task->data = data;
}
*/
e_SD_task_state_t SD_task_get_state(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
return task->state;
}
*/
const char *SD_task_get_name(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
return task->name;
}
unsigned int i;
xbt_dynar_t parents;
SD_dependency_t dep;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
parents = xbt_dynar_new(sizeof(SD_task_t), NULL);
xbt_dynar_foreach(task->tasks_before, i, dep) {
unsigned int i;
xbt_dynar_t children;
SD_dependency_t dep;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
children = xbt_dynar_new(sizeof(SD_task_t), NULL);
xbt_dynar_foreach(task->tasks_after, i, dep) {
*/
int SD_task_get_workstation_count(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
- //xbt_assert(task->state_set != sd_global->scheduled_task_set,
- // "Unscheduled task %s", task->name);
return task->workstation_nb;
}
*/
SD_workstation_t *SD_task_get_workstation_list(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
- //xbt_assert(task->state_set != sd_global->scheduled_task_set,
- // "Unscheduled task %s", task->name);
return task->workstation_list;
}
*/
double SD_task_get_amount(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
return task->amount;
}
*/
double SD_task_get_remaining_amount(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
-
if (task->surf_action)
return surf_workstation_model->get_remains(task->surf_action);
else
int i;
SD_dependency_t dependency;
- SD_CHECK_INIT_DONE();
- xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
-
dynar = src->tasks_after;
length = xbt_dynar_length(dynar);
unsigned int counter;
SD_dependency_t dependency;
- SD_CHECK_INIT_DONE();
xbt_assert(src != NULL
|| dst != NULL,
"Invalid parameter: both src and dst are NULL");
int i;
SD_dependency_t dependency;
- SD_CHECK_INIT_DONE();
- xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
-
/* remove the dependency from src->tasks_after */
dynar = src->tasks_after;
length = xbt_dynar_length(dynar);
int i;
SD_dependency_t dependency;
-
- SD_CHECK_INIT_DONE();
- xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
-
dynar = src->tasks_after;
length = xbt_dynar_length(dynar);
*/
void SD_task_watch(SD_task_t task, e_SD_task_state_t state)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
-
if (state & SD_NOT_SCHEDULED)
THROWF(arg_error, 0,
"Cannot add a watch point for state SD_NOT_SCHEDULED");
*/
void SD_task_unwatch(SD_task_t task, e_SD_task_state_t state)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
xbt_assert(state != SD_NOT_SCHEDULED,
"SimDag error: Cannot have a watch point for state SD_NOT_SCHEDULED");
{
double time, max_time = 0.0;
int i, j;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL && workstation_nb > 0
- && workstation_list != NULL, "Invalid parameter");
+ xbt_assert(workstation_nb > 0, "Invalid parameter");
/* the task execution time is the maximum execution time of the parallel tasks */
static XBT_INLINE void SD_task_do_schedule(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
-
if (!__SD_task_is_not_scheduled(task) && !__SD_task_is_schedulable(task))
THROWF(arg_error, 0, "Task '%s' has already been scheduled",
SD_task_get_name(task));
*/
void SD_task_unschedule(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
-
if (task->state_set != sd_global->scheduled_task_set &&
task->state_set != sd_global->runnable_task_set &&
task->state_set != sd_global->running_task_set &&
*/
static void __SD_task_destroy_scheduling_data(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
if (!__SD_task_is_scheduled_or_runnable(task)
&& !__SD_task_is_in_fifo(task))
THROWF(arg_error, 0,
int i;
void **surf_workstations;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
xbt_assert(__SD_task_is_runnable_or_in_fifo(task),
"Task '%s' is not runnable or in a fifo! Task state: %d",
SD_task_get_name(task), SD_task_get_state(task));
int i;
SD_workstation_t workstation;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
xbt_assert(__SD_task_is_runnable(task),
"Task '%s' is not runnable! Task state: %d",
SD_task_get_name(task), SD_task_get_state(task));
SD_task_t *candidates;
int can_start = 1;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
xbt_assert(__SD_task_is_running(task),
"The task must be running! Task state: %d",
SD_task_get_state(task));
*/
double SD_task_get_start_time(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
if (task->surf_action)
return surf_workstation_model->
action_get_start_time(task->surf_action);
*/
double SD_task_get_finish_time(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
-
if (task->surf_action) /* should never happen as actions are destroyed right after their completion */
return surf_workstation_model->
action_get_finish_time(task->surf_action);