pending 54 ompi/mca/mtl/portals4/mtl_portals4_request.h struct ompi_mtl_portals4_pending_request_t *pending; pending 72 ompi/mca/mtl/portals4/mtl_portals4_send.c ompi_mtl_portals4_pending_request_t *pending = pending 73 ompi/mca/mtl/portals4/mtl_portals4_send.c ptl_request->pending; pending 80 ompi/mca/mtl/portals4/mtl_portals4_send.c if (pending->fc_notified) { pending 83 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->fc_notified = 1; pending 96 ompi/mca/mtl/portals4/mtl_portals4_send.c &pending->super.super); pending 179 ompi/mca/mtl/portals4/mtl_portals4_send.c &ptl_request->pending->super); pending 421 ompi/mca/mtl/portals4/mtl_portals4_send.c ompi_mtl_portals4_pending_request_t *pending; pending 437 ompi/mca/mtl/portals4/mtl_portals4_send.c pending = (ompi_mtl_portals4_pending_request_t*) item; pending 438 ompi/mca/mtl/portals4/mtl_portals4_send.c if (pending->length <= ompi_mtl_portals4.short_limit) { pending 439 ompi/mca/mtl/portals4/mtl_portals4_send.c ret = ompi_mtl_portals4_short_isend(pending->mode, pending 440 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->start, pending 441 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->length, pending 442 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->contextid, pending 443 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->tag, pending 444 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->my_rank, pending 445 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->ptl_proc, pending 446 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->ptl_request); pending 448 ompi/mca/mtl/portals4/mtl_portals4_send.c ret = ompi_mtl_portals4_long_isend(pending->start, pending 449 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->length, pending 450 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->contextid, pending 451 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->tag, pending 452 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->my_rank, pending 453 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->ptl_proc, pending 454 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->ptl_request); pending 458 ompi/mca/mtl/portals4/mtl_portals4_send.c &pending->super.super); pending 482 ompi/mca/mtl/portals4/mtl_portals4_send.c ompi_mtl_portals4_pending_request_t *pending; pending 511 ompi/mca/mtl/portals4/mtl_portals4_send.c pending = (ompi_mtl_portals4_pending_request_t*) item; pending 512 ompi/mca/mtl/portals4/mtl_portals4_send.c ptl_request->pending = pending; pending 513 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->mode = mode; pending 514 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->start = start; pending 515 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->length = length; pending 516 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->contextid = comm->c_contextid; pending 517 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->tag = tag; pending 518 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->my_rank = comm->c_my_rank; pending 519 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->fc_notified = 0; pending 520 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->ptl_proc = ptl_proc; pending 521 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->ptl_request = ptl_request; pending 526 ompi/mca/mtl/portals4/mtl_portals4_send.c &pending->super.super); pending 533 ompi/mca/mtl/portals4/mtl_portals4_send.c &pending->super.super); pending 541 ompi/mca/mtl/portals4/mtl_portals4_send.c &pending->super.super); pending 693 ompi/mca/osc/pt2pt/osc_pt2pt.h static inline void osc_pt2pt_add_pending (ompi_osc_pt2pt_pending_t *pending) pending 696 ompi/mca/osc/pt2pt/osc_pt2pt.h opal_list_append (&mca_osc_pt2pt_component.pending_operations, &pending->super)); pending 158 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ompi_osc_pt2pt_pending_t *pending, *next; pending 176 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OPAL_LIST_FOREACH_SAFE(pending, next, &mca_osc_pt2pt_component.pending_operations, ompi_osc_pt2pt_pending_t) { pending 179 ompi/mca/osc/pt2pt/osc_pt2pt_component.c switch (pending->header.base.type) { pending 181 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ret = ompi_osc_pt2pt_process_flush (pending->module, pending->source, pending 182 ompi/mca/osc/pt2pt/osc_pt2pt_component.c &pending->header.flush); pending 185 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ret = ompi_osc_pt2pt_process_unlock (pending->module, pending->source, pending 186 ompi/mca/osc/pt2pt/osc_pt2pt_component.c &pending->header.unlock); pending 195 ompi/mca/osc/pt2pt/osc_pt2pt_component.c opal_list_remove_item (&mca_osc_pt2pt_component.pending_operations, &pending->super); pending 196 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_RELEASE(pending); pending 109 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c static void osc_pt2pt_pending_acc_constructor (osc_pt2pt_pending_acc_t *pending) pending 111 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c pending->data = NULL; pending 112 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c pending->datatype = NULL; pending 115 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c static void osc_pt2pt_pending_acc_destructor (osc_pt2pt_pending_acc_t *pending) pending 117 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c if (NULL != pending->data) { pending 118 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c free (pending->data); pending 121 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c if (NULL != pending->datatype) { pending 122 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c OMPI_DATATYPE_RELEASE(pending->datatype); pending 1364 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_osc_pt2pt_pending_t *pending; pending 1366 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c pending = OBJ_NEW(ompi_osc_pt2pt_pending_t); pending 1367 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c pending->module = module; pending 1368 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c pending->source = source; pending 1369 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c pending->header.flush = *flush_header; pending 1371 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c osc_pt2pt_add_pending (pending); pending 1398 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_osc_pt2pt_pending_t *pending; pending 1400 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c pending = OBJ_NEW(ompi_osc_pt2pt_pending_t); pending 1401 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c pending->module = module; pending 1402 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c pending->source = source; pending 1403 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c pending->header.unlock = *unlock_header; pending 1405 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c osc_pt2pt_add_pending (pending); pending 68 ompi/mca/osc/pt2pt/osc_pt2pt_frag.c assert(0 == frag->pending && peer->active_frag != (intptr_t) frag); pending 106 ompi/mca/osc/pt2pt/osc_pt2pt_frag.c active_frag->target, active_frag->pending)); pending 109 ompi/mca/osc/pt2pt/osc_pt2pt_frag.c if (0 != OPAL_THREAD_ADD_FETCH32(&active_frag->pending, -1)) { pending 36 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h opal_atomic_int32_t pending; pending 54 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h if (0 == OPAL_THREAD_ADD_FETCH32(&buffer->pending, -1)) { pending 90 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->pending = 1; pending 149 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h OPAL_THREAD_ADD_FETCH32(&curr->pending, 1); pending 722 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c ompi_osc_pt2pt_pending_lock_t *pending = pending 724 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c if (NULL == pending) { pending 728 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c pending->peer = requestor; pending 729 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c pending->lock_type = lock_type; pending 730 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c pending->lock_ptr = lock_ptr; pending 735 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c OPAL_THREAD_SCOPED_LOCK(&module->locks_pending_lock, opal_list_append(&module->locks_pending, &pending->super)); pending 581 ompi/mca/osc/rdma/osc_rdma.h } while (ompi_osc_rdma_sync_get_count (sync) || (sync->module->rdma_frag && (sync->module->rdma_frag->pending > 1))); pending 21 ompi/mca/osc/rdma/osc_rdma_frag.h OSC_RDMA_VERBOSE(MCA_BASE_VERBOSE_INFO, "returning frag. pending = %d", frag->pending); pending 22 ompi/mca/osc/rdma/osc_rdma_frag.h if (0 == OPAL_THREAD_ADD_FETCH32(&frag->pending, -1)) { pending 25 ompi/mca/osc/rdma/osc_rdma_frag.h (void) opal_atomic_swap_32 (&frag->pending, 1); pending 63 ompi/mca/osc/rdma/osc_rdma_frag.h curr->pending = 1; pending 85 ompi/mca/osc/rdma/osc_rdma_frag.h OSC_RDMA_VERBOSE(MCA_BASE_VERBOSE_INFO, "allocating frag. pending = %d", curr->pending); pending 86 ompi/mca/osc/rdma/osc_rdma_frag.h OPAL_THREAD_ADD_FETCH32(&curr->pending, 1); pending 202 ompi/mca/osc/rdma/osc_rdma_types.h opal_atomic_int32_t pending; pending 85 opal/mca/btl/portals4/btl_portals4_recv.c block->pending = 0; pending 35 opal/mca/btl/portals4/btl_portals4_recv.h volatile int32_t pending; pending 102 opal/mca/btl/portals4/btl_portals4_recv.h block->pending = 0; pending 534 opal/mca/event/libevent2022/libevent/listener.c DWORD pending = 0; pending 562 opal/mca/event/libevent2022/libevent/listener.c as->buflen/2, as->buflen/2, &pending, &as->overlapped.overlapped)) pending 1579 opal/mca/event/libevent2022/libevent/test/regress_dns.c static int pending = 0; pending 1624 opal/mca/event/libevent2022/libevent/test/regress_dns.c if (--pending <= 0) pending 1642 opal/mca/event/libevent2022/libevent/test/regress_dns.c ++pending; pending 670 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c if (!channel->pending) { pending 775 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c wev->pending = false; pending 1026 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c wev->pending = false; pending 67 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h bool pending; pending 133 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h wev->pending = true; \ pending 46 orte/mca/filem/raw/filem_raw.h bool pending; pending 60 orte/mca/filem/raw/filem_raw.h bool pending; pending 542 orte/mca/filem/raw/filem_raw_module.c xfer->pending = true; pending 764 orte/mca/filem/raw/filem_raw_module.c rev->pending = false; pending 851 orte/mca/filem/raw/filem_raw_module.c rev->pending = true; pending 1094 orte/mca/filem/raw/filem_raw_module.c if (!incoming->pending) { pending 1096 orte/mca/filem/raw/filem_raw_module.c incoming->pending = true; pending 1124 orte/mca/filem/raw/filem_raw_module.c sink->pending = false; pending 1206 orte/mca/filem/raw/filem_raw_module.c sink->pending = true; pending 1231 orte/mca/filem/raw/filem_raw_module.c sink->pending = true; pending 1244 orte/mca/filem/raw/filem_raw_module.c ptr->pending = false; pending 1253 orte/mca/filem/raw/filem_raw_module.c if (ptr->pending) { pending 1290 orte/mca/filem/raw/filem_raw_module.c ptr->pending = false; pending 1302 orte/mca/filem/raw/filem_raw_module.c if (ptr->pending) { pending 91 orte/mca/iof/base/base.h bool pending; pending 171 orte/mca/iof/base/base.h wev->pending = true; \ pending 276 orte/mca/iof/base/iof_base_frame.c wev->pending = false; pending 262 orte/mca/iof/base/iof_base_output.c if (!channel->pending) { pending 372 orte/mca/iof/base/iof_base_output.c wev->pending = false; pending 544 orte/mca/iof/hnp/iof_hnp.c wev->pending = false; pending 399 orte/mca/iof/orted/iof_orted.c wev->pending = false; pending 112 orte/runtime/orte_data_server.c static opal_list_t pending; pending 148 orte/runtime/orte_data_server.c OBJ_CONSTRUCT(&pending, opal_list_t); pending 175 orte/runtime/orte_data_server.c OPAL_LIST_DESTRUCT(&pending); pending 279 orte/runtime/orte_data_server.c OPAL_LIST_FOREACH_SAFE(req, rqnext, &pending, orte_data_req_t) { pending 345 orte/runtime/orte_data_server.c opal_list_remove_item(&pending, &req->super); pending 539 orte/runtime/orte_data_server.c opal_list_append(&pending, &req->super);