Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Move pending_recv_request_queues into host_data (ie, wanna be process_data)
[simgrid.git] / src / smpi / smpi_global.c
index 91287da..0648f05 100644 (file)
@@ -165,7 +165,6 @@ void smpi_global_init()
 
   // queues
   smpi_global->pending_send_request_queues = xbt_new(xbt_fifo_t, size);
-  smpi_global->pending_recv_request_queues = xbt_new(xbt_fifo_t, size);
   smpi_global->received_message_queues = xbt_new(xbt_fifo_t, size);
 
   // sender/receiver processes
@@ -183,7 +182,6 @@ void smpi_global_init()
 
   for (i = 0; i < size; i++) {
     smpi_global->pending_send_request_queues[i] = xbt_fifo_new();
-    smpi_global->pending_recv_request_queues[i] = xbt_fifo_new();
     smpi_global->received_message_queues[i] = xbt_fifo_new();
   }
 
@@ -253,12 +251,10 @@ void smpi_global_destroy()
 
   for (i = 0; i < size; i++) {
     xbt_fifo_free(smpi_global->pending_send_request_queues[i]);
-    xbt_fifo_free(smpi_global->pending_recv_request_queues[i]);
     xbt_fifo_free(smpi_global->received_message_queues[i]);
   }
 
   xbt_free(smpi_global->pending_send_request_queues);
-  xbt_free(smpi_global->pending_recv_request_queues);
   xbt_free(smpi_global->received_message_queues);
 
   xbt_free(smpi_global);
@@ -303,8 +299,6 @@ int smpi_run_simulation(int *argc, char **argv)
   SIMIX_create_environment(argv[1]);
 
   SIMIX_function_register("smpi_simulated_main", smpi_simulated_main);
-  SIMIX_function_register("smpi_sender", smpi_sender);
-  SIMIX_function_register("smpi_receiver", smpi_receiver);
   SIMIX_launch_application(argv[2]);
 
   // must initialize globals between creating environment and launching app....