docs/master/mpi_8h_source.html

 #pragma once


 #include <distributed/control_msg.h>

 #include <lp/msg.h>


 extern void mpi_global_init(int *argc_p, char ***argv_p);

 extern void mpi_global_fini(void);


 extern void mpi_remote_msg_send(struct lp_msg *msg, nid_t dest_nid);

 extern void mpi_remote_anti_msg_send(struct lp_msg *msg, nid_t dest_nid);


 extern void mpi_control_msg_broadcast(enum msg_ctrl_code ctrl);

 extern void mpi_control_msg_send_to(enum msg_ctrl_code ctrl, nid_t dest);

 extern void mpi_remote_msg_handle(void);

 extern void mpi_remote_msg_drain(void);


 extern void mpi_reduce_sum_scatter(const uint32_t values[n_nodes], uint32_t *result);

 extern bool mpi_reduce_sum_scatter_done(void);


 extern void mpi_reduce_min(double *node_min_p);

 extern bool mpi_reduce_min_done(void);


 extern void mpi_node_barrier(void);

 extern void mpi_blocking_data_send(const void *data, int data_size, nid_t dest);

 extern void *mpi_blocking_data_rcv(int *data_size_p, nid_t src);

control_msg.h
MPI remote control messages header.

msg_ctrl_code
msg_ctrl_code
A control message MPI tag value.
Definition: control_msg.h:17

n_nodes
nid_t n_nodes
The total number of MPI nodes in the simulation.
Definition: core.c:14

nid_t
int nid_t
Used to identify MPI nodes in a distributed environment.
Definition: core.h:72

mpi_global_init
void mpi_global_init(int *argc_p, char ***argv_p)
Initializes the MPI environment.
Definition: mpi.c:64

mpi_reduce_min
void mpi_reduce_min(double *node_min_p)
Computes the min-reduction operation across all nodes.
Definition: mpi.c:293

mpi_control_msg_send_to
void mpi_control_msg_send_to(enum msg_ctrl_code ctrl, nid_t dest)
Sends a platform control message to a specific nodes.
Definition: mpi.c:156

mpi_control_msg_broadcast
void mpi_control_msg_broadcast(enum msg_ctrl_code ctrl)
Sends a platform control message to all the nodes, including self.
Definition: mpi.c:143

mpi_reduce_sum_scatter_done
bool mpi_reduce_sum_scatter_done(void)
Checks if a previous mpi_reduce_sum_scatter() operation has completed.
Definition: mpi.c:276

mpi_remote_msg_handle
void mpi_remote_msg_handle(void)
Empties the queue of incoming MPI messages, doing the right thing for each one of them.
Definition: mpi.c:171

mpi_remote_msg_drain
void mpi_remote_msg_drain(void)
Empties the queue of incoming MPI messages, ignoring them.
Definition: mpi.c:216

mpi_reduce_min_done
bool mpi_reduce_min_done(void)
Checks if a previous mpi_reduce_min() operation has completed.
Definition: mpi.c:304

mpi_blocking_data_send
void mpi_blocking_data_send(const void *data, int data_size, nid_t dest)
Sends a byte buffer to another node.
Definition: mpi.c:328

mpi_remote_anti_msg_send
void mpi_remote_anti_msg_send(struct lp_msg *msg, nid_t dest_nid)
Sends a model anti-message to a LP residing on another node.
Definition: mpi.c:130

mpi_node_barrier
void mpi_node_barrier(void)
A node barrier.
Definition: mpi.c:314

mpi_blocking_data_rcv
void * mpi_blocking_data_rcv(int *data_size_p, nid_t src)
Receives a byte buffer from another node.
Definition: mpi.c:341

mpi_remote_msg_send
void mpi_remote_msg_send(struct lp_msg *msg, nid_t dest_nid)
Sends a model message to a LP residing on another node.
Definition: mpi.c:111

mpi_reduce_sum_scatter
void mpi_reduce_sum_scatter(const uint32_t values[n_nodes], uint32_t *result)
Computes the sum-reduction-scatter operation across all nodes.
Definition: mpi.c:267

mpi_global_fini
void mpi_global_fini(void)
Finalizes the MPI environment.
Definition: mpi.c:92

msg.h
Message management functions.

lp_msg
A model simulation message.
Definition: msg.h:59