simdata_task = simdata->waiting_task->simdata;
+ simdata->suspended = 1;
+ if(simdata->blocked) return MSG_OK;
+
xbt_assert0(((simdata_task->compute)||(simdata_task->comm))&&
- !((simdata_task->comm)&&(simdata_task->comm)),
+ !((simdata_task->compute)&&(simdata_task->comm)),
"Got a problem in deciding which action to choose !");
simdata->suspended = 1;
if(simdata_task->compute)
- surf_workstation_resource->extension_public->suspend(simdata_task->compute);
+ surf_workstation_resource->common_public->suspend(simdata_task->compute);
else
- surf_workstation_resource->extension_public->suspend(simdata_task->comm);
+ surf_workstation_resource->common_public->suspend(simdata_task->comm);
} else {
m_task_t dummy = MSG_TASK_UNINITIALIZED;
dummy = MSG_task_create("suspended", 0.0, 0, NULL);
+ simdata = process->simdata;
simdata->suspended = 1;
__MSG_task_execute(process,dummy);
- surf_workstation_resource->extension_public->suspend(dummy->simdata->compute);
+ surf_workstation_resource->common_public->suspend(dummy->simdata->compute);
__MSG_wait_for_computation(process,dummy);
simdata->suspended = 0;
if(simdata_task->compute)
- surf_workstation_resource->extension_public->resume(simdata_task->compute);
+ surf_workstation_resource->common_public->resume(simdata_task->compute);
else
- surf_workstation_resource->extension_public->resume(simdata_task->comm);
+ surf_workstation_resource->common_public->resume(simdata_task->comm);
MSG_RETURN(MSG_OK);
}
-MSG_error_t __MSG_process_block()
+MSG_error_t __MSG_process_block(void)
{
m_process_t process = MSG_process_self();
process->simdata->blocked=1;
__MSG_task_execute(process,dummy);
- surf_workstation_resource->extension_public->suspend(dummy->simdata->compute);
+ surf_workstation_resource->common_public->suspend(dummy->simdata->compute);
__MSG_wait_for_computation(process,dummy);
process->simdata->blocked=0;
xbt_assert0(simdata->blocked,"Process not blocked");
- surf_workstation_resource->extension_public->resume(simdata_task->compute);
+ surf_workstation_resource->common_public->resume(simdata_task->compute);
MSG_RETURN(MSG_OK);
}