if(__MSG_process_isBlocked(t_simdata->sender))
__MSG_process_unblock(t_simdata->sender);
- PAJE_PROCESS_STATE(process,"C");
+ PAJE_PROCESS_PUSH_STATE(process,"C");
do {
__MSG_task_wait_event(process, t);
xbt_context_yield();
}
+ PAJE_PROCESS_POP_STATE(process);
PAJE_COMM_STOP(process,t,channel);
if(state == SURF_ACTION_DONE) MSG_RETURN(MSG_OK);
if(remote_host->simdata->sleeping[channel])
__MSG_process_unblock(remote_host->simdata->sleeping[channel]);
-/* else { */
+
process->simdata->put_host = dest;
process->simdata->put_channel = channel;
while(!(task_simdata->comm))
__MSG_process_block();
process->simdata->put_host = NULL;
process->simdata->put_channel = -1;
-/* } */
- PAJE_PROCESS_STATE(process,"C");
+
+ PAJE_PROCESS_PUSH_STATE(process,"C");
state=surf_workstation_resource->common_public->action_get_state(task_simdata->comm);
while (state==SURF_ACTION_RUNNING) {
MSG_task_destroy(task);
+ PAJE_PROCESS_POP_STATE(process);
+
if(state == SURF_ACTION_DONE) MSG_RETURN(MSG_OK);
else if(surf_workstation_resource->extension_public->get_state(local_host->simdata->host)
== SURF_CPU_OFF)
MSG_error_t MSG_task_execute(m_task_t task)
{
m_process_t process = MSG_process_self();
-
+ MSG_error_t res;
__MSG_task_execute(process, task);
- PAJE_PROCESS_STATE(process,"E");
- return __MSG_wait_for_computation(process,task);
+
+ PAJE_PROCESS_PUSH_STATE(process,"E");
+ res = __MSG_wait_for_computation(process,task);
+ PAJE_PROCESS_POP_STATE(process);
+ return res;
}
void __MSG_task_execute(m_process_t process, m_task_t task)