X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1c19e8ee59414e654e441b692dda9231c3c9348d..725184f3bce66a3eff87cc3a01e5d96477a5d28a:/src/smpi/private.h diff --git a/src/smpi/private.h b/src/smpi/private.h index 63be652dcb..487d12913f 100644 --- a/src/smpi/private.h +++ b/src/smpi/private.h @@ -83,16 +83,10 @@ typedef struct smpi_global_t { double reference_speed; // state vars - - smx_host_t *hosts; - int host_count; + int process_count; xbt_mallocator_t request_mallocator; xbt_mallocator_t message_mallocator; - // FIXME: request queues should be moved to host data... - xbt_fifo_t *pending_send_request_queues; - xbt_fifo_t *received_message_queues; - smx_process_t *main_processes; xbt_os_timer_t timer; @@ -117,14 +111,16 @@ typedef struct smpi_host_data_t { smx_process_t sender; smx_process_t receiver; - int finalize; /* for main stopping sender&receiver */ + int finalize; /* so that main process stops its sender&receiver */ xbt_fifo_t pending_recv_request_queue; -} s_smpi_host_data_t; -typedef struct smpi_host_data_t *smpi_host_data_t; + xbt_fifo_t pending_send_request_queue; + xbt_fifo_t received_message_queue; +} s_smpi_process_data_t; +typedef struct smpi_host_data_t *smpi_process_data_t; // function prototypes -void smpi_process_init(void); +void smpi_process_init(int *argc,char ***argv); void smpi_process_finalize(void); int smpi_mpi_comm_rank(smpi_mpi_communicator_t comm); @@ -142,9 +138,9 @@ void smpi_bench_skip(void); void smpi_global_init(void); void smpi_global_destroy(void); -int smpi_host_index(void); -smx_mutex_t smpi_host_mutex(void); -smx_cond_t smpi_host_cond(void); +int smpi_process_index(void); +smx_mutex_t smpi_process_mutex(void); +smx_cond_t smpi_process_cond(void); int smpi_run_simulation(int *argc, char **argv); int smpi_create_request(void *buf, int count, smpi_mpi_datatype_t datatype, int src, int dst, int tag,