X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dff9e15c44ab6340d27215957c56fa72fad246a2..16e1615dff6a9f5a19efb4861563436a638642ed:/src/smpi/smpi_global.c

diff --git a/src/smpi/smpi_global.c b/src/smpi/smpi_global.c
index 710353d8f8..870bae3351 100644
--- a/src/smpi/smpi_global.c
+++ b/src/smpi/smpi_global.c
@@ -120,6 +120,11 @@ int smpi_create_request(void *buf, int count, smpi_mpi_datatype_t datatype,
   }
   return retval;
 }
+/* FIXME: understand what they do and put the prototypes in a header file (live in smpi_base.c) */
+void smpi_mpi_land_func(void *a, void *b, int *length,
+                        MPI_Datatype * datatype);
+void smpi_mpi_sum_func(void *a, void *b, int *length,
+                       MPI_Datatype * datatype);
 
 void smpi_global_init()
 {
@@ -142,20 +147,12 @@ void smpi_global_init()
   // config variable
   smpi_global->reference_speed = SMPI_DEFAULT_SPEED;
 
-  smpi_global->root_ready = 0;
-  smpi_global->ready_process_count = 0;
-
-  // start/stop
-  smpi_global->start_stop_mutex = SIMIX_mutex_init();
-  smpi_global->start_stop_cond = SIMIX_cond_init();
-
   // host info blank until sim starts
   // FIXME: is this okay?
   smpi_global->hosts = NULL;
   smpi_global->host_count = 0;
 
   // running hosts
-  smpi_global->running_hosts_count_mutex = SIMIX_mutex_init();
   smpi_global->running_hosts_count = 0;
 
   // mallocators
@@ -168,15 +165,10 @@ void smpi_global_init()
 
   // queues
   smpi_global->pending_send_request_queues = xbt_new(xbt_fifo_t, size);
-  smpi_global->pending_send_request_queues_mutexes =
-    xbt_new(smx_mutex_t, size);
-  smpi_global->pending_recv_request_queues = xbt_new(xbt_fifo_t, size);
-  smpi_global->pending_recv_request_queues_mutexes =
-    xbt_new(smx_mutex_t, size);
   smpi_global->received_message_queues = xbt_new(xbt_fifo_t, size);
-  smpi_global->received_message_queues_mutexes = xbt_new(smx_mutex_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);
 
@@ -191,13 +183,43 @@ void smpi_global_init()
 
   for (i = 0; i < size; i++) {
     smpi_global->pending_send_request_queues[i] = xbt_fifo_new();
-    smpi_global->pending_send_request_queues_mutexes[i] = SIMIX_mutex_init();
-    smpi_global->pending_recv_request_queues[i] = xbt_fifo_new();
-    smpi_global->pending_recv_request_queues_mutexes[i] = SIMIX_mutex_init();
     smpi_global->received_message_queues[i] = xbt_fifo_new();
-    smpi_global->received_message_queues_mutexes[i] = SIMIX_mutex_init();
   }
 
+  smpi_global->hosts = SIMIX_host_get_table();
+  smpi_global->host_count = SIMIX_host_get_number();
+
+  smpi_mpi_global = xbt_new(s_smpi_mpi_global_t, 1);
+
+  // global communicator
+  smpi_mpi_global->mpi_comm_world = xbt_new(s_smpi_mpi_communicator_t, 1);
+  smpi_mpi_global->mpi_comm_world->size = smpi_global->host_count;
+  smpi_mpi_global->mpi_comm_world->barrier_count = 0;
+  smpi_mpi_global->mpi_comm_world->barrier_mutex = SIMIX_mutex_init();
+  smpi_mpi_global->mpi_comm_world->barrier_cond = SIMIX_cond_init();
+  smpi_mpi_global->mpi_comm_world->rank_to_index_map =
+    xbt_new(int, smpi_global->host_count);
+  smpi_mpi_global->mpi_comm_world->index_to_rank_map =
+    xbt_new(int, smpi_global->host_count);
+  for (i = 0; i < smpi_global->host_count; i++) {
+    smpi_mpi_global->mpi_comm_world->rank_to_index_map[i] = i;
+    smpi_mpi_global->mpi_comm_world->index_to_rank_map[i] = i;
+  }
+
+  // mpi datatypes
+  smpi_mpi_global->mpi_byte = xbt_new(s_smpi_mpi_datatype_t, 1);
+  smpi_mpi_global->mpi_byte->size = (size_t) 1;
+  smpi_mpi_global->mpi_int = xbt_new(s_smpi_mpi_datatype_t, 1);
+  smpi_mpi_global->mpi_int->size = sizeof(int);
+  smpi_mpi_global->mpi_double = xbt_new(s_smpi_mpi_datatype_t, 1);
+  smpi_mpi_global->mpi_double->size = sizeof(double);
+
+  // mpi operations
+  smpi_mpi_global->mpi_land = xbt_new(s_smpi_mpi_op_t, 1);
+  smpi_mpi_global->mpi_land->func = smpi_mpi_land_func;
+  smpi_mpi_global->mpi_sum = xbt_new(s_smpi_mpi_op_t, 1);
+  smpi_mpi_global->mpi_sum->func = smpi_mpi_sum_func;
+
 }
 
 void smpi_global_destroy()
