Lines Matching refs:greq

49     ompi_grequest_t* greq = (ompi_grequest_t*)req;  in ompi_grequest_cancel()  local
51 if (greq->greq_cancel.c_cancel != NULL) { in ompi_grequest_cancel()
52 if (greq->greq_funcs_are_c) { in ompi_grequest_cancel()
53 rc = greq->greq_cancel.c_cancel(greq->greq_state, in ompi_grequest_cancel()
54 REQUEST_COMPLETE(&greq->greq_base)); in ompi_grequest_cancel()
56 fflag = (ompi_fortran_logical_t) REQUEST_COMPLETE(&greq->greq_base); in ompi_grequest_cancel()
57 greq->greq_cancel.f_cancel((MPI_Aint*)greq->greq_state, &fflag, &ierr); in ompi_grequest_cancel()
64 static void ompi_grequest_construct(ompi_grequest_t* greq) in ompi_grequest_construct() argument
66 greq->greq_base.req_free = ompi_grequest_free; in ompi_grequest_construct()
67 greq->greq_base.req_cancel = ompi_grequest_cancel; in ompi_grequest_construct()
68 greq->greq_base.req_type = OMPI_REQUEST_GEN; in ompi_grequest_construct()
69 greq->greq_base.req_mpi_object.comm = &(ompi_mpi_comm_world.comm); in ompi_grequest_construct()
73 greq->greq_funcs_are_c = true; in ompi_grequest_construct()
122 static void ompi_grequest_destruct(ompi_grequest_t* greq) in ompi_grequest_destruct() argument
126 if (greq->greq_free.c_free != NULL) { in ompi_grequest_destruct()
127 if (greq->greq_funcs_are_c) { in ompi_grequest_destruct()
128 greq->greq_free.c_free(greq->greq_state); in ompi_grequest_destruct()
130 greq->greq_free.f_free((MPI_Aint*)greq->greq_state, &ierr); in ompi_grequest_destruct()
134 OMPI_REQUEST_FINI(&greq->greq_base); in ompi_grequest_destruct()
152 ompi_grequest_t *greq = OBJ_NEW(ompi_grequest_t); in ompi_grequest_start() local
153 if(greq == NULL) { in ompi_grequest_start()
158 OBJ_RETAIN(greq); in ompi_grequest_start()
160 greq->greq_base.req_state = OMPI_REQUEST_ACTIVE; in ompi_grequest_start()
161 greq->greq_state = gstate; in ompi_grequest_start()
162 greq->greq_query.c_query = gquery_fn; in ompi_grequest_start()
163 greq->greq_free.c_free = gfree_fn; in ompi_grequest_start()
164 greq->greq_cancel.c_cancel = gcancel_fn; in ompi_grequest_start()
165 greq->greq_base.req_status = ompi_status_empty; in ompi_grequest_start()
166 greq->greq_base.req_complete = REQUEST_PENDING; in ompi_grequest_start()
168 *request = &greq->greq_base; in ompi_grequest_start()