seq 188 ompi/mca/pml/ob1/pml_ob1_irecv.c uint64_t seq; seq 197 ompi/mca/pml/ob1/pml_ob1_irecv.c seq = recvreq->req_recv.req_base.req_sequence; seq 232 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_sequence = seq; seq 281 ompi/mca/pml/ob1/pml_ob1_irecv.c uint64_t seq; seq 290 ompi/mca/pml/ob1/pml_ob1_irecv.c seq = recvreq->req_recv.req_base.req_sequence; seq 324 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_sequence = seq; seq 120 ompi/mca/pml/ob1/pml_ob1_recvfrag.c uint16_t seq) seq 191 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if( parent->hdr.hdr_match.hdr_seq >= seq ) seq 192 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if( abs(parent->hdr.hdr_match.hdr_seq - seq) < abs((*queue)->hdr.hdr_match.hdr_seq - seq)) seq 745 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_sequence_t *seq; seq 750 ompi/mca/pml/ob1/pml_ob1_recvfrag.c seq = &wild_recv_seq; seq 754 ompi/mca/pml/ob1/pml_ob1_recvfrag.c seq = &specific_recv_seq; seq 766 ompi/mca/pml/ob1/pml_ob1_recvfrag.c *seq = (*match) ? (*match)->req_recv.req_base.req_sequence : PML_MAX_SEQ; seq 180 ompi/mca/pml/ob1/pml_ob1_recvfrag.h uint16_t seq); seq 190 ompi/mca/pml/ob1/pml_ob1_sendreq.h #define MCA_PML_OB1_SEND_REQUEST_START_W_SEQ(sendreq, endpoint, seq, rc) \ seq 192 ompi/mca/pml/ob1/pml_ob1_sendreq.h rc = mca_pml_ob1_send_request_start_seq (sendreq, endpoint, seq); \ seq 26 ompi/mpiext/cr/c/checkpoint.c int OMPI_CR_Checkpoint(char **handle, int *seq, MPI_Info *info) seq 75 ompi/mpiext/cr/c/checkpoint.c *seq = datum->seq_num; seq 82 ompi/mpiext/cr/c/checkpoint.c MPI_Bcast(seq, 1, MPI_INT, 0, comm); seq 20 ompi/mpiext/cr/c/mpiext_cr_c.h OMPI_DECLSPEC int OMPI_CR_Checkpoint(char **handle, int *seq, MPI_Info *info); seq 25 ompi/mpiext/cr/c/mpiext_cr_c.h OMPI_DECLSPEC int OMPI_CR_Restart(char *handle, int seq, MPI_Info *info); seq 77 ompi/mpiext/cr/c/mpiext_cr_c.h OMPI_DECLSPEC int OMPI_CR_Quiesce_checkpoint(MPI_Comm comm, char **handle, int *seq, MPI_Info *info); seq 25 ompi/mpiext/cr/c/quiesce_checkpoint.c int OMPI_CR_Quiesce_checkpoint(MPI_Comm commP, char **handle, int *seq, MPI_Info *info) seq 64 ompi/mpiext/cr/c/quiesce_checkpoint.c *seq = datum->seq_num; seq 25 ompi/mpiext/cr/c/restart.c int OMPI_CR_Restart(char *handle, int seq, MPI_Info *info) seq 47 ompi/mpiext/cr/c/restart.c datum->seq_num = seq; seq 150 opal/mca/btl/usnic/btl_usnic_recv.h opal_btl_usnic_seq_t seq; seq 189 opal/mca/btl/usnic/btl_usnic_recv.h seq = seg->rs_base.us_btl_header->pkt_seq; seq 190 opal/mca/btl/usnic/btl_usnic_recv.h delta = SEQ_DIFF(seq, endpoint->endpoint_next_contig_seq_to_recv); seq 234 opal/mca/btl/usnic/btl_usnic_recv.h i = SEQ_DIFF(seq, endpoint->endpoint_next_contig_seq_to_recv); seq 243 opal/mca/btl/usnic/btl_usnic_recv.h assert(SEQ_LE(seq, endpoint->endpoint_highest_seq_rcvd)); seq 246 opal/mca/btl/usnic/btl_usnic_recv.h assert (SEQ_GT(seq, endpoint->endpoint_next_contig_seq_to_recv - 1)); seq 254 opal/mca/btl/usnic/btl_usnic_recv.h if (SEQ_GT(seq, endpoint->endpoint_highest_seq_rcvd)) { seq 255 opal/mca/btl/usnic/btl_usnic_recv.h endpoint->endpoint_highest_seq_rcvd = seq; seq 282 opal/mca/btl/usnic/btl_usnic_recv.h opal_btl_usnic_seq_t seq; seq 309 opal/mca/btl/usnic/btl_usnic_recv.h seq = seg->rs_base.us_btl_header->pkt_seq; seq 310 opal/mca/btl/usnic/btl_usnic_recv.h delta = SEQ_DIFF(seq, endpoint->endpoint_next_contig_seq_to_recv); seq 315 opal/mca/btl/usnic/btl_usnic_recv.h i = seq - endpoint->endpoint_next_contig_seq_to_recv; seq 55 opal/mca/btl/vader/btl_vader_endpoint.h uint16_t seq; seq 62 opal/mca/btl/vader/btl_vader_endpoint.h uint16_t seq; seq 102 opal/mca/btl/vader/btl_vader_endpoint.h endpoint->fbox_in.seq = 0; seq 115 opal/mca/btl/vader/btl_vader_endpoint.h endpoint->fbox_out.seq = 0; seq 32 opal/mca/btl/vader/btl_vader_fbox.h uint16_t seq; seq 57 opal/mca/btl/vader/btl_vader_fbox.h uint16_t seq, uint32_t size) seq 59 opal/mca/btl/vader/btl_vader_fbox.h mca_btl_vader_fbox_hdr_t tmp = {.data = {.tag = tag, .seq = seq, .size = size}}; seq 129 opal/mca/btl/vader/btl_vader_fbox.h mca_btl_vader_fbox_set_header (MCA_BTL_VADER_FBOX_HDR(dst), 0xff, ep->fbox_out.seq++, seq 171 opal/mca/btl/vader/btl_vader_fbox.h mca_btl_vader_fbox_set_header (MCA_BTL_VADER_FBOX_HDR(dst), tag, ep->fbox_out.seq++, data_size); seq 198 opal/mca/btl/vader/btl_vader_fbox.h if (0 == hdr.data.tag || hdr.data.seq != ep->fbox_in.seq) { seq 202 opal/mca/btl/vader/btl_vader_fbox.h ++ep->fbox_in.seq; seq 208 opal/mca/btl/vader/btl_vader_fbox.h ep->peer_smp_rank, hdr.data.tag, hdr.data.size, hdr.data.seq, start)); seq 53 opal/mca/reachable/netlink/libnl_utils.h uint32_t seq; seq 75 opal/mca/reachable/netlink/reachable_netlink_utils_common.c || nlm_hdr->nlmsg_seq != unlsk->seq) { seq 79 opal/mca/reachable/netlink/reachable_netlink_utils_common.c nlm_hdr->nlmsg_seq, unlsk->seq); seq 111 opal/mca/reachable/netlink/reachable_netlink_utils_common.c nlhdr->nlmsg_seq = ++unlsk->seq; seq 169 opal/mca/reachable/netlink/reachable_netlink_utils_common.c unlsk->seq = time(NULL); seq 100 orte/mca/rmaps/seq/rmaps_seq.c seq_node_t *sq, *save=NULL, *seq;; seq 334 orte/mca/rmaps/seq/rmaps_seq.c seq = (seq_node_t*)item; seq 339 orte/mca/rmaps/seq/rmaps_seq.c if (orte_ifislocal(seq->hostname)) { seq 341 orte/mca/rmaps/seq/rmaps_seq.c "mca:rmaps:seq: removing head node %s", seq->hostname); seq 112 orte/mca/sstore/base/base.h char *basedir, char *ref, int seq, seq 189 orte/mca/sstore/base/sstore_base_fns.c char *basedir, char *ref, int seq, seq 234 orte/mca/sstore/base/sstore_base_fns.c if( seq < 0 ) { seq 235 orte/mca/sstore/base/sstore_base_fns.c if( ORTE_SUCCESS != (ret = orte_sstore_base_find_largest_seq_num(snapshot, &seq)) ) { seq 242 orte/mca/sstore/base/sstore_base_fns.c snapshot->seq_num = seq; seq 244 orte/mca/sstore/base/sstore_base_fns.c snapshot->seq_num = seq; seq 52 orte/mca/sstore/central/sstore_central.h int orte_sstore_central_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid); seq 53 orte/mca/sstore/central/sstore_central.h int orte_sstore_central_request_restart_handle(orte_sstore_base_handle_t *handle, char *basedir, char *ref, int seq, seq 76 orte/mca/sstore/central/sstore_central.h int orte_sstore_central_global_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid); seq 80 orte/mca/sstore/central/sstore_central.h char *ref, int seq, seq 95 orte/mca/sstore/central/sstore_central.h int orte_sstore_central_local_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid); seq 110 orte/mca/sstore/central/sstore_central.h int orte_sstore_central_app_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid); seq 192 orte/mca/sstore/central/sstore_central_app.c int orte_sstore_central_app_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid) seq 148 orte/mca/sstore/central/sstore_central_global.c static orte_sstore_central_global_snapshot_info_t *create_new_handle_info(int seq, int type, orte_jobid_t jobid); seq 150 orte/mca/sstore/central/sstore_central_global.c static orte_sstore_central_global_snapshot_info_t *find_handle_info_from_ref(char *ref, int seq); seq 301 orte/mca/sstore/central/sstore_central_global.c int orte_sstore_central_global_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid) seq 313 orte/mca/sstore/central/sstore_central_global.c handle_info = create_new_handle_info(seq, SSTORE_HANDLE_TYPE_CKPT, jobid); seq 334 orte/mca/sstore/central/sstore_central_global.c char *ref, int seq, seq 340 orte/mca/sstore/central/sstore_central_global.c handle_info = find_handle_info_from_ref(ref, seq); seq 718 orte/mca/sstore/central/sstore_central_global.c static orte_sstore_central_global_snapshot_info_t *create_new_handle_info(int seq, int type, orte_jobid_t jobid) seq 731 orte/mca/sstore/central/sstore_central_global.c handle_info->seq_num = seq; seq 774 orte/mca/sstore/central/sstore_central_global.c static orte_sstore_central_global_snapshot_info_t *find_handle_info_from_ref(char *ref, int seq) seq 784 orte/mca/sstore/central/sstore_central_global.c if( handle_info->seq_num == seq ) { seq 294 orte/mca/sstore/central/sstore_central_local.c int orte_sstore_central_local_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid) seq 137 orte/mca/sstore/central/sstore_central_module.c int orte_sstore_central_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid) seq 143 orte/mca/sstore/central/sstore_central_module.c return orte_sstore_central_global_request_checkpoint_handle(handle, seq, jobid); seq 146 orte/mca/sstore/central/sstore_central_module.c return orte_sstore_central_local_request_checkpoint_handle(handle, seq, jobid); seq 149 orte/mca/sstore/central/sstore_central_module.c return orte_sstore_central_app_request_checkpoint_handle(handle, seq, jobid); seq 155 orte/mca/sstore/central/sstore_central_module.c int orte_sstore_central_request_restart_handle(orte_sstore_base_handle_t *handle, char *basedir, char *ref, int seq, seq 159 orte/mca/sstore/central/sstore_central_module.c return orte_sstore_base_tool_request_restart_handle(handle, basedir, ref, seq, snapshot); seq 162 orte/mca/sstore/central/sstore_central_module.c return orte_sstore_central_global_request_restart_handle(handle, basedir, ref, seq, snapshot); seq 208 orte/mca/sstore/sstore.h (orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid); seq 223 orte/mca/sstore/sstore.h char *basedir, char *ref, int seq, seq 67 orte/mca/sstore/stage/sstore_stage.h int orte_sstore_stage_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid); seq 68 orte/mca/sstore/stage/sstore_stage.h int orte_sstore_stage_request_restart_handle(orte_sstore_base_handle_t *handle, char *basedir, char *ref, int seq, seq 91 orte/mca/sstore/stage/sstore_stage.h int orte_sstore_stage_global_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid); seq 107 orte/mca/sstore/stage/sstore_stage.h int orte_sstore_stage_local_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid); seq 130 orte/mca/sstore/stage/sstore_stage.h int orte_sstore_stage_app_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid); seq 192 orte/mca/sstore/stage/sstore_stage_app.c int orte_sstore_stage_app_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid) seq 177 orte/mca/sstore/stage/sstore_stage_global.c static orte_sstore_stage_global_snapshot_info_t *create_new_handle_info(int seq, int type, orte_jobid_t jobid); seq 422 orte/mca/sstore/stage/sstore_stage_global.c int orte_sstore_stage_global_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid) seq 434 orte/mca/sstore/stage/sstore_stage_global.c handle_info = create_new_handle_info(seq, SSTORE_HANDLE_TYPE_CKPT, jobid); seq 919 orte/mca/sstore/stage/sstore_stage_global.c static orte_sstore_stage_global_snapshot_info_t *create_new_handle_info(int seq, int type, orte_jobid_t jobid) seq 932 orte/mca/sstore/stage/sstore_stage_global.c handle_info->seq_num = seq; seq 183 orte/mca/sstore/stage/sstore_stage_local.c static orte_sstore_stage_local_snapshot_info_t *find_handle_info_ref(char * ref, int seq); seq 201 orte/mca/sstore/stage/sstore_stage_local.c char *global_loc, char *ref, char *postfix, int seq); seq 504 orte/mca/sstore/stage/sstore_stage_local.c int orte_sstore_stage_local_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid) seq 986 orte/mca/sstore/stage/sstore_stage_local.c static orte_sstore_stage_local_snapshot_info_t *find_handle_info_ref(char * ref, int seq) seq 1001 orte/mca/sstore/stage/sstore_stage_local.c handle_info->seq_num == seq ) { seq 1980 orte/mca/sstore/stage/sstore_stage_local.c char *global_loc, char *ref, char *postfix, int seq) seq 2022 orte/mca/sstore/stage/sstore_stage_local.c seq); seq 143 orte/mca/sstore/stage/sstore_stage_module.c int orte_sstore_stage_request_checkpoint_handle(orte_sstore_base_handle_t *handle, int seq, orte_jobid_t jobid) seq 149 orte/mca/sstore/stage/sstore_stage_module.c return orte_sstore_stage_global_request_checkpoint_handle(handle, seq, jobid); seq 152 orte/mca/sstore/stage/sstore_stage_module.c return orte_sstore_stage_local_request_checkpoint_handle(handle, seq, jobid); seq 155 orte/mca/sstore/stage/sstore_stage_module.c return orte_sstore_stage_app_request_checkpoint_handle(handle, seq, jobid); seq 161 orte/mca/sstore/stage/sstore_stage_module.c int orte_sstore_stage_request_restart_handle(orte_sstore_base_handle_t *handle, char *basedir, char *ref, int seq, seq 165 orte/mca/sstore/stage/sstore_stage_module.c return orte_sstore_base_tool_request_restart_handle(handle, basedir, ref, seq, snapshot);