req_peer 202 ompi/debuggers/ompi_common_dll.c ompi_field_offset(i_info->mca_pml_base_request_t.offset.req_peer, req_peer 203 ompi/debuggers/ompi_common_dll.c qh_type, mca_pml_base_request_t, req_peer); req_peer 116 ompi/debuggers/ompi_common_dll_defs.h int req_peer; req_peer 1138 ompi/debuggers/ompi_msgq_dll.c res->desired_local_rank = ompi_fetch_int( proc, current_item + i_info->mca_pml_base_request_t.offset.req_peer, p_info ); req_peer 1599 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c breq->req_peer, req_peer 1611 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c breq->req_peer, req_peer 1685 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c breq->req_peer, src, breq->req_comm->c_contextid)); req_peer 1842 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c breq->req_peer, src, breq->req_comm->c_contextid)); req_peer 2078 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( 0 <= breq->req_peer ) { req_peer 2080 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c breq->req_peer, req_peer 2091 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c breq->req_peer, req_peer 2196 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( 0 <= breq->req_peer ) { req_peer 2198 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c breq->req_peer, req_peer 2209 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c breq->req_peer, req_peer 2344 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c breq->req_peer, src, breq->req_comm->c_contextid)); req_peer 2589 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c breq->req_peer, src, breq->req_comm->c_contextid)); req_peer 2905 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c src = breq->req_peer; req_peer 77 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_peer = src; \ req_peer 75 ompi/mca/pml/base/pml_base_request.h int32_t req_peer; /**< peer process - rank w/in this communicator */ req_peer 91 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_peer = (int32_t)peer; \ req_peer 42 ompi/mca/pml/cm/pml_cm_recvreq.h int32_t req_peer; /**< peer process - rank w/in this communicator */ req_peer 171 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_peer = src; \ req_peer 210 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_peer = src; \ req_peer 293 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_peer, \ req_peer 55 ompi/mca/pml/cm/pml_cm_sendreq.h int32_t req_peer; /**< peer process - rank w/in this communicator */ req_peer 281 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_peer = dst; \ req_peer 395 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_peer, \ req_peer 59 ompi/mca/pml/cm/pml_cm_start.c sendreq->req_peer, req_peer 40 ompi/mca/pml/monitoring/pml_monitoring_start.c if(OPAL_SUCCESS == mca_common_monitoring_get_world_rank(pml_request->req_peer, req_peer 329 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h if( OMPI_ANY_SOURCE == req->req_peer ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); req_peer 330 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h else snprintf(cpeer, 64, "%d", req->req_peer); req_peer 113 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h if((req->req_peer == peer || req->req_peer == OMPI_ANY_SOURCE) && (req->req_tag == tag || req->req_tag == OMPI_ANY_TAG)) req_peer 116 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h printf("Found list: %x tag: %x peer: %x\n", list, req->req_tag, req->req_peer); req_peer 159 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h if(((0x1l << i) & result) && req && ((req->req_peer == peer || req->req_peer == OMPI_ANY_SOURCE) && (req->req_tag == tag || req->req_tag == OMPI_ANY_TAG))) req_peer 189 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h printf("Index: %d Found list: %x tag: %x peer: %x\n", i, list, req->req_tag, req->req_peer); req_peer 216 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h printf("custom_match_prq_append list: %x key: %x mask: %x tag: %x peer: %x\n", list, key, mask, req->req_tag, req->req_peer); req_peer 336 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h if( OMPI_ANY_SOURCE == req->req_peer ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); req_peer 337 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h else snprintf(cpeer, 64, "%d", req->req_peer); req_peer 113 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h if((req->req_peer == peer || req->req_peer == OMPI_ANY_SOURCE) && (req->req_tag == tag || req->req_tag == OMPI_ANY_TAG)) req_peer 116 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h printf("Found list: %x tag: %x peer: %x\n", list, req->req_tag, req->req_peer); req_peer 153 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h if((0x1 << i & result) && req && ((req->req_peer == peer || req->req_peer == OMPI_ANY_SOURCE) && (req->req_tag == tag || req->req_tag == OMPI_ANY_TAG))) req_peer 183 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h printf("Found list: %x tag: %x peer: %x\n", list, req->req_tag, req->req_peer); req_peer 210 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h printf("custom_match_prq_append list: %x key: %x mask: %x tag: %x peer: %x\n", list, key, mask, req->req_tag, req->req_peer); req_peer 328 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h if( OMPI_ANY_SOURCE == req->req_peer ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); req_peer 329 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h else snprintf(cpeer, 64, "%d", req->req_peer); req_peer 112 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h if((req->req_peer == peer || req->req_peer == OMPI_ANY_SOURCE) && (req->req_tag == tag || req->req_tag == OMPI_ANY_TAG)) req_peer 115 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h printf("Found list: %x tag: %x peer: %x\n", list, req->req_tag, req->req_peer); req_peer 153 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h if((0x1 << i & result) && req && ((req->req_peer == peer || req->req_peer == OMPI_ANY_SOURCE) && (req->req_tag == tag || req->req_tag == OMPI_ANY_TAG))) req_peer 183 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h printf("Found list: %x tag: %x peer: %x\n", list, req->req_tag, req->req_peer); req_peer 221 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h printf("custom_match_prq_append list: %x key: %x mask: %x tag: %x peer: %x\n", list, key, mask, req->req_tag, req->req_peer); req_peer 337 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h if( OMPI_ANY_SOURCE == req->req_peer ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); req_peer 338 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h else snprintf(cpeer, 64, "%d", req->req_peer); req_peer 141 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h printf("Found list: %x tag: %x peer: %x\n", list, req->req_tag, req->req_peer); req_peer 173 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h printf("custom_match_prq_append list: %x tag: %x soruce: %x tag: %x peer: %x\n", list, tag, source, req->req_tag, req->req_peer); req_peer 288 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h if( OMPI_ANY_SOURCE == req->req_peer ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); req_peer 289 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h else snprintf(cpeer, 64, "%d", req->req_peer); req_peer 118 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h printf("Found list: %p tag: %x peer: %x\n", (void *) list, req->req_tag, req->req_peer); req_peer 155 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h if((0x1 << i & result) && req && ((req->req_peer == peer || req->req_peer == OMPI_ANY_SOURCE) && (req->req_tag == tag || req->req_tag == OMPI_ANY_TAG))) req_peer 187 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h printf("Found list: %p tag: %x peer: %x\n", (void *) list, req->req_tag, req->req_peer); req_peer 222 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h mask_src, mask_tag, req->req_tag, req->req_peer); req_peer 347 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h if( OMPI_ANY_SOURCE == req->req_peer ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); req_peer 348 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h else snprintf(cpeer, 64, "%d", req->req_peer); req_peer 553 ompi/mca/pml/ob1/pml_ob1.c if( OMPI_ANY_SOURCE == req->req_peer ) snprintf(cpeer, 64, "%s", "ANY_SOURCE"); req_peer 554 ompi/mca/pml/ob1/pml_ob1.c else snprintf(cpeer, 64, "%d", req->req_peer); req_peer 234 ompi/mca/pml/ob1/pml_ob1_irecv.c proc = mca_pml_ob1_peer_lookup (comm, recvreq->req_recv.req_base.req_peer); req_peer 326 ompi/mca/pml/ob1/pml_ob1_irecv.c proc = mca_pml_ob1_peer_lookup (comm, recvreq->req_recv.req_base.req_peer); req_peer 116 ompi/mca/pml/ob1/pml_ob1_recvreq.c if( request->req_recv.req_base.req_peer == OMPI_ANY_SOURCE ) { req_peer 119 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_comm_proc_t* proc = mca_pml_ob1_peer_lookup (comm, request->req_recv.req_base.req_peer); req_peer 1147 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_peer, req_peer 1175 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_peer, req_peer 1267 ompi/mca/pml/ob1/pml_ob1_recvreq.c if(req->req_recv.req_base.req_peer == OMPI_ANY_SOURCE) { req_peer 1286 ompi/mca/pml/ob1/pml_ob1_recvreq.c proc = mca_pml_ob1_peer_lookup (comm, req->req_recv.req_base.req_peer); req_peer 1308 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_peer); req_peer 252 ompi/mca/pml/ob1/pml_ob1_recvreq.h if(MPI_ANY_SOURCE == req->req_recv.req_base.req_peer) { req_peer 488 ompi/mca/pml/ob1/pml_ob1_sendreq.h mca_pml_ob1_comm_proc_t *ob1_proc = mca_pml_ob1_peer_lookup (comm, sendreq->req_send.req_base.req_peer); req_peer 69 ompi/mca/pml/ob1/pml_ob1_start.c pml_request->req_peer, req_peer 43 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(MPI_ANY_SOURCE == pmlreq->req_peer) req_peer 42 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c V_OUTPUT_VERBOSE(50, "pessimist:\treq\tfree\t%"PRIpclock"\tpeer %d\ttag %d\tsize %lu", VPESSIMIST_FTREQ(pmlreq)->reqid, pmlreq->req_peer, pmlreq->req_tag, (unsigned long) pmlreq->req_count); req_peer 196 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr->dst = pmlreq->req_base.req_peer; req_peer 27 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c V_OUTPUT_VERBOSE(50, "pessimist:\tstart\trecv\t%"PRIpclock"\tfrom %d\ttag %d\tsize %lu", mca_vprotocol_pessimist.clock, pml_request->req_peer, pml_request->req_tag, (long) pml_request->req_count); req_peer 29 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c VPROTOCOL_PESSIMIST_MATCHING_REPLAY(pml_request->req_peer); req_peer 33 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c V_OUTPUT_VERBOSE(50, "pessimist:\tstart\tsend\t%"PRIpclock"\tto %d\ttag %d\tsize %lu", mca_vprotocol_pessimist.clock, pml_request->req_peer, pml_request->req_tag, (long) pml_request->req_count); req_peer 39 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c V_OUTPUT_VERBOSE(50, "pessimist:\tstart\twrong %d\t%"PRIpclock"\tfrom %d\ttag %d\tsize %lu", pml_request->req_type, mca_vprotocol_pessimist.clock, pml_request->req_peer, pml_request->req_tag, (long) pml_request->req_count); req_peer 82 ompi/peruse/peruse-internal.h _comm_spec.peer = (base_req)->req_peer; \ req_peer 100 ompi/peruse/peruse-internal.h _comm_spec.peer = (base_req)->req_peer; \ req_peer 60 oshmem/mca/spml/base/spml_base_atomicreq.h (request)->req_base.req_peer = src; \ req_peer 54 oshmem/mca/spml/base/spml_base_getreq.h (request)->req_base.req_peer = (int32_t)peer; \ req_peer 61 oshmem/mca/spml/base/spml_base_putreq.h (request)->req_base.req_peer = (int32_t)peer; \ req_peer 74 oshmem/mca/spml/base/spml_base_request.h int32_t req_peer; /**< peer process - rank of process executing the parallel program */