req_base 238 ompi/mca/pml/base/pml_base_bsend.c sendreq->req_base.req_pml_complete = true; req_base 252 ompi/mca/pml/base/pml_base_bsend.c if((rc = opal_convertor_pack( &sendreq->req_base.req_convertor, req_base 260 ompi/mca/pml/base/pml_base_bsend.c opal_convertor_prepare_for_send( &sendreq->req_base.req_convertor, &(ompi_mpi_packed.dt.super), req_base 293 ompi/mca/pml/base/pml_base_bsend.c sendreq->req_base.req_pml_complete = true; req_base 371 ompi/mca/pml/base/pml_base_bsend.c sendreq->req_addr == sendreq->req_base.req_addr) req_base 379 ompi/mca/pml/base/pml_base_bsend.c sendreq->req_addr = sendreq->req_base.req_addr; req_base 41 ompi/mca/pml/base/pml_base_recvreq.c request->req_base.req_type = MCA_PML_REQUEST_RECV; req_base 42 ompi/mca/pml/base/pml_base_recvreq.c OBJ_CONSTRUCT(&request->req_base.req_convertor, opal_convertor_t); req_base 39 ompi/mca/pml/base/pml_base_recvreq.h mca_pml_base_request_t req_base; /**< base request */ req_base 72 ompi/mca/pml/base/pml_base_recvreq.h OMPI_REQUEST_INIT(&(request)->req_base.req_ompi, persistent); \ req_base 73 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_ompi.req_mpi_object.comm = comm; \ req_base 75 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_addr = addr; \ req_base 76 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_count = count; \ req_base 77 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_peer = src; \ req_base 78 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_tag = tag; \ req_base 79 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_comm = comm; \ req_base 80 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_proc = NULL; \ req_base 81 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_sequence = 0; \ req_base 82 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_datatype = datatype; \ req_base 84 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_pml_complete = false; \ req_base 85 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_free_called = false; \ req_base 94 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_pml_complete = false; \ req_base 100 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_ompi.req_status.MPI_SOURCE = OMPI_ANY_SOURCE; \ req_base 101 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_ompi.req_status.MPI_TAG = OMPI_ANY_TAG; \ req_base 102 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; \ req_base 103 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_ompi.req_status._ucount = 0; \ req_base 104 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_ompi.req_status._cancelled = 0; \ req_base 106 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_ompi.req_complete = REQUEST_PENDING; \ req_base 107 ompi/mca/pml/base/pml_base_recvreq.h (request)->req_base.req_ompi.req_state = OMPI_REQUEST_ACTIVE; \ req_base 118 ompi/mca/pml/base/pml_base_recvreq.h OMPI_REQUEST_FINI(&(request)->req_base.req_ompi); \ req_base 119 ompi/mca/pml/base/pml_base_recvreq.h OBJ_RELEASE( (request)->req_base.req_comm); \ req_base 120 ompi/mca/pml/base/pml_base_recvreq.h OMPI_DATATYPE_RELEASE( (request)->req_base.req_datatype ); \ req_base 121 ompi/mca/pml/base/pml_base_recvreq.h opal_convertor_cleanup( &((request)->req_base.req_convertor) ); \ req_base 38 ompi/mca/pml/base/pml_base_sendreq.c request->req_base.req_type = MCA_PML_REQUEST_SEND; req_base 39 ompi/mca/pml/base/pml_base_sendreq.c OBJ_CONSTRUCT(&request->req_base.req_convertor, opal_convertor_t); req_base 43 ompi/mca/pml/base/pml_base_sendreq.h mca_pml_base_request_t req_base; /**< base request type - common data structure for use by wait/test */ req_base 84 ompi/mca/pml/base/pml_base_sendreq.h OMPI_REQUEST_INIT(&(request)->req_base.req_ompi, persistent); \ req_base 85 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_ompi.req_mpi_object.comm = comm; \ req_base 88 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_addr = (void *)addr; \ req_base 89 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_count = count; \ req_base 90 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_datatype = datatype; \ req_base 91 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_peer = (int32_t)peer; \ req_base 92 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_tag = (int32_t)tag; \ req_base 93 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_comm = comm; \ req_base 95 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_pml_complete = false; \ req_base 96 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_free_called = false; \ req_base 97 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_ompi.req_status._cancelled = 0; \ req_base 106 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_proc->super.proc_convertor, \ req_base 107 ompi/mca/pml/base/pml_base_sendreq.h &((request)->req_base.req_datatype->super), \ req_base 108 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_count, \ req_base 109 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_addr, \ req_base 111 ompi/mca/pml/base/pml_base_sendreq.h &(request)->req_base.req_convertor ); \ req_base 112 ompi/mca/pml/base/pml_base_sendreq.h opal_convertor_get_packed_size( &(request)->req_base.req_convertor, \ req_base 120 ompi/mca/pml/base/pml_base_sendreq.h opal_convertor_set_position(&(sendreq)->req_send.req_base.req_convertor, \ req_base 132 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_pml_complete = false; \ req_base 133 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_ompi.req_complete = REQUEST_PENDING; \ req_base 134 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_ompi.req_state = OMPI_REQUEST_ACTIVE; \ req_base 135 ompi/mca/pml/base/pml_base_sendreq.h (request)->req_base.req_ompi.req_status._cancelled = 0; \ req_base 147 ompi/mca/pml/base/pml_base_sendreq.h OMPI_REQUEST_FINI(&(request)->req_base.req_ompi); \ req_base 148 ompi/mca/pml/base/pml_base_sendreq.h OBJ_RELEASE((request)->req_base.req_comm); \ req_base 149 ompi/mca/pml/base/pml_base_sendreq.h if( 0 != (request)->req_base.req_count ) \ req_base 150 ompi/mca/pml/base/pml_base_sendreq.h OMPI_DATATYPE_RELEASE((request)->req_base.req_datatype); \ req_base 151 ompi/mca/pml/base/pml_base_sendreq.h opal_convertor_cleanup( &((request)->req_base.req_convertor) ); \ req_base 249 ompi/mca/pml/cm/pml_cm.h sendreq->req_send.req_base.req_pml_complete = true; req_base 540 ompi/mca/pml/cm/pml_cm.h ompi_request_wait_completion(&recvreq->req_base.req_ompi); req_base 543 ompi/mca/pml/cm/pml_cm.h *status = recvreq->req_base.req_ompi.req_status; req_base 545 ompi/mca/pml/cm/pml_cm.h ret = recvreq->req_base.req_ompi.req_status.MPI_ERROR; req_base 59 ompi/mca/pml/cm/pml_cm_recvreq.c recvreq->req_base.req_ompi.req_start = mca_pml_cm_start; req_base 60 ompi/mca/pml/cm/pml_cm_recvreq.c recvreq->req_base.req_ompi.req_free = mca_pml_cm_recv_request_free; req_base 61 ompi/mca/pml/cm/pml_cm_recvreq.c recvreq->req_base.req_ompi.req_cancel = mca_pml_cm_cancel; req_base 62 ompi/mca/pml/cm/pml_cm_recvreq.c OBJ_CONSTRUCT( &(recvreq->req_base.req_convertor), opal_convertor_t ); req_base 32 ompi/mca/pml/cm/pml_cm_recvreq.h mca_pml_cm_request_t req_base; req_base 39 ompi/mca/pml/cm/pml_cm_recvreq.h mca_pml_cm_request_t req_base; req_base 63 ompi/mca/pml/cm/pml_cm_recvreq.h recvreq->req_base.req_pml_type = MCA_PML_CM_REQUEST_RECV_THIN; \ req_base 72 ompi/mca/pml/cm/pml_cm_recvreq.h recvreq->req_base.req_pml_type = MCA_PML_CM_REQUEST_RECV_HEAVY; \ req_base 99 ompi/mca/pml/cm/pml_cm_recvreq.h OMPI_REQUEST_INIT(&(request)->req_base.req_ompi, false); \ req_base 100 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_ompi.req_mpi_object.comm = comm; \ req_base 101 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_pml_complete = false; \ req_base 102 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_free_called = false; \ req_base 103 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_comm = comm; \ req_base 104 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_datatype = datatype; \ req_base 120 ompi/mca/pml/cm/pml_cm_recvreq.h &(request)->req_base.req_convertor ); \ req_base 132 ompi/mca/pml/cm/pml_cm_recvreq.h OMPI_REQUEST_INIT(&(request)->req_base.req_ompi, false); \ req_base 133 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_ompi.req_mpi_object.comm = comm; \ req_base 134 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_pml_complete = false; \ req_base 135 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_free_called = false; \ req_base 136 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_comm = comm; \ req_base 137 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_datatype = datatype; \ req_base 148 ompi/mca/pml/cm/pml_cm_recvreq.h &(request)->req_base.req_convertor ); \ req_base 164 ompi/mca/pml/cm/pml_cm_recvreq.h OMPI_REQUEST_INIT(&(request)->req_base.req_ompi, persistent); \ req_base 165 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_ompi.req_mpi_object.comm = comm; \ req_base 166 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_pml_complete = OPAL_INT_TO_BOOL(persistent); \ req_base 167 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_free_called = false; \ req_base 168 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_comm = comm; \ req_base 169 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_datatype = datatype; \ req_base 189 ompi/mca/pml/cm/pml_cm_recvreq.h &(request)->req_base.req_convertor ); \ req_base 203 ompi/mca/pml/cm/pml_cm_recvreq.h OMPI_REQUEST_INIT(&(request)->req_base.req_ompi, persistent); \ req_base 204 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_ompi.req_mpi_object.comm = comm; \ req_base 205 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_pml_complete = OPAL_INT_TO_BOOL(persistent); \ req_base 206 ompi/mca/pml/cm/pml_cm_recvreq.h (request)->req_base.req_free_called = false; \ req_base 207 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_comm = comm; \ req_base 208 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_datatype = datatype; \ req_base 223 ompi/mca/pml/cm/pml_cm_recvreq.h &(request)->req_base.req_convertor ); \ req_base 236 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_pml_complete = false; \ req_base 237 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_complete = false; \ req_base 238 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_state = OMPI_REQUEST_ACTIVE; \ req_base 244 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_status.MPI_TAG = OMPI_ANY_TAG; \ req_base 245 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; \ req_base 246 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_status._cancelled = 0; \ req_base 251 ompi/mca/pml/cm/pml_cm_recvreq.h &recvreq->req_base.req_convertor, \ req_base 258 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_pml_complete = false; \ req_base 259 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_complete = false; \ req_base 260 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_state = OMPI_REQUEST_ACTIVE; \ req_base 266 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_status.MPI_TAG = OMPI_ANY_TAG; \ req_base 267 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; \ req_base 268 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_status._cancelled = 0; \ req_base 270 ompi/mca/pml/cm/pml_cm_recvreq.h &recvreq->req_base.req_convertor, \ req_base 280 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_pml_complete = false; \ req_base 281 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_complete = false; \ req_base 282 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_state = OMPI_REQUEST_ACTIVE; \ req_base 288 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_status.MPI_TAG = OMPI_ANY_TAG; \ req_base 289 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; \ req_base 290 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_ompi.req_status._cancelled = 0; \ req_base 292 ompi/mca/pml/cm/pml_cm_recvreq.h request->req_base.req_comm, \ req_base 295 ompi/mca/pml/cm/pml_cm_recvreq.h &recvreq->req_base.req_convertor, \ req_base 307 ompi/mca/pml/cm/pml_cm_recvreq.h ompi_request_complete( &(recvreq->req_base.req_ompi), true ); \ req_base 318 ompi/mca/pml/cm/pml_cm_recvreq.h assert( false == recvreq->req_base.req_pml_complete ); \ req_base 320 ompi/mca/pml/cm/pml_cm_recvreq.h if( true == recvreq->req_base.req_free_called ) { \ req_base 323 ompi/mca/pml/cm/pml_cm_recvreq.h recvreq->req_base.req_pml_complete = true; \ req_base 324 ompi/mca/pml/cm/pml_cm_recvreq.h ompi_request_complete( &(recvreq->req_base.req_ompi), true ); \ req_base 338 ompi/mca/pml/cm/pml_cm_recvreq.h assert( false == recvreq->req_base.req_pml_complete ); \ req_base 340 ompi/mca/pml/cm/pml_cm_recvreq.h if( true == recvreq->req_base.req_free_called ) { \ req_base 344 ompi/mca/pml/cm/pml_cm_recvreq.h if(recvreq->req_base.req_ompi.req_persistent) { \ req_base 347 ompi/mca/pml/cm/pml_cm_recvreq.h opal_convertor_set_position(&recvreq->req_base.req_convertor, &offset); \ req_base 349 ompi/mca/pml/cm/pml_cm_recvreq.h recvreq->req_base.req_pml_complete = true; \ req_base 350 ompi/mca/pml/cm/pml_cm_recvreq.h ompi_request_complete( &(recvreq->req_base.req_ompi), true ); \ req_base 360 ompi/mca/pml/cm/pml_cm_recvreq.h OBJ_RELEASE((recvreq)->req_base.req_comm); \ req_base 361 ompi/mca/pml/cm/pml_cm_recvreq.h OMPI_DATATYPE_RELEASE((recvreq)->req_base.req_datatype); \ req_base 362 ompi/mca/pml/cm/pml_cm_recvreq.h OMPI_REQUEST_FINI(&(recvreq)->req_base.req_ompi); \ req_base 363 ompi/mca/pml/cm/pml_cm_recvreq.h opal_convertor_cleanup( &((recvreq)->req_base.req_convertor) ); \ req_base 373 ompi/mca/pml/cm/pml_cm_recvreq.h OBJ_RELEASE((recvreq)->req_base.req_comm); \ req_base 374 ompi/mca/pml/cm/pml_cm_recvreq.h OMPI_DATATYPE_RELEASE((recvreq)->req_base.req_datatype); \ req_base 375 ompi/mca/pml/cm/pml_cm_recvreq.h OMPI_REQUEST_FINI(&(recvreq)->req_base.req_ompi); \ req_base 376 ompi/mca/pml/cm/pml_cm_recvreq.h opal_convertor_cleanup( &((recvreq)->req_base.req_convertor) ); \ req_base 36 ompi/mca/pml/cm/pml_cm_sendreq.c assert( false == sendreq->req_base.req_free_called ); req_base 38 ompi/mca/pml/cm/pml_cm_sendreq.c sendreq->req_base.req_free_called = true; req_base 39 ompi/mca/pml/cm/pml_cm_sendreq.c if( true == sendreq->req_base.req_pml_complete ) { req_base 40 ompi/mca/pml/cm/pml_cm_sendreq.c if( MCA_PML_CM_REQUEST_SEND_THIN == sendreq->req_base.req_pml_type ) { req_base 56 ompi/mca/pml/cm/pml_cm_sendreq.c if( MCA_PML_CM_REQUEST_SEND_THIN == base_request->req_base.req_pml_type ) { req_base 66 ompi/mca/pml/cm/pml_cm_sendreq.c sendreq->req_send.req_base.req_ompi.req_start = mca_pml_cm_start; req_base 67 ompi/mca/pml/cm/pml_cm_sendreq.c sendreq->req_send.req_base.req_ompi.req_free = mca_pml_cm_send_request_free; req_base 68 ompi/mca/pml/cm/pml_cm_sendreq.c sendreq->req_send.req_base.req_ompi.req_cancel = mca_pml_cm_cancel; req_base 36 ompi/mca/pml/cm/pml_cm_sendreq.h mca_pml_cm_request_t req_base; req_base 76 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_send.req_base.req_pml_type = MCA_PML_CM_REQUEST_SEND_THIN; \ req_base 87 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_send.req_base.req_pml_type = MCA_PML_CM_REQUEST_SEND_THIN; \ req_base 104 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_send.req_base.req_pml_type = MCA_PML_CM_REQUEST_SEND_HEAVY; \ req_base 115 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_send.req_base.req_pml_type = MCA_PML_CM_REQUEST_SEND_HEAVY; \ req_base 134 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_comm = comm; \ req_base 135 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_datatype = datatype; \ req_base 143 ompi/mca/pml/cm/pml_cm_sendreq.h &(req_send)->req_base.req_convertor ); \ req_base 144 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_mpi_object.comm = comm; \ req_base 145 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status.MPI_SOURCE = \ req_base 147 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status.MPI_TAG = tag; \ req_base 148 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status._ucount = count; \ req_base 150 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_free_called = false; \ req_base 165 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_comm = comm; \ req_base 166 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_datatype = datatype; \ req_base 174 ompi/mca/pml/cm/pml_cm_sendreq.h &(req_send)->req_base.req_convertor ); \ req_base 175 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_mpi_object.comm = comm; \ req_base 176 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status.MPI_SOURCE = \ req_base 178 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status.MPI_TAG = tag; \ req_base 179 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status._ucount = count; \ req_base 181 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_free_called = false; \ req_base 198 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_comm = comm; \ req_base 199 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_datatype = datatype; \ req_base 207 ompi/mca/pml/cm/pml_cm_sendreq.h &(req_send)->req_base.req_convertor ); \ req_base 208 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_mpi_object.comm = comm; \ req_base 209 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status.MPI_SOURCE = \ req_base 211 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status.MPI_TAG = tag; \ req_base 212 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status._ucount = count; \ req_base 214 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_free_called = false; \ req_base 230 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_comm = comm; \ req_base 231 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_datatype = datatype; \ req_base 233 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_convertor.remoteArch = \ req_base 235 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_convertor.flags = \ req_base 237 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_convertor.master = \ req_base 239 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_convertor.local_size = \ req_base 241 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_convertor.pBaseBuf = \ req_base 243 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_convertor.count = count; \ req_base 244 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_convertor.pDesc = &datatype->super; \ req_base 253 ompi/mca/pml/cm/pml_cm_sendreq.h &(req_send)->req_base.req_convertor ); \ req_base 255 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_mpi_object.comm = comm; \ req_base 256 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status.MPI_SOURCE = \ req_base 258 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status.MPI_TAG = tag; \ req_base 259 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status._ucount = count; \ req_base 261 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_free_called = false; \ req_base 278 ompi/mca/pml/cm/pml_cm_sendreq.h OMPI_REQUEST_INIT(&(sendreq->req_send.req_base.req_ompi), \ req_base 294 ompi/mca/pml/cm/pml_cm_sendreq.h &sendreq->req_send.req_base.req_convertor, \ req_base 298 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_send.req_base.req_pml_complete = \ req_base 314 ompi/mca/pml/cm/pml_cm_sendreq.h OMPI_REQUEST_INIT(&(sendreq->req_send.req_base.req_ompi), \ req_base 325 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_send.req_base.req_pml_complete = false; \ req_base 331 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_pml_complete = false; \ req_base 332 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_complete = REQUEST_PENDING; \ req_base 333 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_state = \ req_base 335 ompi/mca/pml/cm/pml_cm_sendreq.h (req_send)->req_base.req_ompi.req_status._cancelled = 0; \ req_base 352 ompi/mca/pml/cm/pml_cm_sendreq.h &sendreq->req_send.req_base.req_convertor, \ req_base 373 ompi/mca/pml/cm/pml_cm_sendreq.h opal_convertor_pack( &sendreq->req_send.req_base.req_convertor, \ req_base 377 ompi/mca/pml/cm/pml_cm_sendreq.h opal_convertor_prepare_for_send( &sendreq->req_send.req_base.req_convertor, \ req_base 394 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_send.req_base.req_comm, \ req_base 397 ompi/mca/pml/cm/pml_cm_sendreq.h &sendreq->req_send.req_base.req_convertor, \ req_base 403 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_send.req_base.req_ompi.req_status.MPI_ERROR = 0; \ req_base 404 ompi/mca/pml/cm/pml_cm_sendreq.h if(!REQUEST_COMPLETE(&sendreq->req_send.req_base.req_ompi)) { \ req_base 406 ompi/mca/pml/cm/pml_cm_sendreq.h ompi_request_complete(&(sendreq)->req_send.req_base.req_ompi, true); \ req_base 421 ompi/mca/pml/cm/pml_cm_sendreq.h assert( false == sendreq->req_send.req_base.req_pml_complete ); \ req_base 428 ompi/mca/pml/cm/pml_cm_sendreq.h if( !REQUEST_COMPLETE(&sendreq->req_send.req_base.req_ompi)) { \ req_base 430 ompi/mca/pml/cm/pml_cm_sendreq.h ompi_request_complete(&(sendreq->req_send.req_base.req_ompi), true); \ req_base 432 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_send.req_base.req_pml_complete = true; \ req_base 434 ompi/mca/pml/cm/pml_cm_sendreq.h if( sendreq->req_send.req_base.req_free_called ) { \ req_base 437 ompi/mca/pml/cm/pml_cm_sendreq.h if(sendreq->req_send.req_base.req_ompi.req_persistent) { \ req_base 440 ompi/mca/pml/cm/pml_cm_sendreq.h opal_convertor_set_position(&sendreq->req_send.req_base.req_convertor, \ req_base 453 ompi/mca/pml/cm/pml_cm_sendreq.h OMPI_DATATYPE_RETAIN(sendreq->req_send.req_base.req_datatype); \ req_base 454 ompi/mca/pml/cm/pml_cm_sendreq.h OBJ_RELEASE(sendreq->req_send.req_base.req_comm); \ req_base 455 ompi/mca/pml/cm/pml_cm_sendreq.h OMPI_REQUEST_FINI(&sendreq->req_send.req_base.req_ompi); \ req_base 456 ompi/mca/pml/cm/pml_cm_sendreq.h opal_convertor_cleanup( &(sendreq->req_send.req_base.req_convertor) ); \ req_base 470 ompi/mca/pml/cm/pml_cm_sendreq.h assert( false == sendreq->req_send.req_base.req_pml_complete ); \ req_base 472 ompi/mca/pml/cm/pml_cm_sendreq.h if( !REQUEST_COMPLETE(&sendreq->req_send.req_base.req_ompi)) { \ req_base 474 ompi/mca/pml/cm/pml_cm_sendreq.h ompi_request_complete(&(sendreq->req_send.req_base.req_ompi), true); \ req_base 476 ompi/mca/pml/cm/pml_cm_sendreq.h sendreq->req_send.req_base.req_pml_complete = true; \ req_base 478 ompi/mca/pml/cm/pml_cm_sendreq.h if( sendreq->req_send.req_base.req_free_called ) { \ req_base 490 ompi/mca/pml/cm/pml_cm_sendreq.h OMPI_DATATYPE_RETAIN(sendreq->req_send.req_base.req_datatype); \ req_base 491 ompi/mca/pml/cm/pml_cm_sendreq.h OBJ_RELEASE(sendreq->req_send.req_base.req_comm); \ req_base 492 ompi/mca/pml/cm/pml_cm_sendreq.h OMPI_REQUEST_FINI(&sendreq->req_send.req_base.req_ompi); \ req_base 493 ompi/mca/pml/cm/pml_cm_sendreq.h opal_convertor_cleanup( &(sendreq->req_send.req_base.req_convertor) ); \ req_base 51 ompi/mca/pml/cm/pml_cm_start.c if (!sendreq->req_send.req_base.req_pml_complete) { req_base 58 ompi/mca/pml/cm/pml_cm_start.c sendreq->req_send.req_base.req_datatype, req_base 62 ompi/mca/pml/cm/pml_cm_start.c sendreq->req_send.req_base.req_comm, req_base 80 ompi/mca/pml/cm/pml_cm_start.c sendreq->req_send.req_base.req_pml_complete = false; req_base 551 ompi/mca/pml/ob1/pml_ob1.c mca_pml_base_request_t *req = &(((mca_pml_ob1_recv_request_t*)item)->req_recv.req_base); req_base 62 ompi/mca/pml/ob1/pml_ob1_cuda.c if ((sendreq->req_send.req_base.req_convertor.flags & CONVERTOR_CUDA) && req_base 68 ompi/mca/pml/ob1/pml_ob1_cuda.c sendreq->req_send.req_base.req_convertor.flags &= ~CONVERTOR_CUDA; req_base 69 ompi/mca/pml/ob1/pml_ob1_cuda.c if (opal_convertor_need_buffers(&sendreq->req_send.req_base.req_convertor) == false) { req_base 71 ompi/mca/pml/ob1/pml_ob1_cuda.c opal_convertor_get_current_pointer( &sendreq->req_send.req_base.req_convertor, (void**)&base ); req_base 73 ompi/mca/pml/ob1/pml_ob1_cuda.c sendreq->req_send.req_base.req_convertor.flags |= CONVERTOR_CUDA; req_base 95 ompi/mca/pml/ob1/pml_ob1_cuda.c sendreq->req_send.req_base.req_convertor.flags |= CONVERTOR_CUDA; req_base 160 ompi/mca/pml/ob1/pml_ob1_cuda.c mca_bml_base_endpoint_t* bml_endpoint = mca_bml_base_get_endpoint (recvreq->req_recv.req_base.req_proc); req_base 170 ompi/mca/pml/ob1/pml_ob1_cuda.c if ((recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA) && req_base 172 ompi/mca/pml/ob1/pml_ob1_cuda.c recvreq->req_recv.req_base.req_convertor.flags &= ~CONVERTOR_CUDA; req_base 173 ompi/mca/pml/ob1/pml_ob1_cuda.c if(opal_convertor_need_buffers(&recvreq->req_recv.req_base.req_convertor) == true) { req_base 174 ompi/mca/pml/ob1/pml_ob1_cuda.c recvreq->req_recv.req_base.req_convertor.flags |= CONVERTOR_CUDA; req_base 177 ompi/mca/pml/ob1/pml_ob1_cuda.c recvreq->req_recv.req_base.req_convertor.flags |= CONVERTOR_CUDA; req_base 36 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq.req_recv.req_base.req_ompi.req_type = OMPI_REQUEST_PML; req_base 37 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq.req_recv.req_base.req_type = MCA_PML_REQUEST_IPROBE; req_base 42 ompi/mca/pml/ob1/pml_ob1_iprobe.c if( REQUEST_COMPLETE( &(recvreq.req_recv.req_base.req_ompi)) ) { req_base 44 ompi/mca/pml/ob1/pml_ob1_iprobe.c *status = recvreq.req_recv.req_base.req_ompi.req_status; req_base 46 ompi/mca/pml/ob1/pml_ob1_iprobe.c rc = recvreq.req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_base 66 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq.req_recv.req_base.req_ompi.req_type = OMPI_REQUEST_PML; req_base 67 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq.req_recv.req_base.req_type = MCA_PML_REQUEST_PROBE; req_base 72 ompi/mca/pml/ob1/pml_ob1_iprobe.c ompi_request_wait_completion(&recvreq.req_recv.req_base.req_ompi); req_base 73 ompi/mca/pml/ob1/pml_ob1_iprobe.c rc = recvreq.req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_base 75 ompi/mca/pml/ob1/pml_ob1_iprobe.c *status = recvreq.req_recv.req_base.req_ompi.req_status; req_base 102 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_IMPROBE; req_base 109 ompi/mca/pml/ob1/pml_ob1_iprobe.c if( REQUEST_COMPLETE( &(recvreq->req_recv.req_base.req_ompi)) ) { req_base 111 ompi/mca/pml/ob1/pml_ob1_iprobe.c *status = recvreq->req_recv.req_base.req_ompi.req_status; req_base 117 ompi/mca/pml/ob1/pml_ob1_iprobe.c (*message)->peer = recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE; req_base 118 ompi/mca/pml/ob1/pml_ob1_iprobe.c (*message)->count = recvreq->req_recv.req_base.req_ompi.req_status._ucount; req_base 120 ompi/mca/pml/ob1/pml_ob1_iprobe.c rc = recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_base 156 ompi/mca/pml/ob1/pml_ob1_iprobe.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_MPROBE; req_base 163 ompi/mca/pml/ob1/pml_ob1_iprobe.c ompi_request_wait_completion(&recvreq->req_recv.req_base.req_ompi); req_base 164 ompi/mca/pml/ob1/pml_ob1_iprobe.c rc = recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_base 167 ompi/mca/pml/ob1/pml_ob1_iprobe.c *status = recvreq->req_recv.req_base.req_ompi.req_status; req_base 172 ompi/mca/pml/ob1/pml_ob1_iprobe.c (*message)->peer = recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE; req_base 173 ompi/mca/pml/ob1/pml_ob1_iprobe.c (*message)->count = recvreq->req_recv.req_base.req_ompi.req_status._ucount; req_base 57 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; req_base 63 ompi/mca/pml/ob1/pml_ob1_irecv.c &((recvreq)->req_recv.req_base), req_base 70 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_pml_complete = true; req_base 89 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; req_base 95 ompi/mca/pml/ob1/pml_ob1_irecv.c &((recvreq)->req_recv.req_base), req_base 126 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; req_base 131 ompi/mca/pml/ob1/pml_ob1_irecv.c &(recvreq->req_recv.req_base), req_base 135 ompi/mca/pml/ob1/pml_ob1_irecv.c ompi_request_wait_completion(&recvreq->req_recv.req_base.req_ompi); req_base 137 ompi/mca/pml/ob1/pml_ob1_irecv.c if( true == recvreq->req_recv.req_base.req_pml_complete ) { req_base 141 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_addr, req_base 142 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_count, req_base 143 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_datatype); req_base 148 ompi/mca/pml/ob1/pml_ob1_irecv.c *status = recvreq->req_recv.req_base.req_ompi.req_status; req_base 151 ompi/mca/pml/ob1/pml_ob1_irecv.c rc = recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_base 153 ompi/mca/pml/ob1/pml_ob1_irecv.c if (recvreq->req_recv.req_base.req_pml_complete) { req_base 158 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_addr, req_base 159 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_count, req_base 160 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_datatype); req_base 193 ompi/mca/pml/ob1/pml_ob1_irecv.c frag = (mca_pml_ob1_recv_frag_t*) recvreq->req_recv.req_base.req_addr; req_base 194 ompi/mca/pml/ob1/pml_ob1_irecv.c src = recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE; req_base 195 ompi/mca/pml/ob1/pml_ob1_irecv.c tag = recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG; req_base 197 ompi/mca/pml/ob1/pml_ob1_irecv.c seq = recvreq->req_recv.req_base.req_sequence; req_base 209 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; req_base 217 ompi/mca/pml/ob1/pml_ob1_irecv.c &((recvreq)->req_recv.req_base), req_base 232 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_sequence = seq; req_base 234 ompi/mca/pml/ob1/pml_ob1_irecv.c proc = mca_pml_ob1_peer_lookup (comm, recvreq->req_recv.req_base.req_peer); req_base 235 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_proc = proc->ompi_proc; req_base 287 ompi/mca/pml/ob1/pml_ob1_irecv.c frag = (mca_pml_ob1_recv_frag_t*) recvreq->req_recv.req_base.req_addr; req_base 288 ompi/mca/pml/ob1/pml_ob1_irecv.c src = recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE; req_base 289 ompi/mca/pml/ob1/pml_ob1_irecv.c tag = recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG; req_base 290 ompi/mca/pml/ob1/pml_ob1_irecv.c seq = recvreq->req_recv.req_base.req_sequence; req_base 302 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_type = MCA_PML_REQUEST_RECV; req_base 310 ompi/mca/pml/ob1/pml_ob1_irecv.c &((recvreq)->req_recv.req_base), req_base 324 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_sequence = seq; req_base 326 ompi/mca/pml/ob1/pml_ob1_irecv.c proc = mca_pml_ob1_peer_lookup (comm, recvreq->req_recv.req_base.req_peer); req_base 327 ompi/mca/pml/ob1/pml_ob1_irecv.c recvreq->req_recv.req_base.req_proc = proc->ompi_proc; req_base 353 ompi/mca/pml/ob1/pml_ob1_irecv.c ompi_request_wait_completion(&(recvreq->req_recv.req_base.req_ompi)); req_base 358 ompi/mca/pml/ob1/pml_ob1_irecv.c *status = recvreq->req_recv.req_base.req_ompi.req_status; req_base 360 ompi/mca/pml/ob1/pml_ob1_irecv.c rc = recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR; req_base 64 ompi/mca/pml/ob1/pml_ob1_isend.c &(sendreq)->req_send.req_base, req_base 71 ompi/mca/pml/ob1/pml_ob1_isend.c sendreq->req_send.req_base.req_pml_complete = true; req_base 195 ompi/mca/pml/ob1/pml_ob1_isend.c &(sendreq)->req_send.req_base, req_base 264 ompi/mca/pml/ob1/pml_ob1_isend.c sendreq->req_send.req_base.req_proc = dst_proc; req_base 275 ompi/mca/pml/ob1/pml_ob1_isend.c &sendreq->req_send.req_base, req_base 280 ompi/mca/pml/ob1/pml_ob1_isend.c ompi_request_wait_completion(&sendreq->req_send.req_base.req_ompi); req_base 282 ompi/mca/pml/ob1/pml_ob1_isend.c rc = sendreq->req_send.req_base.req_ompi.req_status.MPI_ERROR; req_base 458 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_addr, req_base 459 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_count, req_base 460 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_datatype); req_base 472 ompi/mca/pml/ob1/pml_ob1_recvfrag.c opal_convertor_unpack( &match->req_recv.req_base.req_convertor, req_base 477 ompi/mca/pml/ob1/pml_ob1_recvfrag.c SPC_USER_OR_MPI(match->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)bytes_received, req_base 484 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_addr, req_base 485 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_count, req_base 486 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_datatype); req_base 609 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if ((sendreq->req_send.req_base.req_convertor.flags & CONVERTOR_CUDA) && req_base 615 ompi/mca/pml/ob1/pml_ob1_recvfrag.c opal_cuda_set_copy_function_async(&sendreq->req_send.req_base.req_convertor, strm); req_base 643 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if (recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA_ASYNC) { req_base 736 ompi/mca/pml/ob1/pml_ob1_recvfrag.c wild_recv->req_recv.req_base.req_sequence : PML_MAX_SEQ; req_base 738 ompi/mca/pml/ob1/pml_ob1_recvfrag.c specific_recv->req_recv.req_base.req_sequence : PML_MAX_SEQ; req_base 757 ompi/mca/pml/ob1/pml_ob1_recvfrag.c req_tag = (*match)->req_recv.req_base.req_tag; req_base 761 ompi/mca/pml/ob1/pml_ob1_recvfrag.c &((*match)->req_recv.req_base), PERUSE_RECV); req_base 766 ompi/mca/pml/ob1/pml_ob1_recvfrag.c *seq = (*match) ? (*match)->req_recv.req_base.req_sequence : PML_MAX_SEQ; req_base 784 ompi/mca/pml/ob1/pml_ob1_recvfrag.c int req_tag = recv_req->req_recv.req_base.req_tag; req_base 789 ompi/mca/pml/ob1/pml_ob1_recvfrag.c &(recv_req->req_recv.req_base), PERUSE_RECV); req_base 826 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_proc = proc->ompi_proc; req_base 828 ompi/mca/pml/ob1/pml_ob1_recvfrag.c if(OPAL_UNLIKELY(MCA_PML_REQUEST_PROBE == match->req_recv.req_base.req_type)) { req_base 834 ompi/mca/pml/ob1/pml_ob1_recvfrag.c } else if (MCA_PML_REQUEST_MPROBE == match->req_recv.req_base.req_type) { req_base 846 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match->req_recv.req_base.req_addr = tmp; req_base 856 ompi/mca/pml/ob1/pml_ob1_recvfrag.c &(match->req_recv.req_base), PERUSE_RECV); req_base 76 ompi/mca/pml/ob1/pml_ob1_recvreq.c assert (false == recvreq->req_recv.req_base.req_free_called); req_base 78 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_free_called = true; req_base 80 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(recvreq->req_recv.req_base), PERUSE_RECV ); req_base 82 ompi/mca/pml/ob1/pml_ob1_recvreq.c if( true == recvreq->req_recv.req_base.req_pml_complete ) { req_base 87 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_base 88 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_base 89 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_base 102 ompi/mca/pml/ob1/pml_ob1_recvreq.c ompi_communicator_t *comm = request->req_recv.req_base.req_comm; req_base 116 ompi/mca/pml/ob1/pml_ob1_recvreq.c if( request->req_recv.req_base.req_peer == OMPI_ANY_SOURCE ) { req_base 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_base 124 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(request->req_recv.req_base), PERUSE_RECV ); req_base 129 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_pml_complete = true; req_base 143 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_addr, req_base 144 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_count, req_base 145 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_datatype); req_base 153 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_ompi.req_start = mca_pml_ob1_start; req_base 154 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_ompi.req_free = mca_pml_ob1_recv_request_free; req_base 155 ompi/mca/pml/ob1/pml_ob1_recvreq.c request->req_recv.req_base.req_ompi.req_cancel = mca_pml_ob1_recv_request_cancel; req_base 209 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)rdma_size, req_base 267 ompi/mca/pml/ob1/pml_ob1_recvreq.c ompi_proc_t* proc = (ompi_proc_t*)recvreq->req_recv.req_base.req_proc; req_base 281 ompi/mca/pml/ob1/pml_ob1_recvreq.c if(opal_convertor_need_buffers(&recvreq->req_recv.req_base.req_convertor) == 0 && req_base 285 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_get_current_pointer( &recvreq->req_recv.req_base.req_convertor, (void**)&(base) ); req_base 308 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_set_position(&recvreq->req_recv.req_base.req_convertor, req_base 339 ompi/mca/pml/ob1/pml_ob1_recvreq.c ompi_proc_t *proc = (ompi_proc_t *) recvreq->req_recv.req_base.req_proc; req_base 394 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_tag, (ompi_spc_value_t)frag->rdma_length, req_base 397 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_send_fin (recvreq->req_recv.req_base.req_proc, req_base 414 ompi/mca/pml/ob1/pml_ob1_recvreq.c ompi_proc_t* proc = (ompi_proc_t*)recvreq->req_recv.req_base.req_proc; req_base 453 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(recvreq->req_recv.req_base), frag->rdma_length, req_base 494 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(((mca_pml_ob1_recv_request_t *) frag->rdma_req)->req_recv.req_base), req_base 536 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_base 537 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_base 538 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_base 552 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_base 553 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_base 554 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_base 558 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)bytes_received, req_base 637 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)bytes_received, req_base 676 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (opal_convertor_need_buffers(&recvreq->req_recv.req_base.req_convertor) == true) { req_base 687 ompi/mca/pml/ob1/pml_ob1_recvreq.c bml_endpoint = mca_bml_base_get_endpoint (recvreq->req_recv.req_base.req_proc); req_base 692 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA) { req_base 723 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA) { req_base 732 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_set_position( &recvreq->req_recv.req_base.req_convertor, &offset); req_base 733 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_get_current_pointer (&recvreq->req_recv.req_base.req_convertor, &data_ptr); req_base 770 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_set_position( &recvreq->req_recv.req_base.req_convertor, &offset); req_base 771 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_get_current_pointer (&recvreq->req_recv.req_base.req_convertor, &frag->local_address); req_base 833 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_base 834 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_base 835 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_base 846 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_base 847 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_base 848 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_base 851 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)bytes_received, req_base 864 ompi/mca/pml/ob1/pml_ob1_recvreq.c if ((recvreq->req_recv.req_base.req_convertor.flags & CONVERTOR_CUDA) && req_base 867 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_cuda_set_copy_function_async(&recvreq->req_recv.req_base.req_convertor, strm); req_base 897 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_base 898 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_base 899 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_base 913 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_addr, req_base 914 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_count, req_base 915 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_datatype); req_base 923 ompi/mca/pml/ob1/pml_ob1_recvreq.c SPC_USER_OR_MPI(recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)bytes_received, req_base 954 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_ompi.req_status.MPI_TAG = hdr->hdr_match.hdr_tag; req_base 955 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_recv.req_base.req_ompi.req_status.MPI_SOURCE = hdr->hdr_match.hdr_src; req_base 1037 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_set_position (&recvreq->req_recv.req_base.req_convertor, req_base 1039 ompi/mca/pml/ob1/pml_ob1_recvreq.c opal_convertor_get_current_pointer (&recvreq->req_recv.req_base.req_convertor, &data_ptr); req_base 1075 ompi/mca/pml/ob1/pml_ob1_recvreq.c ((MCA_PML_REQUEST_IPROBE == (R)->req_recv.req_base.req_type) || \ req_base 1076 ompi/mca/pml/ob1/pml_ob1_recvreq.c (MCA_PML_REQUEST_PROBE == (R)->req_recv.req_base.req_type) || \ req_base 1077 ompi/mca/pml/ob1/pml_ob1_recvreq.c (MCA_PML_REQUEST_IMPROBE == (R)->req_recv.req_base.req_type) || \ req_base 1078 ompi/mca/pml/ob1/pml_ob1_recvreq.c (MCA_PML_REQUEST_MPROBE == (R)->req_recv.req_base.req_type)) req_base 1080 ompi/mca/pml/ob1/pml_ob1_recvreq.c ((MCA_PML_REQUEST_IMPROBE == (R)->req_recv.req_base.req_type) || \ req_base 1081 ompi/mca/pml/ob1/pml_ob1_recvreq.c (MCA_PML_REQUEST_MPROBE == (R)->req_recv.req_base.req_type)) req_base 1092 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (req->req_recv.req_base.req_type != MCA_PML_REQUEST_PROBE && req_base 1093 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_type != MCA_PML_REQUEST_MPROBE) { req_base 1095 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(req->req_recv.req_base), PERUSE_RECV); req_base 1124 ompi/mca/pml/ob1/pml_ob1_recvreq.c int tag = req->req_recv.req_base.req_tag; req_base 1145 ompi/mca/pml/ob1/pml_ob1_recvreq.c return custom_match_umq_find_verify_hold(req->req_recv.req_base.req_comm->c_pml_comm->umq, req_base 1146 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_tag, req_base 1147 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_peer, req_base 1169 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_comm_t* comm = req->req_recv.req_base.req_comm->c_pml_comm; req_base 1174 ompi/mca/pml/ob1/pml_ob1_recvreq.c frag = custom_match_umq_find_verify_hold (comm->umq, req->req_recv.req_base.req_tag, req_base 1175 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_peer, req_base 1180 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = procp[frag->hdr.hdr_match.hdr_src]->ompi_proc; req_base 1204 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = procp[i]->ompi_proc; req_base 1216 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = procp[i]->ompi_proc; req_base 1230 ompi/mca/pml/ob1/pml_ob1_recvreq.c ompi_communicator_t *comm = req->req_recv.req_base.req_comm; req_base 1261 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(req->req_recv.req_base), PERUSE_RECV); req_base 1264 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_sequence = ob1_comm->recv_sequence++; req_base 1267 ompi/mca/pml/ob1/pml_ob1_recvreq.c if(req->req_recv.req_base.req_peer == OMPI_ANY_SOURCE) { req_base 1281 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = ompi_proc_local_proc; req_base 1286 ompi/mca/pml/ob1/pml_ob1_recvreq.c proc = mca_pml_ob1_peer_lookup (comm, req->req_recv.req_base.req_peer); req_base 1287 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_proc = proc->ompi_proc; req_base 1300 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(req->req_recv.req_base), PERUSE_RECV); req_base 1303 ompi/mca/pml/ob1/pml_ob1_recvreq.c if(OPAL_LIKELY(req->req_recv.req_base.req_type != MCA_PML_REQUEST_IPROBE && req_base 1304 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_type != MCA_PML_REQUEST_IMPROBE)) req_base 1307 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_tag, req_base 1308 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_peer); req_base 1317 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(req->req_recv.req_base), PERUSE_RECV); req_base 1321 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_comm, req_base 1327 ompi/mca/pml/ob1/pml_ob1_recvreq.c &(req->req_recv.req_base), PERUSE_RECV); req_base 1330 ompi/mca/pml/ob1/pml_ob1_recvreq.c custom_match_umq_remove_hold(req->req_recv.req_base.req_comm->c_pml_comm->umq, hold_prev, hold_elem, hold_index); req_base 1366 ompi/mca/pml/ob1/pml_ob1_recvreq.c custom_match_umq_remove_hold(req->req_recv.req_base.req_comm->c_pml_comm->umq, hold_prev, hold_elem, hold_index); req_base 1374 ompi/mca/pml/ob1/pml_ob1_recvreq.c req->req_recv.req_base.req_addr = frag; req_base 127 ompi/mca/pml/ob1/pml_ob1_recvreq.h &(recvreq->req_recv.req_base), PERUSE_RECV ); \ req_base 128 ompi/mca/pml/ob1/pml_ob1_recvreq.h ompi_request_complete( &(recvreq->req_recv.req_base.req_ompi), true ); \ req_base 161 ompi/mca/pml/ob1/pml_ob1_recvreq.h if(false == recvreq->req_recv.req_base.req_pml_complete){ req_base 165 ompi/mca/pml/ob1/pml_ob1_recvreq.h &recvreq->req_recv.req_base, PERUSE_RECV ); req_base 179 ompi/mca/pml/ob1/pml_ob1_recvreq.h if(true == recvreq->req_recv.req_base.req_free_called) { req_base 180 ompi/mca/pml/ob1/pml_ob1_recvreq.h if( MPI_SUCCESS != recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR ) { req_base 186 ompi/mca/pml/ob1/pml_ob1_recvreq.h recvreq->req_recv.req_base.req_pml_complete = true; req_base 187 ompi/mca/pml/ob1/pml_ob1_recvreq.h recvreq->req_recv.req_base.req_ompi.req_status._ucount = req_base 190 ompi/mca/pml/ob1/pml_ob1_recvreq.h recvreq->req_recv.req_base.req_ompi.req_status._ucount = req_base 192 ompi/mca/pml/ob1/pml_ob1_recvreq.h recvreq->req_recv.req_base.req_ompi.req_status.MPI_ERROR = req_base 225 ompi/mca/pml/ob1/pml_ob1_recvreq.h if( req->req_recv.req_base.req_datatype->super.size | req->req_recv.req_base.req_count ) { req_base 227 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_proc->super.proc_convertor, req_base 228 ompi/mca/pml/ob1/pml_ob1_recvreq.h &(req->req_recv.req_base.req_datatype->super), req_base 229 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_count, req_base 230 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_addr, req_base 232 ompi/mca/pml/ob1/pml_ob1_recvreq.h &req->req_recv.req_base.req_convertor); req_base 233 ompi/mca/pml/ob1/pml_ob1_recvreq.h opal_convertor_get_unpacked_size(&req->req_recv.req_base.req_convertor, req_base 244 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_ompi.req_status.MPI_SOURCE = hdr->hdr_src; req_base 245 ompi/mca/pml/ob1/pml_ob1_recvreq.h req->req_recv.req_base.req_ompi.req_status.MPI_TAG = hdr->hdr_tag; req_base 252 ompi/mca/pml/ob1/pml_ob1_recvreq.h if(MPI_ANY_SOURCE == req->req_recv.req_base.req_peer) { req_base 258 ompi/mca/pml/ob1/pml_ob1_recvreq.h &req->req_recv.req_base, PERUSE_RECV); req_base 296 ompi/mca/pml/ob1/pml_ob1_recvreq.h &(request->req_recv.req_base), max_data, \ req_base 298 ompi/mca/pml/ob1/pml_ob1_recvreq.h opal_convertor_set_position( &(request->req_recv.req_base.req_convertor), \ req_base 300 ompi/mca/pml/ob1/pml_ob1_recvreq.h opal_convertor_unpack( &(request)->req_recv.req_base.req_convertor, \ req_base 104 ompi/mca/pml/ob1/pml_ob1_sendreq.c if(false == sendreq->req_send.req_base.req_free_called) { req_base 106 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_free_called = true; req_base 108 ompi/mca/pml/ob1/pml_ob1_sendreq.c &(sendreq->req_send.req_base), PERUSE_SEND ); req_base 110 ompi/mca/pml/ob1/pml_ob1_sendreq.c if( true == sendreq->req_send.req_base.req_pml_complete ) { req_base 115 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_addr, req_base 116 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_count, req_base 117 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_datatype); req_base 135 ompi/mca/pml/ob1/pml_ob1_sendreq.c req->req_send.req_base.req_type = MCA_PML_REQUEST_SEND; req_base 136 ompi/mca/pml/ob1/pml_ob1_sendreq.c req->req_send.req_base.req_ompi.req_start = mca_pml_ob1_start; req_base 137 ompi/mca/pml/ob1/pml_ob1_sendreq.c req->req_send.req_base.req_ompi.req_free = mca_pml_ob1_send_request_free; req_base 138 ompi/mca/pml/ob1/pml_ob1_sendreq.c req->req_send.req_base.req_ompi.req_cancel = mca_pml_ob1_send_request_cancel; req_base 168 ompi/mca/pml/ob1/pml_ob1_sendreq.c &(sendreq->req_send.req_base), PERUSE_SEND ); req_base 203 ompi/mca/pml/ob1/pml_ob1_sendreq.c &(sendreq->req_send.req_base), PERUSE_SEND ); req_base 207 ompi/mca/pml/ob1/pml_ob1_sendreq.c SPC_USER_OR_MPI(sendreq->req_send.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)req_bytes_delivered, req_base 266 ompi/mca/pml/ob1/pml_ob1_sendreq.c SPC_USER_OR_MPI(sendreq->req_send.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)rdma_length, req_base 328 ompi/mca/pml/ob1/pml_ob1_sendreq.c SPC_USER_OR_MPI(sendreq->req_send.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)req_bytes_delivered, req_base 406 ompi/mca/pml/ob1/pml_ob1_sendreq.c if((rc = opal_convertor_pack( &sendreq->req_send.req_base.req_convertor, req_base 418 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_contextid, req_base 419 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_my_rank, req_base 420 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_tag, req_base 421 ompi/mca/pml/ob1/pml_ob1_sendreq.c (uint16_t)sendreq->req_send.req_base.req_sequence, req_base 424 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_RNDV, sendreq->req_send.req_base.req_proc); req_base 433 ompi/mca/pml/ob1/pml_ob1_sendreq.c if( OPAL_LIKELY(sendreq->req_send.req_addr == sendreq->req_send.req_base.req_addr) ) { req_base 443 ompi/mca/pml/ob1/pml_ob1_sendreq.c if((rc = opal_convertor_pack( &sendreq->req_send.req_base.req_convertor, req_base 452 ompi/mca/pml/ob1/pml_ob1_sendreq.c opal_convertor_prepare_for_send( &sendreq->req_send.req_base.req_convertor, req_base 498 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_contextid, req_base 499 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_my_rank, req_base 500 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_tag, req_base 501 ompi/mca/pml/ob1/pml_ob1_sendreq.c (uint16_t)sendreq->req_send.req_base.req_sequence); req_base 503 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton (&match, MCA_PML_OB1_HDR_TYPE_MATCH, sendreq->req_send.req_base.req_proc); req_base 506 ompi/mca/pml/ob1/pml_ob1_sendreq.c rc = mca_bml_base_sendi( bml_btl, &sendreq->req_send.req_base.req_convertor, req_base 514 ompi/mca/pml/ob1/pml_ob1_sendreq.c SPC_USER_OR_MPI(sendreq->req_send.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)size, req_base 549 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_addr, req_base 550 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_count, req_base 551 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_datatype); req_base 553 ompi/mca/pml/ob1/pml_ob1_sendreq.c (void)opal_convertor_pack( &sendreq->req_send.req_base.req_convertor, req_base 560 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_addr, req_base 561 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_count, req_base 562 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_datatype); req_base 570 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_contextid, req_base 571 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_my_rank, req_base 572 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_tag, req_base 573 ompi/mca/pml/ob1/pml_ob1_sendreq.c (uint16_t)sendreq->req_send.req_base.req_sequence); req_base 575 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_MATCH, sendreq->req_send.req_base.req_proc); req_base 586 ompi/mca/pml/ob1/pml_ob1_sendreq.c SPC_USER_OR_MPI(sendreq->req_send.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)size, req_base 621 ompi/mca/pml/ob1/pml_ob1_sendreq.c &sendreq->req_send.req_base.req_convertor, req_base 635 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_contextid, req_base 636 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_my_rank, req_base 637 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_tag, req_base 638 ompi/mca/pml/ob1/pml_ob1_sendreq.c (uint16_t)sendreq->req_send.req_base.req_sequence); req_base 640 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_MATCH, sendreq->req_send.req_base.req_proc); req_base 648 ompi/mca/pml/ob1/pml_ob1_sendreq.c SPC_USER_OR_MPI(sendreq->req_send.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)size, req_base 694 ompi/mca/pml/ob1/pml_ob1_sendreq.c opal_convertor_get_current_pointer (&sendreq->req_send.req_base.req_convertor, &data_ptr); req_base 731 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_contextid, req_base 732 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_my_rank, req_base 733 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_tag, req_base 734 ompi/mca/pml/ob1/pml_ob1_sendreq.c (uint16_t)sendreq->req_send.req_base.req_sequence, req_base 738 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_RGET, sendreq->req_send.req_base.req_proc); req_base 750 ompi/mca/pml/ob1/pml_ob1_sendreq.c &(sendreq->req_send.req_base), PERUSE_SEND ); req_base 789 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_addr, req_base 790 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_count, req_base 791 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_datatype); req_base 794 ompi/mca/pml/ob1/pml_ob1_sendreq.c &sendreq->req_send.req_base.req_convertor, req_base 803 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_addr, req_base 804 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_count, req_base 805 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_datatype); req_base 818 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_contextid, req_base 819 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_comm->c_my_rank, req_base 820 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_tag, req_base 821 ompi/mca/pml/ob1/pml_ob1_sendreq.c (uint16_t)sendreq->req_send.req_base.req_sequence, req_base 824 ompi/mca/pml/ob1/pml_ob1_sendreq.c ob1_hdr_hton(hdr, MCA_PML_OB1_HDR_TYPE_RNDV, sendreq->req_send.req_base.req_proc); req_base 986 ompi/mca/pml/ob1/pml_ob1_sendreq.c if ((sendreq->req_send.req_base.req_convertor.flags & CONVERTOR_CUDA) && (bml_btl->btl->btl_cuda_max_send_size != 0)) { req_base 1002 ompi/mca/pml/ob1/pml_ob1_sendreq.c opal_convertor_set_position(&sendreq->req_send.req_base.req_convertor, req_base 1009 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_addr, req_base 1010 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_count, req_base 1011 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_datatype); req_base 1013 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_bml_base_prepare_src(bml_btl, &sendreq->req_send.req_base.req_convertor, req_base 1019 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_addr, req_base 1020 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_count, req_base 1021 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_datatype); req_base 1044 ompi/mca/pml/ob1/pml_ob1_sendreq.c sendreq->req_send.req_base.req_proc); req_base 1048 ompi/mca/pml/ob1/pml_ob1_sendreq.c &(sendreq->req_send.req_base), size, PERUSE_SEND); req_base 1114 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_send_fin (sendreq->req_send.req_base.req_proc, bml_btl, req_base 1145 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_send_fin (sendreq->req_send.req_base.req_proc, bml_btl, req_base 1151 ompi/mca/pml/ob1/pml_ob1_sendreq.c SPC_USER_OR_MPI(sendreq->req_send.req_base.req_ompi.req_status.MPI_TAG, (ompi_spc_value_t)frag->rdma_length, req_base 1198 ompi/mca/pml/ob1/pml_ob1_sendreq.c &(((mca_pml_ob1_send_request_t*)frag->rdma_req)->req_send.req_base), frag->rdma_length, PERUSE_SEND ); req_base 1261 ompi/mca/pml/ob1/pml_ob1_sendreq.c opal_convertor_get_offset_pointer (&sendreq->req_send.req_base.req_convertor, req_base 132 ompi/mca/pml/ob1/pml_ob1_sendreq.h sendreq->req_send.req_base.req_proc = proc; \ req_base 202 ompi/mca/pml/ob1/pml_ob1_sendreq.h (sendreq)->req_send.req_base.req_ompi.req_status.MPI_SOURCE = \ req_base 203 ompi/mca/pml/ob1/pml_ob1_sendreq.h (sendreq)->req_send.req_base.req_comm->c_my_rank; \ req_base 204 ompi/mca/pml/ob1/pml_ob1_sendreq.h (sendreq)->req_send.req_base.req_ompi.req_status.MPI_TAG = \ req_base 205 ompi/mca/pml/ob1/pml_ob1_sendreq.h (sendreq)->req_send.req_base.req_tag; \ req_base 206 ompi/mca/pml/ob1/pml_ob1_sendreq.h (sendreq)->req_send.req_base.req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; \ req_base 207 ompi/mca/pml/ob1/pml_ob1_sendreq.h (sendreq)->req_send.req_base.req_ompi.req_status._ucount = \ req_base 210 ompi/mca/pml/ob1/pml_ob1_sendreq.h &(sendreq->req_send.req_base), PERUSE_SEND); \ req_base 212 ompi/mca/pml/ob1/pml_ob1_sendreq.h ompi_request_complete( &((sendreq)->req_send.req_base.req_ompi), (with_signal) ); \ req_base 246 ompi/mca/pml/ob1/pml_ob1_sendreq.h if(false == sendreq->req_send.req_base.req_pml_complete) { req_base 249 ompi/mca/pml/ob1/pml_ob1_sendreq.h &(sendreq->req_send.req_base), PERUSE_SEND); req_base 256 ompi/mca/pml/ob1/pml_ob1_sendreq.h sendreq->req_send.req_addr != sendreq->req_send.req_base.req_addr) { req_base 260 ompi/mca/pml/ob1/pml_ob1_sendreq.h if (!sendreq->req_send.req_base.req_free_called) { req_base 261 ompi/mca/pml/ob1/pml_ob1_sendreq.h sendreq->req_send.req_base.req_pml_complete = true; req_base 263 ompi/mca/pml/ob1/pml_ob1_sendreq.h if( !REQUEST_COMPLETE( &((sendreq->req_send).req_base.req_ompi)) ) { req_base 267 ompi/mca/pml/ob1/pml_ob1_sendreq.h if( MPI_SUCCESS != sendreq->req_send.req_base.req_ompi.req_status.MPI_ERROR ) { req_base 383 ompi/mca/pml/ob1/pml_ob1_sendreq.h if (btl->btl_cuda_eager_limit && (sendreq->req_send.req_base.req_convertor.flags & CONVERTOR_CUDA)) { req_base 414 ompi/mca/pml/ob1/pml_ob1_sendreq.h (opal_convertor_need_buffers(&sendreq->req_send.req_base.req_convertor) == false) { req_base 416 ompi/mca/pml/ob1/pml_ob1_sendreq.h opal_convertor_get_current_pointer( &sendreq->req_send.req_base.req_convertor, (void**)&base ); req_base 434 ompi/mca/pml/ob1/pml_ob1_sendreq.h if (sendreq->req_send.req_base.req_convertor.flags & CONVERTOR_CUDA) { req_base 454 ompi/mca/pml/ob1/pml_ob1_sendreq.h sendreq->req_send.req_base.req_sequence = seqn; req_base 469 ompi/mca/pml/ob1/pml_ob1_sendreq.h sendreq->req_send.req_addr == sendreq->req_send.req_base.req_addr) { req_base 486 ompi/mca/pml/ob1/pml_ob1_sendreq.h mca_bml_base_endpoint_t *endpoint = mca_bml_base_get_endpoint (sendreq->req_send.req_base.req_proc); req_base 487 ompi/mca/pml/ob1/pml_ob1_sendreq.h ompi_communicator_t *comm = sendreq->req_send.req_base.req_comm; req_base 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_base 93 ompi/mca/pml/ob1/pml_ob1_start.c opal_convertor_set_position (&sendreq->req_send.req_base.req_convertor, req_base 88 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.c ((uintptr_t) &pml_req.req_base.req_convertor - req_base 53 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h opal_convertor_clone_with_position( &pmlreq->req_base.req_convertor, req_base 75 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h pConv = & (REQ)->req_base.req_convertor; \ req_base 122 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h opal_convertor_clone_with_position(&req->req_base.req_convertor, req_base 151 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h if((pmlreq->req_base.req_type == MCA_PML_REQUEST_SEND) && req_base 196 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr->dst = pmlreq->req_base.req_peer; req_base 197 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr->tag = pmlreq->req_base.req_tag; req_base 198 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr->contextid = pmlreq->req_base.req_comm->c_contextid; req_base 199 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h sbhdr->sequence = pmlreq->req_base.req_sequence; req_base 28 oshmem/mca/spml/base/spml_base_atomicreq.c request->req_base.req_type = MCA_SPML_REQUEST_ATOMIC_CAS; req_base 29 oshmem/mca/spml/base/spml_base_atomicreq.c OBJ_CONSTRUCT(&request->req_base.req_convertor, opal_convertor_t); req_base 26 oshmem/mca/spml/base/spml_base_atomicreq.h mca_spml_base_request_t req_base; /**< base request */ req_base 55 oshmem/mca/spml/base/spml_base_atomicreq.h OSHMEM_REQUEST_INIT(&(request)->req_base.req_oshmem, persistent); \ req_base 56 oshmem/mca/spml/base/spml_base_atomicreq.h (request)->req_base.req_oshmem.req_shmem_object.comm = comm; \ req_base 58 oshmem/mca/spml/base/spml_base_atomicreq.h (request)->req_base.req_addr = addr; \ req_base 59 oshmem/mca/spml/base/spml_base_atomicreq.h (request)->req_base.req_count = count; \ req_base 60 oshmem/mca/spml/base/spml_base_atomicreq.h (request)->req_base.req_peer = src; \ req_base 61 oshmem/mca/spml/base/spml_base_atomicreq.h (request)->req_base.req_comm = comm; \ req_base 62 oshmem/mca/spml/base/spml_base_atomicreq.h (request)->req_base.req_proc = NULL; \ req_base 63 oshmem/mca/spml/base/spml_base_atomicreq.h (request)->req_base.req_sequence = 0; \ req_base 65 oshmem/mca/spml/base/spml_base_atomicreq.h (request)->req_base.req_spml_complete = OPAL_INT_TO_BOOL(persistent); \ req_base 66 oshmem/mca/spml/base/spml_base_atomicreq.h (request)->req_base.req_free_called = false; \ req_base 93 oshmem/mca/spml/base/spml_base_atomicreq.h OSHMEM_REQUEST_FINI(&(request)->req_base.req_oshmem); \ req_base 94 oshmem/mca/spml/base/spml_base_atomicreq.h OBJ_RELEASE( (request)->req_base.req_comm); \ req_base 95 oshmem/mca/spml/base/spml_base_atomicreq.h opal_convertor_cleanup( &((request)->req_base.req_convertor) ); \ req_base 28 oshmem/mca/spml/base/spml_base_getreq.c request->req_base.req_type = MCA_SPML_REQUEST_GET; req_base 29 oshmem/mca/spml/base/spml_base_getreq.c OBJ_CONSTRUCT(&request->req_base.req_convertor, opal_convertor_t); req_base 26 oshmem/mca/spml/base/spml_base_getreq.h mca_spml_base_request_t req_base; /**< base request */ req_base 50 oshmem/mca/spml/base/spml_base_getreq.h OSHMEM_REQUEST_INIT(&(request)->req_base.req_oshmem, persistent); \ req_base 52 oshmem/mca/spml/base/spml_base_getreq.h (request)->req_base.req_addr = addr; \ req_base 53 oshmem/mca/spml/base/spml_base_getreq.h (request)->req_base.req_count = count; \ req_base 54 oshmem/mca/spml/base/spml_base_getreq.h (request)->req_base.req_peer = (int32_t)peer; \ req_base 55 oshmem/mca/spml/base/spml_base_getreq.h (request)->req_base.req_spml_complete = OPAL_INT_TO_BOOL(persistent); \ req_base 56 oshmem/mca/spml/base/spml_base_getreq.h (request)->req_base.req_free_called = false; \ req_base 57 oshmem/mca/spml/base/spml_base_getreq.h (request)->req_base.req_oshmem.req_status._cancelled = 0; \ req_base 86 oshmem/mca/spml/base/spml_base_getreq.h OSHMEM_REQUEST_FINI(&(request)->req_base.req_oshmem); \ req_base 87 oshmem/mca/spml/base/spml_base_getreq.h opal_convertor_cleanup( &((request)->req_base.req_convertor) ); \ req_base 26 oshmem/mca/spml/base/spml_base_putreq.c request->req_base.req_type = MCA_SPML_REQUEST_PUT; req_base 27 oshmem/mca/spml/base/spml_base_putreq.h mca_spml_base_request_t req_base; /**< base request type - common data structure for use by wait/test */ req_base 57 oshmem/mca/spml/base/spml_base_putreq.h OSHMEM_REQUEST_INIT(&(request)->req_base.req_oshmem, persistent); \ req_base 59 oshmem/mca/spml/base/spml_base_putreq.h (request)->req_base.req_addr = addr; \ req_base 60 oshmem/mca/spml/base/spml_base_putreq.h (request)->req_base.req_count = count; \ req_base 61 oshmem/mca/spml/base/spml_base_putreq.h (request)->req_base.req_peer = (int32_t)peer; \ req_base 62 oshmem/mca/spml/base/spml_base_putreq.h (request)->req_base.req_spml_complete = OPAL_INT_TO_BOOL(persistent); \ req_base 63 oshmem/mca/spml/base/spml_base_putreq.h (request)->req_base.req_free_called = false; \ req_base 64 oshmem/mca/spml/base/spml_base_putreq.h (request)->req_base.req_oshmem.req_status._cancelled = 0; \ req_base 91 oshmem/mca/spml/base/spml_base_putreq.h OSHMEM_REQUEST_FINI(&(request)->req_base.req_oshmem); \ req_base 92 oshmem/mca/spml/base/spml_base_putreq.h opal_convertor_cleanup( &((request)->req_base.req_convertor) ); \