receiver->simdata->host, size, rate);
surf_workstation_resource->common_public->action_set_data(simdata->surf_action,act);
+ DEBUG1("Create communicate action %p",act);
return act;
}
surf_workstation_resource->common_public->action_set_data(simdata->surf_action,act);
+ DEBUG1("Create execute action %p",act);
return act;
}
surf_workstation_resource->common_public->action_set_data(simdata->surf_action,act);
+ DEBUG1("Create sleep action %p",act);
return act;
}
{
xbt_assert0((action != NULL), "Invalid parameter");
+ DEBUG1("Cancel action %p",action);
if(action->simdata->surf_action) {
surf_workstation_resource->common_public->action_cancel(action->simdata->surf_action);
}
xbt_assert1((xbt_fifo_size(action->cond_list)==0),
"Conditional list not empty %d. There is a problem. Cannot destroy it now!", xbt_fifo_size(action->cond_list));
+ DEBUG1("Destroy action %p",action);
if(action->name) xbt_free(action->name);
xbt_fifo_free(action->cond_list);
{
xbt_assert0( (action != NULL) && (cond != NULL), "Invalid parameters");
+ DEBUG2("Register action %p to condtion %p",action,cond);
xbt_fifo_push(cond->actions,action);
}
xbt_assert0((action != NULL), "Invalid parameter");
return action->simdata->surf_action->remains;
}
+
+smx_action_t SIMIX_action_parallel_execute(char *name, int workstation_nb, void **workstation_list, double *computation_amount, double *communication_amount, double amount, double rate)
+{
+
+ /* alloc structures */
+ smx_action_t act = xbt_new0(s_smx_action_t,1);
+ act->simdata = xbt_new0(s_smx_simdata_action_t,1);
+ smx_simdata_action_t simdata = act->simdata;
+ act->cond_list = xbt_fifo_new();
+
+ /* initialize them */
+ act-> name = xbt_strdup(name);
+
+ /* set communication */
+ simdata->surf_action = surf_workstation_resource->extension_public->execute_parallel_task(workstation_nb, workstation_list, computation_amount, communication_amount, amount, rate);
+
+ surf_workstation_resource->common_public->action_set_data(simdata->surf_action,act);
+
+ return act;
+}
+
+e_surf_action_state_t SIMIX_action_get_state(smx_action_t action)
+{
+ xbt_assert0((action != NULL), "Invalid parameter");
+ return surf_workstation_resource->common_public->action_get_state(action->simdata->surf_action);
+
+}