X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b110f915460bff6576e1fc6d3a4f391992852714..16e1615dff6a9f5a19efb4861563436a638642ed:/src/smpi/private.h diff --git a/src/smpi/private.h b/src/smpi/private.h index 5f731a54f7..90b5b34f6f 100644 --- a/src/smpi/private.h +++ b/src/smpi/private.h @@ -91,14 +91,13 @@ 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 *main_processes; smx_process_t *sender_processes; smx_process_t *receiver_processes; int running_hosts_count; - smx_mutex_t running_hosts_count_mutex; xbt_os_timer_t timer; smx_mutex_t timer_mutex; @@ -117,12 +116,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); @@ -148,8 +153,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