25 #ifndef MCA_CRCP_HOKE_PML_EXPORT_H
26 #define MCA_CRCP_HOKE_PML_EXPORT_H
28 #include "ompi_config.h"
32 #include "ompi/communicator/communicator.h"
73 int dst,
int tag, mca_pml_base_send_mode_t mode,
80 int dst,
int tag, mca_pml_base_send_mode_t mode,
87 int dst,
int tag, mca_pml_base_send_mode_t mode,
120 enum ompi_crcp_bkmrk_pml_quiesce_tag_type_t {
121 QUIESCE_TAG_NONE = 0,
123 QUIESCE_TAG_CONTINUE,
127 typedef enum ompi_crcp_bkmrk_pml_quiesce_tag_type_t ompi_crcp_bkmrk_pml_quiesce_tag_type_t;
129 int ompi_crcp_bkmrk_pml_quiesce_start(ompi_crcp_bkmrk_pml_quiesce_tag_type_t tag );
130 int ompi_crcp_bkmrk_pml_quiesce_end(ompi_crcp_bkmrk_pml_quiesce_tag_type_t tag );
143 enum ompi_crcp_bkmrk_pml_message_type_t {
144 COORD_MSG_TYPE_UNKNOWN,
145 COORD_MSG_TYPE_B_SEND,
146 COORD_MSG_TYPE_I_SEND,
147 COORD_MSG_TYPE_P_SEND,
148 COORD_MSG_TYPE_B_RECV,
149 COORD_MSG_TYPE_I_RECV,
150 COORD_MSG_TYPE_P_RECV
152 typedef enum ompi_crcp_bkmrk_pml_message_type_t ompi_crcp_bkmrk_pml_message_type_t;
416 uint32_t matched_msgs_sent;
420 uint32_t matched_msgs_recvd;
int already_posted
Count of the number of posted PML messages that match this reference.
Definition: crcp_bkmrk_pml.h:254
size_t count
Count for data.
Definition: crcp_bkmrk_pml.h:216
int tag
Message Tag.
Definition: crcp_bkmrk_pml.h:303
opal_list_t recv_init_list
pml_irecv_init
Definition: crcp_bkmrk_pml.h:392
bool ack_required
If peer is expecting an ACK after draining the messages.
Definition: crcp_bkmrk_pml.h:426
bool done
Done ? - Only useful in Drain.
Definition: crcp_bkmrk_pml.h:183
opal_list_item_t super
This is a list object.
Definition: crcp_bkmrk_pml.h:379
Definition: ompi_datatype.h:68
Checkpoint/Restart Coordination Protocol (CRCP) Interface.
Definition: crcp_bkmrk_pml.h:166
uint32_t total_msgs_sent
Total Number of messages sent.
Definition: crcp_bkmrk_pml.h:415
opal_list_t send_list
List of messages sent to this peer.
Definition: crcp_bkmrk_pml.h:385
int matched
Has this message been matched by the peer?
Definition: crcp_bkmrk_pml.h:337
orte_process_name_t proc_name
Name of peer.
Definition: crcp_bkmrk_pml.h:382
orte_process_name_t proc_name
Peer which we received from.
Definition: crcp_bkmrk_pml.h:237
struct ompi_datatype_t * datatype
Datatype.
Definition: crcp_bkmrk_pml.h:219
opal_list_t isend_list
pml_isend
Definition: crcp_bkmrk_pml.h:386
uint64_t msg_id
Sequence Number of this message.
Definition: crcp_bkmrk_pml.h:291
Remote Open MPI process structure.
Definition: proc.h:56
opal_list_item_t super
This is a list object.
Definition: crcp_bkmrk_pml.h:168
opal_list_t msg_contents
Message Contents.
Definition: crcp_bkmrk_pml.h:312
Top-level interface for all MCA components.
Definition: opal_list.h:98
uint64_t msg_id
Sequence Number of this message.
Definition: crcp_bkmrk_pml.h:210
ompi_communicator_t * comm
Communicator pointer.
Definition: crcp_bkmrk_pml.h:309
bool already_drained
Drained.
Definition: crcp_bkmrk_pml.h:189
orte_process_name_t proc_name
Peer which we received from.
Definition: crcp_bkmrk_pml.h:315
bool complete
Complete flag.
Definition: crcp_bkmrk_pml.h:271
opal_list_t irecv_list
pml_irecv
Definition: crcp_bkmrk_pml.h:391
bool active
Active ?
Definition: crcp_bkmrk_pml.h:180
uint32_t total_drained_msgs
Total Number of messages drained.
Definition: crcp_bkmrk_pml.h:423
Definition: crcp_bkmrk_pml.h:205
void * buffer
Buffer for data.
Definition: crcp_bkmrk_pml.h:171
uint64_t msg_id
JJH XXX Debug counter.
Definition: crcp_bkmrk_pml.h:192
opal_list_item_t super
This is a list object.
Definition: crcp_bkmrk_pml.h:268
opal_list_t msg_contents
Message Contents.
Definition: crcp_bkmrk_pml.h:234
uint32_t total_msgs_recvd
Total Number of messages received.
Definition: crcp_bkmrk_pml.h:419
int done
Count of the number of completed PML messages that match this reference.
Definition: crcp_bkmrk_pml.h:242
Definition: crcp_bkmrk_pml.h:286
size_t ddt_size
Quick reference to the size of the datatype.
Definition: crcp_bkmrk_pml.h:300
Definition: opal_list.h:147
int done
Is this message complete WRT PML semantics?
Definition: crcp_bkmrk_pml.h:344
int active
Count of the number of active PML messages that match this reference.
Definition: crcp_bkmrk_pml.h:247
Definition: crcp_bkmrk_pml.h:437
ompi_crcp_bkmrk_pml_message_type_t msg_type
Type of message this references.
Definition: crcp_bkmrk_pml.h:213
Definition: crcp_bkmrk_pml.h:266
ompi_crcp_bkmrk_pml_message_type_t msg_type
Type of message this references.
Definition: crcp_bkmrk_pml.h:294
ompi_communicator_t * comm
Communicator pointer.
Definition: crcp_bkmrk_pml.h:231
opal_list_t send_init_list
pml_isend_init
Definition: crcp_bkmrk_pml.h:387
opal_list_t recv_list
List of messages recved from this peer.
Definition: crcp_bkmrk_pml.h:390
int tag
Message Tag.
Definition: crcp_bkmrk_pml.h:225
opal_list_item_t super
This is a list object.
Definition: crcp_bkmrk_pml.h:288
int active
Is the message actively being worked on?
Definition: crcp_bkmrk_pml.h:351
int active_drain
Actively drained These are messages that are active, and being drained.
Definition: crcp_bkmrk_pml.h:362
Definition: communicator.h:118
size_t ddt_size
Quick reference to the size of the datatype.
Definition: crcp_bkmrk_pml.h:222
Main top-level request struct definition.
Definition: request.h:100
orte_process_name_t peer
Peer which we received from.
Definition: crcp_bkmrk_pml.h:274
bool already_posted
Already_posted ? - Only useful in Drain.
Definition: crcp_bkmrk_pml.h:186
size_t count
Count for data.
Definition: crcp_bkmrk_pml.h:297
opal_list_item_t super
This is a list object.
Definition: crcp_bkmrk_pml.h:207
int rank
Peer rank to which it was sent/recv'ed if known.
Definition: crcp_bkmrk_pml.h:306
int posted
How many times a persistent send/recv has been posted, but not activated.
Definition: crcp_bkmrk_pml.h:356
#define OBJ_CLASS_DECLARATION(NAME)
Declaration for class descriptor.
Definition: opal_object.h:236
Definition: crcp_bkmrk_pml.h:377
int rank
Peer rank to which it was sent/recv'ed if known.
Definition: crcp_bkmrk_pml.h:228
opal_list_t drained_list
List of messages drained from this peer.
Definition: crcp_bkmrk_pml.h:395
ompi_status_public_t status
Status.
Definition: crcp_bkmrk_pml.h:177