// FIXME: request queues should be moved to host data...
xbt_fifo_t *pending_send_request_queues;
- smx_mutex_t *pending_send_request_queues_mutexes;
-
- xbt_fifo_t *pending_recv_request_queues;
- smx_mutex_t *pending_recv_request_queues_mutexes;
-
xbt_fifo_t *received_message_queues;
- smx_mutex_t *received_message_queues_mutexes;
- smx_process_t *sender_processes;
- smx_process_t *receiver_processes;
+ smx_process_t *main_processes;
int running_hosts_count;
- smx_mutex_t running_hosts_count_mutex;
xbt_os_timer_t timer;
smx_mutex_t timer_mutex;
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);
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