ftreq 44 ompi/mca/vprotocol/base/vprotocol_base_request.h #define VPROTOCOL_RECV_REQ(ftreq) \ ftreq 46 ompi/mca/vprotocol/base/vprotocol_base_request.h (((uintptr_t) ftreq) - mca_pml_v.host_pml_req_send_size)) ftreq 60 ompi/mca/vprotocol/base/vprotocol_base_request.h #define VPROTOCOL_SEND_REQ(ftreq) \ ftreq 62 ompi/mca/vprotocol/base/vprotocol_base_request.h (((uintptr_t) ftreq) - mca_pml_v.host_pml_req_send_size)) ftreq 60 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_vprotocol_pessimist_request_t *ftreq = VPESSIMIST_FTREQ(req); ftreq 61 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(ftreq->event) ftreq 66 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h V_OUTPUT_VERBOSE(70, "pessimist:\tlog\tmatch\t%"PRIpclock"\tsrc %d\tseq %"PRIpclock, ftreq->reqid, req->req_status.MPI_SOURCE, ((mca_pml_base_request_t *) req)->req_sequence); ftreq 67 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event = ftreq->event; ftreq 69 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mevent->reqid = ftreq->reqid; ftreq 71 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h ftreq->event = NULL; ftreq 26 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c mca_vprotocol_pessimist_request_t *ftreq; ftreq 28 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c ftreq = VPESSIMIST_FTREQ(req); ftreq 29 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c V_OUTPUT_VERBOSE(250, "pessimist:\treq\tnew\treq=%p\tPreq=%p (aligned to %p)", (void *) req, (void *) ftreq, (void *) &ftreq->pml_req_free); ftreq 31 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c ftreq->pml_req_free = req->req_ompi.req_free; ftreq 32 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c ftreq->event = NULL; ftreq 33 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c ftreq->sb.bytes_progressed = 0; ftreq 34 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c assert(ftreq->pml_req_free == req->req_ompi.req_free); /* detection of aligment issues on different arch */ ftreq 36 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c OBJ_CONSTRUCT(& ftreq->list_item, opal_list_item_t); ftreq 157 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.c mca_vprotocol_pessimist_send_request_t *ftreq; ftreq 159 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.c ftreq = VPESSIMIST_CONV_REQ(pConvertor); ftreq 160 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.c pConvertor->flags = ftreq->sb.conv_flags; ftreq 161 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.c pConvertor->fAdvance = ftreq->sb.conv_advance; ftreq 167 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.c MEMCPY((void *) ftreq->sb.cursor, iov[i].iov_base, iov[i].iov_len); ftreq 169 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.c ftreq->sb.cursor += iov[i].iov_len; ftreq 73 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h mca_vprotocol_pessimist_send_request_t *ftreq; \ ftreq 76 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h ftreq = VPESSIMIST_SEND_FTREQ(REQ); \ ftreq 77 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h ftreq->sb.conv_flags = pConv->flags; \ ftreq 78 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h ftreq->sb.conv_advance = pConv->fAdvance; \ ftreq 99 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h mca_vprotocol_pessimist_send_request_t *ftreq = VPESSIMIST_SEND_FTREQ(req); ftreq 100 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h ftreq->sb.bytes_progressed = 0; ftreq 102 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h &ftreq->list_item); ftreq 108 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h mca_vprotocol_pessimist_request_t *ftreq = VPESSIMIST_SEND_FTREQ(req); ftreq 111 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h if(ftreq->sb.bytes_progressed < req->req_bytes_packed) ftreq 116 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h uintptr_t position = ftreq->sb.bytes_progressed; ftreq 117 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h max_data = req->req_bytes_packed - ftreq->sb.bytes_progressed; ftreq 119 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h iov.iov_base = (IOVBASE_TYPE *) (ftreq->sb.cursor + position); ftreq 121 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h V_OUTPUT_VERBOSE(80, "pessimist:\tsb\tprgress\t%"PRIpclock"\tsize %lu from position %lu", ftreq->reqid, max_data, position); ftreq 125 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h ftreq->sb.bytes_progressed += max_data; ftreq 137 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h mca_vprotocol_pessimist_request_t *ftreq = (mca_vprotocol_pessimist_request_t *) ftreq 139 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h if(vprotocol_pessimist_sb_progress_req(VPROTOCOL_SEND_REQ(ftreq))) ftreq 142 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h &ftreq->list_item); ftreq 154 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h mca_vprotocol_pessimist_request_t *ftreq = VPESSIMIST_SEND_FTREQ(req); ftreq 157 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h (opal_list_item_t *) ftreq); ftreq 159 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h assert(pmlreq->req_bytes_packed == ftreq->sb.bytes_progressed); ftreq 172 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h mca_vprotocol_pessimist_request_t *ftreq = VPESSIMIST_SEND_FTREQ(req); ftreq 185 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h ftreq->sb.cursor = mca_vprotocol_pessimist.sender_based.sb_cursor; ftreq 194 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr = (vprotocol_pessimist_sender_based_header_t *) ftreq->sb.cursor; ftreq 200 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h ftreq->sb.cursor += sizeof(vprotocol_pessimist_sender_based_header_t);