pmlreq 42 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_pml_base_request_t *pmlreq = (mca_pml_base_request_t *) req; pmlreq 43 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(MPI_ANY_SOURCE == pmlreq->req_peer) pmlreq 47 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event->req = pmlreq; pmlreq 41 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c mca_pml_base_request_t *pmlreq = (mca_pml_base_request_t *) *req; pmlreq 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); pmlreq 44 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c pmlreq->req_ompi.req_status.MPI_SOURCE = -1; /* no matching made flag */ pmlreq 46 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c return VPESSIMIST_FTREQ(pmlreq)->pml_req_free(req); pmlreq 41 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h static inline void __SENDER_BASED_METHOD_COPY(mca_pml_base_send_request_t *pmlreq) pmlreq 43 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h if(0 != pmlreq->req_bytes_packed) pmlreq 51 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h max_data = iov.iov_len = pmlreq->req_bytes_packed; pmlreq 52 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h iov.iov_base = (IOVBASE_TYPE *) VPESSIMIST_SEND_FTREQ(pmlreq)->sb.cursor; pmlreq 53 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h opal_convertor_clone_with_position( &pmlreq->req_base.req_convertor, pmlreq 149 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h mca_pml_base_send_request_t *pmlreq = (mca_pml_base_send_request_t *) req; pmlreq 151 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h if((pmlreq->req_base.req_type == MCA_PML_REQUEST_SEND) && pmlreq 152 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h pmlreq->req_bytes_packed) pmlreq 158 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h vprotocol_pessimist_sb_progress_req(pmlreq); pmlreq 159 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h assert(pmlreq->req_bytes_packed == ftreq->sb.bytes_progressed); pmlreq 173 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h mca_pml_base_send_request_t *pmlreq = (mca_pml_base_send_request_t *) req; pmlreq 177 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h pmlreq->req_bytes_packed + pmlreq 180 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h vprotocol_pessimist_sender_based_alloc(pmlreq->req_bytes_packed); pmlreq 189 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h pmlreq->req_bytes_packed; pmlreq 192 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h pmlreq->req_bytes_packed; pmlreq 195 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr->size = pmlreq->req_bytes_packed; pmlreq 196 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr->dst = pmlreq->req_base.req_peer; pmlreq 197 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr->tag = pmlreq->req_base.req_tag; pmlreq 198 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr->contextid = pmlreq->req_base.req_comm->c_contextid; pmlreq 199 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr->sequence = pmlreq->req_base.req_sequence; pmlreq 201 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h V_OUTPUT_VERBOSE(70, "pessimist:\tsb\tsend\t%"PRIpclock"\tsize %lu (+%lu header)", VPESSIMIST_FTREQ(req)->reqid, (long unsigned)pmlreq->req_bytes_packed, (long unsigned)sizeof(vprotocol_pessimist_sender_based_header_t)); pmlreq 204 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h __SENDER_BASED_METHOD_COPY(pmlreq);