From: mquinson <mquinson@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Date: Wed, 24 Jun 2009 19:53:50 +0000 (+0000)
Subject: SMPI: Add a global table of processes, which one day will replace the table of hosts
X-Git-Tag: SVN~1300
X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/commitdiff_plain/16e1615dff6a9f5a19efb4861563436a638642ed

SMPI: Add a global table of processes, which one day will replace the table of hosts

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

diff --git a/src/smpi/private.h b/src/smpi/private.h
index 5f796225ae..90b5b34f6f 100644
--- a/src/smpi/private.h
+++ b/src/smpi/private.h
@@ -93,6 +93,7 @@ typedef struct smpi_global_t {
   xbt_fifo_t *pending_send_request_queues;
   xbt_fifo_t *received_message_queues;
 
+  smx_process_t *main_processes;
   smx_process_t *sender_processes;
   smx_process_t *receiver_processes;
 
diff --git a/src/smpi/smpi_base.c b/src/smpi/smpi_base.c
index 6af070a6ff..fbc34fb0a2 100644
--- a/src/smpi/smpi_base.c
+++ b/src/smpi/smpi_base.c
@@ -78,6 +78,8 @@ void smpi_process_init()
           smpi_receiver, hdata,
           SIMIX_host_get_name(SIMIX_host_self()), 0, NULL,
           /*props */ NULL);
+
+  smpi_global->main_processes[hdata->index] = SIMIX_process_self();
   return;
 }
 
diff --git a/src/smpi/smpi_global.c b/src/smpi/smpi_global.c
index 0648f059bb..870bae3351 100644
--- a/src/smpi/smpi_global.c
+++ b/src/smpi/smpi_global.c
@@ -168,6 +168,7 @@ void smpi_global_init()
   smpi_global->received_message_queues = xbt_new(xbt_fifo_t, size);
 
   // sender/receiver processes
+  smpi_global->main_processes = xbt_new(smx_process_t, size);
   smpi_global->sender_processes = xbt_new(smx_process_t, size);
   smpi_global->receiver_processes = xbt_new(smx_process_t, size);
 
@@ -230,6 +231,7 @@ void smpi_global_destroy()
   smpi_do_once_duration_node_t curr, next;
 
   // processes
+  xbt_free(smpi_global->main_processes);
   xbt_free(smpi_global->sender_processes);
   xbt_free(smpi_global->receiver_processes);