X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/994908f535190638662797b1215506fc0664bd37..cac63707a2f233d0a979a67403336292eb2a3038:/src/smpi/private.h diff --git a/src/smpi/private.h b/src/smpi/private.h index f3e8515c8f..2db330e2ca 100644 --- a/src/smpi/private.h +++ b/src/smpi/private.h @@ -91,11 +91,9 @@ typedef struct smpi_global_t { // FIXME: request queues should be moved to host data... xbt_fifo_t *pending_send_request_queues; - xbt_fifo_t *pending_recv_request_queues; xbt_fifo_t *received_message_queues; - smx_process_t *sender_processes; - smx_process_t *receiver_processes; + smx_process_t *main_processes; int running_hosts_count; @@ -116,12 +114,18 @@ typedef struct smpi_host_data_t { int index; smx_mutex_t mutex; smx_cond_t cond; + + smx_process_t main; + smx_process_t sender; + smx_process_t receiver; + + xbt_fifo_t pending_recv_request_queue; } s_smpi_host_data_t; typedef struct smpi_host_data_t *smpi_host_data_t; // function prototypes -void smpi_init_process(void); -void smpi_mpi_finalize(void); +void smpi_process_init(void); +void smpi_process_finalize(void); int smpi_mpi_comm_rank(smpi_mpi_communicator_t comm); int smpi_mpi_barrier(smpi_mpi_communicator_t comm); @@ -147,8 +151,7 @@ int smpi_create_request(void *buf, int count, smpi_mpi_datatype_t datatype, smpi_mpi_communicator_t comm, smpi_mpi_request_t * request); -int smpi_sender(int argc, char **argv); - -int smpi_receiver(int argc, char **argv); +int smpi_sender(int argc,char*argv[]); +int smpi_receiver(int argc, char*argv[]); #endif