pending_op 52 ompi/mca/osc/rdma/osc_rdma_active_target.c static void ompi_osc_rdma_pending_op_construct (ompi_osc_rdma_pending_op_t *pending_op) pending_op 54 ompi/mca/osc/rdma/osc_rdma_active_target.c pending_op->op_frag = NULL; pending_op 55 ompi/mca/osc/rdma/osc_rdma_active_target.c pending_op->op_buffer = NULL; pending_op 56 ompi/mca/osc/rdma/osc_rdma_active_target.c pending_op->op_result = NULL; pending_op 57 ompi/mca/osc/rdma/osc_rdma_active_target.c pending_op->op_complete = false; pending_op 58 ompi/mca/osc/rdma/osc_rdma_active_target.c pending_op->cbfunc = NULL; pending_op 59 ompi/mca/osc/rdma/osc_rdma_active_target.c pending_op->module = NULL; pending_op 62 ompi/mca/osc/rdma/osc_rdma_active_target.c static void ompi_osc_rdma_pending_op_destruct (ompi_osc_rdma_pending_op_t *pending_op) pending_op 64 ompi/mca/osc/rdma/osc_rdma_active_target.c if (NULL != pending_op->op_frag) { pending_op 65 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_frag_complete (pending_op->op_frag); pending_op 68 ompi/mca/osc/rdma/osc_rdma_active_target.c if (NULL != pending_op->module) { pending_op 69 ompi/mca/osc/rdma/osc_rdma_active_target.c (void) opal_atomic_fetch_add_32 (&pending_op->module->pending_ops, -1); pending_op 72 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_pending_op_construct (pending_op); pending_op 86 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_pending_op_t *pending_op = (ompi_osc_rdma_pending_op_t *) context; pending_op 88 ompi/mca/osc/rdma/osc_rdma_active_target.c OSC_RDMA_VERBOSE(MCA_BASE_VERBOSE_INFO, "pending atomic %p complete with status %d", (void*)pending_op, status); pending_op 90 ompi/mca/osc/rdma/osc_rdma_active_target.c if (pending_op->op_result) { pending_op 91 ompi/mca/osc/rdma/osc_rdma_active_target.c memmove (pending_op->op_result, pending_op->op_buffer, pending_op->op_size); pending_op 94 ompi/mca/osc/rdma/osc_rdma_active_target.c if (NULL != pending_op->cbfunc) { pending_op 95 ompi/mca/osc/rdma/osc_rdma_active_target.c pending_op->cbfunc (pending_op->cbdata, pending_op->cbcontext, status); pending_op 98 ompi/mca/osc/rdma/osc_rdma_active_target.c if (NULL != pending_op->op_frag) { pending_op 99 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_frag_complete (pending_op->op_frag); pending_op 100 ompi/mca/osc/rdma/osc_rdma_active_target.c pending_op->op_frag = NULL; pending_op 103 ompi/mca/osc/rdma/osc_rdma_active_target.c pending_op->op_complete = true; pending_op 104 ompi/mca/osc/rdma/osc_rdma_active_target.c OBJ_RELEASE(pending_op); pending_op 42 ompi/mca/osc/rdma/osc_rdma_lock.h ompi_osc_rdma_pending_op_t *pending_op; pending_op 45 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op = OBJ_NEW(ompi_osc_rdma_pending_op_t); pending_op 46 ompi/mca/osc/rdma/osc_rdma_lock.h assert (NULL != pending_op); pending_op 49 ompi/mca/osc/rdma/osc_rdma_lock.h OBJ_RETAIN(pending_op); pending_op 52 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->module = module; pending_op 56 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->op_result = (void *) result; pending_op 57 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->op_size = (MCA_BTL_ATOMIC_FLAG_32BIT & flags) ? 4 : 8; pending_op 58 ompi/mca/osc/rdma/osc_rdma_lock.h OBJ_RETAIN(pending_op); pending_op 60 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->cbfunc = cbfunc; pending_op 61 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->cbdata = cbdata; pending_op 62 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->cbcontext = cbcontext; pending_op 67 ompi/mca/osc/rdma/osc_rdma_lock.h if (NULL == pending_op->op_frag) { pending_op 68 ompi/mca/osc/rdma/osc_rdma_lock.h ret = ompi_osc_rdma_frag_alloc (module, 8, &pending_op->op_frag, (char **) &pending_op->op_buffer); pending_op 71 ompi/mca/osc/rdma/osc_rdma_lock.h if (NULL != pending_op->op_frag) { pending_op 72 ompi/mca/osc/rdma/osc_rdma_lock.h ret = module->selected_btl->btl_atomic_fop (module->selected_btl, endpoint, pending_op->op_buffer, pending_op 73 ompi/mca/osc/rdma/osc_rdma_lock.h (intptr_t) address, pending_op->op_frag->handle, address_handle, pending_op 75 ompi/mca/osc/rdma/osc_rdma_lock.h (void *) pending_op, NULL); pending_op 86 ompi/mca/osc/rdma/osc_rdma_lock.h *result = ((int64_t *) pending_op->op_buffer)[0]; pending_op 88 ompi/mca/osc/rdma/osc_rdma_lock.h ompi_osc_rdma_atomic_complete (module->selected_btl, endpoint, pending_op->op_buffer, pending_op 89 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->op_frag->handle, (void *) pending_op, NULL, OPAL_SUCCESS); pending_op 93 ompi/mca/osc/rdma/osc_rdma_lock.h OBJ_RELEASE(pending_op); pending_op 95 ompi/mca/osc/rdma/osc_rdma_lock.h while (!pending_op->op_complete) { pending_op 100 ompi/mca/osc/rdma/osc_rdma_lock.h OBJ_RELEASE(pending_op); pending_op 120 ompi/mca/osc/rdma/osc_rdma_lock.h ompi_osc_rdma_pending_op_t *pending_op; pending_op 128 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op = OBJ_NEW(ompi_osc_rdma_pending_op_t); pending_op 129 ompi/mca/osc/rdma/osc_rdma_lock.h assert (NULL != pending_op); pending_op 130 ompi/mca/osc/rdma/osc_rdma_lock.h OBJ_RETAIN(pending_op); pending_op 132 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->cbfunc = cbfunc; pending_op 133 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->cbdata = cbdata; pending_op 134 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->cbcontext = cbcontext; pending_op 139 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->module = module; pending_op 147 ompi/mca/osc/rdma/osc_rdma_lock.h (void *) pending_op, NULL); pending_op 157 ompi/mca/osc/rdma/osc_rdma_lock.h OBJ_RELEASE(pending_op); pending_op 165 ompi/mca/osc/rdma/osc_rdma_lock.h while (!pending_op->op_complete) { pending_op 170 ompi/mca/osc/rdma/osc_rdma_lock.h OBJ_RELEASE(pending_op); pending_op 188 ompi/mca/osc/rdma/osc_rdma_lock.h ompi_osc_rdma_pending_op_t *pending_op; pending_op 191 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op = OBJ_NEW(ompi_osc_rdma_pending_op_t); pending_op 192 ompi/mca/osc/rdma/osc_rdma_lock.h assert (NULL != pending_op); pending_op 194 ompi/mca/osc/rdma/osc_rdma_lock.h OBJ_RETAIN(pending_op); pending_op 196 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->op_result = (void *) result; pending_op 197 ompi/mca/osc/rdma/osc_rdma_lock.h pending_op->op_size = (MCA_BTL_ATOMIC_FLAG_32BIT & flags) ? 4 : 8; pending_op 201 ompi/mca/osc/rdma/osc_rdma_lock.h if (NULL == pending_op->op_frag) { pending_op 202 ompi/mca/osc/rdma/osc_rdma_lock.h ret = ompi_osc_rdma_frag_alloc (module, 8, &pending_op->op_frag, (char **) &pending_op->op_buffer); pending_op 204 ompi/mca/osc/rdma/osc_rdma_lock.h if (NULL != pending_op->op_frag) { pending_op 205 ompi/mca/osc/rdma/osc_rdma_lock.h ret = module->selected_btl->btl_atomic_cswap (module->selected_btl, endpoint, pending_op->op_buffer, pending_op 206 ompi/mca/osc/rdma/osc_rdma_lock.h address, pending_op->op_frag->handle, address_handle, compare, pending_op 207 ompi/mca/osc/rdma/osc_rdma_lock.h value, flags, 0, ompi_osc_rdma_atomic_complete, (void *) pending_op, pending_op 219 ompi/mca/osc/rdma/osc_rdma_lock.h *result = ((int64_t *) pending_op->op_buffer)[0]; pending_op 224 ompi/mca/osc/rdma/osc_rdma_lock.h OBJ_RELEASE(pending_op); pending_op 226 ompi/mca/osc/rdma/osc_rdma_lock.h while (!pending_op->op_complete) { pending_op 231 ompi/mca/osc/rdma/osc_rdma_lock.h OBJ_RELEASE(pending_op);