pml_request 309 ompi/mca/osc/pt2pt/osc_pt2pt.h ompi_request_t *pml_request; pml_request 485 ompi/mca/osc/pt2pt/osc_pt2pt_component.c recv->pml_request = NULL; pml_request 491 ompi/mca/osc/pt2pt/osc_pt2pt_component.c if (recv->pml_request && MPI_REQUEST_NULL != recv->pml_request) { pml_request 492 ompi/mca/osc/pt2pt/osc_pt2pt_component.c recv->pml_request->req_complete_cb = NULL; pml_request 493 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ompi_request_cancel (recv->pml_request); pml_request 494 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ompi_request_free (&recv->pml_request); pml_request 1630 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_request_wait_completion (recv->pml_request); pml_request 1633 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c recv->pml_request->req_complete_cb = ompi_osc_pt2pt_callback; pml_request 1634 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c recv->pml_request->req_complete_cb_data = (void *) recv; pml_request 1636 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c return MCA_PML_CALL(start(1, &recv->pml_request)); pml_request 1643 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c size_t incoming_length = recv->pml_request->req_status._ucount; pml_request 1644 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c int source = recv->pml_request->req_status.MPI_SOURCE; pml_request 1720 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c MPI_BYTE, OMPI_ANY_SOURCE, OSC_PT2PT_FRAG_TAG, module->comm, &module->recv_frags[i].pml_request, pml_request 40 ompi/mca/pml/cm/pml_cm_start.c mca_pml_cm_request_t *pml_request = (mca_pml_cm_request_t*)requests[i]; pml_request 41 ompi/mca/pml/cm/pml_cm_start.c if (OMPI_REQUEST_PML != requests[i]->req_type || NULL == pml_request) { pml_request 46 ompi/mca/pml/cm/pml_cm_start.c switch (pml_request->req_pml_type) { pml_request 50 ompi/mca/pml/cm/pml_cm_start.c (mca_pml_cm_hvy_send_request_t*)pml_request; pml_request 69 ompi/mca/pml/cm/pml_cm_start.c request->req_complete_cb = pml_request->req_ompi.req_complete_cb; pml_request 70 ompi/mca/pml/cm/pml_cm_start.c request->req_complete_cb_data = pml_request->req_ompi.req_complete_cb_data; pml_request 73 ompi/mca/pml/cm/pml_cm_start.c pml_request->req_free_called = true; pml_request 90 ompi/mca/pml/cm/pml_cm_start.c (mca_pml_cm_hvy_recv_request_t*)pml_request; pml_request 24 ompi/mca/pml/monitoring/pml_monitoring_start.c mca_pml_base_request_t *pml_request = (mca_pml_base_request_t*)requests[i]; pml_request 27 ompi/mca/pml/monitoring/pml_monitoring_start.c if(NULL == pml_request) { pml_request 33 ompi/mca/pml/monitoring/pml_monitoring_start.c if(MCA_PML_REQUEST_SEND != pml_request->req_type) { pml_request 40 ompi/mca/pml/monitoring/pml_monitoring_start.c if(OPAL_SUCCESS == mca_common_monitoring_get_world_rank(pml_request->req_peer, pml_request 41 ompi/mca/pml/monitoring/pml_monitoring_start.c pml_request->req_comm->c_remote_group, pml_request 44 ompi/mca/pml/monitoring/pml_monitoring_start.c ompi_datatype_type_size(pml_request->req_datatype, &type_size); pml_request 45 ompi/mca/pml/monitoring/pml_monitoring_start.c data_size = pml_request->req_count * type_size; pml_request 37 ompi/mca/pml/ob1/pml_ob1_start.c mca_pml_base_request_t *pml_request = (mca_pml_base_request_t*)requests[i]; pml_request 38 ompi/mca/pml/ob1/pml_ob1_start.c if (NULL == pml_request || OMPI_REQUEST_PML != requests[i]->req_type) { pml_request 51 ompi/mca/pml/ob1/pml_ob1_start.c switch(pml_request->req_type) { pml_request 54 ompi/mca/pml/ob1/pml_ob1_start.c mca_pml_ob1_send_request_t* sendreq = (mca_pml_ob1_send_request_t*)pml_request; pml_request 57 ompi/mca/pml/ob1/pml_ob1_start.c pml_request->req_addr, pml_request->req_count, pml_request 58 ompi/mca/pml/ob1/pml_ob1_start.c pml_request->req_datatype); pml_request 61 ompi/mca/pml/ob1/pml_ob1_start.c if (!pml_request->req_pml_complete) { pml_request 66 ompi/mca/pml/ob1/pml_ob1_start.c rc = mca_pml_ob1_isend_init (pml_request->req_addr, pml_request 67 ompi/mca/pml/ob1/pml_ob1_start.c pml_request->req_count, pml_request 68 ompi/mca/pml/ob1/pml_ob1_start.c pml_request->req_datatype, pml_request 69 ompi/mca/pml/ob1/pml_ob1_start.c pml_request->req_peer, pml_request 70 ompi/mca/pml/ob1/pml_ob1_start.c pml_request->req_tag, pml_request 72 ompi/mca/pml/ob1/pml_ob1_start.c pml_request->req_comm, pml_request 79 ompi/mca/pml/ob1/pml_ob1_start.c request->req_complete_cb = pml_request->req_ompi.req_complete_cb; pml_request 80 ompi/mca/pml/ob1/pml_ob1_start.c request->req_complete_cb_data = pml_request->req_ompi.req_complete_cb_data; pml_request 83 ompi/mca/pml/ob1/pml_ob1_start.c pml_request->req_free_called = true; pml_request 98 ompi/mca/pml/ob1/pml_ob1_start.c pml_request->req_pml_complete = false; pml_request 107 ompi/mca/pml/ob1/pml_ob1_start.c mca_pml_ob1_recv_request_t* recvreq = (mca_pml_ob1_recv_request_t*)pml_request; pml_request 21 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c mca_pml_base_request_t *pml_request = (mca_pml_base_request_t *) requests[i]; pml_request 22 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c if(NULL == pml_request) continue; pml_request 24 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c switch(pml_request->req_type) pml_request 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); pml_request 29 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c VPROTOCOL_PESSIMIST_MATCHING_REPLAY(pml_request->req_peer); pml_request 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); pml_request 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);