- if(!task->surf_action)
- task->surf_action = surf_workstation_resource->extension_public->
- execute_parallel_task(task->workstation_nb,
- surf_workstations,
- task->computation_amount,
- task->communication_amount,
- task->amount,
- task->rate);
-
- surf_workstation_resource->common_public->action_set_data(task->surf_action, task);
- task->state_changed = 1;
-
- DEBUG1("surf_action = %p", task->surf_action);
-
- xbt_free(surf_workstations);
- __SD_task_destroy_scheduling_data(task); /* now the scheduling data are not useful anymore */
+ 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 */