mpi.h

Go to the documentation of this file.

#pragma once

#ifdef HAVE_MPI

#include <stdbool.h>
#include <mpi.h>

#include <core/core.h>
#include <communication/wnd.h>
#include <statistics/statistics.h>

#define lock_mpi() {if(!mpi_support_multithread) spin_lock(&mpi_lock);}

#define unlock_mpi() {if(!mpi_support_multithread) spin_unlock(&mpi_lock);}

extern bool mpi_support_multithread;
extern spinlock_t mpi_lock;

void mpi_init(int *argc, char ***argv);
void inter_kernel_comm_init(void);
void inter_kernel_comm_finalize(void);
void mpi_finalize(void);
void syncronize_all(void);
void send_remote_msg(msg_t * msg);
bool pending_msgs(int tag);
void receive_remote_msgs(void);
bool is_request_completed(MPI_Request *);
bool all_kernels_terminated(void);
void broadcast_termination(void);
void collect_termination(void);
void mpi_reduce_statistics(struct stat_t *, struct stat_t *);

#endif /* HAVE_MPI */