ev 705 ompi/mca/coll/portals4/coll_portals4_component.c ptl_event_t ev; ev 709 ompi/mca/coll/portals4/coll_portals4_component.c ret = PtlEQGet(mca_coll_portals4_component.eq_h, &ev); ev 712 ompi/mca/coll/portals4/coll_portals4_component.c OPAL_OUTPUT_VERBOSE((10, ompi_coll_base_framework.framework_output, "event type=%s\n", evname[ev.type])); ev 715 ompi/mca/coll/portals4/coll_portals4_component.c switch (ev.type) { ev 718 ompi/mca/coll/portals4/coll_portals4_component.c if (PTL_OK == ev.ni_fail_type) { ev 721 ompi/mca/coll/portals4/coll_portals4_component.c (void*) ev.hdr_data, ev.match_bits)); ev 722 ompi/mca/coll/portals4/coll_portals4_component.c assert(0 != ev.hdr_data); ev 723 ompi/mca/coll/portals4/coll_portals4_component.c ptl_request = (ompi_coll_portals4_request_t*) ev.hdr_data; ev 748 ompi/mca/coll/portals4/coll_portals4_component.c if (PTL_OK != ev.ni_fail_type) { ev 749 ompi/mca/coll/portals4/coll_portals4_component.c OPAL_OUTPUT_VERBOSE((10, ompi_coll_base_framework.framework_output, "ni_fail_type=%s\n", failtype[ev.ni_fail_type])); ev 754 ompi/mca/coll/portals4/coll_portals4_component.c "Unexpected event of type %d", ev.type); ev 500 ompi/mca/mtl/portals4/mtl_portals4_component.c ptl_event_t ev; ev 505 ompi/mca/mtl/portals4/mtl_portals4_component.c ret = PtlEQPoll(ompi_mtl_portals4.eqs_h, 2, 0, &ev, &which); ev 508 ompi/mca/mtl/portals4/mtl_portals4_component.c "Found event of type %d\n", ev.type)); ev 510 ompi/mca/mtl/portals4/mtl_portals4_component.c switch (ev.type) { ev 520 ompi/mca/mtl/portals4/mtl_portals4_component.c if (NULL != ev.user_ptr) { ev 521 ompi/mca/mtl/portals4/mtl_portals4_component.c ptl_request = ev.user_ptr; ev 522 ompi/mca/mtl/portals4/mtl_portals4_component.c ret = ptl_request->event_callback(&ev, ptl_request); ev 532 ompi/mca/mtl/portals4/mtl_portals4_component.c if (NULL != ev.user_ptr) { ev 533 ompi/mca/mtl/portals4/mtl_portals4_component.c rndv_get_frag = ev.user_ptr; ev 534 ompi/mca/mtl/portals4/mtl_portals4_component.c ret = rndv_get_frag->event_callback(&ev, rndv_get_frag); ev 547 ompi/mca/mtl/portals4/mtl_portals4_component.c (int) ev.pt_index)); ev 568 ompi/mca/mtl/portals4/mtl_portals4_component.c "Unexpected event of type %d", ev.type); ev 24 ompi/mca/mtl/portals4/mtl_portals4_flowctl.c static int flowctl_alert_callback(ptl_event_t *ev, ev 26 ompi/mca/mtl/portals4/mtl_portals4_flowctl.c static int flowctl_fanout_callback(ptl_event_t *ev, ev 577 ompi/mca/mtl/portals4/mtl_portals4_flowctl.c flowctl_alert_callback(ptl_event_t *ev, ev 585 ompi/mca/mtl/portals4/mtl_portals4_flowctl.c flowctl_fanout_callback(ptl_event_t *ev, ev 18 ompi/mca/mtl/portals4/mtl_portals4_message.h ptl_event_t ev; ev 26 ompi/mca/mtl/portals4/mtl_portals4_message.h ompi_mtl_portals4_message_alloc(const ptl_event_t *ev) ev 36 ompi/mca/mtl/portals4/mtl_portals4_message.h message->ev = *ev; ev 38 ompi/mca/mtl/portals4/mtl_portals4_message.h if (0 == ev->mlength) { ev 44 ompi/mca/mtl/portals4/mtl_portals4_message.h memcpy(message->buffer, ev->start, ev->mlength); ev 45 ompi/mca/mtl/portals4/mtl_portals4_message.h message->ev.start = message->buffer; ev 30 ompi/mca/mtl/portals4/mtl_portals4_probe.c completion_fn(ptl_event_t *ev, ompi_mtl_portals4_base_request_t *ptl_base_request) ev 37 ompi/mca/mtl/portals4/mtl_portals4_probe.c __FILE__, __LINE__, ev->type, ev->ni_fail_type); ev 39 ompi/mca/mtl/portals4/mtl_portals4_probe.c if (OPAL_UNLIKELY(ev->ni_fail_type == PTL_OK)) { ev 41 ompi/mca/mtl/portals4/mtl_portals4_probe.c ptl_request->status.MPI_SOURCE = MTL_PORTALS4_GET_SOURCE(ev->match_bits); ev 42 ompi/mca/mtl/portals4/mtl_portals4_probe.c ptl_request->status.MPI_TAG = MTL_PORTALS4_GET_TAG(ev->match_bits); ev 44 ompi/mca/mtl/portals4/mtl_portals4_probe.c ptl_request->status._ucount = MTL_PORTALS4_GET_LENGTH(ev->hdr_data); ev 45 ompi/mca/mtl/portals4/mtl_portals4_probe.c if (ev->type != PTL_EVENT_SEARCH) { ev 46 ompi/mca/mtl/portals4/mtl_portals4_probe.c ptl_request->message = ompi_mtl_portals4_message_alloc(ev); ev 40 ompi/mca/mtl/portals4/mtl_portals4_recv.c ompi_mtl_portals4_recv_progress(ptl_event_t *ev, ev 43 ompi/mca/mtl/portals4/mtl_portals4_recv.c ompi_mtl_portals4_rndv_get_frag_progress(ptl_event_t *ev, ev 114 ompi/mca/mtl/portals4/mtl_portals4_recv.c ompi_mtl_portals4_recv_progress(ptl_event_t *ev, ev 126 ompi/mca/mtl/portals4/mtl_portals4_recv.c switch (ev->type) { ev 130 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->opcount, ev->hdr_data)); ev 132 ompi/mca/mtl/portals4/mtl_portals4_recv.c if (ev->ni_fail_type != PTL_NI_OK) { ev 135 ompi/mca/mtl/portals4/mtl_portals4_recv.c __FILE__, __LINE__, ev->ni_fail_type); ev 142 ompi/mca/mtl/portals4/mtl_portals4_recv.c msg_length = MTL_PORTALS4_GET_LENGTH(ev->hdr_data); ev 144 ompi/mca/mtl/portals4/mtl_portals4_recv.c MTL_PORTALS4_GET_SOURCE(ev->match_bits); ev 146 ompi/mca/mtl/portals4/mtl_portals4_recv.c MTL_PORTALS4_GET_TAG(ev->match_bits); ev 154 ompi/mca/mtl/portals4/mtl_portals4_recv.c if (ev->mlength < msg_length) ev 159 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->hdr_data = ev->hdr_data; ev 162 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status._ucount = ev->mlength; ev 163 ompi/mca/mtl/portals4/mtl_portals4_recv.c if (!MTL_PORTALS4_IS_SHORT_MSG(ev->match_bits) && msg_length > ev->mlength) { ev 167 ompi/mca/mtl/portals4/mtl_portals4_recv.c ret = read_msg((char*)ptl_request->delivery_ptr + ev->mlength, ev 168 ompi/mca/mtl/portals4/mtl_portals4_recv.c ((msg_length > ptl_request->delivery_len) ? ptl_request->delivery_len : msg_length) - ev->mlength, ev 169 ompi/mca/mtl/portals4/mtl_portals4_recv.c ev->initiator, ev 170 ompi/mca/mtl/portals4/mtl_portals4_recv.c ev->hdr_data, ev 171 ompi/mca/mtl/portals4/mtl_portals4_recv.c ev->mlength, ev 182 ompi/mca/mtl/portals4/mtl_portals4_recv.c ev->start, ev 183 ompi/mca/mtl/portals4/mtl_portals4_recv.c ev->mlength); ev 200 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->opcount, ev->hdr_data)); ev 202 ompi/mca/mtl/portals4/mtl_portals4_recv.c if (OPAL_UNLIKELY(ev->ni_fail_type != PTL_NI_OK)) { ev 205 ompi/mca/mtl/portals4/mtl_portals4_recv.c __FILE__, __LINE__, ev->ni_fail_type); ev 212 ompi/mca/mtl/portals4/mtl_portals4_recv.c msg_length = MTL_PORTALS4_GET_LENGTH(ev->hdr_data); ev 214 ompi/mca/mtl/portals4/mtl_portals4_recv.c MTL_PORTALS4_GET_SOURCE(ev->match_bits); ev 216 ompi/mca/mtl/portals4/mtl_portals4_recv.c MTL_PORTALS4_GET_TAG(ev->match_bits); ev 221 ompi/mca/mtl/portals4/mtl_portals4_recv.c MTL_PORTALS4_IS_SHORT_MSG(ev->match_bits)); ev 226 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->hdr_data = ev->hdr_data; ev 231 ompi/mca/mtl/portals4/mtl_portals4_recv.c if (MTL_PORTALS4_IS_SHORT_MSG(ev->match_bits)) { ev 232 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status._ucount = ev->mlength; ev 233 ompi/mca/mtl/portals4/mtl_portals4_recv.c if (ev->mlength > 0) { ev 237 ompi/mca/mtl/portals4/mtl_portals4_recv.c iov.iov_base = (char*) ev->start; ev 238 ompi/mca/mtl/portals4/mtl_portals4_recv.c iov.iov_len = ev->mlength; ev 253 ompi/mca/mtl/portals4/mtl_portals4_recv.c if (MTL_PORTALS4_IS_SYNC_MSG(ev->hdr_data)) { ev 261 ompi/mca/mtl/portals4/mtl_portals4_recv.c ev->initiator, ev 263 ompi/mca/mtl/portals4/mtl_portals4_recv.c ev->hdr_data, ev 277 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->opcount, ptl_request->hdr_data, (long) ev->start)); ev 287 ompi/mca/mtl/portals4/mtl_portals4_recv.c ev->initiator, ev 288 ompi/mca/mtl/portals4/mtl_portals4_recv.c ev->hdr_data, ev 305 ompi/mca/mtl/portals4/mtl_portals4_recv.c ev->type); ev 320 ompi/mca/mtl/portals4/mtl_portals4_recv.c ompi_mtl_portals4_rndv_get_frag_progress(ptl_event_t *ev, ev 327 ompi/mca/mtl/portals4/mtl_portals4_recv.c assert(PTL_EVENT_REPLY == ev->type); ev 334 ompi/mca/mtl/portals4/mtl_portals4_recv.c if (OPAL_UNLIKELY(ev->ni_fail_type != PTL_NI_OK)) { ev 337 ompi/mca/mtl/portals4/mtl_portals4_recv.c __FILE__, __LINE__, ev->ni_fail_type); ev 339 ompi/mca/mtl/portals4/mtl_portals4_recv.c if (OPAL_UNLIKELY(ev->ni_fail_type != PTL_NI_DROPPED)) { ev 342 ompi/mca/mtl/portals4/mtl_portals4_recv.c (uint32_t)ev->ni_fail_type); ev 382 ompi/mca/mtl/portals4/mtl_portals4_recv.c ptl_request->super.super.ompi_req->req_status._ucount += ev->mlength; ev 571 ompi/mca/mtl/portals4/mtl_portals4_recv.c return ompi_mtl_portals4_recv_progress(&(ptl_message->ev), &ptl_request->super); ev 37 ompi/mca/mtl/portals4/mtl_portals4_recv_short.c ompi_mtl_portals4_recv_block_progress(ptl_event_t *ev, ev 45 ompi/mca/mtl/portals4/mtl_portals4_recv_short.c switch (ev->type) { ev 134 ompi/mca/mtl/portals4/mtl_portals4_recv_short.c "Other EVENT %d, hdr_data = %lx", ev->type, (long unsigned) ev->hdr_data)); ev 43 ompi/mca/mtl/portals4/mtl_portals4_request.h int (*event_callback)(ptl_event_t *ev, struct ompi_mtl_portals4_base_request_t*); ev 100 ompi/mca/mtl/portals4/mtl_portals4_request.h int (*event_callback)(ptl_event_t *ev, struct ompi_mtl_portals4_rndv_get_frag_t*); ev 39 ompi/mca/mtl/portals4/mtl_portals4_send.c ompi_mtl_portals4_callback(ptl_event_t *ev, ev 47 ompi/mca/mtl/portals4/mtl_portals4_send.c if (PTL_EVENT_GET == ev->type) { ev 71 ompi/mca/mtl/portals4/mtl_portals4_send.c if (OPAL_UNLIKELY(ev->ni_fail_type == PTL_NI_PT_DISABLED)) { ev 77 ompi/mca/mtl/portals4/mtl_portals4_send.c ptl_request->opcount, ev->type)); ev 104 ompi/mca/mtl/portals4/mtl_portals4_send.c if (OPAL_UNLIKELY(ev->ni_fail_type != PTL_NI_OK)) { ev 107 ompi/mca/mtl/portals4/mtl_portals4_send.c __FILE__, __LINE__, ev->ni_fail_type); ev 114 ompi/mca/mtl/portals4/mtl_portals4_send.c ptl_request->opcount, ev->type)); ev 121 ompi/mca/mtl/portals4/mtl_portals4_send.c if ((PTL_EVENT_ACK == ev->type) && ev 122 ompi/mca/mtl/portals4/mtl_portals4_send.c (PTL_PRIORITY_LIST == ev->ptl_list) && ev 143 ompi/mca/mtl/portals4/mtl_portals4_send.c if ((PTL_EVENT_ACK == ev->type) && ev 144 ompi/mca/mtl/portals4/mtl_portals4_send.c (PTL_PRIORITY_LIST == ev->ptl_list) && ev 145 ompi/mca/mtl/portals4/mtl_portals4_send.c (ev->mlength == ptl_request->length) && ev 192 ompi/mca/mtl/portals4/mtl_portals4_send.c ompi_mtl_portals4_send_callback(ptl_event_t *ev, ev 200 ompi/mca/mtl/portals4/mtl_portals4_send.c ret = ompi_mtl_portals4_callback(ev, ptl_base_request, &complete); ev 212 ompi/mca/mtl/portals4/mtl_portals4_send.c ompi_mtl_portals4_isend_callback(ptl_event_t *ev, ev 220 ompi/mca/mtl/portals4/mtl_portals4_send.c ret = ompi_mtl_portals4_callback(ev, ptl_base_request, &complete); ev 190 ompi/mca/osc/portals4/osc_portals4_component.c ptl_event_t ev; ev 195 ompi/mca/osc/portals4/osc_portals4_component.c ret = PtlEQGet(mca_osc_portals4_component.matching_eq_h, &ev); ev 213 ompi/mca/osc/portals4/osc_portals4_component.c if (ev.ni_fail_type != PTL_OK) { ev 216 ompi/mca/osc/portals4/osc_portals4_component.c __FILE__, __LINE__, ev.type, ev.ni_fail_type); ev 222 ompi/mca/osc/portals4/osc_portals4_component.c if (NULL != ev.user_ptr) { ev 224 ompi/mca/osc/portals4/osc_portals4_component.c if (ev.type == PTL_EVENT_LINK) { ev 225 ompi/mca/osc/portals4/osc_portals4_component.c *(int *)ev.user_ptr = *(int *)ev.user_ptr + 1; ev 230 ompi/mca/osc/portals4/osc_portals4_component.c req = (ompi_osc_portals4_request_t*) ev.user_ptr; ev 231 ompi/mca/osc/portals4/osc_portals4_component.c opal_atomic_add_fetch_size_t(&req->super.req_status._ucount, ev.mlength); ev 572 opal/mca/btl/portals4/btl_portals4_component.c static ptl_event_t ev; ev 579 opal/mca/btl/portals4/btl_portals4_component.c ret = PtlEQPoll(mca_btl_portals4_component.eqs_h, mca_btl_portals4_component.num_btls, 0, &ev, &which); ev 583 opal/mca/btl/portals4/btl_portals4_component.c ev.type, ev.ni_fail_type, which)); ev 587 opal/mca/btl/portals4/btl_portals4_component.c switch (ev.type) { ev 591 opal/mca/btl/portals4/btl_portals4_component.c frag = ev.user_ptr; ev 624 opal/mca/btl/portals4/btl_portals4_component.c frag = ev.user_ptr; ev 630 opal/mca/btl/portals4/btl_portals4_component.c "PTL_EVENT_ACK received rlength=%ld mlength=%ld des_flags=%d\n", ev.rlength, ev.mlength, frag->base.des_flags)); ev 659 opal/mca/btl/portals4/btl_portals4_component.c tag = (unsigned char) (ev.hdr_data); ev 663 opal/mca/btl/portals4/btl_portals4_component.c seg[0].seg_addr.pval = ev.start; ev 664 opal/mca/btl/portals4/btl_portals4_component.c seg[0].seg_len = ev.mlength; ev 683 opal/mca/btl/portals4/btl_portals4_component.c frag = ev.user_ptr; ev 694 opal/mca/btl/portals4/btl_portals4_component.c mca_btl_portals4_activate_block(ev.user_ptr); ev 706 opal/mca/btl/portals4/btl_portals4_component.c "PTL_EVENT_GET received at target rlength=%ld mlength=%ld\n", ev.rlength, ev.mlength)); ev 712 opal/mca/btl/portals4/btl_portals4_component.c frag = ev.user_ptr; ev 714 opal/mca/btl/portals4/btl_portals4_component.c if (PTL_NI_PERM_VIOLATION == ev.ni_fail_type) { ev 745 opal/mca/btl/portals4/btl_portals4_component.c ev.start, ev 1086 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_t *ev = calloc(sizeof(*ev), 1); ev 1093 opal/mca/btl/usnic/btl_usnic_cagent.c ev, -1, 0, agent_thread_finalize, ev); ev 1094 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_add(ev, &finalize_retry); ev 1240 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_t *ev = calloc(sizeof(*ev), 1); ev 1242 opal/mca/btl/usnic/btl_usnic_cagent.c ev, -1, OPAL_EV_WRITE, agent_thread_finalize, ev); ev 1243 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_active(ev, OPAL_EV_WRITE, 1); ev 47 opal/mca/event/event.h #define OPAL_EVENT_SIGNAL(ev) opal_event_get_signal(ev) ev 85 opal/mca/event/external/event_external_module.c opal_event_t *ev; ev 87 opal/mca/event/external/event_external_module.c ev = (opal_event_t*)malloc(sizeof(opal_event_t)); ev 88 opal/mca/event/external/event_external_module.c return ev; ev 84 opal/mca/event/external/external.h #define opal_event_add(ev, tv) event_add((ev), (tv)) ev 86 opal/mca/event/external/external.h #define opal_event_del(ev) event_del((ev)) ev 335 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int _bufferevent_add_event(struct event *ev, const struct timeval *tv); ev 855 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_add_event(struct event *ev, const struct timeval *tv) ev 858 opal/mca/event/libevent2022/libevent/bufferevent.c return event_add(ev, NULL); ev 860 opal/mca/event/libevent2022/libevent/bufferevent.c return event_add(ev, tv); ev 98 opal/mca/event/libevent2022/libevent/bufferevent_sock.c #define be_socket_add(ev, t) \ ev 99 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_add_event((ev), (t)) ev 425 opal/mca/event/libevent2022/libevent/epoll.c short ev = 0; ev 428 opal/mca/event/libevent2022/libevent/epoll.c ev = EV_READ | EV_WRITE; ev 431 opal/mca/event/libevent2022/libevent/epoll.c ev |= EV_READ; ev 433 opal/mca/event/libevent2022/libevent/epoll.c ev |= EV_WRITE; ev 436 opal/mca/event/libevent2022/libevent/epoll.c if (!ev) ev 439 opal/mca/event/libevent2022/libevent/epoll.c evmap_io_active(base, events[i].data.fd, ev | EV_ET); ev 349 opal/mca/event/libevent2022/libevent/event-internal.h void event_active_nolock(struct event *ev, int res, short count); ev 131 opal/mca/event/libevent2022/libevent/event.c static inline int event_add_internal(struct event *ev, ev 133 opal/mca/event/libevent2022/libevent/event.c static inline int event_del_internal(struct event *ev); ev 145 opal/mca/event/libevent2022/libevent/event.c static inline void event_signal_closure(struct event_base *, struct event *ev); ev 146 opal/mca/event/libevent2022/libevent/event.c static inline void event_persist_closure(struct event_base *, struct event *ev); ev 199 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_note_setup(ev) do { \ ev 202 opal/mca/event/libevent2022/libevent/event.c find.ptr = (ev); \ ev 212 opal/mca/event/libevent2022/libevent/event.c dent->ptr = (ev); \ ev 221 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_note_teardown(ev) do { \ ev 224 opal/mca/event/libevent2022/libevent/event.c find.ptr = (ev); \ ev 234 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_note_add(ev) do { \ ev 237 opal/mca/event/libevent2022/libevent/event.c find.ptr = (ev); \ ev 247 opal/mca/event/libevent2022/libevent/event.c __func__, (ev), (ev)->ev_events, \ ev 248 opal/mca/event/libevent2022/libevent/event.c EV_SOCK_ARG((ev)->ev_fd), (ev)->ev_flags); \ ev 255 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_note_del(ev) do { \ ev 258 opal/mca/event/libevent2022/libevent/event.c find.ptr = (ev); \ ev 268 opal/mca/event/libevent2022/libevent/event.c __func__, (ev), (ev)->ev_events, \ ev 269 opal/mca/event/libevent2022/libevent/event.c EV_SOCK_ARG((ev)->ev_fd), (ev)->ev_flags); \ ev 276 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_assert_is_setup(ev) do { \ ev 279 opal/mca/event/libevent2022/libevent/event.c find.ptr = (ev); \ ev 287 opal/mca/event/libevent2022/libevent/event.c __func__, (ev), (ev)->ev_events, \ ev 288 opal/mca/event/libevent2022/libevent/event.c EV_SOCK_ARG((ev)->ev_fd), (ev)->ev_flags); \ ev 295 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_assert_not_added(ev) do { \ ev 298 opal/mca/event/libevent2022/libevent/event.c find.ptr = (ev); \ ev 306 opal/mca/event/libevent2022/libevent/event.c __func__, (ev), (ev)->ev_events, \ ev 307 opal/mca/event/libevent2022/libevent/event.c EV_SOCK_ARG((ev)->ev_fd), (ev)->ev_flags); \ ev 313 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_note_setup(ev) \ ev 315 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_note_teardown(ev) \ ev 317 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_note_add(ev) \ ev 319 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_note_del(ev) \ ev 321 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_assert_is_setup(ev) \ ev 323 opal/mca/event/libevent2022/libevent/event.c #define _event_debug_assert_not_added(ev) \ ev 693 opal/mca/event/libevent2022/libevent/event.c struct event *ev; ev 727 opal/mca/event/libevent2022/libevent/event.c for (ev = TAILQ_FIRST(&base->eventqueue); ev; ) { ev 728 opal/mca/event/libevent2022/libevent/event.c struct event *next = TAILQ_NEXT(ev, ev_next); ev 729 opal/mca/event/libevent2022/libevent/event.c if (!(ev->ev_flags & EVLIST_INTERNAL)) { ev 730 opal/mca/event/libevent2022/libevent/event.c event_del(ev); ev 733 opal/mca/event/libevent2022/libevent/event.c ev = next; ev 735 opal/mca/event/libevent2022/libevent/event.c while ((ev = min_heap_top(&base->timeheap)) != NULL) { ev 736 opal/mca/event/libevent2022/libevent/event.c event_del(ev); ev 744 opal/mca/event/libevent2022/libevent/event.c for (ev = TAILQ_FIRST(&ctl->events); ev; ) { ev 745 opal/mca/event/libevent2022/libevent/event.c struct event *next = TAILQ_NEXT(ev, ev 747 opal/mca/event/libevent2022/libevent/event.c if (!(ev->ev_flags & EVLIST_INTERNAL)) { ev 748 opal/mca/event/libevent2022/libevent/event.c event_del(ev); ev 751 opal/mca/event/libevent2022/libevent/event.c ev = next; ev 759 opal/mca/event/libevent2022/libevent/event.c for (ev = TAILQ_FIRST(&base->activequeues[i]); ev; ) { ev 760 opal/mca/event/libevent2022/libevent/event.c struct event *next = TAILQ_NEXT(ev, ev_active_next); ev 761 opal/mca/event/libevent2022/libevent/event.c if (!(ev->ev_flags & EVLIST_INTERNAL)) { ev 762 opal/mca/event/libevent2022/libevent/event.c event_del(ev); ev 765 opal/mca/event/libevent2022/libevent/event.c ev = next; ev 802 opal/mca/event/libevent2022/libevent/event.c struct event *ev; ev 867 opal/mca/event/libevent2022/libevent/event.c TAILQ_FOREACH(ev, &base->eventqueue, ev_next) { ev 868 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_events & (EV_READ|EV_WRITE)) { ev 869 opal/mca/event/libevent2022/libevent/event.c if (ev == &base->sig.ev_signal) { ev 876 opal/mca/event/libevent2022/libevent/event.c if (evmap_io_add(base, ev->ev_fd, ev) == -1) ev 878 opal/mca/event/libevent2022/libevent/event.c } else if (ev->ev_events & EV_SIGNAL) { ev 879 opal/mca/event/libevent2022/libevent/event.c if (evmap_signal_add(base, (int)ev->ev_fd, ev) == -1) ev 1051 opal/mca/event/libevent2022/libevent/event.c event_signal_closure(struct event_base *base, struct event *ev) ev 1057 opal/mca/event/libevent2022/libevent/event.c ncalls = ev->ev_ncalls; ev 1059 opal/mca/event/libevent2022/libevent/event.c ev->ev_pncalls = &ncalls; ev 1063 opal/mca/event/libevent2022/libevent/event.c ev->ev_ncalls = ncalls; ev 1065 opal/mca/event/libevent2022/libevent/event.c ev->ev_pncalls = NULL; ev 1066 opal/mca/event/libevent2022/libevent/event.c (*ev->ev_callback)(ev->ev_fd, ev->ev_res, ev->ev_arg); ev 1074 opal/mca/event/libevent2022/libevent/event.c ev->ev_pncalls = NULL; ev 1164 opal/mca/event/libevent2022/libevent/event.c struct event *ev = NULL; ev 1168 opal/mca/event/libevent2022/libevent/event.c ev = TAILQ_FIRST(&ctl->events); ev 1169 opal/mca/event/libevent2022/libevent/event.c if (!ev || ev->ev_timeout.tv_sec > now.tv_sec || ev 1170 opal/mca/event/libevent2022/libevent/event.c (ev->ev_timeout.tv_sec == now.tv_sec && ev 1171 opal/mca/event/libevent2022/libevent/event.c (ev->ev_timeout.tv_usec&MICROSECONDS_MASK) > now.tv_usec)) ev 1173 opal/mca/event/libevent2022/libevent/event.c event_del_internal(ev); ev 1174 opal/mca/event/libevent2022/libevent/event.c event_active_nolock(ev, EV_TIMEOUT, 1); ev 1176 opal/mca/event/libevent2022/libevent/event.c if (ev) ev 1177 opal/mca/event/libevent2022/libevent/event.c common_timeout_schedule(ctl, &now, ev); ev 1259 opal/mca/event/libevent2022/libevent/event.c event_persist_closure(struct event_base *base, struct event *ev) ev 1270 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_io_timeout.tv_sec || ev->ev_io_timeout.tv_usec) { ev 1277 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(is_same_common_timeout(&ev->ev_timeout, ev 1278 opal/mca/event/libevent2022/libevent/event.c &ev->ev_io_timeout)); ev 1280 opal/mca/event/libevent2022/libevent/event.c if (is_common_timeout(&ev->ev_timeout, base)) { ev 1281 opal/mca/event/libevent2022/libevent/event.c delay = ev->ev_io_timeout; ev 1284 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_res & EV_TIMEOUT) { ev 1285 opal/mca/event/libevent2022/libevent/event.c relative_to = ev->ev_timeout; ev 1291 opal/mca/event/libevent2022/libevent/event.c delay = ev->ev_io_timeout; ev 1292 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_res & EV_TIMEOUT) { ev 1293 opal/mca/event/libevent2022/libevent/event.c relative_to = ev->ev_timeout; ev 1308 opal/mca/event/libevent2022/libevent/event.c event_add_internal(ev, &run_at, 1); ev 1312 opal/mca/event/libevent2022/libevent/event.c evcb_callback = ev->ev_callback; ev 1313 opal/mca/event/libevent2022/libevent/event.c evcb_fd = ev->ev_fd; ev 1314 opal/mca/event/libevent2022/libevent/event.c evcb_res = ev->ev_res; ev 1315 opal/mca/event/libevent2022/libevent/event.c evcb_arg = ev->ev_arg; ev 1335 opal/mca/event/libevent2022/libevent/event.c struct event *ev; ev 1340 opal/mca/event/libevent2022/libevent/event.c for (ev = TAILQ_FIRST(activeq); ev; ev = TAILQ_FIRST(activeq)) { ev 1341 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_events & EV_PERSIST) ev 1342 opal/mca/event/libevent2022/libevent/event.c event_queue_remove(base, ev, EVLIST_ACTIVE); ev 1344 opal/mca/event/libevent2022/libevent/event.c event_del_internal(ev); ev 1345 opal/mca/event/libevent2022/libevent/event.c if (!(ev->ev_flags & EVLIST_INTERNAL)) ev 1350 opal/mca/event/libevent2022/libevent/event.c ev, ev 1351 opal/mca/event/libevent2022/libevent/event.c ev->ev_res & EV_READ ? "EV_READ " : " ", ev 1352 opal/mca/event/libevent2022/libevent/event.c ev->ev_res & EV_WRITE ? "EV_WRITE " : " ", ev 1353 opal/mca/event/libevent2022/libevent/event.c ev->ev_callback)); ev 1356 opal/mca/event/libevent2022/libevent/event.c base->current_event = ev; ev 1360 opal/mca/event/libevent2022/libevent/event.c switch (ev->ev_closure) { ev 1362 opal/mca/event/libevent2022/libevent/event.c event_signal_closure(base, ev); ev 1365 opal/mca/event/libevent2022/libevent/event.c event_persist_closure(base, ev); ev 1370 opal/mca/event/libevent2022/libevent/event.c (*ev->ev_callback)( ev 1371 opal/mca/event/libevent2022/libevent/event.c ev->ev_fd, ev->ev_res, ev->ev_arg); ev 1665 opal/mca/event/libevent2022/libevent/event.c struct event ev; ev 1679 opal/mca/event/libevent2022/libevent/event.c event_debug_unassign(&eonce->ev); ev 1719 opal/mca/event/libevent2022/libevent/event.c evtimer_assign(&eonce->ev, base, event_once_cb, eonce); ev 1723 opal/mca/event/libevent2022/libevent/event.c event_assign(&eonce->ev, base, fd, events, event_once_cb, eonce); ev 1731 opal/mca/event/libevent2022/libevent/event.c res = event_add(&eonce->ev, tv); ev 1741 opal/mca/event/libevent2022/libevent/event.c event_assign(struct event *ev, struct event_base *base, evutil_socket_t fd, short events, void (*callback)(evutil_socket_t, short, void *), void *arg) ev 1746 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_not_added(ev); ev 1748 opal/mca/event/libevent2022/libevent/event.c ev->ev_base = base; ev 1750 opal/mca/event/libevent2022/libevent/event.c ev->ev_callback = callback; ev 1751 opal/mca/event/libevent2022/libevent/event.c ev->ev_arg = arg; ev 1752 opal/mca/event/libevent2022/libevent/event.c ev->ev_fd = fd; ev 1753 opal/mca/event/libevent2022/libevent/event.c ev->ev_events = events; ev 1754 opal/mca/event/libevent2022/libevent/event.c ev->ev_res = 0; ev 1755 opal/mca/event/libevent2022/libevent/event.c ev->ev_flags = EVLIST_INIT; ev 1756 opal/mca/event/libevent2022/libevent/event.c ev->ev_ncalls = 0; ev 1757 opal/mca/event/libevent2022/libevent/event.c ev->ev_pncalls = NULL; ev 1765 opal/mca/event/libevent2022/libevent/event.c ev->ev_closure = EV_CLOSURE_SIGNAL; ev 1768 opal/mca/event/libevent2022/libevent/event.c evutil_timerclear(&ev->ev_io_timeout); ev 1769 opal/mca/event/libevent2022/libevent/event.c ev->ev_closure = EV_CLOSURE_PERSIST; ev 1771 opal/mca/event/libevent2022/libevent/event.c ev->ev_closure = EV_CLOSURE_NONE; ev 1775 opal/mca/event/libevent2022/libevent/event.c min_heap_elem_init(ev); ev 1779 opal/mca/event/libevent2022/libevent/event.c ev->ev_pri = base->nactivequeues / 2; ev 1782 opal/mca/event/libevent2022/libevent/event.c _event_debug_note_setup(ev); ev 1788 opal/mca/event/libevent2022/libevent/event.c event_base_set(struct event_base *base, struct event *ev) ev 1791 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags != EVLIST_INIT) ev 1794 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 1796 opal/mca/event/libevent2022/libevent/event.c ev->ev_base = base; ev 1797 opal/mca/event/libevent2022/libevent/event.c ev->ev_pri = base->nactivequeues/2; ev 1803 opal/mca/event/libevent2022/libevent/event.c event_set(struct event *ev, evutil_socket_t fd, short events, ev 1807 opal/mca/event/libevent2022/libevent/event.c r = event_assign(ev, current_base, fd, events, callback, arg); ev 1814 opal/mca/event/libevent2022/libevent/event.c struct event *ev; ev 1815 opal/mca/event/libevent2022/libevent/event.c ev = mm_malloc(sizeof(struct event)); ev 1816 opal/mca/event/libevent2022/libevent/event.c if (ev == NULL) ev 1818 opal/mca/event/libevent2022/libevent/event.c if (event_assign(ev, base, fd, events, cb, arg) < 0) { ev 1819 opal/mca/event/libevent2022/libevent/event.c mm_free(ev); ev 1823 opal/mca/event/libevent2022/libevent/event.c return (ev); ev 1827 opal/mca/event/libevent2022/libevent/event.c event_free(struct event *ev) ev 1829 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 1832 opal/mca/event/libevent2022/libevent/event.c event_del(ev); ev 1833 opal/mca/event/libevent2022/libevent/event.c _event_debug_note_teardown(ev); ev 1834 opal/mca/event/libevent2022/libevent/event.c mm_free(ev); ev 1839 opal/mca/event/libevent2022/libevent/event.c event_debug_unassign(struct event *ev) ev 1841 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_not_added(ev); ev 1842 opal/mca/event/libevent2022/libevent/event.c _event_debug_note_teardown(ev); ev 1844 opal/mca/event/libevent2022/libevent/event.c ev->ev_flags &= ~EVLIST_INIT; ev 1853 opal/mca/event/libevent2022/libevent/event.c event_priority_set(struct event *ev, int pri) ev 1855 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 1857 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags & EVLIST_ACTIVE) ev 1859 opal/mca/event/libevent2022/libevent/event.c if (pri < 0 || pri >= ev->ev_base->nactivequeues) ev 1862 opal/mca/event/libevent2022/libevent/event.c ev->ev_pri = pri; ev 1872 opal/mca/event/libevent2022/libevent/event.c event_pending(const struct event *ev, short event, struct timeval *tv) ev 1876 opal/mca/event/libevent2022/libevent/event.c if (EVUTIL_FAILURE_CHECK(ev->ev_base == NULL)) { ev 1881 opal/mca/event/libevent2022/libevent/event.c EVBASE_ACQUIRE_LOCK(ev->ev_base, th_base_lock); ev 1882 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 1884 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags & EVLIST_INSERTED) ev 1885 opal/mca/event/libevent2022/libevent/event.c flags |= (ev->ev_events & (EV_READ|EV_WRITE|EV_SIGNAL)); ev 1886 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags & EVLIST_ACTIVE) ev 1887 opal/mca/event/libevent2022/libevent/event.c flags |= ev->ev_res; ev 1888 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags & EVLIST_TIMEOUT) ev 1895 opal/mca/event/libevent2022/libevent/event.c struct timeval tmp = ev->ev_timeout; ev 1899 opal/mca/event/libevent2022/libevent/event.c evutil_timeradd(&ev->ev_base->tv_clock_diff, &tmp, tv); ev 1905 opal/mca/event/libevent2022/libevent/event.c EVBASE_RELEASE_LOCK(ev->ev_base, th_base_lock); ev 1911 opal/mca/event/libevent2022/libevent/event.c event_initialized(const struct event *ev) ev 1913 opal/mca/event/libevent2022/libevent/event.c if (!(ev->ev_flags & EVLIST_INIT)) ev 1943 opal/mca/event/libevent2022/libevent/event.c event_get_fd(const struct event *ev) ev 1945 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 1946 opal/mca/event/libevent2022/libevent/event.c return ev->ev_fd; ev 1950 opal/mca/event/libevent2022/libevent/event.c event_get_base(const struct event *ev) ev 1952 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 1953 opal/mca/event/libevent2022/libevent/event.c return ev->ev_base; ev 1957 opal/mca/event/libevent2022/libevent/event.c event_get_events(const struct event *ev) ev 1959 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 1960 opal/mca/event/libevent2022/libevent/event.c return ev->ev_events; ev 1964 opal/mca/event/libevent2022/libevent/event.c event_get_callback(const struct event *ev) ev 1966 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 1967 opal/mca/event/libevent2022/libevent/event.c return ev->ev_callback; ev 1971 opal/mca/event/libevent2022/libevent/event.c event_get_callback_arg(const struct event *ev) ev 1973 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 1974 opal/mca/event/libevent2022/libevent/event.c return ev->ev_arg; ev 1978 opal/mca/event/libevent2022/libevent/event.c event_add(struct event *ev, const struct timeval *tv) ev 1982 opal/mca/event/libevent2022/libevent/event.c if (EVUTIL_FAILURE_CHECK(!ev->ev_base)) { ev 1987 opal/mca/event/libevent2022/libevent/event.c EVBASE_ACQUIRE_LOCK(ev->ev_base, th_base_lock); ev 1989 opal/mca/event/libevent2022/libevent/event.c res = event_add_internal(ev, tv, 0); ev 1991 opal/mca/event/libevent2022/libevent/event.c EVBASE_RELEASE_LOCK(ev->ev_base, th_base_lock); ev 2050 opal/mca/event/libevent2022/libevent/event.c event_add_internal(struct event *ev, const struct timeval *tv, ev 2053 opal/mca/event/libevent2022/libevent/event.c struct event_base *base = ev->ev_base; ev 2058 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 2062 opal/mca/event/libevent2022/libevent/event.c ev, ev 2063 opal/mca/event/libevent2022/libevent/event.c EV_SOCK_ARG(ev->ev_fd), ev 2064 opal/mca/event/libevent2022/libevent/event.c ev->ev_events & EV_READ ? "EV_READ " : " ", ev 2065 opal/mca/event/libevent2022/libevent/event.c ev->ev_events & EV_WRITE ? "EV_WRITE " : " ", ev 2067 opal/mca/event/libevent2022/libevent/event.c ev->ev_callback)); ev 2069 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(!(ev->ev_flags & ~EVLIST_ALL)); ev 2075 opal/mca/event/libevent2022/libevent/event.c if (tv != NULL && !(ev->ev_flags & EVLIST_TIMEOUT)) { ev 2086 opal/mca/event/libevent2022/libevent/event.c if (base->current_event == ev && (ev->ev_events & EV_SIGNAL) ev 2093 opal/mca/event/libevent2022/libevent/event.c if ((ev->ev_events & (EV_READ|EV_WRITE|EV_SIGNAL)) && ev 2094 opal/mca/event/libevent2022/libevent/event.c !(ev->ev_flags & (EVLIST_INSERTED|EVLIST_ACTIVE))) { ev 2095 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_events & (EV_READ|EV_WRITE)) ev 2096 opal/mca/event/libevent2022/libevent/event.c res = evmap_io_add(base, ev->ev_fd, ev); ev 2097 opal/mca/event/libevent2022/libevent/event.c else if (ev->ev_events & EV_SIGNAL) ev 2098 opal/mca/event/libevent2022/libevent/event.c res = evmap_signal_add(base, (int)ev->ev_fd, ev); ev 2100 opal/mca/event/libevent2022/libevent/event.c event_queue_insert(base, ev, EVLIST_INSERTED); ev 2122 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_closure == EV_CLOSURE_PERSIST && !tv_is_absolute) ev 2123 opal/mca/event/libevent2022/libevent/event.c ev->ev_io_timeout = *tv; ev 2129 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags & EVLIST_TIMEOUT) { ev 2131 opal/mca/event/libevent2022/libevent/event.c if (min_heap_elt_is_top(ev)) ev 2133 opal/mca/event/libevent2022/libevent/event.c event_queue_remove(base, ev, EVLIST_TIMEOUT); ev 2139 opal/mca/event/libevent2022/libevent/event.c if ((ev->ev_flags & EVLIST_ACTIVE) && ev 2140 opal/mca/event/libevent2022/libevent/event.c (ev->ev_res & EV_TIMEOUT)) { ev 2141 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_events & EV_SIGNAL) { ev 2145 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_ncalls && ev->ev_pncalls) { ev 2147 opal/mca/event/libevent2022/libevent/event.c *ev->ev_pncalls = 0; ev 2151 opal/mca/event/libevent2022/libevent/event.c event_queue_remove(base, ev, EVLIST_ACTIVE); ev 2158 opal/mca/event/libevent2022/libevent/event.c ev->ev_timeout = *tv; ev 2162 opal/mca/event/libevent2022/libevent/event.c evutil_timeradd(&now, &tmp, &ev->ev_timeout); ev 2163 opal/mca/event/libevent2022/libevent/event.c ev->ev_timeout.tv_usec |= ev 2166 opal/mca/event/libevent2022/libevent/event.c evutil_timeradd(&now, tv, &ev->ev_timeout); ev 2171 opal/mca/event/libevent2022/libevent/event.c (int)tv->tv_sec, ev->ev_callback)); ev 2173 opal/mca/event/libevent2022/libevent/event.c event_queue_insert(base, ev, EVLIST_TIMEOUT); ev 2176 opal/mca/event/libevent2022/libevent/event.c get_common_timeout_list(base, &ev->ev_timeout); ev 2177 opal/mca/event/libevent2022/libevent/event.c if (ev == TAILQ_FIRST(&ctl->events)) { ev 2178 opal/mca/event/libevent2022/libevent/event.c common_timeout_schedule(ctl, &now, ev); ev 2185 opal/mca/event/libevent2022/libevent/event.c if (min_heap_elt_is_top(ev)) ev 2194 opal/mca/event/libevent2022/libevent/event.c _event_debug_note_add(ev); ev 2200 opal/mca/event/libevent2022/libevent/event.c event_del(struct event *ev) ev 2204 opal/mca/event/libevent2022/libevent/event.c if (EVUTIL_FAILURE_CHECK(!ev->ev_base)) { ev 2209 opal/mca/event/libevent2022/libevent/event.c EVBASE_ACQUIRE_LOCK(ev->ev_base, th_base_lock); ev 2211 opal/mca/event/libevent2022/libevent/event.c res = event_del_internal(ev); ev 2213 opal/mca/event/libevent2022/libevent/event.c EVBASE_RELEASE_LOCK(ev->ev_base, th_base_lock); ev 2220 opal/mca/event/libevent2022/libevent/event.c event_del_internal(struct event *ev) ev 2226 opal/mca/event/libevent2022/libevent/event.c ev, EV_SOCK_ARG(ev->ev_fd), ev->ev_callback)); ev 2229 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_base == NULL) ev 2232 opal/mca/event/libevent2022/libevent/event.c EVENT_BASE_ASSERT_LOCKED(ev->ev_base); ev 2239 opal/mca/event/libevent2022/libevent/event.c base = ev->ev_base; ev 2241 opal/mca/event/libevent2022/libevent/event.c if (base->current_event == ev && !EVBASE_IN_THREAD(base)) { ev 2247 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(!(ev->ev_flags & ~EVLIST_ALL)); ev 2250 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_events & EV_SIGNAL) { ev 2251 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_ncalls && ev->ev_pncalls) { ev 2253 opal/mca/event/libevent2022/libevent/event.c *ev->ev_pncalls = 0; ev 2257 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags & EVLIST_TIMEOUT) { ev 2265 opal/mca/event/libevent2022/libevent/event.c event_queue_remove(base, ev, EVLIST_TIMEOUT); ev 2268 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags & EVLIST_ACTIVE) ev 2269 opal/mca/event/libevent2022/libevent/event.c event_queue_remove(base, ev, EVLIST_ACTIVE); ev 2271 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags & EVLIST_INSERTED) { ev 2272 opal/mca/event/libevent2022/libevent/event.c event_queue_remove(base, ev, EVLIST_INSERTED); ev 2273 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_events & (EV_READ|EV_WRITE)) ev 2274 opal/mca/event/libevent2022/libevent/event.c res = evmap_io_del(base, ev->ev_fd, ev); ev 2276 opal/mca/event/libevent2022/libevent/event.c res = evmap_signal_del(base, (int)ev->ev_fd, ev); ev 2288 opal/mca/event/libevent2022/libevent/event.c _event_debug_note_del(ev); ev 2294 opal/mca/event/libevent2022/libevent/event.c event_active(struct event *ev, int res, short ncalls) ev 2296 opal/mca/event/libevent2022/libevent/event.c if (EVUTIL_FAILURE_CHECK(!ev->ev_base)) { ev 2301 opal/mca/event/libevent2022/libevent/event.c EVBASE_ACQUIRE_LOCK(ev->ev_base, th_base_lock); ev 2303 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(ev); ev 2305 opal/mca/event/libevent2022/libevent/event.c event_active_nolock(ev, res, ncalls); ev 2307 opal/mca/event/libevent2022/libevent/event.c EVBASE_RELEASE_LOCK(ev->ev_base, th_base_lock); ev 2312 opal/mca/event/libevent2022/libevent/event.c event_active_nolock(struct event *ev, int res, short ncalls) ev 2317 opal/mca/event/libevent2022/libevent/event.c ev, EV_SOCK_ARG(ev->ev_fd), (int)res, ev->ev_callback)); ev 2321 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags & EVLIST_ACTIVE) { ev 2322 opal/mca/event/libevent2022/libevent/event.c ev->ev_res |= res; ev 2326 opal/mca/event/libevent2022/libevent/event.c base = ev->ev_base; ev 2330 opal/mca/event/libevent2022/libevent/event.c ev->ev_res = res; ev 2332 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_pri < base->event_running_priority) ev 2335 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_events & EV_SIGNAL) { ev 2337 opal/mca/event/libevent2022/libevent/event.c if (base->current_event == ev && !EVBASE_IN_THREAD(base)) { ev 2342 opal/mca/event/libevent2022/libevent/event.c ev->ev_ncalls = ncalls; ev 2343 opal/mca/event/libevent2022/libevent/event.c ev->ev_pncalls = NULL; ev 2346 opal/mca/event/libevent2022/libevent/event.c event_queue_insert(base, ev, EVLIST_ACTIVE); ev 2407 opal/mca/event/libevent2022/libevent/event.c struct event *ev; ev 2411 opal/mca/event/libevent2022/libevent/event.c ev = min_heap_top(&base->timeheap); ev 2413 opal/mca/event/libevent2022/libevent/event.c if (ev == NULL) { ev 2424 opal/mca/event/libevent2022/libevent/event.c if (evutil_timercmp(&ev->ev_timeout, &now, <=)) { ev 2429 opal/mca/event/libevent2022/libevent/event.c evutil_timersub(&ev->ev_timeout, &now, tv); ev 2480 opal/mca/event/libevent2022/libevent/event.c struct event *ev; ev 2483 opal/mca/event/libevent2022/libevent/event.c TAILQ_FOREACH(ev, &ctl->events, ev 2485 opal/mca/event/libevent2022/libevent/event.c struct timeval *ev_tv = &ev->ev_timeout; ev 2503 opal/mca/event/libevent2022/libevent/event.c struct event *ev; ev 2511 opal/mca/event/libevent2022/libevent/event.c while ((ev = min_heap_top(&base->timeheap))) { ev 2512 opal/mca/event/libevent2022/libevent/event.c if (evutil_timercmp(&ev->ev_timeout, &now, >)) ev 2516 opal/mca/event/libevent2022/libevent/event.c event_del_internal(ev); ev 2519 opal/mca/event/libevent2022/libevent/event.c ev->ev_callback)); ev 2520 opal/mca/event/libevent2022/libevent/event.c event_active_nolock(ev, EV_TIMEOUT, 1); ev 2526 opal/mca/event/libevent2022/libevent/event.c event_queue_remove(struct event_base *base, struct event *ev, int queue) ev 2530 opal/mca/event/libevent2022/libevent/event.c if (!(ev->ev_flags & queue)) { ev 2532 opal/mca/event/libevent2022/libevent/event.c ev, EV_SOCK_ARG(ev->ev_fd), queue); ev 2536 opal/mca/event/libevent2022/libevent/event.c if (~ev->ev_flags & EVLIST_INTERNAL) ev 2539 opal/mca/event/libevent2022/libevent/event.c ev->ev_flags &= ~queue; ev 2542 opal/mca/event/libevent2022/libevent/event.c TAILQ_REMOVE(&base->eventqueue, ev, ev_next); ev 2546 opal/mca/event/libevent2022/libevent/event.c TAILQ_REMOVE(&base->activequeues[ev->ev_pri], ev 2547 opal/mca/event/libevent2022/libevent/event.c ev, ev_active_next); ev 2550 opal/mca/event/libevent2022/libevent/event.c if (is_common_timeout(&ev->ev_timeout, base)) { ev 2552 opal/mca/event/libevent2022/libevent/event.c get_common_timeout_list(base, &ev->ev_timeout); ev 2553 opal/mca/event/libevent2022/libevent/event.c TAILQ_REMOVE(&ctl->events, ev, ev 2556 opal/mca/event/libevent2022/libevent/event.c min_heap_erase(&base->timeheap, ev); ev 2567 opal/mca/event/libevent2022/libevent/event.c struct event *ev) ev 2584 opal/mca/event/libevent2022/libevent/event.c is_same_common_timeout(&e->ev_timeout, &ev->ev_timeout)); ev 2585 opal/mca/event/libevent2022/libevent/event.c if (evutil_timercmp(&ev->ev_timeout, &e->ev_timeout, >=)) { ev 2586 opal/mca/event/libevent2022/libevent/event.c TAILQ_INSERT_AFTER(&ctl->events, e, ev, ev 2591 opal/mca/event/libevent2022/libevent/event.c TAILQ_INSERT_HEAD(&ctl->events, ev, ev 2596 opal/mca/event/libevent2022/libevent/event.c event_queue_insert(struct event_base *base, struct event *ev, int queue) ev 2600 opal/mca/event/libevent2022/libevent/event.c if (ev->ev_flags & queue) { ev 2606 opal/mca/event/libevent2022/libevent/event.c ev, EV_SOCK_ARG(ev->ev_fd), queue); ev 2610 opal/mca/event/libevent2022/libevent/event.c if (~ev->ev_flags & EVLIST_INTERNAL) ev 2613 opal/mca/event/libevent2022/libevent/event.c ev->ev_flags |= queue; ev 2616 opal/mca/event/libevent2022/libevent/event.c TAILQ_INSERT_TAIL(&base->eventqueue, ev, ev_next); ev 2620 opal/mca/event/libevent2022/libevent/event.c TAILQ_INSERT_TAIL(&base->activequeues[ev->ev_pri], ev 2621 opal/mca/event/libevent2022/libevent/event.c ev,ev_active_next); ev 2624 opal/mca/event/libevent2022/libevent/event.c if (is_common_timeout(&ev->ev_timeout, base)) { ev 2626 opal/mca/event/libevent2022/libevent/event.c get_common_timeout_list(base, &ev->ev_timeout); ev 2627 opal/mca/event/libevent2022/libevent/event.c insert_common_timeout_inorder(ctl, ev); ev 2629 opal/mca/event/libevent2022/libevent/event.c min_heap_push(&base->timeheap, ev); ev 2925 opal/mca/event/libevent2022/libevent/event.c struct event *ev, *p_ev; ev 2926 opal/mca/event/libevent2022/libevent/event.c ev = base->timeheap.p[i]; ev 2928 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(ev->ev_flags & EV_TIMEOUT); ev 2929 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(evutil_timercmp(&p_ev->ev_timeout, &ev->ev_timeout, <=)); ev 2930 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(ev->ev_timeout_pos.min_heap_idx == i); ev 2936 opal/mca/event/libevent2022/libevent/event.c struct event *last=NULL, *ev; ev 2937 opal/mca/event/libevent2022/libevent/event.c TAILQ_FOREACH(ev, &ctl->events, ev_timeout_pos.ev_next_with_common_timeout) { ev 2939 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(evutil_timercmp(&last->ev_timeout, &ev->ev_timeout, <=)); ev 2940 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(ev->ev_flags & EV_TIMEOUT); ev 2941 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(is_common_timeout(&ev->ev_timeout,base)); ev 2942 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(COMMON_TIMEOUT_IDX(&ev->ev_timeout) == i); ev 2943 opal/mca/event/libevent2022/libevent/event.c last = ev; ev 62 opal/mca/event/libevent2022/libevent/evmap-internal.h int evmap_io_add(struct event_base *base, evutil_socket_t fd, struct event *ev); ev 71 opal/mca/event/libevent2022/libevent/evmap-internal.h int evmap_io_del(struct event_base *base, evutil_socket_t fd, struct event *ev); ev 84 opal/mca/event/libevent2022/libevent/evmap-internal.h int evmap_signal_add(struct event_base *base, int signum, struct event *ev); ev 85 opal/mca/event/libevent2022/libevent/evmap-internal.h int evmap_signal_del(struct event_base *base, int signum, struct event *ev); ev 263 opal/mca/event/libevent2022/libevent/evmap.c evmap_io_add(struct event_base *base, evutil_socket_t fd, struct event *ev) ev 272 opal/mca/event/libevent2022/libevent/evmap.c EVUTIL_ASSERT(fd == ev->ev_fd); ev 294 opal/mca/event/libevent2022/libevent/evmap.c if (ev->ev_events & EV_READ) { ev 298 opal/mca/event/libevent2022/libevent/evmap.c if (ev->ev_events & EV_WRITE) { ev 309 opal/mca/event/libevent2022/libevent/evmap.c (old_ev->ev_events&EV_ET) != (ev->ev_events&EV_ET)) { ev 320 opal/mca/event/libevent2022/libevent/evmap.c if (evsel->add(base, ev->ev_fd, ev 321 opal/mca/event/libevent2022/libevent/evmap.c old, (ev->ev_events & EV_ET) | res, extra) == -1) ev 328 opal/mca/event/libevent2022/libevent/evmap.c TAILQ_INSERT_TAIL(&ctx->events, ev, ev_io_next); ev 336 opal/mca/event/libevent2022/libevent/evmap.c evmap_io_del(struct event_base *base, evutil_socket_t fd, struct event *ev) ev 347 opal/mca/event/libevent2022/libevent/evmap.c EVUTIL_ASSERT(fd == ev->ev_fd); ev 364 opal/mca/event/libevent2022/libevent/evmap.c if (ev->ev_events & EV_READ) { ev 369 opal/mca/event/libevent2022/libevent/evmap.c if (ev->ev_events & EV_WRITE) { ev 377 opal/mca/event/libevent2022/libevent/evmap.c if (evsel->del(base, ev->ev_fd, old, res, extra) == -1) ev 384 opal/mca/event/libevent2022/libevent/evmap.c TAILQ_REMOVE(&ctx->events, ev, ev_io_next); ev 394 opal/mca/event/libevent2022/libevent/evmap.c struct event *ev; ev 402 opal/mca/event/libevent2022/libevent/evmap.c TAILQ_FOREACH(ev, &ctx->events, ev_io_next) { ev 403 opal/mca/event/libevent2022/libevent/evmap.c if (ev->ev_events & events) ev 404 opal/mca/event/libevent2022/libevent/evmap.c event_active_nolock(ev, ev->ev_events & events, 1); ev 418 opal/mca/event/libevent2022/libevent/evmap.c evmap_signal_add(struct event_base *base, int sig, struct event *ev) ev 433 opal/mca/event/libevent2022/libevent/evmap.c if (evsel->add(base, ev->ev_fd, 0, EV_SIGNAL, NULL) ev 438 opal/mca/event/libevent2022/libevent/evmap.c TAILQ_INSERT_TAIL(&ctx->events, ev, ev_signal_next); ev 444 opal/mca/event/libevent2022/libevent/evmap.c evmap_signal_del(struct event_base *base, int sig, struct event *ev) ev 456 opal/mca/event/libevent2022/libevent/evmap.c if (evsel->del(base, ev->ev_fd, 0, EV_SIGNAL, NULL) == -1) ev 460 opal/mca/event/libevent2022/libevent/evmap.c TAILQ_REMOVE(&ctx->events, ev, ev_signal_next); ev 470 opal/mca/event/libevent2022/libevent/evmap.c struct event *ev; ev 475 opal/mca/event/libevent2022/libevent/evmap.c TAILQ_FOREACH(ev, &ctx->events, ev_signal_next) ev 476 opal/mca/event/libevent2022/libevent/evmap.c event_active_nolock(ev, EV_SIGNAL, ncalls); ev 735 opal/mca/event/libevent2022/libevent/evmap.c struct event *ev; ev 744 opal/mca/event/libevent2022/libevent/evmap.c TAILQ_FOREACH(ev, &base->eventqueue, ev_next) { ev 745 opal/mca/event/libevent2022/libevent/evmap.c EVUTIL_ASSERT(ev->ev_flags & EVLIST_INSERTED); ev 746 opal/mca/event/libevent2022/libevent/evmap.c EVUTIL_ASSERT(ev->ev_flags & EVLIST_INIT); ev 747 opal/mca/event/libevent2022/libevent/evmap.c ev->ev_flags &= ~(EVLIST_X_SIGFOUND|EVLIST_X_IOFOUND); ev 762 opal/mca/event/libevent2022/libevent/evmap.c TAILQ_FOREACH(ev, &ctx->events, ev_io_next) { ev 763 opal/mca/event/libevent2022/libevent/evmap.c EVUTIL_ASSERT(!(ev->ev_flags & EVLIST_X_IOFOUND)); ev 764 opal/mca/event/libevent2022/libevent/evmap.c EVUTIL_ASSERT(ev->ev_fd == i); ev 765 opal/mca/event/libevent2022/libevent/evmap.c ev->ev_flags |= EVLIST_X_IOFOUND; ev 775 opal/mca/event/libevent2022/libevent/evmap.c TAILQ_FOREACH(ev, &ctx->events, ev_signal_next) { ev 776 opal/mca/event/libevent2022/libevent/evmap.c EVUTIL_ASSERT(!(ev->ev_flags & EVLIST_X_SIGFOUND)); ev 777 opal/mca/event/libevent2022/libevent/evmap.c EVUTIL_ASSERT(ev->ev_fd == i); ev 778 opal/mca/event/libevent2022/libevent/evmap.c ev->ev_flags |= EVLIST_X_SIGFOUND; ev 783 opal/mca/event/libevent2022/libevent/evmap.c TAILQ_FOREACH(ev, &base->eventqueue, ev_next) { ev 784 opal/mca/event/libevent2022/libevent/evmap.c if (ev->ev_events & (EV_READ|EV_WRITE)) { ev 785 opal/mca/event/libevent2022/libevent/evmap.c EVUTIL_ASSERT(ev->ev_flags & EVLIST_X_IOFOUND); ev 788 opal/mca/event/libevent2022/libevent/evmap.c if (ev->ev_events & EV_SIGNAL) { ev 789 opal/mca/event/libevent2022/libevent/evmap.c EVUTIL_ASSERT(ev->ev_flags & EVLIST_X_SIGFOUND); ev 359 opal/mca/event/libevent2022/libevent/http.c evhttp_add_event(struct event *ev, int timeout, int default_timeout) ev 366 opal/mca/event/libevent2022/libevent/http.c return event_add(ev, &tv); ev 368 opal/mca/event/libevent2022/libevent/http.c return event_add(ev, NULL); ev 762 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evtimer_assign(ev, b, cb, arg) \ ev 763 opal/mca/event/libevent2022/libevent/include/event2/event.h event_assign((ev), (b), -1, 0, (cb), (arg)) ev 765 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evtimer_add(ev, tv) event_add((ev), (tv)) ev 766 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evtimer_del(ev) event_del(ev) ev 767 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evtimer_pending(ev, tv) event_pending((ev), EV_TIMEOUT, (tv)) ev 768 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evtimer_initialized(ev) event_initialized(ev) ev 777 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evsignal_add(ev, tv) event_add((ev), (tv)) ev 778 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evsignal_assign(ev, b, x, cb, arg) \ ev 779 opal/mca/event/libevent2022/libevent/include/event2/event.h event_assign((ev), (b), (x), EV_SIGNAL|EV_PERSIST, cb, (arg)) ev 782 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evsignal_del(ev) event_del(ev) ev 783 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evsignal_pending(ev, tv) event_pending((ev), EV_SIGNAL, (tv)) ev 784 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evsignal_initialized(ev) event_initialized(ev) ev 945 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_add(struct event *ev, const struct timeval *timeout); ev 975 opal/mca/event/libevent2022/libevent/include/event2/event.h void event_active(struct event *ev, int res, short ncalls); ev 990 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_pending(const struct event *ev, short events, struct timeval *tv); ev 1008 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_initialized(const struct event *ev); ev 1013 opal/mca/event/libevent2022/libevent/include/event2/event.h #define event_get_signal(ev) ((int)event_get_fd(ev)) ev 1019 opal/mca/event/libevent2022/libevent/include/event2/event.h evutil_socket_t event_get_fd(const struct event *ev); ev 1024 opal/mca/event/libevent2022/libevent/include/event2/event.h struct event_base *event_get_base(const struct event *ev); ev 1029 opal/mca/event/libevent2022/libevent/include/event2/event.h short event_get_events(const struct event *ev); ev 1034 opal/mca/event/libevent2022/libevent/include/event2/event.h event_callback_fn event_get_callback(const struct event *ev); ev 1039 opal/mca/event/libevent2022/libevent/include/event2/event.h void *event_get_callback_arg(const struct event *ev); ev 176 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define evtimer_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) ev 177 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define evsignal_set(ev, x, cb, arg) \ ev 178 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h event_set((ev), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg)) ev 188 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define timeout_add(ev, tv) event_add((ev), (tv)) ev 189 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define timeout_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) ev 190 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define timeout_del(ev) event_del(ev) ev 191 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define timeout_pending(ev, tv) event_pending((ev), EV_TIMEOUT, (tv)) ev 192 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define timeout_initialized(ev) event_initialized(ev) ev 202 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define signal_add(ev, tv) event_add((ev), (tv)) ev 203 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define signal_set(ev, x, cb, arg) \ ev 204 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h event_set((ev), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg)) ev 205 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define signal_del(ev) event_del(ev) ev 206 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define signal_pending(ev, tv) event_pending((ev), EV_SIGNAL, (tv)) ev 207 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define signal_initialized(ev) event_initialized(ev) ev 212 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define EVENT_FD(ev) ((int)event_get_fd(ev)) ev 213 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define EVENT_SIGNAL(ev) event_get_signal(ev) ev 101 opal/mca/event/libevent2022/libevent/poll.c struct event *ev; ev 36 opal/mca/event/libevent2022/libevent/sample/event-test.c struct event *ev = arg; ev 42 opal/mca/event/libevent2022/libevent/sample/event-test.c event_add(ev, NULL); ev 52 opal/mca/event/libevent2022/libevent/sample/event-test.c event_del(ev); ev 104 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev; ev 157 opal/mca/event/libevent2022/libevent/test/regress.c event_del(arg->ev); ev 181 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev = arg; ev 192 opal/mca/event/libevent2022/libevent/test/regress.c event_del(ev); ev 201 opal/mca/event/libevent2022/libevent/test/regress.c event_del(ev); ev 206 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(ev, NULL) == -1) ev 214 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev = arg; ev 222 opal/mca/event/libevent2022/libevent/test/regress.c event_del(ev); ev 228 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(ev, NULL) == -1) ev 254 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 272 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(&both->ev, NULL) == -1) ev 298 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(&both->ev, NULL) == -1) ev 314 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 325 opal/mca/event/libevent2022/libevent/test/regress.c event_set(&ev, pair[1], EV_READ, simple_read_cb, &ev); ev 326 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(&ev, NULL) == -1) ev 336 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 341 opal/mca/event/libevent2022/libevent/test/regress.c event_set(&ev, pair[0], EV_WRITE, simple_write_cb, &ev); ev 342 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(&ev, NULL) == -1) ev 492 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev, ev2; ev 504 opal/mca/event/libevent2022/libevent/test/regress.c event_set(&ev, pair[0], EV_WRITE, multiple_write_cb, &ev); ev 505 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(&ev, NULL) == -1) ev 521 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev, ev2; ev 533 opal/mca/event/libevent2022/libevent/test/regress.c event_set(&ev, pair[0], EV_WRITE|EV_PERSIST, multiple_write_cb, &ev); ev 534 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(&ev, NULL) == -1) ev 561 opal/mca/event/libevent2022/libevent/test/regress.c event_set(&r1.ev, pair[0], EV_READ, combined_read_cb, &r1); ev 562 opal/mca/event/libevent2022/libevent/test/regress.c event_set(&w1.ev, pair[0], EV_WRITE, combined_write_cb, &w1); ev 563 opal/mca/event/libevent2022/libevent/test/regress.c event_set(&r2.ev, pair[1], EV_READ, combined_read_cb, &r2); ev 564 opal/mca/event/libevent2022/libevent/test/regress.c event_set(&w2.ev, pair[1], EV_WRITE, combined_write_cb, &w2); ev 565 opal/mca/event/libevent2022/libevent/test/regress.c tt_assert(event_add(&r1.ev, NULL) != -1); ev 566 opal/mca/event/libevent2022/libevent/test/regress.c tt_assert(!event_add(&w1.ev, NULL)); ev 567 opal/mca/event/libevent2022/libevent/test/regress.c tt_assert(!event_add(&r2.ev, NULL)); ev 568 opal/mca/event/libevent2022/libevent/test/regress.c tt_assert(!event_add(&w2.ev, NULL)); ev 582 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 588 opal/mca/event/libevent2022/libevent/test/regress.c evtimer_set(&ev, timeout_cb, NULL); ev 589 opal/mca/event/libevent2022/libevent/test/regress.c evtimer_add(&ev, &tv); ev 615 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 621 opal/mca/event/libevent2022/libevent/test/regress.c event_assign(&ev, global_base, -1, EV_TIMEOUT|EV_PERSIST, ev 623 opal/mca/event/libevent2022/libevent/test/regress.c event_add(&ev, &tv); ev 627 opal/mca/event/libevent2022/libevent/test/regress.c event_del(&ev); ev 634 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 639 opal/mca/event/libevent2022/libevent/test/regress.c event_assign(&ev, data->base, -1, EV_PERSIST, periodic_timeout_cb, &count); ev 640 opal/mca/event/libevent2022/libevent/test/regress.c event_add(&ev, &msec100); ev 652 opal/mca/event/libevent2022/libevent/test/regress.c event_del(&ev); ev 664 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev = arg; ev 665 opal/mca/event/libevent2022/libevent/test/regress.c event_active(ev, EV_READ, 1); ev 683 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 693 opal/mca/event/libevent2022/libevent/test/regress.c event_assign(&ev, base, -1, EV_TIMEOUT|EV_PERSIST, ev 695 opal/mca/event/libevent2022/libevent/test/regress.c event_add(&ev, &tv); ev 699 opal/mca/event/libevent2022/libevent/test/regress.c event_base_once(base, -1, EV_TIMEOUT, activate_cb, &ev, &tv2); ev 719 opal/mca/event/libevent2022/libevent/test/regress.c event_del(&ev); ev 723 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 736 opal/mca/event/libevent2022/libevent/test/regress.c event_del(&ti->ev); ev 769 opal/mca/event/libevent2022/libevent/test/regress.c event_assign(&info[i].ev, base, -1, EV_TIMEOUT|EV_PERSIST, ev 772 opal/mca/event/libevent2022/libevent/test/regress.c event_add(&info[i].ev, ms_100); ev 774 opal/mca/event/libevent2022/libevent/test/regress.c event_add(&info[i].ev, ms_200); ev 802 opal/mca/event/libevent2022/libevent/test/regress.c event_add(&info[i].ev, ms_100); ev 804 opal/mca/event/libevent2022/libevent/test/regress.c event_add(&info[i].ev, ms_200); ev 837 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev, sig_ev; ev 849 opal/mca/event/libevent2022/libevent/test/regress.c event_set(&ev, pair[1], EV_READ, simple_read_cb, &ev); ev 850 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(&ev, NULL) == -1) ev 932 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev = arg; ev 934 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_del(ev); ev 941 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 945 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_set(&ev, SIGALRM, signal_cb, &ev); ev 946 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_add(&ev, NULL); ev 948 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_del(&ev); ev 949 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_add(&ev, NULL); ev 958 opal/mca/event/libevent2022/libevent/test/regress.c if (evsignal_del(&ev) == -1) ev 997 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 1000 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_set(&ev, SIGUSR1, signal_cb, &ev); ev 1001 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_add(&ev, NULL); ev 1004 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_del(&ev); ev 1012 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 1014 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_set(&ev, SIGUSR1, signal_cb, &ev); ev 1015 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_add(&ev, NULL); ev 1016 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_del(&ev); ev 1105 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 1109 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_set(&ev, SIGCONT, signal_cb, &ev); ev 1110 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_add(&ev, NULL); ev 1115 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_del(&ev); ev 1140 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 1157 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_set(&ev, SIGUSR1, signal_cb, &ev); ev 1158 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_add(&ev, NULL); ev 1159 opal/mca/event/libevent2022/libevent/test/regress.c evsignal_del(&ev); ev 1199 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev, ev_timer; ev 1206 opal/mca/event/libevent2022/libevent/test/regress.c signal_set(&ev, SIGUSR1, signal_cb_swp, NULL); ev 1207 opal/mca/event/libevent2022/libevent/test/regress.c signal_add(&ev, NULL); ev 1270 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 1273 opal/mca/event/libevent2022/libevent/test/regress.c r = event_assign(&ev, NULL, -1, EV_SIGNAL|EV_READ, dummy_read_cb, NULL); ev 1301 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 1303 opal/mca/event/libevent2022/libevent/test/regress.c event_assign(&ev, base, -1, ev 1306 opal/mca/event/libevent2022/libevent/test/regress.c event_active(&ev, EV_WRITE, 1); ev 1339 opal/mca/event/libevent2022/libevent/test/regress.c args.ev = &ev1; ev 1359 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 1365 opal/mca/event/libevent2022/libevent/test/regress.c evtimer_set(&ev, timeout_cb, NULL); ev 1366 opal/mca/event/libevent2022/libevent/test/regress.c evtimer_add(&ev, &tv); ev 1377 opal/mca/event/libevent2022/libevent/test/regress.c evtimer_del(&ev); ev 1526 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 1544 opal/mca/event/libevent2022/libevent/test/regress.c event_add(&pri->ev, &tv); ev 1560 opal/mca/event/libevent2022/libevent/test/regress.c timeout_set(&one.ev, test_priorities_cb, &one); ev 1561 opal/mca/event/libevent2022/libevent/test/regress.c if (event_priority_set(&one.ev, 0) == -1) { ev 1566 opal/mca/event/libevent2022/libevent/test/regress.c timeout_set(&two.ev, test_priorities_cb, &two); ev 1567 opal/mca/event/libevent2022/libevent/test/regress.c if (event_priority_set(&two.ev, npriorities - 1) == -1) { ev 1574 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(&one.ev, &tv) == -1) ev 1576 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(&two.ev, &tv) == -1) ev 1581 opal/mca/event/libevent2022/libevent/test/regress.c event_del(&one.ev); ev 1582 opal/mca/event/libevent2022/libevent/test/regress.c event_del(&two.ev); ev 1727 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; ev 1742 opal/mca/event/libevent2022/libevent/test/regress.c event_set(&ev, pair[1], EV_READ, read_once_cb, &ev); ev 1743 opal/mca/event/libevent2022/libevent/test/regress.c if (event_add(&ev, NULL) == -1) ev 2349 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev[MANY]; ev 2360 opal/mca/event/libevent2022/libevent/test/regress.c memset(ev, 0, sizeof(ev)); ev 2374 opal/mca/event/libevent2022/libevent/test/regress.c ev[i] = event_new(base, sock[i], EV_WRITE|evflags, ev 2376 opal/mca/event/libevent2022/libevent/test/regress.c event_add(ev[i], NULL); ev 2392 opal/mca/event/libevent2022/libevent/test/regress.c if (ev[i]) ev 2393 opal/mca/event/libevent2022/libevent/test/regress.c event_free(ev[i]); ev 83 opal/mca/event/libevent2022/libevent/test/regress_et.c struct event *ev = NULL; ev 125 opal/mca/event/libevent2022/libevent/test/regress_et.c ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev); ev 127 opal/mca/event/libevent2022/libevent/test/regress_et.c event_add(ev, NULL); ev 148 opal/mca/event/libevent2022/libevent/test/regress_et.c if (ev) { ev 149 opal/mca/event/libevent2022/libevent/test/regress_et.c event_del(ev); ev 150 opal/mca/event/libevent2022/libevent/test/regress_et.c event_free(ev); ev 35 opal/mca/event/libevent2022/libevent/test/regress_minheap.c set_random_timeout(struct event *ev) ev 37 opal/mca/event/libevent2022/libevent/test/regress_minheap.c ev->ev_timeout.tv_sec = rand(); ev 38 opal/mca/event/libevent2022/libevent/test/regress_minheap.c ev->ev_timeout.tv_usec = rand() & 0xfffff; ev 39 opal/mca/event/libevent2022/libevent/test/regress_minheap.c ev->ev_timeout_pos.min_heap_idx = -1; ev 118 opal/mca/event/libevent2022/libevent/test/regress_thread.c struct event ev; ev 126 opal/mca/event/libevent2022/libevent/test/regress_thread.c evtimer_assign(&ev, base, wake_all_timeout, &cw); ev 136 opal/mca/event/libevent2022/libevent/test/regress_thread.c assert(evtimer_add(&ev, &tv) == 0); ev 185 opal/mca/event/libevent2022/libevent/test/regress_thread.c struct event ev; ev 246 opal/mca/event/libevent2022/libevent/test/regress_thread.c evtimer_assign(&ev, base, NULL, NULL); ev 249 opal/mca/event/libevent2022/libevent/test/regress_thread.c event_add(&ev, &tv); ev 256 opal/mca/event/libevent2022/libevent/test/regress_thread.c event_del(&ev); ev 164 opal/mca/event/libevent2022/libevent/test/test-changelist.c struct event* ev; ev 191 opal/mca/event/libevent2022/libevent/test/test-changelist.c ev = event_new(base,pair[1],EV_WRITE | EV_PERSIST, write_cb, &ev); ev 198 opal/mca/event/libevent2022/libevent/test/test-changelist.c event_add(ev, NULL); ev 204 opal/mca/event/libevent2022/libevent/test/test-changelist.c event_free(ev); ev 91 opal/mca/event/libevent2022/libevent/test/test-eof.c struct event ev; ev 116 opal/mca/event/libevent2022/libevent/test/test-eof.c event_set(&ev, pair[1], EV_READ | EV_TIMEOUT, read_cb, &ev); ev 118 opal/mca/event/libevent2022/libevent/test/test-eof.c event_add(&ev, &timeout); ev 49 opal/mca/event/libevent2022/libevent/test/test-time.c struct event *ev[NEVENT]; ev 75 opal/mca/event/libevent2022/libevent/test/test-time.c evtimer_add(ev[j], &tv); ev 77 opal/mca/event/libevent2022/libevent/test/test-time.c evtimer_del(ev[j]); ev 100 opal/mca/event/libevent2022/libevent/test/test-time.c ev[i] = malloc(sizeof(struct event)); ev 103 opal/mca/event/libevent2022/libevent/test/test-time.c evtimer_set(ev[i], time_cb, ev[i]); ev 106 opal/mca/event/libevent2022/libevent/test/test-time.c evtimer_add(ev[i], &tv); ev 86 opal/mca/event/libevent2022/libevent/test/test-weof.c struct event ev; ev 109 opal/mca/event/libevent2022/libevent/test/test-weof.c event_set(&ev, pair[1], EV_WRITE, write_cb, &ev); ev 111 opal/mca/event/libevent2022/libevent/test/test-weof.c event_add(&ev, NULL); ev 115 opal/mca/event/libevent2022/libevent2022.h #define opal_event_add(ev, tv) event_add((ev), (tv)) ev 117 opal/mca/event/libevent2022/libevent2022.h #define opal_event_del(ev) event_del((ev)) ev 135 opal/mca/event/libevent2022/libevent2022_module.c opal_event_t *ev; ev 137 opal/mca/event/libevent2022/libevent2022_module.c ev = (opal_event_t*)malloc(sizeof(opal_event_t)); ev 138 opal/mca/event/libevent2022/libevent2022_module.c return ev; ev 123 opal/mca/pmix/cray/pmix_cray.c opal_event_t ev; ev 943 opal/mca/pmix/cray/pmix_cray.c event_assign(&op->ev, opal_pmix_base.evbase, -1, ev 945 opal/mca/pmix/cray/pmix_cray.c event_active(&op->ev, EV_WRITE, 1); ev 90 opal/mca/pmix/ext2x/ext2x.h opal_event_t ev; ev 142 opal/mca/pmix/ext2x/ext2x.h opal_event_t ev; ev 175 opal/mca/pmix/ext2x/ext2x.h opal_event_assign(&((_cd)->ev), opal_pmix_base.evbase, \ ev 178 opal/mca/pmix/ext2x/ext2x.h opal_event_active(&((_cd)->ev), EV_WRITE, 1); \ ev 190 opal/mca/pmix/ext2x/ext2x.h opal_event_assign(&((_cd)->ev), opal_pmix_base.evbase, \ ev 193 opal/mca/pmix/ext2x/ext2x.h opal_event_active(&((_cd)->ev), EV_WRITE, 1); \ ev 206 opal/mca/pmix/ext2x/ext2x.h opal_event_assign(&((_cd)->ev), opal_pmix_base.evbase, \ ev 209 opal/mca/pmix/ext2x/ext2x.h opal_event_active(&((_cd)->ev), EV_WRITE, 1); \ ev 214 opal/mca/pmix/ext2x/ext2x.h opal_event_assign(&((p)->ev), opal_pmix_base.evbase, \ ev 217 opal/mca/pmix/ext2x/ext2x.h opal_event_active(&((p)->ev), EV_WRITE, 1); \ ev 164 opal/mca/pmix/ext2x/ext2x_client.c opal_ext2x_event_t *ev = (opal_ext2x_event_t*)cbdata; ev 165 opal/mca/pmix/ext2x/ext2x_client.c OPAL_PMIX_WAKEUP_THREAD(&ev->lock); ev 65 opal/mca/pmix/ext2x/ext2x_server_south.c opal_ext2x_event_t *ev = (opal_ext2x_event_t*)cbdata; ev 67 opal/mca/pmix/ext2x/ext2x_server_south.c OPAL_ACQUIRE_OBJECT(ev); ev 68 opal/mca/pmix/ext2x/ext2x_server_south.c ev->index = errhandler_ref; ev 72 opal/mca/pmix/ext2x/ext2x_server_south.c OPAL_POST_OBJECT(ev); ev 73 opal/mca/pmix/ext2x/ext2x_server_south.c OPAL_PMIX_WAKEUP_THREAD(&ev->lock); ev 179 opal/mca/pmix/ext2x/ext2x_server_south.c opal_ext2x_event_t *ev = (opal_ext2x_event_t*)cbdata; ev 180 opal/mca/pmix/ext2x/ext2x_server_south.c OPAL_PMIX_WAKEUP_THREAD(&ev->lock); ev 84 opal/mca/pmix/ext3x/ext3x.h opal_event_t ev; ev 137 opal/mca/pmix/ext3x/ext3x.h opal_event_t ev; ev 170 opal/mca/pmix/ext3x/ext3x.h opal_event_assign(&((_cd)->ev), opal_pmix_base.evbase, \ ev 173 opal/mca/pmix/ext3x/ext3x.h opal_event_active(&((_cd)->ev), EV_WRITE, 1); \ ev 185 opal/mca/pmix/ext3x/ext3x.h opal_event_assign(&((_cd)->ev), opal_pmix_base.evbase, \ ev 188 opal/mca/pmix/ext3x/ext3x.h opal_event_active(&((_cd)->ev), EV_WRITE, 1); \ ev 201 opal/mca/pmix/ext3x/ext3x.h opal_event_assign(&((_cd)->ev), opal_pmix_base.evbase, \ ev 204 opal/mca/pmix/ext3x/ext3x.h opal_event_active(&((_cd)->ev), EV_WRITE, 1); \ ev 209 opal/mca/pmix/ext3x/ext3x.h opal_event_assign(&((p)->ev), opal_pmix_base.evbase, \ ev 212 opal/mca/pmix/ext3x/ext3x.h opal_event_active(&((p)->ev), EV_WRITE, 1); \ ev 164 opal/mca/pmix/ext3x/ext3x_client.c opal_ext3x_event_t *ev = (opal_ext3x_event_t*)cbdata; ev 165 opal/mca/pmix/ext3x/ext3x_client.c OPAL_PMIX_WAKEUP_THREAD(&ev->lock); ev 66 opal/mca/pmix/ext3x/ext3x_server_south.c opal_ext3x_event_t *ev = (opal_ext3x_event_t*)cbdata; ev 68 opal/mca/pmix/ext3x/ext3x_server_south.c OPAL_ACQUIRE_OBJECT(ev); ev 69 opal/mca/pmix/ext3x/ext3x_server_south.c ev->index = errhandler_ref; ev 73 opal/mca/pmix/ext3x/ext3x_server_south.c OPAL_POST_OBJECT(ev); ev 74 opal/mca/pmix/ext3x/ext3x_server_south.c OPAL_PMIX_WAKEUP_THREAD(&ev->lock); ev 181 opal/mca/pmix/ext3x/ext3x_server_south.c opal_ext3x_event_t *ev = (opal_ext3x_event_t*)cbdata; ev 182 opal/mca/pmix/ext3x/ext3x_server_south.c OPAL_PMIX_WAKEUP_THREAD(&ev->lock); ev 717 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_event_t ev; ev 814 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_event_assign(&tev.ev, pmix_globals.evbase, -1, 0, ev 818 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_event_add(&tev.ev, &tv); ev 831 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_event_del(&tev.ev); ev 574 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_event_evtimer_set(pmix_globals.evbase, &cb->ev, ev 576 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_event_evtimer_add(&cb->ev, &tv); ev 805 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_event_del(&stdinev->ev); ev 826 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_event_del(&stdinev->ev); ev 833 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_event_del(&stdinev->ev); ev 1004 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_event_del(&rev->ev); ev 1035 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_event_del(&wev->ev); ev 69 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h pmix_event_t ev; ev 96 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h pmix_event_t ev; ev 139 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h if (pmix_event_add(&wev->ev, tv)) { \ ev 162 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h &(snk)->wev.ev, wrthndlr, (snk)); \ ev 165 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h &(snk)->wev.ev, (snk)->wev.fd, \ ev 180 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h if (pmix_event_add(&(rev)->ev, tv)) { \ ev 216 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h &rev->ev, (cbfunc), rev); \ ev 219 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h &rev->ev, (fid), \ ev 121 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h pmix_event_t ev; ev 228 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h pmix_event_assign(&ch->ev, pmix_globals.evbase, -1, 0, \ ev 231 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h pmix_event_add(&ch->ev, &pmix_globals.event_window); \ ev 249 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h pmix_event_del(&ch->ev); \ ev 251 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h pmix_event_add(&ch->ev, &pmix_globals.event_window); \ ev 1437 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_event_del(&p->ev); ev 32 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_event_t ev; ev 464 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_event_hdlr_t *evhdlr, *ev; ev 739 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c ev = (pmix_event_hdlr_t*)pmix_list_get_first(cd->list); ev 740 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (PMIX_EVENT_ORDER_FIRST == ev->precedence) { ev 752 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c ev = (pmix_event_hdlr_t*)pmix_list_get_last(cd->list); ev 753 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (PMIX_EVENT_ORDER_LAST == ev->precedence) { ev 767 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c ev = (pmix_event_hdlr_t*)pmix_list_get_first(cd->list); ev 768 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (PMIX_EVENT_ORDER_FIRST == ev->precedence) { ev 769 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c ev = (pmix_event_hdlr_t*)pmix_list_get_next(&ev->super); ev 770 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL != ev) { ev 771 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_list_insert_pos(cd->list, &ev->super, &evhdlr->super); ev 783 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c ev = (pmix_event_hdlr_t*)pmix_list_get_last(cd->list); ev 784 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (PMIX_EVENT_ORDER_LAST == ev->precedence) { ev 785 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_list_insert_pos(cd->list, &ev->super, &evhdlr->super); ev 792 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_LIST_FOREACH(ev, cd->list, pmix_event_hdlr_t) { ev 793 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL == ev->name) { ev 796 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (0 == strcmp(ev->name, name)) { ev 799 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_list_insert_pos(cd->list, &ev->super, &evhdlr->super); ev 802 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c ev = (pmix_event_hdlr_t*)pmix_list_get_next(&ev->super); ev 803 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL != ev) { ev 804 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_list_insert_pos(cd->list, &ev->super, &evhdlr->super); ev 909 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_event_hdlr_t *evhdlr, *ev; ev 937 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c ev = pmix_globals.events.first; ev 939 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c ev = pmix_globals.events.last; ev 944 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL == ev->codes) { ev 955 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c for (n=0; n < ev->ncodes; n++) { ev 958 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (active->code == ev->codes[n]) { ev 978 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (ev == pmix_globals.events.first) { ev 983 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_RELEASE(ev); ev 315 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c pmix_event_del(&p->ev); ev 586 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c int pmix_event_assign(struct event *ev, pmix_event_base_t *evbase, ev 590 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c event_set(ev, fd, arg, cbfn, cbd); ev 591 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c event_base_set(evbase, ev); ev 593 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c event_assign(ev, evbase, fd, arg, cbfn, cbd); ev 601 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c pmix_event_t *ev = NULL; ev 604 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c ev = (pmix_event_t*)calloc(1, sizeof(pmix_event_t)); ev 605 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c ev->ev_base = b; ev 607 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c ev = event_new(b, fd, fg, (event_callback_fn) cbfn, cbd); ev 610 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c return ev; ev 277 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_event_t ev; ev 301 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_event_t ev; ev 334 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_event_t ev; ev 346 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_event_t ev; ev 380 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_event_t ev; ev 414 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_event_assign(&((r)->ev), pmix_globals.evbase, \ ev 417 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_event_active(&((r)->ev), EV_WRITE, 1); \ ev 423 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_event_t ev; ev 259 opal/mca/pmix/pmix4x/pmix/src/include/types.h PMIX_EXPORT int pmix_event_assign(struct event *ev, pmix_event_base_t *evbase, ev 265 opal/mca/pmix/pmix4x/pmix/src/include/types.h PMIX_EXPORT int pmix_event_add(struct event *ev, struct timeval *tv); ev 266 opal/mca/pmix/pmix4x/pmix/src/include/types.h PMIX_EXPORT int pmix_event_del(struct event *ev); ev 267 opal/mca/pmix/pmix4x/pmix/src/include/types.h PMIX_EXPORT void pmix_event_active (struct event *ev, int res, short ncalls); ev 270 opal/mca/pmix/pmix4x/pmix/src/include/types.h #define pmix_event_add(ev, tv) event_add((ev), (tv)) ev 271 opal/mca/pmix/pmix4x/pmix/src/include/types.h #define pmix_event_del(ev) event_del((ev)) ev 70 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_event_t ev; ev 118 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_event_del(&ft->ev); ev 134 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_event_t ev; ev 168 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_event_evtimer_set(pmix_psensor_base.evbase, &ft->ev, ev 170 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_event_evtimer_add(&ft->ev, &ft->tv); ev 267 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_event_assign(&cd->ev, pmix_psensor_base.evbase, -1, ev 270 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_event_active(&cd->ev, EV_WRITE, 1); ev 304 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_event_evtimer_add(&ft->ev, &ft->tv); ev 360 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_event_evtimer_add(&ft->ev, &ft->tv); ev 56 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_t ev; ev 94 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_del(&ft->ev); ev 107 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_t ev; ev 131 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_t ev; ev 161 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_evtimer_set(pmix_psensor_base.evbase, &ft->ev, ev 163 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_evtimer_add(&ft->ev, &ft->tv); ev 261 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_assign(&cd->ev, pmix_psensor_base.evbase, -1, ev 264 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_active(&cd->ev, EV_WRITE, 1); ev 322 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_evtimer_add(&ft->ev, &ft->tv); ev 357 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_assign(&b->ev, pmix_psensor_base.evbase, -1, ev 360 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_event_active(&b->ev, EV_WRITE, 1); ev 253 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_event_assign(&pending_connection->ev, pmix_globals.evbase, -1, ev 288 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_event_active(&pending_connection->ev, EV_WRITE, 1); ev 174 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_event_assign(&(req->ev), pmix_globals.evbase, -1, ev 176 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_event_active(&(req->ev), EV_WRITE, 1); ev 208 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_event_assign(&(req->ev), pmix_globals.evbase, -1, ev 210 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_event_active(&(req->ev), EV_WRITE, 1); ev 132 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_event_t ev; ev 144 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_event_t ev; ev 158 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_event_t ev; ev 169 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_event_t ev; ev 181 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_event_t ev; ev 197 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_event_t ev; ev 243 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_event_assign(&((ms)->ev), pmix_globals.evbase, -1, \ ev 246 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h pmix_event_active(&((ms)->ev), EV_WRITE, 1); \ ev 738 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_event_t ev; ev 762 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_event_evtimer_set(pmix_globals.evbase, &ev, ev 764 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_event_evtimer_add(&ev, &tv); ev 333 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_event_assign(&pending_connection->ev, pmix_globals.evbase, -1, ev 335 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_event_active(&pending_connection->ev, EV_WRITE, 1); ev 104 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c struct event *ev; ev 126 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c (void)event_add(cd->ev, cd->tv); ev 129 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c (void)event_del(cd->ev); ev 132 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c (void)event_active(cd->ev, cd->res, cd->ncalls); ev 141 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c int pmix_event_add(struct event *ev, struct timeval *tv) { ev 143 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk = pmix_progress_tracker_get_by_base(ev->ev_base); ev 147 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c cd->ev = ev; ev 155 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c res = event_add(ev, tv); ev 160 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c int pmix_event_del(struct event *ev) { ev 162 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk = pmix_progress_tracker_get_by_base(ev->ev_base); ev 166 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c cd->ev = ev; ev 173 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c res = event_del(ev); ev 178 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c void pmix_event_active (struct event *ev, int res, short ncalls) { ev 179 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk = pmix_progress_tracker_get_by_base(ev->ev_base); ev 183 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c cd->ev = ev; ev 191 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c event_active(ev, res, ncalls); ev 2308 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_event_del(&tracker->ev); ev 2525 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_event_del(&tracker->ev); ev 2697 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_event_del(&tracker->ev); ev 62 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_event_t ev; ev 252 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_event_evtimer_set(pmix_globals.evbase, &req->ev, ev 254 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_event_evtimer_add(&req->ev, &tv); ev 280 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_event_evtimer_set(pmix_globals.evbase, &req->ev, ev 282 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_event_evtimer_add(&req->ev, &tv); ev 388 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_event_evtimer_set(pmix_globals.evbase, &req->ev, ev 390 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_event_evtimer_add(&req->ev, &tv); ev 435 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_event_evtimer_set(pmix_globals.evbase, &req->ev, ev 437 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_event_evtimer_add(&req->ev, &tv); ev 975 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_set(pmix_globals.evbase, &cd->ev, ev 977 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_add(&cd->ev, &tv); ev 1823 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_set(pmix_globals.evbase, &cd->ev, ev 1825 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_add(&cd->ev, &tv); ev 3735 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_del(&trk->ev); ev 4113 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_set(pmix_globals.evbase, &trk->ev, ev 4115 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_add(&trk->ev, &tv); ev 4153 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_del(&trk->ev); ev 4183 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_del(&trk->ev); ev 4313 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_set(pmix_globals.evbase, &trk->ev, ev 4315 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_add(&trk->ev, &tv); ev 4334 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_del(&trk->ev); ev 4404 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c memset(&cd->ev, 0, sizeof(pmix_event_t)); ev 4412 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_del(&cd->ev); ev 4533 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c memset(&p->ev, 0, sizeof(pmix_event_t)); ev 4540 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_del(&p->ev); ev 37 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_event_t ev; ev 44 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_event_t ev; ev 89 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_event_t ev; ev 121 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_event_t ev; ev 228 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_event_assign(&((c)->ev), pmix_globals.evbase, -1, \ ev 230 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_event_active(&((c)->ev), EV_WRITE, 1); \ ev 665 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev.ev, ev 670 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev.ev, fd, ev 690 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev.ev, ev 695 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev.ev, fd, ev 1088 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_t ev; ev 1117 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_del(&tev->ev); // stop the timer ev 1170 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_assign(&tev.ev, pmix_globals.evbase, -1, 0, ev 1174 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_add(&tev.ev, &tv); ev 1179 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_del(&tev.ev); ev 1189 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_del(&tev.ev); ev 1288 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_assign(&tev.ev, pmix_globals.evbase, -1, 0, ev 1292 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_add(&tev.ev, &tv); ev 1297 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_del(&tev.ev); ev 1306 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_del(&tev.ev); ev 131 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *ev = pmix_timing_event_alloc(t); ev 132 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev == NULL ){ ev 136 opal/mca/pmix/pmix4x/pmix/src/util/timings.c PMIX_CONSTRUCT(ev, pmix_timing_event_t); ev 137 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->ts = t->get_ts(); ev 140 opal/mca/pmix/pmix4x/pmix/src/util/timings.c vsnprintf(ev->descr, PMIX_TIMING_DESCR_MAX - 1, fmt, args); ev 141 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->descr[PMIX_TIMING_DESCR_MAX-1] = '\0'; ev 143 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_prep_t p = { t, ev, 0 }; ev 152 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *ev = pmix_timing_event_alloc(t); ev 153 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev == NULL ){ ev 157 opal/mca/pmix/pmix4x/pmix/src/util/timings.c PMIX_CONSTRUCT(ev, pmix_timing_event_t); ev 158 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->ts = t->get_ts(); ev 159 opal/mca/pmix/pmix4x/pmix/src/util/timings.c p.ev = ev; ev 168 opal/mca/pmix/pmix4x/pmix/src/util/timings.c p.ev->func = func; ev 169 opal/mca/pmix/pmix4x/pmix/src/util/timings.c p.ev->file = file; ev 170 opal/mca/pmix/pmix4x/pmix/src/util/timings.c p.ev->line = line; ev 171 opal/mca/pmix/pmix4x/pmix/src/util/timings.c p.ev->type = PMIX_TIMING_TRACE; ev 172 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_list_append(p.t->events, (pmix_list_item_t*)p.ev); ev 181 opal/mca/pmix/pmix4x/pmix/src/util/timings.c p.ev->func = func; ev 182 opal/mca/pmix/pmix4x/pmix/src/util/timings.c p.ev->file = file; ev 183 opal/mca/pmix/pmix4x/pmix/src/util/timings.c p.ev->line = line; ev 184 opal/mca/pmix/pmix4x/pmix/src/util/timings.c p.ev->type = PMIX_TIMING_INTDESCR; ev 185 opal/mca/pmix/pmix4x/pmix/src/util/timings.c p.ev->id = p.t->next_id_cntr; ev 187 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_list_append(p.t->events, (pmix_list_item_t*)p.ev); ev 188 opal/mca/pmix/pmix4x/pmix/src/util/timings.c return p.ev->id; ev 197 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *ev = pmix_timing_event_alloc(t); ev 198 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev == NULL ){ ev 201 opal/mca/pmix/pmix4x/pmix/src/util/timings.c PMIX_CONSTRUCT(ev, pmix_timing_event_t); ev 204 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->ts = t->get_ts(); ev 205 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->func = func; ev 206 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->file = file; ev 207 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->line = line; ev 208 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->type = PMIX_TIMING_INTBEGIN; ev 209 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->id = id; ev 210 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_list_append(t->events, (pmix_list_item_t*)ev); ev 217 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *ev = pmix_timing_event_alloc(t); ev 218 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev == NULL ){ ev 221 opal/mca/pmix/pmix4x/pmix/src/util/timings.c PMIX_CONSTRUCT(ev, pmix_timing_event_t); ev 224 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->id = t->current_id; ev 230 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->id = id; ev 232 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->ts = t->get_ts(); ev 233 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->func = func; ev 234 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->file = file; ev 235 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->line = line; ev 236 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->type = PMIX_TIMING_INTEND; ev 237 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_list_append(t->events, (pmix_list_item_t*)ev); ev 243 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *ev = p.ev; ev 245 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( !p.errcode && ( NULL != ev ) ){ ev 247 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->id = p.t->current_id; ev 249 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->func = func; ev 250 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->file = file; ev 251 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->line = line; ev 252 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->type = PMIX_TIMING_INTEND; ev 253 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_list_append(p.t->events, (pmix_list_item_t*)ev); ev 260 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *ev, *next; ev 270 opal/mca/pmix/pmix4x/pmix/src/util/timings.c PMIX_LIST_FOREACH_SAFE(ev, next, t->events, pmix_timing_event_t){ ev 276 opal/mca/pmix/pmix4x/pmix/src/util/timings.c switch(ev->type){ ev 278 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev->id >= t->next_id_cntr){ ev 279 opal/mca/pmix/pmix4x/pmix/src/util/timings.c char *file = pmix_basename(ev->file); ev 281 opal/mca/pmix/pmix4x/pmix/src/util/timings.c file, ev->line, ev->func); ev 283 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_list_remove_item(t->events, (pmix_list_item_t *)ev); ev 286 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( NULL != descr[ev->id].descr_ev ){ ev 287 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *prev = descr[ev->id].descr_ev; ev 288 opal/mca/pmix/pmix4x/pmix/src/util/timings.c char *file = pmix_basename(ev->file); ev 291 opal/mca/pmix/pmix4x/pmix/src/util/timings.c "previous: %s:%d:%s, ignore and remove", file, ev->line, ev->func, ev 295 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_list_remove_item(t->events, (pmix_list_item_t *)ev); ev 299 opal/mca/pmix/pmix4x/pmix/src/util/timings.c descr[ev->id].descr_ev = ev; ev 300 opal/mca/pmix/pmix4x/pmix/src/util/timings.c descr[ev->id].begin_ev = NULL; ev 301 opal/mca/pmix/pmix4x/pmix/src/util/timings.c descr[ev->id].interval = 0; ev 302 opal/mca/pmix/pmix4x/pmix/src/util/timings.c descr[ev->id].overhead = 0; ev 307 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev->id >= t->next_id_cntr || (NULL == descr[ev->id].descr_ev ) ){ ev 308 opal/mca/pmix/pmix4x/pmix/src/util/timings.c char *file = pmix_basename(ev->file); ev 310 opal/mca/pmix/pmix4x/pmix/src/util/timings.c file, ev->line, ev->func); ev 312 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_list_remove_item(t->events, (pmix_list_item_t *)ev); ev 328 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *ev; ev 355 opal/mca/pmix/pmix4x/pmix/src/util/timings.c PMIX_LIST_FOREACH(ev, t->events, pmix_timing_event_t){ ev 357 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev->fib && pmix_timing_overhead ){ ev 358 opal/mca/pmix/pmix4x/pmix/src/util/timings.c overhead += ev->ts_ovh; ev 360 opal/mca/pmix/pmix4x/pmix/src/util/timings.c file = pmix_basename(ev->file); ev 361 opal/mca/pmix/pmix4x/pmix/src/util/timings.c switch( ev->type ){ ev 367 opal/mca/pmix/pmix4x/pmix/src/util/timings.c nodename, getpid(), jobid, ev->descr, file, ev->line, ev 368 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->ts + hnp_offs + overhead); ev 372 opal/mca/pmix/pmix4x/pmix/src/util/timings.c nodename, getpid(), jobid, descr[ev->id].descr_ev->descr, ev 373 opal/mca/pmix/pmix4x/pmix/src/util/timings.c file, ev->line, ev->ts + hnp_offs + overhead); ev 377 opal/mca/pmix/pmix4x/pmix/src/util/timings.c nodename, getpid(), jobid, descr[ev->id].descr_ev->descr, ev 378 opal/mca/pmix/pmix4x/pmix/src/util/timings.c file, ev->line, ev->ts + hnp_offs + overhead); ev 442 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *ev; ev 461 opal/mca/pmix/pmix4x/pmix/src/util/timings.c PMIX_LIST_FOREACH(ev, t->events, pmix_timing_event_t){ ev 463 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev->fib ){ ev 471 opal/mca/pmix/pmix4x/pmix/src/util/timings.c descr[i].overhead += ev->ts_ovh; ev 479 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev->type == PMIX_TIMING_INTDESCR || ev 480 opal/mca/pmix/pmix4x/pmix/src/util/timings.c ev->type == PMIX_TIMING_TRACE){ ev 485 opal/mca/pmix/pmix4x/pmix/src/util/timings.c id = ev->id; ev 487 opal/mca/pmix/pmix4x/pmix/src/util/timings.c char *file = pmix_basename(ev->file); ev 489 opal/mca/pmix/pmix4x/pmix/src/util/timings.c id, file, ev->line, ev->func, t->next_id_cntr - 1 ); ev 498 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev->type == PMIX_TIMING_INTBEGIN ){ ev 502 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *prev = descr[ev->id].begin_ev; ev 503 opal/mca/pmix/pmix4x/pmix/src/util/timings.c char *file = pmix_basename(ev->file); ev 506 opal/mca/pmix/pmix4x/pmix/src/util/timings.c "previous: %s:%d:%s", file, ev->line, ev->func, ev 512 opal/mca/pmix/pmix4x/pmix/src/util/timings.c descr[id].begin_ev = ev; ev 518 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev->type == PMIX_TIMING_INTEND ){ ev 521 opal/mca/pmix/pmix4x/pmix/src/util/timings.c char *file = pmix_basename(ev->file); ev 523 opal/mca/pmix/pmix4x/pmix/src/util/timings.c file, ev->line, ev->func ); ev 526 opal/mca/pmix/pmix4x/pmix/src/util/timings.c descr[id].interval += ev->ts - descr[id].begin_ev->ts; ev 528 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev->fib ){ ev 529 opal/mca/pmix/pmix4x/pmix/src/util/timings.c descr[id].overhead += ev->ts_ovh; ev 536 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_output(0, "pmix_timing_deltas: bad event type %d", ev->type); ev 625 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *ev = (pmix_timing_event_t *)pmix_list_remove_first(t->events); ev 626 opal/mca/pmix/pmix4x/pmix/src/util/timings.c if( ev->fib ){ ev 627 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_list_append(tmp,(pmix_list_item_t*)ev); ev 633 opal/mca/pmix/pmix4x/pmix/src/util/timings.c pmix_timing_event_t *ev = (pmix_timing_event_t *)pmix_list_remove_first(tmp); ev 634 opal/mca/pmix/pmix4x/pmix/src/util/timings.c free(ev); ev 64 opal/mca/pmix/pmix4x/pmix/src/util/timings.h pmix_timing_event_t *ev; ev 49 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c cli_info[n].ev = NULL; ev 71 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c cli->ev = pmix_event_new(ebase, sd, ev 73 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c pmix_event_add(cli->ev,NULL); ev 107 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c if( NULL == cli->ev ){ ev 112 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c pmix_event_del(cli->ev); ev 113 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c pmix_event_free(cli->ev); ev 114 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c cli->ev = NULL; ev 45 opal/mca/pmix/pmix4x/pmix/test/cli_stages.h pmix_event_t *ev; ev 156 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c pmix_event_t ev; ev 915 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c pmix_event_t ev; ev 1105 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c pmix_event_t ev; ev 1170 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c pmix_event_t ev; ev 141 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c pmix_event_t ev; ev 84 opal/mca/pmix/pmix4x/pmix4x.h opal_event_t ev; ev 137 opal/mca/pmix/pmix4x/pmix4x.h opal_event_t ev; ev 170 opal/mca/pmix/pmix4x/pmix4x.h opal_event_assign(&((_cd)->ev), opal_pmix_base.evbase, \ ev 173 opal/mca/pmix/pmix4x/pmix4x.h opal_event_active(&((_cd)->ev), EV_WRITE, 1); \ ev 185 opal/mca/pmix/pmix4x/pmix4x.h opal_event_assign(&((_cd)->ev), opal_pmix_base.evbase, \ ev 188 opal/mca/pmix/pmix4x/pmix4x.h opal_event_active(&((_cd)->ev), EV_WRITE, 1); \ ev 201 opal/mca/pmix/pmix4x/pmix4x.h opal_event_assign(&((_cd)->ev), opal_pmix_base.evbase, \ ev 204 opal/mca/pmix/pmix4x/pmix4x.h opal_event_active(&((_cd)->ev), EV_WRITE, 1); \ ev 209 opal/mca/pmix/pmix4x/pmix4x.h opal_event_assign(&((p)->ev), opal_pmix_base.evbase, \ ev 212 opal/mca/pmix/pmix4x/pmix4x.h opal_event_active(&((p)->ev), EV_WRITE, 1); \ ev 163 opal/mca/pmix/pmix4x/pmix4x_client.c opal_pmix4x_event_t *ev = (opal_pmix4x_event_t*)cbdata; ev 164 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_PMIX_WAKEUP_THREAD(&ev->lock); ev 65 opal/mca/pmix/pmix4x/pmix4x_server_south.c opal_pmix4x_event_t *ev = (opal_pmix4x_event_t*)cbdata; ev 67 opal/mca/pmix/pmix4x/pmix4x_server_south.c OPAL_ACQUIRE_OBJECT(ev); ev 68 opal/mca/pmix/pmix4x/pmix4x_server_south.c ev->index = errhandler_ref; ev 72 opal/mca/pmix/pmix4x/pmix4x_server_south.c OPAL_POST_OBJECT(ev); ev 73 opal/mca/pmix/pmix4x/pmix4x_server_south.c OPAL_PMIX_WAKEUP_THREAD(&ev->lock); ev 180 opal/mca/pmix/pmix4x/pmix4x_server_south.c opal_pmix4x_event_t *ev = (opal_pmix4x_event_t*)cbdata; ev 181 opal/mca/pmix/pmix4x/pmix4x_server_south.c OPAL_PMIX_WAKEUP_THREAD(&ev->lock); ev 90 opal/mca/pmix/s1/pmix_s1.c opal_event_t ev; ev 627 opal/mca/pmix/s1/pmix_s1.c event_assign(&op->ev, opal_pmix_base.evbase, -1, ev 629 opal/mca/pmix/s1/pmix_s1.c event_active(&op->ev, EV_WRITE, 1); ev 93 opal/mca/pmix/s2/pmix_s2.c opal_event_t ev; ev 646 opal/mca/pmix/s2/pmix_s2.c event_assign(&op->ev, opal_pmix_base.evbase, -1, ev 648 opal/mca/pmix/s2/pmix_s2.c event_active(&op->ev, EV_WRITE, 1); ev 182 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c opal_event_evtimer_set(orte_event_base, timer->ev, wakeup, NULL); ev 183 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c opal_event_set_priority(timer->ev, ORTE_ERROR_PRI); ev 185 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c opal_event_evtimer_add(timer->ev, &timer->tv); ev 226 orte/mca/errmgr/default_orted/errmgr_default_orted.c opal_event_evtimer_set(orte_event_base, timer->ev, wakeup, NULL); ev 227 orte/mca/errmgr/default_orted/errmgr_default_orted.c opal_event_set_priority(timer->ev, ORTE_ERROR_PRI); ev 229 orte/mca/errmgr/default_orted/errmgr_default_orted.c opal_event_evtimer_add(timer->ev, &timer->tv); ev 414 orte/mca/errmgr/default_orted/errmgr_default_orted.c opal_event_set(t2->evb, &t2->ev, -1, ev 416 orte/mca/errmgr/default_orted/errmgr_default_orted.c opal_event_set_priority(&t2->ev, ORTE_MSG_PRI); ev 417 orte/mca/errmgr/default_orted/errmgr_default_orted.c opal_event_active(&t2->ev, OPAL_EV_WRITE, 1); ev 89 orte/mca/ess/base/ess_base_std_orted.c static void setup_sighandler(int signal, opal_event_t *ev, ev 92 orte/mca/ess/base/ess_base_std_orted.c opal_event_signal_set(orte_event_base, ev, signal, cbfunc, ev); ev 93 orte/mca/ess/base/ess_base_std_orted.c opal_event_set_priority(ev, ORTE_ERROR_PRI); ev 94 orte/mca/ess/base/ess_base_std_orted.c opal_event_signal_add(ev, NULL); ev 122 orte/mca/ess/hnp/ess_hnp_module.c static void setup_sighandler(int signal, opal_event_t *ev, ev 125 orte/mca/ess/hnp/ess_hnp_module.c opal_event_signal_set(orte_event_base, ev, signal, cbfunc, ev); ev 126 orte/mca/ess/hnp/ess_hnp_module.c opal_event_set_priority(ev, ORTE_ERROR_PRI); ev 127 orte/mca/ess/hnp/ess_hnp_module.c opal_event_signal_add(ev, NULL); ev 45 orte/mca/filem/raw/filem_raw.h opal_event_t ev; ev 59 orte/mca/filem/raw/filem_raw.h opal_event_t ev; ev 540 orte/mca/filem/raw/filem_raw_module.c opal_event_set(orte_event_base, &xfer->ev, fd, OPAL_EV_READ, send_chunk, xfer); ev 541 orte/mca/filem/raw/filem_raw_module.c opal_event_set_priority(&xfer->ev, ORTE_MSG_PRI); ev 544 orte/mca/filem/raw/filem_raw_module.c opal_event_add(&xfer->ev, 0); ev 775 orte/mca/filem/raw/filem_raw_module.c opal_event_add(&rev->ev, 0); ev 853 orte/mca/filem/raw/filem_raw_module.c opal_event_add(&rev->ev, 0); ev 1076 orte/mca/filem/raw/filem_raw_module.c opal_event_set(orte_event_base, &incoming->ev, incoming->fd, ev 1078 orte/mca/filem/raw/filem_raw_module.c opal_event_set_priority(&incoming->ev, ORTE_MSG_PRI); ev 1098 orte/mca/filem/raw/filem_raw_module.c opal_event_add(&incoming->ev, 0); ev 1208 orte/mca/filem/raw/filem_raw_module.c opal_event_add(&sink->ev, 0); ev 1233 orte/mca/filem/raw/filem_raw_module.c opal_event_add(&sink->ev, 0); ev 1254 orte/mca/filem/raw/filem_raw_module.c opal_event_del(&ptr->ev); ev 1303 orte/mca/filem/raw/filem_raw_module.c opal_event_del(&ptr->ev); ev 62 orte/mca/grpcomm/base/grpcomm_base_stubs.c opal_event_t ev; ev 220 orte/mca/grpcomm/base/grpcomm_base_stubs.c opal_event_set(orte_event_base, &cd->ev, -1, OPAL_EV_WRITE, allgather_stub, cd); ev 221 orte/mca/grpcomm/base/grpcomm_base_stubs.c opal_event_set_priority(&cd->ev, ORTE_MSG_PRI); ev 223 orte/mca/grpcomm/base/grpcomm_base_stubs.c opal_event_active(&cd->ev, OPAL_EV_WRITE, 1); ev 93 orte/mca/iof/base/base.h opal_event_t *ev; ev 116 orte/mca/iof/base/base.h opal_event_t *ev; ev 177 orte/mca/iof/base/base.h if (opal_event_add(wev->ev, tv)) { \ ev 202 orte/mca/iof/base/base.h ep->wev->ev, wrthndlr, ep); \ ev 205 orte/mca/iof/base/base.h ep->wev->ev, ep->wev->fd, \ ev 209 orte/mca/iof/base/base.h opal_event_set_priority(ep->wev->ev, ORTE_MSG_PRI); \ ev 222 orte/mca/iof/base/base.h if (opal_event_add(rev->ev, tv)) { \ ev 259 orte/mca/iof/base/base.h rev->ev, (cbfunc), rev); \ ev 262 orte/mca/iof/base/base.h rev->ev, (fid), \ ev 266 orte/mca/iof/base/base.h opal_event_set_priority(rev->ev, ORTE_MSG_PRI); \ ev 244 orte/mca/iof/base/iof_base_frame.c rev->ev = opal_event_alloc(); ev 253 orte/mca/iof/base/iof_base_frame.c opal_event_free(rev->ev); ev 280 orte/mca/iof/base/iof_base_frame.c wev->ev = opal_event_alloc(); ev 286 orte/mca/iof/base/iof_base_frame.c opal_event_free(wev->ev); ev 93 orte/mca/iof/hnp/iof_hnp_read.c opal_event_del(mca_iof_hnp_component.stdinev->ev); ev 93 orte/mca/iof/hnp/iof_hnp_receive.c opal_event_del(mca_iof_hnp_component.stdinev->ev); ev 882 orte/mca/odls/base/odls_base_default_fns.c opal_event_active(ll->ev, OPAL_EV_WRITE, 1); ev 1449 orte/mca/odls/base/odls_base_default_fns.c opal_event_set(evb, &cd->ev, -1, ev 1451 orte/mca/odls/base/odls_base_default_fns.c opal_event_set_priority(&cd->ev, ORTE_MSG_PRI); ev 1452 orte/mca/odls/base/odls_base_default_fns.c opal_event_active(&cd->ev, OPAL_EV_WRITE, 1); ev 2132 orte/mca/odls/base/odls_base_default_fns.c opal_event_set(evb, &cd->ev, -1, ev 2134 orte/mca/odls/base/odls_base_default_fns.c opal_event_set_priority(&cd->ev, ORTE_MSG_PRI); ev 2135 orte/mca/odls/base/odls_base_default_fns.c opal_event_active(&cd->ev, OPAL_EV_WRITE, 1); ev 317 orte/mca/odls/base/odls_base_frame.c ptr->ev = opal_event_alloc(); ev 324 orte/mca/odls/base/odls_base_frame.c opal_event_free(ptr->ev); ev 97 orte/mca/odls/base/odls_private.h opal_event_t ev; ev 114 orte/mca/odls/base/odls_private.h opal_event_t *ev; ev 127 orte/mca/odls/base/odls_private.h opal_event_set(orte_event_base, ll->ev, -1, OPAL_EV_WRITE, \ ev 129 orte/mca/odls/base/odls_private.h opal_event_set_priority(ll->ev, ORTE_SYS_PRI); \ ev 130 orte/mca/odls/base/odls_private.h opal_event_active(ll->ev, OPAL_EV_WRITE, 1); \ ev 95 orte/mca/oob/base/base.h opal_event_t ev; ev 43 orte/mca/oob/tcp/oob_tcp_connection.h opal_event_t ev; ev 70 orte/mca/oob/tcp/oob_tcp_connection.h opal_event_set(orte_oob_base.ev_base, &cop->ev, s, \ ev 72 orte/mca/oob/tcp/oob_tcp_connection.h opal_event_set_priority(&cop->ev, ORTE_MSG_PRI); \ ev 74 orte/mca/oob/tcp/oob_tcp_connection.h opal_event_add(&cop->ev, 0); \ ev 88 orte/mca/oob/tcp/oob_tcp_connection.h &cop->ev, \ ev 91 orte/mca/oob/tcp/oob_tcp_connection.h opal_event_evtimer_add(&cop->ev, (tv)); \ ev 747 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set(orte_oob_base.ev_base, &pending_connection->ev, -1, ev 749 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set_priority(&pending_connection->ev, ORTE_MSG_PRI); ev 824 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_active(&pending_connection->ev, OPAL_EV_WRITE, 1); ev 53 orte/mca/oob/tcp/oob_tcp_listener.h opal_event_t ev; ev 71 orte/mca/oob/tcp/oob_tcp_peer.h opal_event_t ev; ev 42 orte/mca/oob/tcp/oob_tcp_sendrecv.h opal_event_t ev; ev 216 orte/mca/oob/tcp/oob_tcp_sendrecv.h opal_event_t ev; ev 237 orte/mca/oob/tcp/oob_tcp_sendrecv.h opal_event_t ev; ev 709 orte/mca/plm/base/plm_base_launch_support.c timer->ev, timer_cb, jdata); ev 710 orte/mca/plm/base/plm_base_launch_support.c opal_event_set_priority(timer->ev, ORTE_ERROR_PRI); ev 715 orte/mca/plm/base/plm_base_launch_support.c opal_event_evtimer_add(timer->ev, &timer->tv); ev 740 orte/mca/plm/base/plm_base_launch_support.c opal_event_evtimer_del(timer->ev); ev 114 orte/mca/rml/base/base.h opal_event_t ev; ev 122 orte/mca/rml/base/base.h opal_event_t ev; ev 147 orte/mca/rml/base/base.h opal_event_t ev; ev 156 orte/mca/rml/base/base.h opal_event_t ev; ev 184 orte/mca/rml/base/base.h opal_event_set(orte_event_base, &msg->ev, -1, \ ev 187 orte/mca/rml/base/base.h opal_event_set_priority(&msg->ev, ORTE_MSG_PRI); \ ev 188 orte/mca/rml/base/base.h opal_event_active(&msg->ev, OPAL_EV_WRITE, 1); \ ev 194 orte/mca/rml/base/base.h opal_event_set(orte_event_base, &(m)->ev, -1, \ ev 197 orte/mca/rml/base/base.h opal_event_set_priority(&(m)->ev, ORTE_MSG_PRI); \ ev 198 orte/mca/rml/base/base.h opal_event_active(&(m)->ev, OPAL_EV_WRITE, 1); \ ev 100 orte/mca/state/base/state_base_frame.c memset(&caddy->ev, 0, sizeof(opal_event_t)); ev 105 orte/mca/state/base/state_base_frame.c opal_event_del(&caddy->ev); ev 68 orte/mca/state/state_types.h opal_event_t ev; ev 1051 orte/orted/orted_main.c opal_event_t *ev = (opal_event_t*)arg; ev 1054 orte/orted/orted_main.c opal_event_free(ev); ev 1008 orte/orted/orted_submit.c opal_event_evtimer_set(orte_event_base, orte_mpiexec_timeout->ev, ev 1010 orte/orted/orted_submit.c opal_event_set_priority(orte_mpiexec_timeout->ev, ORTE_ERROR_PRI); ev 1011 orte/orted/orted_submit.c opal_event_evtimer_add(orte_mpiexec_timeout->ev, &orte_mpiexec_timeout->tv); ev 1026 orte/orted/orted_submit.c opal_event_evtimer_set(orte_event_base, orte_memprofile_timeout->ev, ev 1028 orte/orted/orted_submit.c opal_event_set_priority(orte_memprofile_timeout->ev, ORTE_ERROR_PRI); ev 1029 orte/orted/orted_submit.c opal_event_evtimer_add(orte_memprofile_timeout->ev, &orte_memprofile_timeout->tv); ev 2948 orte/orted/orted_submit.c opal_event_evtimer_add(tm->ev, &tm->tv); ev 2992 orte/orted/orted_submit.c opal_event_evtimer_add(tm->ev, &tm->tv); ev 3256 orte/orted/orted_submit.c stack_trace_timer.ev, stack_trace_timeout, NULL); ev 3257 orte/orted/orted_submit.c opal_event_set_priority(stack_trace_timer.ev, ORTE_ERROR_PRI); ev 3259 orte/orted/orted_submit.c opal_event_evtimer_add(stack_trace_timer.ev, &stack_trace_timer.tv); ev 3325 orte/orted/orted_submit.c opal_event_evtimer_set(orte_event_base, orte_memprofile_timeout->ev, ev 3327 orte/orted/orted_submit.c opal_event_set_priority(orte_memprofile_timeout->ev, ORTE_ERROR_PRI); ev 3328 orte/orted/orted_submit.c opal_event_evtimer_add(orte_memprofile_timeout->ev, &orte_memprofile_timeout->tv); ev 3332 orte/orted/orted_submit.c profile_timer.ev, profile_timeout, NULL); ev 3333 orte/orted/orted_submit.c opal_event_set_priority(profile_timer.ev, ORTE_ERROR_PRI); ev 3335 orte/orted/orted_submit.c opal_event_evtimer_add(profile_timer.ev, &profile_timer.tv); ev 3391 orte/orted/orted_submit.c profile_timer.ev, profile_timeout, NULL); ev 3392 orte/orted/orted_submit.c opal_event_set_priority(profile_timer.ev, ORTE_ERROR_PRI); ev 3394 orte/orted/orted_submit.c opal_event_evtimer_add(profile_timer.ev, &profile_timer.tv); ev 472 orte/orted/pmix/pmix_server.c opal_event_set(orte_event_base, &(req->ev), ev 474 orte/orted/pmix/pmix_server.c opal_event_set_priority(&(req->ev), ORTE_MSG_PRI); ev 476 orte/orted/pmix/pmix_server.c opal_event_active(&(req->ev), OPAL_EV_WRITE, 1); ev 840 orte/orted/pmix/pmix_server_gen.c opal_event_set(orte_event_base, &(cd->ev), -1, ev 842 orte/orted/pmix/pmix_server_gen.c opal_event_set_priority(&(cd->ev), ORTE_MSG_PRI); ev 844 orte/orted/pmix/pmix_server_gen.c opal_event_active(&(cd->ev), OPAL_EV_WRITE, 1); ev 1038 orte/orted/pmix/pmix_server_gen.c opal_event_set(orte_event_base, &(cd->ev), -1, ev 1040 orte/orted/pmix/pmix_server_gen.c opal_event_set_priority(&(cd->ev), ORTE_MSG_PRI); ev 1042 orte/orted/pmix/pmix_server_gen.c opal_event_active(&(cd->ev), OPAL_EV_WRITE, 1); ev 68 orte/orted/pmix/pmix_server_internal.h opal_event_t ev; ev 91 orte/orted/pmix/pmix_server_internal.h opal_event_t ev; ev 122 orte/orted/pmix/pmix_server_internal.h opal_event_set(orte_event_base, &(_req->ev), \ ev 124 orte/orted/pmix/pmix_server_internal.h opal_event_set_priority(&(_req->ev), ORTE_MSG_PRI); \ ev 126 orte/orted/pmix/pmix_server_internal.h opal_event_active(&(_req->ev), OPAL_EV_WRITE, 1); \ ev 137 orte/orted/pmix/pmix_server_internal.h opal_event_set(orte_event_base, &(_req->ev), \ ev 139 orte/orted/pmix/pmix_server_internal.h opal_event_set_priority(&(_req->ev), ORTE_MSG_PRI); \ ev 141 orte/orted/pmix/pmix_server_internal.h opal_event_active(&(_req->ev), OPAL_EV_WRITE, 1); \ ev 152 orte/orted/pmix/pmix_server_internal.h opal_event_set(orte_event_base, &(_cd->ev), -1, \ ev 154 orte/orted/pmix/pmix_server_internal.h opal_event_set_priority(&(_cd->ev), ORTE_MSG_PRI); \ ev 156 orte/orted/pmix/pmix_server_internal.h opal_event_active(&(_cd->ev), OPAL_EV_WRITE, 1); \ ev 171 orte/orted/pmix/pmix_server_internal.h opal_event_set(orte_event_base, &(_cd->ev), -1, \ ev 173 orte/orted/pmix/pmix_server_internal.h opal_event_set_priority(&(_cd->ev), ORTE_MSG_PRI); \ ev 175 orte/orted/pmix/pmix_server_internal.h opal_event_active(&(_cd->ev), OPAL_EV_WRITE, 1); \ ev 318 orte/orted/pmix/pmix_server_pub.c opal_event_set(orte_event_base, &(req->ev), ev 320 orte/orted/pmix/pmix_server_pub.c opal_event_set_priority(&(req->ev), ORTE_MSG_PRI); ev 322 orte/orted/pmix/pmix_server_pub.c opal_event_active(&(req->ev), OPAL_EV_WRITE, 1); ev 420 orte/orted/pmix/pmix_server_pub.c opal_event_set(orte_event_base, &(req->ev), ev 422 orte/orted/pmix/pmix_server_pub.c opal_event_set_priority(&(req->ev), ORTE_MSG_PRI); ev 424 orte/orted/pmix/pmix_server_pub.c opal_event_active(&(req->ev), OPAL_EV_WRITE, 1); ev 509 orte/orted/pmix/pmix_server_pub.c opal_event_set(orte_event_base, &(req->ev), ev 511 orte/orted/pmix/pmix_server_pub.c opal_event_set_priority(&(req->ev), ORTE_MSG_PRI); ev 513 orte/orted/pmix/pmix_server_pub.c opal_event_active(&(req->ev), OPAL_EV_WRITE, 1); ev 110 orte/runtime/orte_globals.h opal_event_t *ev; ev 71 orte/runtime/orte_wait.c tm->ev = opal_event_alloc(); ev 76 orte/runtime/orte_wait.c opal_event_free(tm->ev); ev 167 orte/runtime/orte_wait.c opal_event_set(t2->evb, &t2->ev, -1, ev 169 orte/runtime/orte_wait.c opal_event_set_priority(&t2->ev, ORTE_MSG_PRI); ev 170 orte/runtime/orte_wait.c opal_event_active(&t2->ev, OPAL_EV_WRITE, 1); ev 265 orte/runtime/orte_wait.c opal_event_set(t2->evb, &t2->ev, -1, ev 267 orte/runtime/orte_wait.c opal_event_set_priority(&t2->ev, ORTE_MSG_PRI); ev 268 orte/runtime/orte_wait.c opal_event_active(&t2->ev, OPAL_EV_WRITE, 1); ev 61 orte/runtime/orte_wait.h opal_event_t ev; ev 140 orte/runtime/orte_wait.h tmp->ev, (cbfunc), tmp); \ ev 141 orte/runtime/orte_wait.h opal_event_set_priority(tmp->ev, ORTE_ERROR_PRI); \ ev 153 orte/runtime/orte_wait.h opal_event_evtimer_add(tmp->ev, &tmp->tv); \ ev 171 orte/runtime/orte_wait.h tm->ev, (cbfunc), tm); \ ev 172 orte/runtime/orte_wait.h opal_event_set_priority(tm->ev, (pri)); \ ev 180 orte/runtime/orte_wait.h opal_event_evtimer_add(tm->ev, &tm->tv); \ ev 66 orte/test/system/evpri-test.c struct event ev; ev 78 orte/test/system/evpri-test.c if (event_assign(&ev, base, SIGTERM, EV_SIGNAL|EV_PERSIST, cbfunc, NULL)<0) ev 80 orte/test/system/evpri-test.c if (event_priority_set(&ev, SIGPRI) < 0) ev 82 orte/test/system/evpri-test.c if (event_add(&ev, NULL) < 0) ev 46 orte/test/system/opal-evpri-test.c opal_event_set(orte_event_base, &c2->ev, -1, OPAL_EV_READ, t1func, c2); ev 47 orte/test/system/opal-evpri-test.c opal_event_set_priority(&c2->ev, ORTE_SYS_PRI); ev 51 orte/test/system/opal-evpri-test.c opal_event_active(&c2->ev, OPAL_EV_WRITE, 1); ev 91 orte/test/system/opal-evpri-test.c opal_event_set(orte_event_base, &caddy->ev, -1, OPAL_EV_READ, t1func, caddy); ev 92 orte/test/system/opal-evpri-test.c opal_event_set_priority(&caddy->ev, ORTE_SYS_PRI); ev 93 orte/test/system/opal-evpri-test.c opal_event_active(&caddy->ev, OPAL_EV_WRITE, 1); ev 26 orte/test/system/test-time.c opal_event_t* ev[NEVENT]; ev 74 orte/test/system/test-time.c ev[i] = (opal_event_t*)malloc(sizeof(opal_event_t)); ev 75 orte/test/system/test-time.c opal_event_evtimer_set(orte_event_base, ev[i], time_cb, ev[i]); ev 78 orte/test/system/test-time.c opal_event_evtimer_add(ev[i], &tv); ev 152 orte/util/comm/comm.c int orte_util_comm_report_event(orte_comm_event_t ev) ev 167 orte/util/comm/comm.c opal_dss.pack(buf, &ev, 1, ORTE_COMM_EVENT); ev 169 orte/util/comm/comm.c switch (ev) { ev 46 orte/util/comm/comm.h ORTE_DECLSPEC int orte_util_comm_report_event(orte_comm_event_t ev); ev 301 orte/util/listener.c opal_event_set(listener->evbase, &pending_connection->ev, -1, ev 303 orte/util/listener.c opal_event_set_priority(&pending_connection->ev, ORTE_MSG_PRI); ev 348 orte/util/listener.c opal_event_active(&pending_connection->ev, OPAL_EV_WRITE, 1); ev 54 orte/util/listener.h opal_event_t ev; ev 39 orte/util/threads.h opal_event_set((eb), &((x)->ev), -1, OPAL_EV_WRITE, (f), (x)); \ ev 40 orte/util/threads.h opal_event_set_priority(&((x)->ev), (p)); \ ev 42 orte/util/threads.h opal_event_active(&((x)->ev), OPAL_EV_WRITE, 1); \ ev 38 test/event/event-test.c opal_event_t *ev = arg; ev 44 test/event/event-test.c opal_event.add(ev, NULL); ev 54 test/event/event-test.c opal_event.del(ev);