making the use of xbt_fifo more uniform and closing Mt's bug

git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@2002 48e7efb5-ca39-0410-a469-dd3cf9ba447f

diff --git a/src/msg/global.c b/src/msg/global.c
index dc3bd02..36bff65 100644 (file)
--- a/src/msg/global.c
+++ b/src/msg/global.c
@@ -466,7 +466,7 @@ int MSG_process_killall(int reset_PIDs)
   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);
   }
 
@@ -494,7 +494,7 @@ MSG_error_t MSG_clean(void)
   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();

diff --git a/src/msg/host.c b/src/msg/host.c
index cb042bf..cfc43c5 100644 (file)
--- a/src/msg/host.c
+++ b/src/msg/host.c
@@ -45,7 +45,7 @@ m_host_t __MSG_host_create(const char *name,
   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);
 

diff --git a/src/msg/m_process.c b/src/msg/m_process.c
index cf35439..7507c33 100644 (file)
--- a/src/msg/m_process.c
+++ b/src/msg/m_process.c
@@ -113,15 +113,17 @@ m_process_t MSG_process_create_with_arguments(const char *name,
   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);
 
@@ -198,7 +200,7 @@ MSG_error_t MSG_process_change_host(m_process_t process, m_host_t host)
 
   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;
 }