void *SD_task_get_data(SD_task_t task)
{
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
+ 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_assert0(task != NULL, "Invalid parameter");
+ 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_assert0(task != NULL, "Invalid parameter");
+ xbt_assert(task != NULL, "Invalid parameter");
return task->state;
}
const char *SD_task_get_name(SD_task_t task)
{
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
+ xbt_assert(task != NULL, "Invalid parameter");
return task->name;
}
xbt_dynar_t parents;
SD_dependency_t dep;
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
+ xbt_assert(task != NULL, "Invalid parameter");
parents = xbt_dynar_new(sizeof(SD_task_t), NULL);
xbt_dynar_foreach(task->tasks_before, i, dep) {
xbt_dynar_t children;
SD_dependency_t dep;
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
+ 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_assert0(task != NULL, "Invalid parameter");
- // xbt_assert1( task->state_set != sd_global->scheduled_task_set,
+ 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_assert0(task != NULL, "Invalid parameter");
- //xbt_assert1( task->state_set != sd_global->scheduled_task_set,
+ 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_assert0(task != NULL, "Invalid parameter");
+ xbt_assert(task != NULL, "Invalid parameter");
return task->amount;
}
double SD_task_get_remaining_amount(SD_task_t task)
{
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
+ xbt_assert(task != NULL, "Invalid parameter");
if (task->surf_action)
return surf_workstation_model->get_remains(task->surf_action);
SD_dependency_t dependency;
SD_CHECK_INIT_DONE();
- xbt_assert0(src != NULL && dst != NULL, "Invalid parameter");
+ xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
dynar = src->tasks_after;
length = xbt_dynar_length(dynar);
if (src == dst)
- THROW1(arg_error, 0,
+ THROWF(arg_error, 0,
"Cannot add a dependency between task '%s' and itself",
SD_task_get_name(src));
if (!__SD_task_is_not_scheduled(src) && !__SD_task_is_schedulable(src)
&& !__SD_task_is_scheduled_or_runnable(src))
- THROW1(arg_error, 0,
+ THROWF(arg_error, 0,
"Task '%s' must be SD_NOT_SCHEDULED, SD_SCHEDULABLE, SD_SCHEDULED or SD_RUNNABLE",
SD_task_get_name(src));
if (!__SD_task_is_not_scheduled(dst) && !__SD_task_is_schedulable(dst)
&& !__SD_task_is_scheduled_or_runnable(dst))
- THROW1(arg_error, 0,
+ THROWF(arg_error, 0,
"Task '%s' must be SD_NOT_SCHEDULED, SD_SCHEDULABLE, SD_SCHEDULED or SD_RUNNABLE",
SD_task_get_name(dst));
}
if (found)
- THROW2(arg_error, 0,
+ THROWF(arg_error, 0,
"A dependency already exists between task '%s' and task '%s'",
SD_task_get_name(src), SD_task_get_name(dst));
SD_dependency_t dependency;
SD_CHECK_INIT_DONE();
- xbt_assert0(src != NULL
+ xbt_assert(src != NULL
|| dst != NULL,
"Invalid parameter: both src and dst are NULL");
SD_dependency_t dependency;
SD_CHECK_INIT_DONE();
- xbt_assert0(src != NULL && dst != NULL, "Invalid parameter");
+ xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
/* remove the dependency from src->tasks_after */
dynar = src->tasks_after;
}
}
if (!found)
- THROW4(arg_error, 0,
+ THROWF(arg_error, 0,
"No dependency found between task '%s' and '%s': task '%s' is not a successor of task '%s'",
SD_task_get_name(src), SD_task_get_name(dst),
SD_task_get_name(dst), SD_task_get_name(src));
}
}
/* should never happen... */
- xbt_assert4(found,
+ xbt_assert(found,
"SimDag error: task '%s' is a successor of '%s' but task '%s' is not a predecessor of task '%s'",
SD_task_get_name(dst), SD_task_get_name(src),
SD_task_get_name(src), SD_task_get_name(dst));
SD_CHECK_INIT_DONE();
- xbt_assert0(src != NULL && dst != NULL, "Invalid parameter");
+ xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
dynar = src->tasks_after;
length = xbt_dynar_length(dynar);
found = (dependency->dst == dst);
}
if (!found)
- THROW2(arg_error, 0, "No dependency found between task '%s' and '%s'",
+ THROWF(arg_error, 0, "No dependency found between task '%s' and '%s'",
SD_task_get_name(src), SD_task_get_name(dst));
return dependency->data;
}
void SD_task_watch(SD_task_t task, e_SD_task_state_t state)
{
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
+ xbt_assert(task != NULL, "Invalid parameter");
if (state & SD_NOT_SCHEDULED)
- THROW0(arg_error, 0,
+ THROWF(arg_error, 0,
"Cannot add a watch point for state SD_NOT_SCHEDULED");
task->watch_points = task->watch_points | state;
void SD_task_unwatch(SD_task_t task, e_SD_task_state_t state)
{
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
- xbt_assert0(state != SD_NOT_SCHEDULED,
+ xbt_assert(task != NULL, "Invalid parameter");
+ xbt_assert(state != SD_NOT_SCHEDULED,
"SimDag error: Cannot have a watch point for state SD_NOT_SCHEDULED");
task->watch_points = task->watch_points & ~state;
double time, max_time = 0.0;
int i, j;
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL && workstation_nb > 0
+ xbt_assert(task != NULL && workstation_nb > 0
&& workstation_list != NULL, "Invalid parameter");
/* the task execution time is the maximum execution time of the parallel tasks */
SD_CHECK_INIT_DONE();
if (!__SD_task_is_not_scheduled(task) && !__SD_task_is_schedulable(task))
- THROW1(arg_error, 0, "Task '%s' has already been scheduled",
+ THROWF(arg_error, 0, "Task '%s' has already been scheduled",
SD_task_get_name(task));
/* update the task state */
* i.e. when its dependencies are satisfied.
*
* \param task the task you want to schedule
- * \param workstation_nb number of workstations on which the task will be executed
+ * \param workstation_count number of workstations on which the task will be executed
* \param workstation_list the workstations on which the task will be executed
* \param computation_amount computation amount for each workstation
* \param communication_amount communication amount between each pair of workstations
int communication_nb;
task->workstation_nb = 0;
task->rate = -1;
- xbt_assert0(workstation_count > 0, "workstation_nb must be positive");
+ xbt_assert(workstation_count > 0, "workstation_nb must be positive");
task->workstation_nb = workstation_count;
task->rate = rate;
void SD_task_unschedule(SD_task_t task)
{
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
+ 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 &&
task->state_set != sd_global->failed_task_set)
- THROW1(arg_error, 0,
+ THROWF(arg_error, 0,
"Task %s: the state must be SD_SCHEDULED, SD_RUNNABLE, SD_RUNNING or SD_FAILED",
SD_task_get_name(task));
SD_CHECK_INIT_DONE();
if (!__SD_task_is_scheduled_or_runnable(task)
&& !__SD_task_is_in_fifo(task))
- THROW1(arg_error, 0,
+ THROWF(arg_error, 0,
"Task '%s' must be SD_SCHEDULED, SD_RUNNABLE or SD_IN_FIFO",
SD_task_get_name(task));
void **surf_workstations;
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
- xbt_assert2(__SD_task_is_runnable_or_in_fifo(task),
+ 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));
- xbt_assert1(task->workstation_list != NULL,
+ xbt_assert(task->workstation_list != NULL,
"Task '%s': workstation_list is NULL!",
SD_task_get_name(task));
if (SD_workstation_get_access_mode(task->workstation_list[i]) ==
SD_WORKSTATION_SEQUENTIAL_ACCESS) {
task->workstation_list[i]->current_task = task;
- xbt_assert0(__SD_workstation_is_busy(task->workstation_list[i]),
+ xbt_assert(__SD_workstation_is_busy(task->workstation_list[i]),
"The workstation should be busy now");
}
}
__SD_task_destroy_scheduling_data(task); /* now the scheduling data are not useful anymore */
__SD_task_set_state(task, SD_RUNNING);
- xbt_assert2(__SD_task_is_running(task), "Bad state of task '%s': %d",
+ xbt_assert(__SD_task_is_running(task), "Bad state of task '%s': %d",
SD_task_get_name(task), SD_task_get_state(task));
}
SD_workstation_t workstation;
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
- xbt_assert2(__SD_task_is_runnable(task),
+ 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_set_state(task, SD_IN_FIFO);
- xbt_assert2(__SD_task_is_in_fifo(task), "Bad state of task '%s': %d",
+ xbt_assert(__SD_task_is_in_fifo(task), "Bad state of task '%s': %d",
SD_task_get_name(task), SD_task_get_state(task));
XBT_DEBUG("Task '%s' state is now SD_IN_FIFO", SD_task_get_name(task));
} else {
int can_start = 1;
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
- xbt_assert1(__SD_task_is_running(task),
+ 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));
- xbt_assert1(task->workstation_list != NULL,
+ xbt_assert(task->workstation_list != NULL,
"Task '%s': workstation_list is NULL!",
SD_task_get_name(task));
XBT_DEBUG("Workstation '%s': access_mode = %d",
SD_workstation_get_name(workstation), workstation->access_mode);
if (workstation->access_mode == SD_WORKSTATION_SEQUENTIAL_ACCESS) {
- xbt_assert1(workstation->task_fifo != NULL,
+ xbt_assert(workstation->task_fifo != NULL,
"Workstation '%s' has sequential access but no fifo!",
SD_workstation_get_name(workstation));
- xbt_assert2(workstation->current_task =
+ xbt_assert(workstation->current_task =
task, "Workstation '%s': current task should be '%s'",
SD_workstation_get_name(workstation),
SD_task_get_name(task));
if (candidate != NULL) {
XBT_DEBUG("Candidate: '%s'", SD_task_get_name(candidate));
- xbt_assert2(__SD_task_is_in_fifo(candidate),
+ xbt_assert(__SD_task_is_in_fifo(candidate),
"Bad state of candidate '%s': %d",
SD_task_get_name(candidate),
SD_task_get_state(candidate));
continue; /* we have already evaluated that task */
}
- xbt_assert2(__SD_task_is_in_fifo(candidate),
+ xbt_assert(__SD_task_is_in_fifo(candidate),
"Bad state of candidate '%s': %d",
SD_task_get_name(candidate), SD_task_get_state(candidate));
XBT_DEBUG("Head of the fifo: '%s'",
(candidate !=
NULL) ? SD_task_get_name(candidate) : "NULL");
- xbt_assert0(candidate == candidates[i],
+ xbt_assert(candidate == candidates[i],
"Error in __SD_task_just_done: bad first task in the fifo");
}
} /* for each workstation */
("Calling __SD_task_is_running: task '%s', state set: %p, running_task_set: %p, is running: %d",
SD_task_get_name(candidate), candidate->state_set,
sd_global->running_task_set, __SD_task_is_running(candidate));
- xbt_assert2(__SD_task_is_running(candidate),
+ xbt_assert(__SD_task_is_running(candidate),
"Bad state of task '%s': %d",
SD_task_get_name(candidate),
SD_task_get_state(candidate));
double SD_task_get_start_time(SD_task_t task)
{
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
+ 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_assert0(task != NULL, "Invalid parameter");
+ 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->
void SD_task_destroy(SD_task_t task)
{
SD_CHECK_INIT_DONE();
- xbt_assert0(task != NULL, "Invalid parameter");
+ xbt_assert(task != NULL, "Invalid parameter");
XBT_DEBUG("Destroying task %s...", SD_task_get_name(task));
int i;
SD_dependency_t dep;
unsigned int cpt;
- xbt_assert1(task->kind != 0,
+ xbt_assert(task->kind != 0,
"Task %s is not typed. Cannot automatically schedule it.",
SD_task_get_name(task));
switch (task->kind) {
SD_task_do_schedule(task);
break;
default:
- xbt_die(bprintf("Kind of task %s not supported by SD_task_schedulev()",
- SD_task_get_name(task)));
+ xbt_die("Kind of task %s not supported by SD_task_schedulev()",
+ SD_task_get_name(task));
}
if (task->kind == SD_TASK_COMM_E2E) {
XBT_VERB("Schedule comm task %s between %s -> %s. It costs %.f bytes",