m_process_t p = NULL;
m_process_t self = MSG_process_self();
- while((p=xbt_fifo_shift(msg_global->process_list))) {
+ while((p=xbt_fifo_pop(msg_global->process_list))) {
if(p!=self) MSG_process_kill(p);
}
m_process_t p = NULL;
- while((p=xbt_fifo_shift(msg_global->process_list))) {
+ while((p=xbt_fifo_pop(msg_global->process_list))) {
MSG_process_kill(p);
}
xbt_context_exit();
simdata->process_list = xbt_fifo_new();
/* Update global variables */
- xbt_fifo_push(msg_global->host, host);
+ xbt_fifo_unshift(msg_global->host, host);
PAJE_HOST_NEW(host);
process->simdata = simdata;
process->data = data;
- xbt_fifo_push(host->simdata->process_list, process);
+ xbt_fifo_unshift(host->simdata->process_list, process);
/* /////////////// FIX du current_process !!! ////////////// */
self = msg_global->current_process;
xbt_context_start(process->simdata->context);
msg_global->current_process = self;
- xbt_fifo_push(msg_global->process_list, process);
- xbt_fifo_push(msg_global->process_to_run, process);
+ xbt_fifo_unshift(msg_global->process_list, process);
+ DEBUG2("Inserting %s(%s) in the to_run list",process->name,
+ host->name);
+ xbt_fifo_unshift(msg_global->process_to_run, process);
PAJE_PROCESS_NEW(process);
xbt_fifo_remove(simdata->host->simdata->process_list,process);
simdata->host = host;
- xbt_fifo_push(host->simdata->process_list,process);
+ xbt_fifo_unshift(host->simdata->process_list,process);
return MSG_OK;
}