@@ -208,17 +230,11 @@ void smpi_global_destroy()
 
   smpi_do_once_duration_node_t curr, next;
 
-  // start/stop
-  SIMIX_mutex_destroy(smpi_global->start_stop_mutex);
-  SIMIX_cond_destroy(smpi_global->start_stop_cond);
-
   // processes
+  xbt_free(smpi_global->main_processes);
   xbt_free(smpi_global->sender_processes);
   xbt_free(smpi_global->receiver_processes);
 
-  // running hosts
-  SIMIX_mutex_destroy(smpi_global->running_hosts_count_mutex);
-
   // mallocators
   xbt_mallocator_free(smpi_global->request_mallocator);
   xbt_mallocator_free(smpi_global->message_mallocator);
@@ -237,19 +253,11 @@ void smpi_global_destroy()
 
   for (i = 0; i < size; i++) {
     xbt_fifo_free(smpi_global->pending_send_request_queues[i]);
-    SIMIX_mutex_destroy(smpi_global->pending_send_request_queues_mutexes[i]);
-    xbt_fifo_free(smpi_global->pending_recv_request_queues[i]);
-    SIMIX_mutex_destroy(smpi_global->pending_recv_request_queues_mutexes[i]);
     xbt_fifo_free(smpi_global->received_message_queues[i]);
-    SIMIX_mutex_destroy(smpi_global->received_message_queues_mutexes[i]);
   }
 
   xbt_free(smpi_global->pending_send_request_queues);
-  xbt_free(smpi_global->pending_send_request_queues_mutexes);
-  xbt_free(smpi_global->pending_recv_request_queues);
-  xbt_free(smpi_global->pending_recv_request_queues_mutexes);
   xbt_free(smpi_global->received_message_queues);
-  xbt_free(smpi_global->received_message_queues_mutexes);
 
   xbt_free(smpi_global);
 
@@ -289,18 +297,15 @@ int smpi_run_simulation(int *argc, char **argv)
 
   SIMIX_global_init(argc, argv);
 
-  SIMIX_function_register("smpi_simulated_main", smpi_simulated_main);
-  SIMIX_function_register("smpi_sender", smpi_sender);
-  SIMIX_function_register("smpi_receiver", smpi_receiver);
-
-  // FIXME: ought to verify these files...
+  // parse the platform file: get the host list
   SIMIX_create_environment(argv[1]);
 
+  SIMIX_function_register("smpi_simulated_main", smpi_simulated_main);
+  SIMIX_launch_application(argv[2]);
+
   // must initialize globals between creating environment and launching app....
   smpi_global_init();
 
-  SIMIX_launch_application(argv[2]);
-
   /* Prepare to display some more info when dying on Ctrl-C pressing */
   // FIXME: doesn't work
   //signal(SIGINT, inthandler);