+ if (__SD_task_is_running(task)) /* the task should become SD_FAILED */
+ surf_workstation_model->action_cancel(task->surf_action);
+ else
+ __SD_task_set_state(task, SD_NOT_SCHEDULED);
+ task->remains = task->amount;
+ task->start_time = -1.0;
+}
+
+/* Destroys the data memorised by SD_task_schedule. Task state must be SD_SCHEDULED or SD_READY.
+ */
+static void __SD_task_destroy_scheduling_data(SD_task_t task)
+{
+ SD_CHECK_INIT_DONE();
+ if (!__SD_task_is_scheduled_or_ready(task) && !__SD_task_is_in_fifo(task))
+ THROW1(arg_error, 0,
+ "Task '%s' must be SD_SCHEDULED, SD_READY or SD_IN_FIFO",
+ SD_task_get_name(task));
+
+ xbt_free(task->computation_amount);
+ xbt_free(task->communication_amount);
+}
+
+/* Runs a task. This function is directly called by __SD_task_try_to_run if the task
+ * doesn't have to wait in fifos. Otherwise, it is called by __SD_task_just_done when
+ * the task gets out of its fifos.
+ */
+void __SD_task_really_run(SD_task_t task)
+{
+
+ int i;
+ void **surf_workstations;
+
+ SD_CHECK_INIT_DONE();
+ xbt_assert0(task != NULL, "Invalid parameter");
+ xbt_assert2(__SD_task_is_ready_or_in_fifo(task),
+ "Task '%s' is not ready or in a fifo! Task state: %d",
+ SD_task_get_name(task), SD_task_get_state(task));
+ xbt_assert1(task->workstation_list != NULL,
+ "Task '%s': workstation_list is NULL!", SD_task_get_name(task));
+
+
+
+ DEBUG1("Really running task '%s'", SD_task_get_name(task));
+
+ /* set this task as current task for the workstations in sequential mode */
+ for (i = 0; i < task->workstation_nb; i++) {
+ 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]),
+ "The workstation should be busy now");
+ }
+ }
+
+ DEBUG1("Task '%s' set as current task for its workstations",
+ SD_task_get_name(task));
+
+ /* start the task */
+
+ /* we have to create a Surf workstation array instead of the SimDag workstation array */
+ surf_workstations = xbt_new(void *, task->workstation_nb);
+
+ for (i = 0; i < task->workstation_nb; i++) {
+ surf_workstations[i] = task->workstation_list[i]->surf_workstation;
+ }
+
+ task->surf_action = NULL;
+ if ((task->workstation_nb == 1) && (task->communication_amount[0] == 0.0)) {
+ task->surf_action =
+ surf_workstation_model->extension.workstation.
+ execute(surf_workstations[0], task->computation_amount[0]);
+ } else if ((task->workstation_nb == 1)
+ && (task->computation_amount[0] == 0.0)) {
+ task->surf_action =
+ surf_workstation_model->extension.workstation.
+ communicate(surf_workstations[0], surf_workstations[0],
+ task->communication_amount[0], task->rate);
+ } else if ((task->workstation_nb == 2)
+ && (task->computation_amount[0] == 0.0)
+ && (task->computation_amount[1] == 0.0)) {
+ int nb = 0;
+ double value = 0.0;
+
+ for (i = 0; i < task->workstation_nb * task->workstation_nb; i++) {
+ if (task->communication_amount[i] > 0.0) {
+ nb++;
+ value = task->communication_amount[i];
+ }
+ }
+ if (nb == 1) {
+ task->surf_action =
+ surf_workstation_model->extension.workstation.
+ communicate(surf_workstations[0], surf_workstations[1], value,
+ task->rate);
+ }
+ }
+ if (!task->surf_action) {
+ double *computation_amount = xbt_new(double, task->workstation_nb);
+ double *communication_amount = xbt_new(double, task->workstation_nb *
+ task->workstation_nb);
+
+ memcpy(computation_amount, task->computation_amount, sizeof(double) *
+ task->workstation_nb);
+ memcpy(communication_amount, task->communication_amount,
+ sizeof(double) * task->workstation_nb * task->workstation_nb);
+
+ task->surf_action =
+ surf_workstation_model->extension.workstation.
+ execute_parallel_task(task->workstation_nb, surf_workstations,
+ computation_amount, communication_amount,
+ task->amount, task->rate);
+ } else {
+ xbt_free(surf_workstations);
+ }
+
+ surf_workstation_model->action_data_set(task->surf_action, task);
+
+ DEBUG1("surf_action = %p", task->surf_action);
+
+ __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",
+ SD_task_get_name(task), SD_task_get_state(task));
+