xbt_free(arg);
}
-
m_process_t MSG_process_create_with_arguments(const char *name,
m_process_code_t code, void *data,
m_host_t host, int argc, char **argv)
return process;
}
+void MSG_process_free(m_process_t process)
+{
+ xbt_fifo_remove(msg_global->process_list,process);
+ xbt_context_free(process->simdata->context);
+ MSG_process_cleanup(process);
+}
+
/** \ingroup m_process_management
* \brief Migrates an agent to another location.
*
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);
}