event 137 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c opal_event_t event; event 141 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c static void mca_btl_tcp2_event_construct(mca_btl_tcp2_event_t* event) event 144 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c opal_list_append(&mca_btl_tcp2_component.tcp_events, &event->item); event 148 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c static void mca_btl_tcp2_event_destruct(mca_btl_tcp2_event_t* event) event 151 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c opal_list_remove_item(&mca_btl_tcp2_component.tcp_events, &event->item); event 323 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c mca_btl_tcp2_event_t* event = (mca_btl_tcp2_event_t*)item; event 325 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c opal_event_del(&event->event); event 326 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c OBJ_RELEASE(event); event 1005 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c mca_btl_tcp2_event_t *event; event 1019 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c event = OBJ_NEW(mca_btl_tcp2_event_t); event 1020 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c opal_event_set(opal_event_base, &event->event, sd, OPAL_EV_READ, mca_btl_tcp2_component_recv_handler, event); event 1021 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c opal_event_add(&event->event, 0); event 1039 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c mca_btl_tcp2_event_t *event = (mca_btl_tcp2_event_t *)user; event 1041 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c OBJ_RELEASE(event); event 40 ompi/mca/coll/portals4/coll_portals4_barrier.c ptl_ct_event_t event; event 169 ompi/mca/coll/portals4/coll_portals4_barrier.c ret = PtlCTWait(request->u.barrier.rtr_ct_h, num_msgs + 2, &event); event 137 ompi/mca/common/monitoring/common_monitoring.c mca_base_pvar_event_t event, event 142 ompi/mca/common/monitoring/common_monitoring.c mca_base_pvar_event_t event, event 168 ompi/mca/common/monitoring/common_monitoring.c mca_base_pvar_event_t event, event 171 ompi/mca/common/monitoring/common_monitoring.c switch (event) { event 190 ompi/mca/common/monitoring/common_monitoring.c mca_base_pvar_event_t event, event 194 ompi/mca/common/monitoring/common_monitoring.c switch (event) { event 211 ompi/mca/common/monitoring/common_monitoring_coll.c mca_base_pvar_event_t event, event 215 ompi/mca/common/monitoring/common_monitoring_coll.c switch (event) { event 28 ompi/mca/common/monitoring/common_monitoring_coll.h mca_base_pvar_event_t event, event 289 ompi/mca/osc/portals4/osc_portals4.h ptl_ct_event_t event; event 291 ompi/mca/osc/portals4/osc_portals4.h ret = PtlCTWait(module->ct_h, module->opcount, &event); event 292 ompi/mca/osc/portals4/osc_portals4.h if (PTL_OK != ret || 0 != event.failure) { event 295 ompi/mca/osc/portals4/osc_portals4.h __FILE__, __LINE__, ret, (int) event.failure); event 296 ompi/mca/osc/portals4/osc_portals4.h event.success = event.failure = 0; event 297 ompi/mca/osc/portals4/osc_portals4.h PtlCTSet(module->ct_h, event); event 300 ompi/mca/osc/portals4/osc_portals4.h assert(event.success == (size_t) module->opcount); event 59 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_event_t *event = (ompi_osc_rdma_event_t *) context; event 62 ompi/mca/osc/rdma/osc_rdma_accumulate.c ret = event->module->selected_btl->btl_put (event->module->selected_btl, event->endpoint, event->local_address, event 63 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->remote_address, event->local_handle, event->remote_handle, event 64 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->length, 0, MCA_BTL_NO_ORDER, event->cbfunc, event->cbcontext, event 65 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->cbdata); event 68 ompi/mca/osc/rdma/osc_rdma_accumulate.c opal_event_del (&event->super); event 69 ompi/mca/osc/rdma/osc_rdma_accumulate.c free (event); event 72 ompi/mca/osc/rdma/osc_rdma_accumulate.c opal_event_active (&event->super, OPAL_EV_READ, 1); event 84 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_event_t *event = malloc (sizeof (*event)); event 89 ompi/mca/osc/rdma/osc_rdma_accumulate.c if (OPAL_UNLIKELY(NULL == event)) { event 93 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->module = module; event 94 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->endpoint = endpoint; event 95 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->local_address = local_address; event 96 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->local_handle = local_handle; event 97 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->remote_address = remote_address; event 98 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->remote_handle = remote_handle; event 99 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->length = length; event 100 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->cbfunc = cbfunc; event 101 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->cbcontext = cbcontext; event 102 ompi/mca/osc/rdma/osc_rdma_accumulate.c event->cbdata = cbdata; event 113 ompi/mca/osc/rdma/osc_rdma_accumulate.c opal_event_set (opal_sync_event_base, &event->super, -1, OPAL_EV_READ, event 114 ompi/mca/osc/rdma/osc_rdma_accumulate.c event_func, event); event 115 ompi/mca/osc/rdma/osc_rdma_accumulate.c opal_event_active (&event->super, OPAL_EV_READ, 1); event 132 ompi/mca/pml/ob1/pml_ob1_component.c static int mca_pml_ob1_comm_size_notify (mca_base_pvar_t *pvar, mca_base_pvar_event_t event, void *obj_handle, int *count) event 134 ompi/mca/pml/ob1/pml_ob1_component.c if (MCA_BASE_PVAR_HANDLE_BIND == event) { event 57 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h #define VPESSIMIST_MATCHING_EVENT_NEW(event) \ event 61 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h event = (mca_vprotocol_pessimist_event_t *) item; \ event 62 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h event->type = VPROTOCOL_PESSIMIST_EVENT_TYPE_MATCHING; \ event 63 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h event->u_event.e_matching.src = -1; \ event 66 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h #define VPESSIMIST_DELIVERY_EVENT_NEW(event) \ event 70 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h event = (mca_vprotocol_pessimist_event_t *) item; \ event 71 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h event->type = VPROTOCOL_PESSIMIST_EVENT_TYPE_DELIVERY; \ event 74 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h #define VPESSIMIST_EVENT_RETURN(event) \ event 76 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h (opal_free_list_item_t *) event) event 80 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c mca_vprotocol_pessimist_event_t *event; event 83 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c for(event = (mca_vprotocol_pessimist_event_t *) opal_list_get_first(&mca_vprotocol_pessimist.replay_events); event 84 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c event != (mca_vprotocol_pessimist_event_t *) opal_list_get_end(&mca_vprotocol_pessimist.replay_events); event 85 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c event = (mca_vprotocol_pessimist_event_t *) opal_list_get_next(event)) event 89 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c if(VPROTOCOL_PESSIMIST_EVENT_TYPE_MATCHING != event->type) continue; event 90 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c mevent = &(event->u_event.e_matching); event 97 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c (opal_list_item_t *) event); event 98 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c VPESSIMIST_EVENT_RETURN(event); event 115 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c mca_vprotocol_pessimist_event_t *event; event 117 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c for(event = (mca_vprotocol_pessimist_event_t *) opal_list_get_first(&mca_vprotocol_pessimist.replay_events); event 118 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c event != (mca_vprotocol_pessimist_event_t *) opal_list_get_end(&mca_vprotocol_pessimist.replay_events); event 119 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c event = (mca_vprotocol_pessimist_event_t *) opal_list_get_next(event)) event 123 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c if(VPROTOCOL_PESSIMIST_EVENT_TYPE_DELIVERY != event->type) continue; event 124 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c devent = &(event->u_event.e_delivery); event 144 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c (opal_list_item_t *) event); event 145 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c VPESSIMIST_EVENT_RETURN(event); event 159 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c (opal_list_item_t *) event); event 160 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c VPESSIMIST_EVENT_RETURN(event); event 45 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_vprotocol_pessimist_event_t *event; event 46 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h VPESSIMIST_MATCHING_EVENT_NEW(event); event 47 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event->req = pmlreq; event 48 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h VPESSIMIST_RECV_FTREQ(req)->event = event; event 50 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h (opal_list_item_t *) event); event 61 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(ftreq->event) event 63 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_vprotocol_pessimist_event_t *event; event 67 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event = ftreq->event; event 68 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mevent = &(event->u_event.e_matching); event 71 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h ftreq->event = NULL; event 72 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event->req = NULL; event 121 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_vprotocol_pessimist_event_t *event; event 124 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h for(event = event 127 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event != event 130 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event = event 132 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h opal_list_get_next(event)) event 134 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(event->u_event.e_matching.src == -1) event 138 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h assert(event->type == VPROTOCOL_PESSIMIST_EVENT_TYPE_MATCHING); event 139 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(event->req->req_ompi.req_status.MPI_SOURCE == -1) event 141 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h V_OUTPUT_VERBOSE(41, "pessimist:\tlog\tel\t%"PRIpclock"\tnot matched yet (%d)", event->u_event.e_matching.reqid, event->u_event.e_matching.src); event 144 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event->u_event.e_matching.src = event 145 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event->req->req_ompi.req_status.MPI_SOURCE; event 148 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h V_OUTPUT_VERBOSE(40, "pessimist:\tlog\tel\t%"PRIpclock"\tfrom %d\tsent to EL", event->u_event.e_matching.reqid, event->u_event.e_matching.src); event 150 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event->u_event; event 157 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h (opal_list_item_t *) event); event 158 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h VPESSIMIST_EVENT_RETURN(event); event 159 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event = prv_event; event 186 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_vprotocol_pessimist_event_t *event; event 193 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event = (mca_vprotocol_pessimist_event_t*) event 195 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(event->type == VPROTOCOL_PESSIMIST_EVENT_TYPE_DELIVERY && event 196 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event->u_event.e_delivery.reqid == 0) event 199 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event->u_event.e_delivery.probeid = mca_vprotocol_pessimist.clock++; event 205 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h VPESSIMIST_DELIVERY_EVENT_NEW(event); event 206 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h devent = &(event->u_event.e_delivery); event 210 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h (opal_list_item_t *) event); event 217 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h VPESSIMIST_DELIVERY_EVENT_NEW(event); event 218 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h devent = &(event->u_event.e_delivery); event 222 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h (opal_list_item_t *) event); event 32 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.c ftreq->event = NULL; event 26 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.h mca_vprotocol_pessimist_event_t *event; event 43 ompi/mpiext/cr/c/checkpoint.c datum->event = ORTE_SNAPC_OP_CHECKPOINT; event 25 ompi/mpiext/cr/c/inc_register_callback.c int OMPI_CR_INC_register_callback(OMPI_CR_INC_callback_event_t event, event 37 ompi/mpiext/cr/c/inc_register_callback.c rc = opal_cr_user_inc_register_callback(event, function, prev_function); event 47 ompi/mpiext/cr/c/migrate.c datum->event = ORTE_SNAPC_OP_MIGRATE; event 44 ompi/mpiext/cr/c/mpiext_cr_c.h typedef int (*OMPI_CR_INC_callback_function)(OMPI_CR_INC_callback_event_t event, event 47 ompi/mpiext/cr/c/mpiext_cr_c.h OMPI_DECLSPEC int OMPI_CR_INC_register_callback(OMPI_CR_INC_callback_event_t event, event 41 ompi/mpiext/cr/c/quiesce_checkpoint.c datum->event = ORTE_SNAPC_OP_QUIESCE_CHECKPOINT; event 41 ompi/mpiext/cr/c/quiesce_end.c datum->event = ORTE_SNAPC_OP_QUIESCE_END; event 45 ompi/mpiext/cr/c/quiesce_start.c datum->event = ORTE_SNAPC_OP_QUIESCE_START; event 40 ompi/mpiext/cr/c/restart.c datum->event = ORTE_SNAPC_OP_RESTART; event 34 ompi/peruse/peruse-internal.h int event; /**< Event being watched */ event 72 ompi/peruse/peruse-internal.h #define PERUSE_TRACE_COMM_EVENT(event, base_req, op) \ event 75 ompi/peruse/peruse-internal.h ompi_peruse_handle_t * _ptr = (base_req)->req_comm->c_peruse_handles[(event)]; \ event 90 ompi/peruse/peruse-internal.h #define PERUSE_TRACE_COMM_OMPI_EVENT(event, base_req, size, op) \ event 93 ompi/peruse/peruse-internal.h ompi_peruse_handle_t * _ptr = (base_req)->req_comm->c_peruse_handles[(event)]; \ event 108 ompi/peruse/peruse-internal.h #define PERUSE_TRACE_MSG_EVENT(event, comm_ptr, hdr_peer, hdr_tag, op) \ event 111 ompi/peruse/peruse-internal.h ompi_peruse_handle_t * _ptr = (comm_ptr)->c_peruse_handles[(event)]; \ event 128 ompi/peruse/peruse-internal.h #define PERUSE_TRACE_COMM_EVENT(event, base_req, op) event 129 ompi/peruse/peruse-internal.h #define PERUSE_TRACE_COMM_OMPI_EVENT(event, base_req, size, op) event 130 ompi/peruse/peruse-internal.h #define PERUSE_TRACE_MSG_EVENT(event, comm_ptr, hdr_peer, hdr_tag, op) event 100 ompi/peruse/peruse.c int PERUSE_Query_event (const char* event_name, int* event) event 106 ompi/peruse/peruse.c *event = PERUSE_events[i].id; event 115 ompi/peruse/peruse.c int PERUSE_Query_event_name (int event, char** event_name) event 117 ompi/peruse/peruse.c if (event < 0 || event > PERUSE_num_events || event 118 ompi/peruse/peruse.c NULL == PERUSE_events[event].name) event 121 ompi/peruse/peruse.c *event_name = strdup(PERUSE_events[event].name); event 146 ompi/peruse/peruse.c int PERUSE_Event_comm_register (int event, event 156 ompi/peruse/peruse.c if( (event < 0) || (event > PERUSE_num_events) || event 157 ompi/peruse/peruse.c (NULL == PERUSE_events[event].name) ) event 176 ompi/peruse/peruse.c handle->event = event; event 190 ompi/peruse/peruse.c comm->c_peruse_handles[event] = handle; event 306 ompi/peruse/peruse.c int PERUSE_Event_get (peruse_event_h event_h, int* event) event 314 ompi/peruse/peruse.c if (NULL == event) event 318 ompi/peruse/peruse.c *event = ((ompi_peruse_handle_t*)event_h)->event; event 108 ompi/peruse/peruse.h OMPI_DECLSPEC int PERUSE_Query_event( const char* event_name, int* event ); event 111 ompi/peruse/peruse.h OMPI_DECLSPEC int PERUSE_Query_event_name( int event, char** event_name ); event 123 ompi/peruse/peruse.h OMPI_DECLSPEC int PERUSE_Event_comm_register( int event, event 149 ompi/peruse/peruse.h OMPI_DECLSPEC int PERUSE_Event_get( peruse_event_h event_h, int* event ); event 31 ompi/peruse/peruse_module.c p->event = PERUSE_EVENT_INVALID; event 177 ompi/runtime/ompi_spc.c static int ompi_spc_notify(mca_base_pvar_t *pvar, mca_base_pvar_event_t event, void *obj_handle, int *count) event 180 ompi/runtime/ompi_spc.c static int ompi_spc_notify(mca_base_pvar_t *pvar, mca_base_pvar_event_t event, void *obj_handle, int *count) event 192 ompi/runtime/ompi_spc.c if(MCA_BASE_PVAR_HANDLE_BIND == event) { event 196 ompi/runtime/ompi_spc.c else if(MCA_BASE_PVAR_HANDLE_START == event) { event 202 ompi/runtime/ompi_spc.c else if(MCA_BASE_PVAR_HANDLE_STOP == event) { event 169 opal/mca/base/mca_base_pvar.c static int mca_base_pvar_notify_ignore (mca_base_pvar_t *pvar, mca_base_pvar_event_t event, void *obj_handle, int *count) event 176 opal/mca/base/mca_base_pvar.c if (MCA_BASE_PVAR_HANDLE_BIND == event) { event 391 opal/mca/base/mca_base_pvar.c int mca_base_pvar_notify (mca_base_pvar_handle_t *handle, mca_base_pvar_event_t event, int *count) event 397 opal/mca/base/mca_base_pvar.c return handle->pvar->notify (handle->pvar, event, handle->obj_handle, count); event 161 opal/mca/base/mca_base_pvar.h typedef int (*mca_base_notify_fn_t) (struct mca_base_pvar_t *pvar, mca_base_pvar_event_t event, void *obj, int *count); event 536 opal/mca/base/mca_base_pvar.h OPAL_DECLSPEC int mca_base_pvar_notify (mca_base_pvar_handle_t *handle, mca_base_pvar_event_t event, int *count); event 88 opal/mca/btl/tcp/btl_tcp.h #define MCA_BTL_TCP_ACTIVATE_EVENT(event, value) \ event 91 opal/mca/btl/tcp/btl_tcp.h opal_event_t* _event = (opal_event_t*)(event); \ event 96 opal/mca/btl/tcp/btl_tcp.h opal_event_add(event, (value)); \ event 188 opal/mca/btl/tcp/btl_tcp_component.c opal_event_t event; event 192 opal/mca/btl/tcp/btl_tcp_component.c static void mca_btl_tcp_event_construct(mca_btl_tcp_event_t* event) event 195 opal/mca/btl/tcp/btl_tcp_component.c opal_list_append(&mca_btl_tcp_component.tcp_events, &event->item); event 199 opal/mca/btl/tcp/btl_tcp_component.c static void mca_btl_tcp_event_destruct(mca_btl_tcp_event_t* event) event 202 opal/mca/btl/tcp/btl_tcp_component.c opal_list_remove_item(&mca_btl_tcp_component.tcp_events, &event->item); event 409 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_event_t *event, *next; event 467 opal/mca/btl/tcp/btl_tcp_component.c OPAL_LIST_FOREACH_SAFE(event, next, &mca_btl_tcp_component.tcp_events, mca_btl_tcp_event_t) { event 468 opal/mca/btl/tcp/btl_tcp_component.c opal_event_del(&event->event); event 469 opal/mca/btl/tcp/btl_tcp_component.c OBJ_RELEASE(event); event 870 opal/mca/btl/tcp/btl_tcp_component.c opal_event_t* event; event 873 opal/mca/btl/tcp/btl_tcp_component.c rc = read(fd, (void*)&event, sizeof(opal_event_t*)); event 880 opal/mca/btl/tcp/btl_tcp_component.c opal_event_add(event, 0); event 1355 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_event_t *event; event 1374 opal/mca/btl/tcp/btl_tcp_component.c event = OBJ_NEW(mca_btl_tcp_event_t); event 1375 opal/mca/btl/tcp/btl_tcp_component.c opal_event_set(mca_btl_tcp_event_base, &(event->event), sd, event 1376 opal/mca/btl/tcp/btl_tcp_component.c OPAL_EV_READ, mca_btl_tcp_component_recv_handler, event); event 1377 opal/mca/btl/tcp/btl_tcp_component.c opal_event_add(&event->event, 0); event 1390 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_event_t *event = (mca_btl_tcp_event_t *)user; event 1432 opal/mca/btl/tcp/btl_tcp_component.c OBJ_RELEASE(event); event 95 opal/mca/btl/ugni/btl_ugni_component.c static inline int mca_btl_ugni_notify_stat (mca_base_pvar_t *pvar, mca_base_pvar_event_t event, void *obj, int *count) event 97 opal/mca/btl/ugni/btl_ugni_component.c if (MCA_BASE_PVAR_HANDLE_BIND == event) { event 77 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_t event; event 92 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_t event; event 216 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_del(&obj->event); event 248 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_del(&obj->event); event 689 opal/mca/btl/usnic/btl_usnic_cagent.c &udp_listener->event, udp_listener->fd, event 692 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_add(&udp_listener->event, 0); event 1041 opal/mca/btl/usnic/btl_usnic_cagent.c &listener->event, client_fd, event 1044 opal/mca/btl/usnic/btl_usnic_cagent.c opal_event_add(&listener->event, 0); event 260 opal/mca/btl/usnic/btl_usnic_module.c uint32_t event; event 278 opal/mca/btl/usnic/btl_usnic_module.c ret = fi_eq_sread(module->av_eq, &event, &entry, sizeof(entry), -1, 0); event 1454 opal/mca/btl/usnic/btl_usnic_module.c uint32_t event; event 1458 opal/mca/btl/usnic/btl_usnic_module.c int ret = fi_eq_read(module->dom_eq, &event, &entry, sizeof(entry), 0); event 1475 opal/mca/btl/usnic/btl_usnic_module.c else if (event == 42 /* RFXXX FI_LINKSTATE */) { event 1476 opal/mca/btl/usnic/btl_usnic_module.c opal_memchecker_base_mem_defined(&event, sizeof(event)); event 123 opal/mca/btl/usnic/btl_usnic_module.h struct event device_async_event; event 265 opal/mca/btl/usnic/btl_usnic_stats.c mca_base_pvar_event_t event, event 268 opal/mca/btl/usnic/btl_usnic_stats.c if (MCA_BASE_PVAR_HANDLE_BIND == event) { event 1082 opal/mca/common/cuda/common_cuda.c result = cuFunc.cuEventRecord((CUevent)cuda_reg->data.event, 0); event 1180 opal/mca/common/cuda/common_cuda.c void mca_common_cuda_construct_event_and_handle(uintptr_t *event, void *handle) event 1184 opal/mca/common/cuda/common_cuda.c result = cuFunc.cuEventCreate((CUevent *)event, CU_EVENT_INTERPROCESS | CU_EVENT_DISABLE_TIMING); event 1190 opal/mca/common/cuda/common_cuda.c result = cuFunc.cuIpcGetEventHandle((CUipcEventHandle *)handle, (CUevent)*event); event 1200 opal/mca/common/cuda/common_cuda.c void mca_common_cuda_destruct_event(uintptr_t event) event 1207 opal/mca/common/cuda/common_cuda.c result = cuFunc.cuEventDestroy((CUevent)event); event 1227 opal/mca/common/cuda/common_cuda.c CUevent event; event 1233 opal/mca/common/cuda/common_cuda.c result = cuFunc.cuIpcOpenEventHandle(&event, evtHandle); event 1244 opal/mca/common/cuda/common_cuda.c result = cuFunc.cuEventRecord(event, 0); event 1251 opal/mca/common/cuda/common_cuda.c result = cuFunc.cuStreamWaitEvent(0, event, 0); event 1258 opal/mca/common/cuda/common_cuda.c result = cuFunc.cuEventDestroy(event); event 34 opal/mca/common/cuda/common_cuda.h uint64_t event; event 75 opal/mca/common/cuda/common_cuda.h OPAL_DECLSPEC void mca_common_cuda_construct_event_and_handle(uintptr_t *event, void *handle); event 76 opal/mca/common/cuda/common_cuda.h OPAL_DECLSPEC void mca_common_cuda_destruct_event(uintptr_t event); event 55 opal/mca/event/base/event_base_frame.c MCA_BASE_FRAMEWORK_DECLARE(opal, event, NULL, NULL, opal_event_base_open, event 38 opal/mca/event/external/external.h typedef struct event opal_event_t; event 105 opal/mca/event/libevent2022/libevent/bufferevent-internal.h struct event master_refill_event; event 132 opal/mca/event/libevent2022/libevent/bufferevent-internal.h struct event refill_bucket_event; event 306 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int bufferevent_disable_hard(struct bufferevent *bufev, short event); event 335 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int _bufferevent_add_event(struct event *ev, const struct timeval *tv); event 407 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_enable(struct bufferevent *bufev, short event) event 411 opal/mca/event/libevent2022/libevent/bufferevent.c short impl_events = event; event 420 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->enabled |= event; event 480 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_disable_hard(struct bufferevent *bufev, short event) event 487 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->enabled &= ~event; event 490 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev->be_ops->disable(bufev, event) < 0) event 498 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_disable(struct bufferevent *bufev, short event) event 503 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->enabled &= ~event; event 505 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev->be_ops->disable(bufev, event) < 0) event 792 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_generic_read_timeout_cb(evutil_socket_t fd, short event, void *ctx) event 801 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_generic_write_timeout_cb(evutil_socket_t fd, short event, void *ctx) event 855 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_add_event(struct event *ev, const struct timeval *tv) event 248 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_enable(struct bufferevent *bev, short event) event 251 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (event & EV_WRITE) event 254 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (event & EV_READ) { event 263 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_disable(struct bufferevent *bev, short event) event 266 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (event & EV_WRITE) event 268 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (event & EV_READ) { event 487 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int event = BEV_EVENT_ERROR; event 495 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event = BEV_EVENT_EOF; event 526 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event = BEV_EVENT_EOF; event 531 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, event); event 908 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int event = 0; event 912 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event = BEV_EVENT_EOF; event 914 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event = BEV_EVENT_ERROR; event 917 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event = what; event 920 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event = what; event 925 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (event) event 926 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, event); event 123 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_readcb(evutil_socket_t fd, short event, void *arg) event 135 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event == EV_TIMEOUT) { event 202 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_writecb(evutil_socket_t fd, short event, void *arg) event 214 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event == EV_TIMEOUT) { event 551 opal/mca/event/libevent2022/libevent/bufferevent_sock.c be_socket_enable(struct bufferevent *bufev, short event) event 553 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event & EV_READ) { event 557 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event & EV_WRITE) { event 565 opal/mca/event/libevent2022/libevent/bufferevent_sock.c be_socket_disable(struct bufferevent *bufev, short event) event 569 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event & EV_READ) { event 574 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if ((event & EV_WRITE) && ! bufev_p->connecting) { event 51 opal/mca/event/libevent2022/libevent/epoll_sub.c epoll_ctl(int epfd, int op, int fd, struct epoll_event *event) event 54 opal/mca/event/libevent2022/libevent/epoll_sub.c return (syscall(__NR_epoll_ctl, epfd, op, fd, event)); event 185 opal/mca/event/libevent2022/libevent/evdns.c struct event timeout_event; event 223 opal/mca/event/libevent2022/libevent/evdns.c struct event event; event 226 opal/mca/event/libevent2022/libevent/evdns.c struct event timeout_event; /* used to keep the timeout for */ event 247 opal/mca/event/libevent2022/libevent/evdns.c struct event event; /* Read/write event */ event 1441 opal/mca/event/libevent2022/libevent/evdns.c (void) event_del(&port->event); event 1442 opal/mca/event/libevent2022/libevent/evdns.c event_assign(&port->event, port->event_base, event 1446 opal/mca/event/libevent2022/libevent/evdns.c if (event_add(&port->event, NULL) < 0) { event 1461 opal/mca/event/libevent2022/libevent/evdns.c (void) event_del(&ns->event); event 1462 opal/mca/event/libevent2022/libevent/evdns.c event_assign(&ns->event, ns->base->event_base, event 1465 opal/mca/event/libevent2022/libevent/evdns.c if (event_add(&ns->event, NULL) < 0) { event 1711 opal/mca/event/libevent2022/libevent/evdns.c event_assign(&port->event, port->event_base, event 1714 opal/mca/event/libevent2022/libevent/evdns.c if (event_add(&port->event, NULL) < 0) { event 2002 opal/mca/event/libevent2022/libevent/evdns.c (void) event_del(&port->event); event 2003 opal/mca/event/libevent2022/libevent/evdns.c event_assign(&port->event, port->event_base, port->socket, (port->closing?0:EV_READ) | EV_WRITE | EV_PERSIST, server_port_ready_callback, port); event 2005 opal/mca/event/libevent2022/libevent/evdns.c if (event_add(&port->event, NULL) < 0) { event 2113 opal/mca/event/libevent2022/libevent/evdns.c (void) event_del(&port->event); event 2114 opal/mca/event/libevent2022/libevent/evdns.c event_debug_unassign(&port->event); event 2386 opal/mca/event/libevent2022/libevent/evdns.c (void) event_del(&server->event); event 2508 opal/mca/event/libevent2022/libevent/evdns.c event_assign(&ns->event, ns->base->event_base, ns->socket, EV_READ | EV_PERSIST, nameserver_ready_callback, ns); event 2509 opal/mca/event/libevent2022/libevent/evdns.c if (event_add(&ns->event, NULL) < 0) { event 2535 opal/mca/event/libevent2022/libevent/evdns.c event_debug_unassign(&ns->event); event 3943 opal/mca/event/libevent2022/libevent/evdns.c (void) event_del(&server->event); event 3944 opal/mca/event/libevent2022/libevent/evdns.c event_debug_unassign(&server->event); event 4169 opal/mca/event/libevent2022/libevent/evdns.c struct event timeout; event 144 opal/mca/event/libevent2022/libevent/event-internal.h struct event timeout_event; event 266 opal/mca/event/libevent2022/libevent/event-internal.h struct event *current_event; event 291 opal/mca/event/libevent2022/libevent/event-internal.h struct event th_notify; event 349 opal/mca/event/libevent2022/libevent/event-internal.h void event_active_nolock(struct event *ev, int res, short count); event 131 opal/mca/event/libevent2022/libevent/event.c static inline int event_add_internal(struct event *ev, event 133 opal/mca/event/libevent2022/libevent/event.c static inline int event_del_internal(struct event *ev); event 135 opal/mca/event/libevent2022/libevent/event.c static void event_queue_insert(struct event_base *, struct event *, int); event 136 opal/mca/event/libevent2022/libevent/event.c static void event_queue_remove(struct event_base *, struct event *, int); event 145 opal/mca/event/libevent2022/libevent/event.c static inline void event_signal_closure(struct event_base *, struct event *ev); event 146 opal/mca/event/libevent2022/libevent/event.c static inline void event_persist_closure(struct event_base *, struct event *ev); event 159 opal/mca/event/libevent2022/libevent/event.c const struct event *ptr; event 693 opal/mca/event/libevent2022/libevent/event.c struct event *ev; event 728 opal/mca/event/libevent2022/libevent/event.c struct event *next = TAILQ_NEXT(ev, ev_next); event 745 opal/mca/event/libevent2022/libevent/event.c struct event *next = TAILQ_NEXT(ev, event 760 opal/mca/event/libevent2022/libevent/event.c struct event *next = TAILQ_NEXT(ev, ev_active_next); event 802 opal/mca/event/libevent2022/libevent/event.c struct event *ev; event 1051 opal/mca/event/libevent2022/libevent/event.c event_signal_closure(struct event_base *base, struct event *ev) event 1148 opal/mca/event/libevent2022/libevent/event.c const struct timeval *now, struct event *head) event 1164 opal/mca/event/libevent2022/libevent/event.c struct event *ev = NULL; event 1259 opal/mca/event/libevent2022/libevent/event.c event_persist_closure(struct event_base *base, struct event *ev) event 1335 opal/mca/event/libevent2022/libevent/event.c struct event *ev; event 1665 opal/mca/event/libevent2022/libevent/event.c struct event ev; event 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) event 1788 opal/mca/event/libevent2022/libevent/event.c event_base_set(struct event_base *base, struct event *ev) event 1803 opal/mca/event/libevent2022/libevent/event.c event_set(struct event *ev, evutil_socket_t fd, short events, event 1811 opal/mca/event/libevent2022/libevent/event.c struct event * event 1814 opal/mca/event/libevent2022/libevent/event.c struct event *ev; event 1815 opal/mca/event/libevent2022/libevent/event.c ev = mm_malloc(sizeof(struct event)); event 1827 opal/mca/event/libevent2022/libevent/event.c event_free(struct event *ev) event 1839 opal/mca/event/libevent2022/libevent/event.c event_debug_unassign(struct event *ev) event 1853 opal/mca/event/libevent2022/libevent/event.c event_priority_set(struct event *ev, int pri) event 1872 opal/mca/event/libevent2022/libevent/event.c event_pending(const struct event *ev, short event, struct timeval *tv) event 1891 opal/mca/event/libevent2022/libevent/event.c event &= (EV_TIMEOUT|EV_READ|EV_WRITE|EV_SIGNAL); event 1894 opal/mca/event/libevent2022/libevent/event.c if (tv != NULL && (flags & event & EV_TIMEOUT)) { event 1907 opal/mca/event/libevent2022/libevent/event.c return (flags & event); event 1911 opal/mca/event/libevent2022/libevent/event.c event_initialized(const struct event *ev) event 1920 opal/mca/event/libevent2022/libevent/event.c event_get_assignment(const struct event *event, struct event_base **base_out, evutil_socket_t *fd_out, short *events_out, event_callback_fn *callback_out, void **arg_out) event 1922 opal/mca/event/libevent2022/libevent/event.c _event_debug_assert_is_setup(event); event 1925 opal/mca/event/libevent2022/libevent/event.c *base_out = event->ev_base; event 1927 opal/mca/event/libevent2022/libevent/event.c *fd_out = event->ev_fd; event 1929 opal/mca/event/libevent2022/libevent/event.c *events_out = event->ev_events; event 1931 opal/mca/event/libevent2022/libevent/event.c *callback_out = event->ev_callback; event 1933 opal/mca/event/libevent2022/libevent/event.c *arg_out = event->ev_arg; event 1939 opal/mca/event/libevent2022/libevent/event.c return sizeof(struct event); event 1943 opal/mca/event/libevent2022/libevent/event.c event_get_fd(const struct event *ev) event 1950 opal/mca/event/libevent2022/libevent/event.c event_get_base(const struct event *ev) event 1957 opal/mca/event/libevent2022/libevent/event.c event_get_events(const struct event *ev) event 1964 opal/mca/event/libevent2022/libevent/event.c event_get_callback(const struct event *ev) event 1971 opal/mca/event/libevent2022/libevent/event.c event_get_callback_arg(const struct event *ev) event 1978 opal/mca/event/libevent2022/libevent/event.c event_add(struct event *ev, const struct timeval *tv) event 2050 opal/mca/event/libevent2022/libevent/event.c event_add_internal(struct event *ev, const struct timeval *tv, event 2200 opal/mca/event/libevent2022/libevent/event.c event_del(struct event *ev) event 2220 opal/mca/event/libevent2022/libevent/event.c event_del_internal(struct event *ev) event 2294 opal/mca/event/libevent2022/libevent/event.c event_active(struct event *ev, int res, short ncalls) event 2312 opal/mca/event/libevent2022/libevent/event.c event_active_nolock(struct event *ev, int res, short ncalls) event 2407 opal/mca/event/libevent2022/libevent/event.c struct event *ev; event 2449 opal/mca/event/libevent2022/libevent/event.c struct event **pev; event 2480 opal/mca/event/libevent2022/libevent/event.c struct event *ev; event 2503 opal/mca/event/libevent2022/libevent/event.c struct event *ev; event 2526 opal/mca/event/libevent2022/libevent/event.c event_queue_remove(struct event_base *base, struct event *ev, int queue) event 2567 opal/mca/event/libevent2022/libevent/event.c struct event *ev) event 2569 opal/mca/event/libevent2022/libevent/event.c struct event *e; event 2596 opal/mca/event/libevent2022/libevent/event.c event_queue_insert(struct event_base *base, struct event *ev, int queue) event 2853 opal/mca/event/libevent2022/libevent/event.c struct event *e; event 2925 opal/mca/event/libevent2022/libevent/event.c struct event *ev, *p_ev; event 2936 opal/mca/event/libevent2022/libevent/event.c struct event *last=NULL, *ev; event 38 opal/mca/event/libevent2022/libevent/evmap-internal.h struct event; event 62 opal/mca/event/libevent2022/libevent/evmap-internal.h int evmap_io_add(struct event_base *base, evutil_socket_t fd, struct event *ev); event 71 opal/mca/event/libevent2022/libevent/evmap-internal.h int evmap_io_del(struct event_base *base, evutil_socket_t fd, struct event *ev); event 84 opal/mca/event/libevent2022/libevent/evmap-internal.h int evmap_signal_add(struct event_base *base, int signum, struct event *ev); event 85 opal/mca/event/libevent2022/libevent/evmap-internal.h int evmap_signal_del(struct event_base *base, int signum, struct event *ev); event 263 opal/mca/event/libevent2022/libevent/evmap.c evmap_io_add(struct event_base *base, evutil_socket_t fd, struct event *ev) event 270 opal/mca/event/libevent2022/libevent/evmap.c struct event *old_ev; event 336 opal/mca/event/libevent2022/libevent/evmap.c evmap_io_del(struct event_base *base, evutil_socket_t fd, struct event *ev) event 394 opal/mca/event/libevent2022/libevent/evmap.c struct event *ev; event 418 opal/mca/event/libevent2022/libevent/evmap.c evmap_signal_add(struct event_base *base, int sig, struct event *ev) event 444 opal/mca/event/libevent2022/libevent/evmap.c evmap_signal_del(struct event_base *base, int sig, struct event *ev) event 470 opal/mca/event/libevent2022/libevent/evmap.c struct event *ev; event 735 opal/mca/event/libevent2022/libevent/evmap.c struct event *ev; event 182 opal/mca/event/libevent2022/libevent/evrpc-internal.h struct event ev_timeout; event 41 opal/mca/event/libevent2022/libevent/evsignal-internal.h struct event ev_signal; event 179 opal/mca/event/libevent2022/libevent/evthread_win32.c HANDLE event; event 197 opal/mca/event/libevent2022/libevent/evthread_win32.c if ((cond->event = CreateEvent(NULL,TRUE,FALSE,NULL)) == NULL) { event 211 opal/mca/event/libevent2022/libevent/evthread_win32.c CloseHandle(cond->event); event 225 opal/mca/event/libevent2022/libevent/evthread_win32.c SetEvent(cond->event); event 252 opal/mca/event/libevent2022/libevent/evthread_win32.c res = WaitForSingleObject(cond->event, ms); event 281 opal/mca/event/libevent2022/libevent/evthread_win32.c ResetEvent(cond->event); event 291 opal/mca/event/libevent2022/libevent/evthread_win32.c ResetEvent(cond->event); event 70 opal/mca/event/libevent2022/libevent/http-internal.h struct event retry_ev; /* for retrying connects */ event 359 opal/mca/event/libevent2022/libevent/http.c evhttp_add_event(struct event *ev, int timeout, int default_timeout) event 408 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_enable(struct bufferevent *bufev, short event); event 418 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_disable(struct bufferevent *bufev, short event); event 80 opal/mca/event/libevent2022/libevent/include/event2/bufferevent_struct.h struct event ev_read; event 84 opal/mca/event/libevent2022/libevent/include/event2/bufferevent_struct.h struct event ev_write; event 276 opal/mca/event/libevent2022/libevent/include/event2/event.h struct event event 336 opal/mca/event/libevent2022/libevent/include/event2/event.h void event_debug_unassign(struct event *); event 635 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_base_set(struct event_base *, struct event *); event 848 opal/mca/event/libevent2022/libevent/include/event2/event.h struct event *event_new(struct event_base *, evutil_socket_t, short, event_callback_fn, void *); event 889 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_assign(struct event *, struct event_base *, evutil_socket_t, short, event_callback_fn, void *); event 897 opal/mca/event/libevent2022/libevent/include/event2/event.h void event_free(struct event *); event 945 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_add(struct event *ev, const struct timeval *timeout); event 958 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_del(struct event *); event 975 opal/mca/event/libevent2022/libevent/include/event2/event.h void event_active(struct event *ev, int res, short ncalls); event 990 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_pending(const struct event *ev, short events, struct timeval *tv); event 1008 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_initialized(const struct event *ev); event 1019 opal/mca/event/libevent2022/libevent/include/event2/event.h evutil_socket_t event_get_fd(const struct event *ev); event 1024 opal/mca/event/libevent2022/libevent/include/event2/event.h struct event_base *event_get_base(const struct event *ev); event 1029 opal/mca/event/libevent2022/libevent/include/event2/event.h short event_get_events(const struct event *ev); event 1034 opal/mca/event/libevent2022/libevent/include/event2/event.h event_callback_fn event_get_callback(const struct event *ev); event 1039 opal/mca/event/libevent2022/libevent/include/event2/event.h void *event_get_callback_arg(const struct event *ev); event 1048 opal/mca/event/libevent2022/libevent/include/event2/event.h void event_get_assignment(const struct event *event, event 1136 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_priority_set(struct event *, int); event 174 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h void event_set(struct event *, evutil_socket_t, short, void (*)(evutil_socket_t, short, void *), void *); event 88 opal/mca/event/libevent2022/libevent/include/event2/event_struct.h TAILQ_ENTRY(event) ev_active_next; event 89 opal/mca/event/libevent2022/libevent/include/event2/event_struct.h TAILQ_ENTRY(event) ev_next; event 92 opal/mca/event/libevent2022/libevent/include/event2/event_struct.h TAILQ_ENTRY(event) ev_next_with_common_timeout; event 102 opal/mca/event/libevent2022/libevent/include/event2/event_struct.h TAILQ_ENTRY(event) ev_io_next; event 108 opal/mca/event/libevent2022/libevent/include/event2/event_struct.h TAILQ_ENTRY(event) ev_signal_next; event 127 opal/mca/event/libevent2022/libevent/include/event2/event_struct.h TAILQ_HEAD (event_list, event); event 87 opal/mca/event/libevent2022/libevent/listener.c struct event listener; event 40 opal/mca/event/libevent2022/libevent/minheap-internal.h struct event** p; event 46 opal/mca/event/libevent2022/libevent/minheap-internal.h static inline void min_heap_elem_init(struct event* e); event 47 opal/mca/event/libevent2022/libevent/minheap-internal.h static inline int min_heap_elt_is_top(const struct event *e); event 48 opal/mca/event/libevent2022/libevent/minheap-internal.h static inline int min_heap_elem_greater(struct event *a, struct event *b); event 51 opal/mca/event/libevent2022/libevent/minheap-internal.h static inline struct event* min_heap_top(min_heap_t* s); event 53 opal/mca/event/libevent2022/libevent/minheap-internal.h static inline int min_heap_push(min_heap_t* s, struct event* e); event 54 opal/mca/event/libevent2022/libevent/minheap-internal.h static inline struct event* min_heap_pop(min_heap_t* s); event 55 opal/mca/event/libevent2022/libevent/minheap-internal.h static inline int min_heap_erase(min_heap_t* s, struct event* e); event 56 opal/mca/event/libevent2022/libevent/minheap-internal.h static inline void min_heap_shift_up_(min_heap_t* s, unsigned hole_index, struct event* e); event 57 opal/mca/event/libevent2022/libevent/minheap-internal.h static inline void min_heap_shift_down_(min_heap_t* s, unsigned hole_index, struct event* e); event 59 opal/mca/event/libevent2022/libevent/minheap-internal.h int min_heap_elem_greater(struct event *a, struct event *b) event 66 opal/mca/event/libevent2022/libevent/minheap-internal.h void min_heap_elem_init(struct event* e) { e->ev_timeout_pos.min_heap_idx = -1; } event 69 opal/mca/event/libevent2022/libevent/minheap-internal.h struct event* min_heap_top(min_heap_t* s) { return s->n ? *s->p : 0; } event 71 opal/mca/event/libevent2022/libevent/minheap-internal.h int min_heap_push(min_heap_t* s, struct event* e) event 79 opal/mca/event/libevent2022/libevent/minheap-internal.h struct event* min_heap_pop(min_heap_t* s) event 83 opal/mca/event/libevent2022/libevent/minheap-internal.h struct event* e = *s->p; event 91 opal/mca/event/libevent2022/libevent/minheap-internal.h int min_heap_elt_is_top(const struct event *e) event 96 opal/mca/event/libevent2022/libevent/minheap-internal.h int min_heap_erase(min_heap_t* s, struct event* e) event 100 opal/mca/event/libevent2022/libevent/minheap-internal.h struct event *last = s->p[--s->n]; event 121 opal/mca/event/libevent2022/libevent/minheap-internal.h struct event** p; event 125 opal/mca/event/libevent2022/libevent/minheap-internal.h if (!(p = (struct event**)mm_realloc(s->p, a * sizeof *p))) event 133 opal/mca/event/libevent2022/libevent/minheap-internal.h void min_heap_shift_up_(min_heap_t* s, unsigned hole_index, struct event* e) event 145 opal/mca/event/libevent2022/libevent/minheap-internal.h void min_heap_shift_down_(min_heap_t* s, unsigned hole_index, struct event* e) event 101 opal/mca/event/libevent2022/libevent/poll.c struct event *ev; event 32 opal/mca/event/libevent2022/libevent/sample/event-test.c fifo_read(evutil_socket_t fd, short event, void *arg) event 36 opal/mca/event/libevent2022/libevent/sample/event-test.c struct event *ev = arg; event 45 opal/mca/event/libevent2022/libevent/sample/event-test.c (int)fd, event, arg); event 76 opal/mca/event/libevent2022/libevent/sample/event-test.c struct event evfifo; event 43 opal/mca/event/libevent2022/libevent/sample/hello-world.c struct event *signal_event; event 36 opal/mca/event/libevent2022/libevent/sample/signal-test.c signal_cb(evutil_socket_t fd, short event, void *arg) event 38 opal/mca/event/libevent2022/libevent/sample/signal-test.c struct event *signal = arg; event 51 opal/mca/event/libevent2022/libevent/sample/signal-test.c struct event signal_int; event 43 opal/mca/event/libevent2022/libevent/sample/time-test.c timeout_cb(evutil_socket_t fd, short event, void *arg) event 46 opal/mca/event/libevent2022/libevent/sample/time-test.c struct event *timeout = arg; event 69 opal/mca/event/libevent2022/libevent/sample/time-test.c struct event timeout; event 66 opal/mca/event/libevent2022/libevent/test/bench.c static struct event *events; event 167 opal/mca/event/libevent2022/libevent/test/bench.c events = calloc(num_pipes, sizeof(struct event)); event 64 opal/mca/event/libevent2022/libevent/test/bench_cascade.c static struct event *events; event 87 opal/mca/event/libevent2022/libevent/test/bench_cascade.c events = calloc(num_pipes, sizeof(struct event)); event 104 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev; event 109 opal/mca/event/libevent2022/libevent/test/regress.c simple_read_cb(evutil_socket_t fd, short event, void *arg) event 128 opal/mca/event/libevent2022/libevent/test/regress.c basic_read_cb(evutil_socket_t fd, short event, void *data) event 162 opal/mca/event/libevent2022/libevent/test/regress.c dummy_read_cb(evutil_socket_t fd, short event, void *arg) event 167 opal/mca/event/libevent2022/libevent/test/regress.c simple_write_cb(evutil_socket_t fd, short event, void *arg) event 179 opal/mca/event/libevent2022/libevent/test/regress.c multiple_write_cb(evutil_socket_t fd, short event, void *arg) event 181 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev = arg; event 212 opal/mca/event/libevent2022/libevent/test/regress.c multiple_read_cb(evutil_socket_t fd, short event, void *arg) event 214 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev = arg; event 234 opal/mca/event/libevent2022/libevent/test/regress.c timeout_cb(evutil_socket_t fd, short event, void *arg) event 254 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 259 opal/mca/event/libevent2022/libevent/test/regress.c combined_read_cb(evutil_socket_t fd, short event, void *arg) event 277 opal/mca/event/libevent2022/libevent/test/regress.c combined_write_cb(evutil_socket_t fd, short event, void *arg) event 314 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 336 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 350 opal/mca/event/libevent2022/libevent/test/regress.c simpleread_multiple_cb(evutil_socket_t fd, short event, void *arg) event 359 opal/mca/event/libevent2022/libevent/test/regress.c struct event one, two; event 412 opal/mca/event/libevent2022/libevent/test/regress.c struct event *rev=NULL, *wev=NULL, *closeev=NULL; event 492 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev, ev2; event 521 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev, ev2; event 582 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 598 opal/mca/event/libevent2022/libevent/test/regress.c periodic_timeout_cb(evutil_socket_t fd, short event, void *arg) event 615 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 634 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 662 opal/mca/event/libevent2022/libevent/test/regress.c activate_cb(evutil_socket_t fd, short event, void *arg) event 664 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev = arg; event 669 opal/mca/event/libevent2022/libevent/test/regress.c persist_active_timeout_cb(evutil_socket_t fd, short event, void *arg) event 673 opal/mca/event/libevent2022/libevent/test/regress.c c->events[c->n] = event; event 683 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 723 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 730 opal/mca/event/libevent2022/libevent/test/regress.c common_timeout_cb(evutil_socket_t fd, short event, void *arg) event 815 opal/mca/event/libevent2022/libevent/test/regress.c static void signal_cb(evutil_socket_t fd, short event, void *arg); event 821 opal/mca/event/libevent2022/libevent/test/regress.c child_signal_cb(evutil_socket_t fd, short event, void *arg) event 837 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev, sig_ev; event 930 opal/mca/event/libevent2022/libevent/test/regress.c signal_cb(evutil_socket_t fd, short event, void *arg) event 932 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev = arg; event 941 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 967 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev_one, ev_two; event 997 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 1012 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 1053 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev1, ev2; event 1105 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 1140 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 1172 opal/mca/event/libevent2022/libevent/test/regress.c signal_cb_swp(int sig, short event, void *arg) event 1181 opal/mca/event/libevent2022/libevent/test/regress.c timeout_cb_swp(evutil_socket_t fd, short event, void *arg) event 1187 opal/mca/event/libevent2022/libevent/test/regress.c evtimer_add((struct event *)arg, &tv); event 1199 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev, ev_timer; event 1223 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev1; event 1249 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev1; event 1270 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 1301 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 1319 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev1; event 1359 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 1436 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev1, ev2; event 1460 opal/mca/event/libevent2022/libevent/test/regress.c static struct event *readd_test_event_last_added = NULL; event 1462 opal/mca/event/libevent2022/libevent/test/regress.c re_add_read_cb(evutil_socket_t fd, short event, void *arg) event 1465 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev_other = arg; event 1479 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev1, ev2; event 1526 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 1610 opal/mca/event/libevent2022/libevent/test/regress.c static struct event pai_events[3]; event 1661 opal/mca/event/libevent2022/libevent/test/regress.c test_multiple_cb(evutil_socket_t fd, short event, void *arg) event 1663 opal/mca/event/libevent2022/libevent/test/regress.c if (event & EV_READ) event 1665 opal/mca/event/libevent2022/libevent/test/regress.c else if (event & EV_WRITE) event 1672 opal/mca/event/libevent2022/libevent/test/regress.c struct event e1, e2; event 1702 opal/mca/event/libevent2022/libevent/test/regress.c read_once_cb(evutil_socket_t fd, short event, void *arg) event 1727 opal/mca/event/libevent2022/libevent/test/regress.c struct event ev; event 2094 opal/mca/event/libevent2022/libevent/test/regress.c read_called_once_cb(evutil_socket_t fd, short event, void *arg) event 2096 opal/mca/event/libevent2022/libevent/test/regress.c tt_int_op(event, ==, EV_READ); event 2103 opal/mca/event/libevent2022/libevent/test/regress.c timeout_called_once_cb(evutil_socket_t fd, short event, void *arg) event 2105 opal/mca/event/libevent2022/libevent/test/regress.c tt_int_op(event, ==, EV_TIMEOUT); event 2147 opal/mca/event/libevent2022/libevent/test/regress.c struct event *r=NULL, *w=NULL, *t=NULL; event 2212 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev1=NULL, *ev2=NULL; event 2330 opal/mca/event/libevent2022/libevent/test/regress.c many_event_cb(evutil_socket_t fd, short event, void *arg) event 2349 opal/mca/event/libevent2022/libevent/test/regress.c struct event *ev[MANY]; event 2403 opal/mca/event/libevent2022/libevent/test/regress.c tt_int_op(event_get_struct_event_size(), <=, sizeof(struct event)); event 590 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c struct event close_listener_event; event 1573 opal/mca/event/libevent2022/libevent/test/regress_dns.c struct event cancel_event; event 55 opal/mca/event/libevent2022/libevent/test/regress_et.c read_cb(evutil_socket_t fd, short event, void *arg) event 63 opal/mca/event/libevent2022/libevent/test/regress_et.c if (event & EV_ET) event 83 opal/mca/event/libevent2022/libevent/test/regress_et.c struct event *ev = NULL; event 163 opal/mca/event/libevent2022/libevent/test/regress_et.c struct event *ev_et=NULL, *ev_lt=NULL; event 3507 opal/mca/event/libevent2022/libevent/test/regress_http.c terminate_chunked_client(evutil_socket_t fd, short event, void *arg) event 35 opal/mca/event/libevent2022/libevent/test/regress_minheap.c set_random_timeout(struct event *ev) event 57 opal/mca/event/libevent2022/libevent/test/regress_minheap.c struct event *inserted[1024]; event 58 opal/mca/event/libevent2022/libevent/test/regress_minheap.c struct event *e, *last_e; event 64 opal/mca/event/libevent2022/libevent/test/regress_minheap.c inserted[i] = malloc(sizeof(struct event)); event 118 opal/mca/event/libevent2022/libevent/test/regress_thread.c struct event ev; event 162 opal/mca/event/libevent2022/libevent/test/regress_thread.c sigchld_cb(evutil_socket_t fd, short event, void *arg) event 175 opal/mca/event/libevent2022/libevent/test/regress_thread.c notify_fd_cb(evutil_socket_t fd, short event, void *arg) event 185 opal/mca/event/libevent2022/libevent/test/regress_thread.c struct event ev; event 191 opal/mca/event/libevent2022/libevent/test/regress_thread.c struct event *notification_event = NULL; event 192 opal/mca/event/libevent2022/libevent/test/regress_thread.c struct event *sigchld_event = NULL; event 313 opal/mca/event/libevent2022/libevent/test/regress_thread.c struct event wake_one; event 314 opal/mca/event/libevent2022/libevent/test/regress_thread.c struct event wake_all; event 138 opal/mca/event/libevent2022/libevent/test/test-changelist.c write_cb(evutil_socket_t fd, short event, void *arg) event 143 opal/mca/event/libevent2022/libevent/test/test-changelist.c event_del(*(struct event**)arg); event 146 opal/mca/event/libevent2022/libevent/test/test-changelist.c event_add(*(struct event**)arg,NULL); event 149 opal/mca/event/libevent2022/libevent/test/test-changelist.c event_del(*(struct event**)arg); event 154 opal/mca/event/libevent2022/libevent/test/test-changelist.c timeout_cb(evutil_socket_t fd, short event, void *arg) event 157 opal/mca/event/libevent2022/libevent/test/test-changelist.c event_del(*(struct event**)arg); event 164 opal/mca/event/libevent2022/libevent/test/test-changelist.c struct event* ev; event 165 opal/mca/event/libevent2022/libevent/test/test-changelist.c struct event* timeout; event 60 opal/mca/event/libevent2022/libevent/test/test-eof.c read_cb(evutil_socket_t fd, short event, void *arg) event 65 opal/mca/event/libevent2022/libevent/test/test-eof.c if (EV_TIMEOUT & event) { event 91 opal/mca/event/libevent2022/libevent/test/test-eof.c struct event ev; event 49 opal/mca/event/libevent2022/libevent/test/test-time.c struct event *ev[NEVENT]; event 62 opal/mca/event/libevent2022/libevent/test/test-time.c time_cb(evutil_socket_t fd, short event, void *arg) event 100 opal/mca/event/libevent2022/libevent/test/test-time.c ev[i] = malloc(sizeof(struct event)); event 63 opal/mca/event/libevent2022/libevent/test/test-weof.c write_cb(evutil_socket_t fd, short event, void *arg) event 86 opal/mca/event/libevent2022/libevent/test/test-weof.c struct event ev; event 69 opal/mca/event/libevent2022/libevent2022.h typedef struct event opal_event_t; event 39 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-gl.c int opcode, event, error; event 49 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-gl.c if(!XQueryExtension(display, "NV-CONTROL", &opcode, &event, &error)) { event 251 opal/mca/pmix/ext2x/ext2x.c opal_ext2x_event_t *event; event 312 opal/mca/pmix/ext2x/ext2x.c OPAL_LIST_FOREACH(event, &mca_pmix_ext2x_component.events, opal_ext2x_event_t) { event 313 opal/mca/pmix/ext2x/ext2x.c if (evhdlr_registration_id == event->index) { event 319 opal/mca/pmix/ext2x/ext2x.c if (NULL != event->handler) { event 320 opal/mca/pmix/ext2x/ext2x.c OBJ_RETAIN(event); event 322 opal/mca/pmix/ext2x/ext2x.c event->handler(cd->status, &cd->pname, event 325 opal/mca/pmix/ext2x/ext2x.c OBJ_RELEASE(event); event 1033 opal/mca/pmix/ext2x/ext2x.c op->event->index = errhandler_ref; event 1089 opal/mca/pmix/ext2x/ext2x.c op->event = OBJ_NEW(opal_ext2x_event_t); event 1090 opal/mca/pmix/ext2x/ext2x.c op->event->handler = evhandler; event 1091 opal/mca/pmix/ext2x/ext2x.c opal_list_append(&mca_pmix_ext2x_component.events, &op->event->super); event 1105 opal/mca/pmix/ext2x/ext2x.c opal_ext2x_event_t *event; event 1117 opal/mca/pmix/ext2x/ext2x.c OPAL_LIST_FOREACH(event, &mca_pmix_ext2x_component.events, opal_ext2x_event_t) { event 1118 opal/mca/pmix/ext2x/ext2x.c if (evhandler == event->index) { event 1119 opal/mca/pmix/ext2x/ext2x.c opal_list_remove_item(&mca_pmix_ext2x_component.events, &event->super); event 1120 opal/mca/pmix/ext2x/ext2x.c OBJ_RELEASE(event); event 1446 opal/mca/pmix/ext2x/ext2x.c p->event = NULL; event 110 opal/mca/pmix/ext2x/ext2x.h opal_ext2x_event_t *event; event 52 opal/mca/pmix/ext2x/ext2x_client.c opal_ext2x_event_t *event = (opal_ext2x_event_t*)cbdata; event 54 opal/mca/pmix/ext2x/ext2x_client.c OPAL_ACQUIRE_OBJECT(event); event 56 opal/mca/pmix/ext2x/ext2x_client.c event->index = errhandler_ref; event 60 opal/mca/pmix/ext2x/ext2x_client.c OPAL_POST_OBJECT(event); event 61 opal/mca/pmix/ext2x/ext2x_client.c OPAL_PMIX_WAKEUP_THREAD(&event->lock); event 70 opal/mca/pmix/ext2x/ext2x_client.c opal_ext2x_event_t *event; event 150 opal/mca/pmix/ext2x/ext2x_client.c event = OBJ_NEW(opal_ext2x_event_t); event 151 opal/mca/pmix/ext2x/ext2x_client.c opal_list_append(&mca_pmix_ext2x_component.events, &event->super); event 154 opal/mca/pmix/ext2x/ext2x_client.c PMIx_Register_event_handler(NULL, 0, NULL, 0, ext2x_event_hdlr, errreg_cbfunc, event); event 155 opal/mca/pmix/ext2x/ext2x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 171 opal/mca/pmix/ext2x/ext2x_client.c opal_ext2x_event_t *event, *ev2; event 183 opal/mca/pmix/ext2x/ext2x_client.c OPAL_LIST_FOREACH_SAFE(event, ev2, &mca_pmix_ext2x_component.events, opal_ext2x_event_t) { event 184 opal/mca/pmix/ext2x/ext2x_client.c OPAL_PMIX_DESTRUCT_LOCK(&event->lock); event 185 opal/mca/pmix/ext2x/ext2x_client.c OPAL_PMIX_CONSTRUCT_LOCK(&event->lock); event 186 opal/mca/pmix/ext2x/ext2x_client.c PMIx_Deregister_event_handler(event->index, dereg_cbfunc, (void*)event); event 187 opal/mca/pmix/ext2x/ext2x_client.c opal_list_remove_item(&mca_pmix_ext2x_component.events, &event->super); event 190 opal/mca/pmix/ext2x/ext2x_client.c opal_list_append(&evlist, &event->super); event 194 opal/mca/pmix/ext2x/ext2x_client.c OPAL_LIST_FOREACH_SAFE(event, ev2, &evlist, opal_ext2x_event_t) { event 195 opal/mca/pmix/ext2x/ext2x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 196 opal/mca/pmix/ext2x/ext2x_client.c opal_list_remove_item(&evlist, &event->super); event 197 opal/mca/pmix/ext2x/ext2x_client.c OBJ_RELEASE(event); event 214 opal/mca/pmix/ext2x/ext2x_client.c opal_ext2x_event_t *event; event 282 opal/mca/pmix/ext2x/ext2x_client.c event = OBJ_NEW(opal_ext2x_event_t); event 283 opal/mca/pmix/ext2x/ext2x_client.c opal_list_append(&mca_pmix_ext2x_component.events, &event->super); event 286 opal/mca/pmix/ext2x/ext2x_client.c PMIx_Register_event_handler(NULL, 0, NULL, 0, ext2x_event_hdlr, errreg_cbfunc, event); event 287 opal/mca/pmix/ext2x/ext2x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 296 opal/mca/pmix/ext2x/ext2x_client.c opal_ext2x_event_t *event, *ev2; event 306 opal/mca/pmix/ext2x/ext2x_client.c OPAL_LIST_FOREACH_SAFE(event, ev2, &mca_pmix_ext2x_component.events, opal_ext2x_event_t) { event 307 opal/mca/pmix/ext2x/ext2x_client.c OPAL_PMIX_DESTRUCT_LOCK(&event->lock); event 308 opal/mca/pmix/ext2x/ext2x_client.c OPAL_PMIX_CONSTRUCT_LOCK(&event->lock); event 309 opal/mca/pmix/ext2x/ext2x_client.c PMIx_Deregister_event_handler(event->index, dereg_cbfunc, (void*)event); event 310 opal/mca/pmix/ext2x/ext2x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 311 opal/mca/pmix/ext2x/ext2x_client.c opal_list_remove_item(&mca_pmix_ext2x_component.events, &event->super); event 312 opal/mca/pmix/ext2x/ext2x_client.c OBJ_RELEASE(event); event 104 opal/mca/pmix/ext2x/ext2x_server_south.c opal_ext2x_event_t *event; event 156 opal/mca/pmix/ext2x/ext2x_server_south.c event = OBJ_NEW(opal_ext2x_event_t); event 157 opal/mca/pmix/ext2x/ext2x_server_south.c opal_list_append(&mca_pmix_ext2x_component.events, &event->super); event 160 opal/mca/pmix/ext2x/ext2x_server_south.c PMIx_Register_event_handler(NULL, 0, pinfo, 1, ext2x_event_hdlr, errreg_cbfunc, (void*)event); event 161 opal/mca/pmix/ext2x/ext2x_server_south.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 186 opal/mca/pmix/ext2x/ext2x_server_south.c opal_ext2x_event_t *event, *ev2; event 195 opal/mca/pmix/ext2x/ext2x_server_south.c OPAL_LIST_FOREACH_SAFE(event, ev2, &mca_pmix_ext2x_component.events, opal_ext2x_event_t) { event 196 opal/mca/pmix/ext2x/ext2x_server_south.c OPAL_PMIX_DESTRUCT_LOCK(&event->lock); event 197 opal/mca/pmix/ext2x/ext2x_server_south.c OPAL_PMIX_CONSTRUCT_LOCK(&event->lock); event 198 opal/mca/pmix/ext2x/ext2x_server_south.c PMIx_Deregister_event_handler(event->index, dereg_cbfunc, (void*)event); event 199 opal/mca/pmix/ext2x/ext2x_server_south.c opal_list_remove_item(&mca_pmix_ext2x_component.events, &event->super); event 202 opal/mca/pmix/ext2x/ext2x_server_south.c opal_list_append(&evlist, &event->super); event 206 opal/mca/pmix/ext2x/ext2x_server_south.c OPAL_LIST_FOREACH_SAFE(event, ev2, &evlist, opal_ext2x_event_t) { event 207 opal/mca/pmix/ext2x/ext2x_server_south.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 208 opal/mca/pmix/ext2x/ext2x_server_south.c opal_list_remove_item(&evlist, &event->super); event 209 opal/mca/pmix/ext2x/ext2x_server_south.c OBJ_RELEASE(event); event 247 opal/mca/pmix/ext3x/ext3x.c opal_ext3x_event_t *event; event 252 opal/mca/pmix/ext3x/ext3x.c OPAL_LIST_FOREACH(event, &mca_pmix_ext3x_component.events, opal_ext3x_event_t) { event 253 opal/mca/pmix/ext3x/ext3x.c if (cd->id == event->index) { event 259 opal/mca/pmix/ext3x/ext3x.c if (NULL != event->handler) { event 260 opal/mca/pmix/ext3x/ext3x.c OBJ_RETAIN(event); event 262 opal/mca/pmix/ext3x/ext3x.c event->handler(cd->status, &cd->pname, event 265 opal/mca/pmix/ext3x/ext3x.c OBJ_RELEASE(event); event 1262 opal/mca/pmix/ext3x/ext3x.c op->event->index = errhandler_ref; event 1318 opal/mca/pmix/ext3x/ext3x.c op->event = OBJ_NEW(opal_ext3x_event_t); event 1319 opal/mca/pmix/ext3x/ext3x.c op->event->handler = evhandler; event 1320 opal/mca/pmix/ext3x/ext3x.c opal_list_append(&mca_pmix_ext3x_component.events, &op->event->super); event 1334 opal/mca/pmix/ext3x/ext3x.c opal_ext3x_event_t *event; event 1346 opal/mca/pmix/ext3x/ext3x.c OPAL_LIST_FOREACH(event, &mca_pmix_ext3x_component.events, opal_ext3x_event_t) { event 1347 opal/mca/pmix/ext3x/ext3x.c if (evhandler == event->index) { event 1348 opal/mca/pmix/ext3x/ext3x.c opal_list_remove_item(&mca_pmix_ext3x_component.events, &event->super); event 1349 opal/mca/pmix/ext3x/ext3x.c OBJ_RELEASE(event); event 1765 opal/mca/pmix/ext3x/ext3x.c p->event = NULL; event 104 opal/mca/pmix/ext3x/ext3x.h opal_ext3x_event_t *event; event 52 opal/mca/pmix/ext3x/ext3x_client.c opal_ext3x_event_t *event = (opal_ext3x_event_t*)cbdata; event 54 opal/mca/pmix/ext3x/ext3x_client.c OPAL_ACQUIRE_OBJECT(event); event 56 opal/mca/pmix/ext3x/ext3x_client.c event->index = errhandler_ref; event 60 opal/mca/pmix/ext3x/ext3x_client.c OPAL_POST_OBJECT(event); event 61 opal/mca/pmix/ext3x/ext3x_client.c OPAL_PMIX_WAKEUP_THREAD(&event->lock); event 70 opal/mca/pmix/ext3x/ext3x_client.c opal_ext3x_event_t *event; event 150 opal/mca/pmix/ext3x/ext3x_client.c event = OBJ_NEW(opal_ext3x_event_t); event 151 opal/mca/pmix/ext3x/ext3x_client.c opal_list_append(&mca_pmix_ext3x_component.events, &event->super); event 154 opal/mca/pmix/ext3x/ext3x_client.c PMIx_Register_event_handler(NULL, 0, NULL, 0, ext3x_event_hdlr, errreg_cbfunc, event); event 155 opal/mca/pmix/ext3x/ext3x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 171 opal/mca/pmix/ext3x/ext3x_client.c opal_ext3x_event_t *event, *ev2; event 183 opal/mca/pmix/ext3x/ext3x_client.c OPAL_LIST_FOREACH_SAFE(event, ev2, &mca_pmix_ext3x_component.events, opal_ext3x_event_t) { event 184 opal/mca/pmix/ext3x/ext3x_client.c OPAL_PMIX_DESTRUCT_LOCK(&event->lock); event 185 opal/mca/pmix/ext3x/ext3x_client.c OPAL_PMIX_CONSTRUCT_LOCK(&event->lock); event 186 opal/mca/pmix/ext3x/ext3x_client.c PMIx_Deregister_event_handler(event->index, dereg_cbfunc, (void*)event); event 187 opal/mca/pmix/ext3x/ext3x_client.c opal_list_remove_item(&mca_pmix_ext3x_component.events, &event->super); event 190 opal/mca/pmix/ext3x/ext3x_client.c opal_list_append(&evlist, &event->super); event 194 opal/mca/pmix/ext3x/ext3x_client.c OPAL_LIST_FOREACH_SAFE(event, ev2, &evlist, opal_ext3x_event_t) { event 195 opal/mca/pmix/ext3x/ext3x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 196 opal/mca/pmix/ext3x/ext3x_client.c opal_list_remove_item(&evlist, &event->super); event 197 opal/mca/pmix/ext3x/ext3x_client.c OBJ_RELEASE(event); event 214 opal/mca/pmix/ext3x/ext3x_client.c opal_ext3x_event_t *event; event 282 opal/mca/pmix/ext3x/ext3x_client.c event = OBJ_NEW(opal_ext3x_event_t); event 283 opal/mca/pmix/ext3x/ext3x_client.c opal_list_append(&mca_pmix_ext3x_component.events, &event->super); event 286 opal/mca/pmix/ext3x/ext3x_client.c PMIx_Register_event_handler(NULL, 0, NULL, 0, ext3x_event_hdlr, errreg_cbfunc, event); event 287 opal/mca/pmix/ext3x/ext3x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 296 opal/mca/pmix/ext3x/ext3x_client.c opal_ext3x_event_t *event, *ev2; event 306 opal/mca/pmix/ext3x/ext3x_client.c OPAL_LIST_FOREACH_SAFE(event, ev2, &mca_pmix_ext3x_component.events, opal_ext3x_event_t) { event 307 opal/mca/pmix/ext3x/ext3x_client.c OPAL_PMIX_DESTRUCT_LOCK(&event->lock); event 308 opal/mca/pmix/ext3x/ext3x_client.c OPAL_PMIX_CONSTRUCT_LOCK(&event->lock); event 309 opal/mca/pmix/ext3x/ext3x_client.c PMIx_Deregister_event_handler(event->index, dereg_cbfunc, (void*)event); event 310 opal/mca/pmix/ext3x/ext3x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 311 opal/mca/pmix/ext3x/ext3x_client.c opal_list_remove_item(&mca_pmix_ext3x_component.events, &event->super); event 312 opal/mca/pmix/ext3x/ext3x_client.c OBJ_RELEASE(event); event 106 opal/mca/pmix/ext3x/ext3x_server_south.c opal_ext3x_event_t *event; event 158 opal/mca/pmix/ext3x/ext3x_server_south.c event = OBJ_NEW(opal_ext3x_event_t); event 159 opal/mca/pmix/ext3x/ext3x_server_south.c opal_list_append(&mca_pmix_ext3x_component.events, &event->super); event 162 opal/mca/pmix/ext3x/ext3x_server_south.c PMIx_Register_event_handler(NULL, 0, pinfo, 1, ext3x_event_hdlr, errreg_cbfunc, (void*)event); event 163 opal/mca/pmix/ext3x/ext3x_server_south.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 188 opal/mca/pmix/ext3x/ext3x_server_south.c opal_ext3x_event_t *event, *ev2; event 197 opal/mca/pmix/ext3x/ext3x_server_south.c OPAL_LIST_FOREACH_SAFE(event, ev2, &mca_pmix_ext3x_component.events, opal_ext3x_event_t) { event 198 opal/mca/pmix/ext3x/ext3x_server_south.c OPAL_PMIX_DESTRUCT_LOCK(&event->lock); event 199 opal/mca/pmix/ext3x/ext3x_server_south.c OPAL_PMIX_CONSTRUCT_LOCK(&event->lock); event 200 opal/mca/pmix/ext3x/ext3x_server_south.c PMIx_Deregister_event_handler(event->index, dereg_cbfunc, (void*)event); event 201 opal/mca/pmix/ext3x/ext3x_server_south.c opal_list_remove_item(&mca_pmix_ext3x_component.events, &event->super); event 204 opal/mca/pmix/ext3x/ext3x_server_south.c opal_list_append(&evlist, &event->super); event 208 opal/mca/pmix/ext3x/ext3x_server_south.c OPAL_LIST_FOREACH_SAFE(event, ev2, &evlist, opal_ext3x_event_t) { event 209 opal/mca/pmix/ext3x/ext3x_server_south.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 210 opal/mca/pmix/ext3x/ext3x_server_south.c opal_list_remove_item(&evlist, &event->super); event 211 opal/mca/pmix/ext3x/ext3x_server_south.c OBJ_RELEASE(event); event 194 opal/mca/pmix/pmix4x/pmix/examples/server.c static void wait_signal_callback(int fd, short event, void *arg); event 865 opal/mca/pmix/pmix4x/pmix/examples/server.c static void wait_signal_callback(int fd, short event, void *arg) event 704 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c void pmix_iof_write_handler(int _fd, short event, void *cbdata) event 793 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c void pmix_iof_stdin_cb(int fd, short event, void *cbdata) event 849 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c void pmix_iof_read_local_handler(int unusedfd, short event, void *cbdata) event 236 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h PMIX_EXPORT void pmix_iof_write_handler(int fd, short event, void *cbdata); event 238 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h PMIX_EXPORT void pmix_iof_read_local_handler(int unusedfd, short event, void *cbdata); event 239 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h PMIX_EXPORT void pmix_iof_stdin_cb(int fd, short event, void *cbdata); event 586 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c int pmix_event_assign(struct event *ev, pmix_event_base_t *evbase, event 236 opal/mca/pmix/pmix4x/pmix/src/include/types.h typedef struct event pmix_event_t; event 259 opal/mca/pmix/pmix4x/pmix/src/include/types.h PMIX_EXPORT int pmix_event_assign(struct event *ev, pmix_event_base_t *evbase, event 265 opal/mca/pmix/pmix4x/pmix/src/include/types.h PMIX_EXPORT int pmix_event_add(struct event *ev, struct timeval *tv); event 266 opal/mca/pmix/pmix4x/pmix/src/include/types.h PMIX_EXPORT int pmix_event_del(struct event *ev); event 267 opal/mca/pmix/pmix4x/pmix/src/include/types.h PMIX_EXPORT void pmix_event_active (struct event *ev, int res, short ncalls); event 104 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c struct event *ev; event 141 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c int pmix_event_add(struct event *ev, struct timeval *tv) { event 160 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c int pmix_event_del(struct event *ev) { event 178 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c void pmix_event_active (struct event *ev, int res, short ncalls) { event 226 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static void wait_signal_callback(int fd, short event, void *arg); event 1018 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static void wait_signal_callback(int fd, short event, void *arg) event 211 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static void wait_signal_callback(int fd, short event, void *arg); event 1219 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static void wait_signal_callback(int fd, short event, void *arg) event 195 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static void wait_signal_callback(int fd, short event, void *arg); event 847 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static void wait_signal_callback(int fd, short event, void *arg) event 80 opal/mca/pmix/pmix4x/pmix/test/test_server.c static void server_read_cb(int fd, short event, void *arg); event 476 opal/mca/pmix/pmix4x/pmix/test/test_server.c static void server_read_cb(int fd, short event, void *arg) event 246 opal/mca/pmix/pmix4x/pmix4x.c opal_pmix4x_event_t *event; event 251 opal/mca/pmix/pmix4x/pmix4x.c OPAL_LIST_FOREACH(event, &mca_pmix_pmix4x_component.events, opal_pmix4x_event_t) { event 252 opal/mca/pmix/pmix4x/pmix4x.c if (cd->id == event->index) { event 258 opal/mca/pmix/pmix4x/pmix4x.c if (NULL != event->handler) { event 259 opal/mca/pmix/pmix4x/pmix4x.c OBJ_RETAIN(event); event 261 opal/mca/pmix/pmix4x/pmix4x.c event->handler(cd->status, &cd->pname, event 264 opal/mca/pmix/pmix4x/pmix4x.c OBJ_RELEASE(event); event 1249 opal/mca/pmix/pmix4x/pmix4x.c op->event->index = errhandler_ref; event 1305 opal/mca/pmix/pmix4x/pmix4x.c op->event = OBJ_NEW(opal_pmix4x_event_t); event 1306 opal/mca/pmix/pmix4x/pmix4x.c op->event->handler = evhandler; event 1307 opal/mca/pmix/pmix4x/pmix4x.c opal_list_append(&mca_pmix_pmix4x_component.events, &op->event->super); event 1321 opal/mca/pmix/pmix4x/pmix4x.c opal_pmix4x_event_t *event; event 1333 opal/mca/pmix/pmix4x/pmix4x.c OPAL_LIST_FOREACH(event, &mca_pmix_pmix4x_component.events, opal_pmix4x_event_t) { event 1334 opal/mca/pmix/pmix4x/pmix4x.c if (evhandler == event->index) { event 1335 opal/mca/pmix/pmix4x/pmix4x.c opal_list_remove_item(&mca_pmix_pmix4x_component.events, &event->super); event 1336 opal/mca/pmix/pmix4x/pmix4x.c OBJ_RELEASE(event); event 1752 opal/mca/pmix/pmix4x/pmix4x.c p->event = NULL; event 104 opal/mca/pmix/pmix4x/pmix4x.h opal_pmix4x_event_t *event; event 51 opal/mca/pmix/pmix4x/pmix4x_client.c opal_pmix4x_event_t *event = (opal_pmix4x_event_t*)cbdata; event 53 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_ACQUIRE_OBJECT(event); event 55 opal/mca/pmix/pmix4x/pmix4x_client.c event->index = errhandler_ref; event 59 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_POST_OBJECT(event); event 60 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_PMIX_WAKEUP_THREAD(&event->lock); event 69 opal/mca/pmix/pmix4x/pmix4x_client.c opal_pmix4x_event_t *event; event 149 opal/mca/pmix/pmix4x/pmix4x_client.c event = OBJ_NEW(opal_pmix4x_event_t); event 150 opal/mca/pmix/pmix4x/pmix4x_client.c opal_list_append(&mca_pmix_pmix4x_component.events, &event->super); event 153 opal/mca/pmix/pmix4x/pmix4x_client.c PMIx_Register_event_handler(NULL, 0, NULL, 0, pmix4x_event_hdlr, errreg_cbfunc, event); event 154 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 170 opal/mca/pmix/pmix4x/pmix4x_client.c opal_pmix4x_event_t *event, *ev2; event 182 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_LIST_FOREACH_SAFE(event, ev2, &mca_pmix_pmix4x_component.events, opal_pmix4x_event_t) { event 183 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_PMIX_DESTRUCT_LOCK(&event->lock); event 184 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_PMIX_CONSTRUCT_LOCK(&event->lock); event 185 opal/mca/pmix/pmix4x/pmix4x_client.c PMIx_Deregister_event_handler(event->index, dereg_cbfunc, (void*)event); event 186 opal/mca/pmix/pmix4x/pmix4x_client.c opal_list_remove_item(&mca_pmix_pmix4x_component.events, &event->super); event 189 opal/mca/pmix/pmix4x/pmix4x_client.c opal_list_append(&evlist, &event->super); event 193 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_LIST_FOREACH_SAFE(event, ev2, &evlist, opal_pmix4x_event_t) { event 194 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 195 opal/mca/pmix/pmix4x/pmix4x_client.c opal_list_remove_item(&evlist, &event->super); event 196 opal/mca/pmix/pmix4x/pmix4x_client.c OBJ_RELEASE(event); event 213 opal/mca/pmix/pmix4x/pmix4x_client.c opal_pmix4x_event_t *event; event 281 opal/mca/pmix/pmix4x/pmix4x_client.c event = OBJ_NEW(opal_pmix4x_event_t); event 282 opal/mca/pmix/pmix4x/pmix4x_client.c opal_list_append(&mca_pmix_pmix4x_component.events, &event->super); event 285 opal/mca/pmix/pmix4x/pmix4x_client.c PMIx_Register_event_handler(NULL, 0, NULL, 0, pmix4x_event_hdlr, errreg_cbfunc, event); event 286 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 295 opal/mca/pmix/pmix4x/pmix4x_client.c opal_pmix4x_event_t *event, *ev2; event 305 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_LIST_FOREACH_SAFE(event, ev2, &mca_pmix_pmix4x_component.events, opal_pmix4x_event_t) { event 306 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_PMIX_DESTRUCT_LOCK(&event->lock); event 307 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_PMIX_CONSTRUCT_LOCK(&event->lock); event 308 opal/mca/pmix/pmix4x/pmix4x_client.c PMIx_Deregister_event_handler(event->index, dereg_cbfunc, (void*)event); event 309 opal/mca/pmix/pmix4x/pmix4x_client.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 310 opal/mca/pmix/pmix4x/pmix4x_client.c opal_list_remove_item(&mca_pmix_pmix4x_component.events, &event->super); event 311 opal/mca/pmix/pmix4x/pmix4x_client.c OBJ_RELEASE(event); event 105 opal/mca/pmix/pmix4x/pmix4x_server_south.c opal_pmix4x_event_t *event; event 157 opal/mca/pmix/pmix4x/pmix4x_server_south.c event = OBJ_NEW(opal_pmix4x_event_t); event 158 opal/mca/pmix/pmix4x/pmix4x_server_south.c opal_list_append(&mca_pmix_pmix4x_component.events, &event->super); event 161 opal/mca/pmix/pmix4x/pmix4x_server_south.c PMIx_Register_event_handler(NULL, 0, pinfo, 1, pmix4x_event_hdlr, errreg_cbfunc, (void*)event); event 162 opal/mca/pmix/pmix4x/pmix4x_server_south.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 187 opal/mca/pmix/pmix4x/pmix4x_server_south.c opal_pmix4x_event_t *event, *ev2; event 196 opal/mca/pmix/pmix4x/pmix4x_server_south.c OPAL_LIST_FOREACH_SAFE(event, ev2, &mca_pmix_pmix4x_component.events, opal_pmix4x_event_t) { event 197 opal/mca/pmix/pmix4x/pmix4x_server_south.c OPAL_PMIX_DESTRUCT_LOCK(&event->lock); event 198 opal/mca/pmix/pmix4x/pmix4x_server_south.c OPAL_PMIX_CONSTRUCT_LOCK(&event->lock); event 199 opal/mca/pmix/pmix4x/pmix4x_server_south.c PMIx_Deregister_event_handler(event->index, dereg_cbfunc, (void*)event); event 200 opal/mca/pmix/pmix4x/pmix4x_server_south.c opal_list_remove_item(&mca_pmix_pmix4x_component.events, &event->super); event 203 opal/mca/pmix/pmix4x/pmix4x_server_south.c opal_list_append(&evlist, &event->super); event 207 opal/mca/pmix/pmix4x/pmix4x_server_south.c OPAL_LIST_FOREACH_SAFE(event, ev2, &evlist, opal_pmix4x_event_t) { event 208 opal/mca/pmix/pmix4x/pmix4x_server_south.c OPAL_PMIX_WAIT_THREAD(&event->lock); event 209 opal/mca/pmix/pmix4x/pmix4x_server_south.c opal_list_remove_item(&evlist, &event->super); event 210 opal/mca/pmix/pmix4x/pmix4x_server_south.c OBJ_RELEASE(event); event 42 opal/mca/rcache/gpusm/rcache_gpusm.h uintptr_t event; /* CUevent */ event 51 opal/mca/rcache/gpusm/rcache_gpusm_module.c mca_common_cuda_construct_event_and_handle(&item->event, event 60 opal/mca/rcache/gpusm/rcache_gpusm_module.c mca_common_cuda_destruct_event(item->event); event 869 opal/runtime/opal_cr.c int opal_cr_user_inc_register_callback(opal_cr_user_inc_callback_event_t event, event 873 opal/runtime/opal_cr.c if (event >= OPAL_CR_INC_MAX) { event 877 opal/runtime/opal_cr.c if( NULL != cur_user_coord_callback[event] ) { event 878 opal/runtime/opal_cr.c *prev_function = cur_user_coord_callback[event]; event 883 opal/runtime/opal_cr.c cur_user_coord_callback[event] = function; event 888 opal/runtime/opal_cr.c int ompi_trigger_user_inc_callback(opal_cr_user_inc_callback_event_t event, event 891 opal/runtime/opal_cr.c if( NULL == cur_user_coord_callback[event] ) { event 895 opal/runtime/opal_cr.c if (event >= OPAL_CR_INC_MAX) { event 899 opal/runtime/opal_cr.c return ((cur_user_coord_callback[event])(event, state)); event 325 opal/runtime/opal_cr.h typedef int (*opal_cr_user_inc_callback_fn_t)(opal_cr_user_inc_callback_event_t event, event 329 opal/runtime/opal_cr.h (opal_cr_user_inc_callback_event_t event, event 333 opal/runtime/opal_cr.h OPAL_DECLSPEC int ompi_trigger_user_inc_callback(opal_cr_user_inc_callback_event_t event, event 86 orte/mca/ess/base/ess_base_std_orted.c static void signal_forward_callback(int fd, short event, void *arg); event 634 orte/mca/ess/base/ess_base_std_orted.c static void signal_forward_callback(int fd, short event, void *arg) event 120 orte/mca/ess/hnp/ess_hnp_module.c static void signal_forward_callback(int fd, short event, void *arg); event 979 orte/mca/ess/hnp/ess_hnp_module.c static void signal_forward_callback(int fd, short event, void *arg) event 99 orte/mca/filem/raw/filem_raw_module.c static void write_handler(int fd, short event, void *cbdata); event 1106 orte/mca/filem/raw/filem_raw_module.c static void write_handler(int fd, short event, void *cbdata) event 282 orte/mca/iof/base/base.h ORTE_DECLSPEC void orte_iof_base_write_handler(int fd, short event, void *cbdata); event 299 orte/mca/iof/base/iof_base_output.c void orte_iof_base_write_handler(int _fd, short event, void *cbdata) event 59 orte/mca/iof/hnp/iof_hnp.c static void stdin_write_handler(int fd, short event, void *cbdata); event 529 orte/mca/iof/hnp/iof_hnp.c static void stdin_write_handler(int fd, short event, void *cbdata) event 77 orte/mca/iof/hnp/iof_hnp.h void orte_iof_hnp_read_local_handler(int fd, short event, void *cbdata); event 78 orte/mca/iof/hnp/iof_hnp.h void orte_iof_hnp_stdin_cb(int fd, short event, void *cbdata); event 52 orte/mca/iof/hnp/iof_hnp_read.c static void restart_stdin(int fd, short event, void *cbdata) event 81 orte/mca/iof/hnp/iof_hnp_read.c void orte_iof_hnp_stdin_cb(int fd, short event, void *cbdata) event 101 orte/mca/iof/hnp/iof_hnp_read.c void orte_iof_hnp_read_local_handler(int fd, short event, void *cbdata) event 61 orte/mca/iof/orted/iof_orted.c static void stdin_write_handler(int fd, short event, void *cbdata); event 384 orte/mca/iof/orted/iof_orted.c static void stdin_write_handler(int _fd, short event, void *cbdata) event 77 orte/mca/iof/orted/iof_orted.h void orte_iof_orted_read_handler(int fd, short event, void *data); event 47 orte/mca/iof/orted/iof_orted_read.c void orte_iof_orted_read_handler(int fd, short event, void *cbdata) event 871 orte/mca/odls/base/odls_base_default_fns.c static void timer_cb(int fd, short event, void *cbdata) event 160 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set(orte_oob_base.ev_base, &listener->event, event 165 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set_priority(&listener->event, ORTE_MSG_PRI); event 167 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_add(&listener->event, 0); event 845 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set(orte_event_base, listener->event, event 850 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_set_priority(listener->event, ORTE_MSG_PRI); event 851 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_add(listener->event, 0); event 945 orte/mca/oob/tcp/oob_tcp_listener.c static void tcp_ev_cons(mca_oob_tcp_listener_t* event) event 947 orte/mca/oob/tcp/oob_tcp_listener.c event->ev_active = false; event 948 orte/mca/oob/tcp/oob_tcp_listener.c event->tcp6 = false; event 949 orte/mca/oob/tcp/oob_tcp_listener.c event->sd = -1; event 950 orte/mca/oob/tcp/oob_tcp_listener.c event->port = 0; event 952 orte/mca/oob/tcp/oob_tcp_listener.c static void tcp_ev_des(mca_oob_tcp_listener_t* event) event 954 orte/mca/oob/tcp/oob_tcp_listener.c if (event->ev_active) { event 955 orte/mca/oob/tcp/oob_tcp_listener.c opal_event_del(&event->event); event 957 orte/mca/oob/tcp/oob_tcp_listener.c event->ev_active = false; event 958 orte/mca/oob/tcp/oob_tcp_listener.c if (0 <= event->sd) { event 959 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(event->sd); event 960 orte/mca/oob/tcp/oob_tcp_listener.c event->sd = -1; event 43 orte/mca/oob/tcp/oob_tcp_listener.h opal_event_t event; event 54 orte/mca/plm/base/base.h ORTE_DECLSPEC void orte_plm_base_app_report_launch(int fd, short event, void *data); event 55 orte/mca/plm/base/base.h ORTE_DECLSPEC void orte_plm_base_receive_process_msg(int fd, short event, void *data); event 571 orte/mca/plm/base/plm_base_launch_support.c static void timer_cb(int fd, short event, void *cbdata) event 53 orte/mca/plm/base/plm_base_orted_cmds.c static void failed_cmd(int fd, short event, void *cbdata) event 414 orte/mca/plm/base/plm_base_receive.c void orte_plm_base_receive_process_msg(int fd, short event, void *data) event 428 orte/mca/plm/tm/plm_tm_module.c tm_event_t event; event 434 orte/mca/plm/tm/plm_tm_module.c rc = tm_poll(TM_NULL_EVENT, &event, 1, &local_err); event 211 orte/mca/snapc/base/snapc_base_fns.c op->event = ORTE_SNAPC_OP_NONE; event 228 orte/mca/snapc/base/snapc_base_fns.c op->event = ORTE_SNAPC_OP_NONE; event 1274 orte/mca/snapc/full/snapc_full_app.c if( ORTE_SNAPC_OP_QUIESCE_END == datum->event) { event 1308 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_QUIESCE_CHECKPOINT == datum->event) { event 1345 orte/mca/snapc/full/snapc_full_app.c datum->event)); event 1362 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(datum->event), 1, OPAL_INT))) { event 1368 orte/mca/snapc/full/snapc_full_app.c if( ORTE_SNAPC_OP_RESTART == datum->event) { event 1380 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_MIGRATE == datum->event) { event 1464 orte/mca/snapc/full/snapc_full_app.c if( ORTE_SNAPC_OP_CHECKPOINT == datum->event) { event 1542 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_RESTART == datum->event) { event 1552 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_MIGRATE == datum->event) { event 1562 orte/mca/snapc/full/snapc_full_app.c datum->event)); event 1596 orte/mca/snapc/full/snapc_full_app.c datum->event)); event 1602 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_QUIESCE_START == datum->event) { event 1617 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_QUIESCE_END == datum->event) { event 249 orte/mca/snapc/snapc.h orte_snapc_base_request_op_event_t event; event 119 orte/mca/sstore/stage/sstore_stage.h short event, event 42 orte/orted/orted.h ORTE_DECLSPEC void orte_daemon_cmd_processor(int fd, short event, void *data); event 153 orte/orted/orted_submit.c static void attach_debugger(int fd, short event, void *arg); event 2514 orte/orted/orted_submit.c void orte_debugger_init_after_spawn(int fd, short event, void *cbdata) event 2914 orte/orted/orted_submit.c static void attach_debugger(int fd, short event, void *arg) event 3100 orte/orted/orted_submit.c void orte_debugger_detached(int fd, short event, void *cbdata) event 38 orte/orted/orted_submit.h ORTE_DECLSPEC void orte_debugger_init_after_spawn(int fd, short event, void *arg); event 39 orte/orted/orted_submit.h ORTE_DECLSPEC void orte_debugger_detached(int fd, short event, void *arg); event 105 orte/runtime/orte_wait.c static void wait_signal_callback(int fd, short event, void *arg); event 231 orte/runtime/orte_wait.c static void wait_signal_callback(int fd, short event, void *arg) event 39 orte/test/system/evpri-test.c struct event *t1 = (struct event*)arg; event 40 orte/test/system/evpri-test.c struct event *t2; event 48 orte/test/system/evpri-test.c t2 = (struct event*)malloc(sizeof(struct event)); event 66 orte/test/system/evpri-test.c struct event ev; event 67 orte/test/system/evpri-test.c struct event *t1; event 87 orte/test/system/evpri-test.c t1 = (struct event*)malloc(sizeof(struct event)); event 17 orte/test/system/evpri-test2.c static struct event ev2, ev3; event 71 orte/test/system/evpri-test2.c struct event ev1; event 107 orte/test/system/evthread-test.c static struct event stop_event; event 37 orte/test/system/test-time.c static void time_cb(int fd, short event, void *arg) event 55 orte/util/comm/comm.c static void quicktime_cb(int fd, short event, void *cbdata) event 335 orte/util/show_help.c static void show_accumulated_duplicates(int fd, short event, void *context) event 171 oshmem/mca/spml/ucx/spml_ucx.h void mca_spml_ucx_async_cb(int fd, short event, void *cbdata); event 169 oshmem/mca/spml/ucx/spml_ucx_component.c void mca_spml_ucx_async_cb(int fd, short event, void *cbdata) event 34 test/event/event-test.c fifo_read(int fd, short event, void *arg) event 47 test/event/event-test.c fd, event, arg); event 36 test/event/signal-test.c signal_cb(int fd, short event, void *arg) event 34 test/event/time-test.c timeout_cb(int fd, short event, void *arg)