/dports/www/trafficserver/trafficserver-9.1.1/iocore/eventsystem/ |
H A D | P_UnixEThread.h | 40 EThread::schedule_imm(Continuation *cont, int callback_event, void *cookie) in schedule_imm() argument 43 e->callback_event = callback_event; in schedule_imm() 52 e->callback_event = callback_event; in schedule_at() 61 e->callback_event = callback_event; in schedule_in() 70 e->callback_event = callback_event; in schedule_every() 109 EThread::schedule_imm_local(Continuation *cont, int callback_event, void *cookie) in schedule_imm_local() argument 112 e->callback_event = callback_event; in schedule_imm_local() 121 e->callback_event = callback_event; in schedule_at_local() 130 e->callback_event = callback_event; in schedule_in_local() 139 e->callback_event = callback_event; in schedule_every_local() [all …]
|
H A D | P_UnixEventProcessor.h | 130 EventProcessor::schedule_imm(Continuation *cont, EventType et, int callback_event, void *cookie) in schedule_imm() argument 138 e->callback_event = callback_event; in schedule_imm() 144 EventProcessor::schedule_at(Continuation *cont, ink_hrtime t, EventType et, int callback_event, voi… in schedule_at() argument 150 e->callback_event = callback_event; in schedule_at() 156 EventProcessor::schedule_in(Continuation *cont, ink_hrtime t, EventType et, int callback_event, voi… in schedule_in() argument 161 e->callback_event = callback_event; in schedule_in() 167 EventProcessor::schedule_every(Continuation *cont, ink_hrtime t, EventType et, int callback_event, … in schedule_every() argument 173 e->callback_event = callback_event; in schedule_every()
|
H A D | I_EventProcessor.h | 152 …Event *schedule_imm(Continuation *c, EventType event_type = ET_CALL, int callback_event = EVENT_IM… 175 …tion *c, ink_hrtime atimeout_at, EventType event_type = ET_CALL, int callback_event = EVENT_INTERV… 197 …tion *c, ink_hrtime atimeout_in, EventType event_type = ET_CALL, int callback_event = EVENT_INTERV… 219 …inuation *c, ink_hrtime aperiod, EventType event_type = ET_CALL, int callback_event = EVENT_INTERV… 230 Event *reschedule_imm(Event *e, int callback_event = EVENT_IMMEDIATE); 231 Event *reschedule_at(Event *e, ink_hrtime atimeout_at, int callback_event = EVENT_INTERVAL); 232 Event *reschedule_in(Event *e, ink_hrtime atimeout_in, int callback_event = EVENT_INTERVAL); 233 Event *reschedule_every(Event *e, ink_hrtime aperiod, int callback_event = EVENT_INTERVAL);
|
H A D | I_EThread.h | 128 …Event *schedule_imm(Continuation *c, int callback_event = EVENT_IMMEDIATE, void *cookie = nullptr); 149 …Event *schedule_at(Continuation *c, ink_hrtime atimeout_at, int callback_event = EVENT_INTERVAL, v… 169 …Event *schedule_in(Continuation *c, ink_hrtime atimeout_in, int callback_event = EVENT_INTERVAL, v… 190 …Event *schedule_every(Continuation *c, ink_hrtime aperiod, int callback_event = EVENT_INTERVAL, vo… 208 …Event *schedule_imm_local(Continuation *c, int callback_event = EVENT_IMMEDIATE, void *cookie = nu… 229 …Event *schedule_at_local(Continuation *c, ink_hrtime atimeout_at, int callback_event = EVENT_INTER… 250 …Event *schedule_in_local(Continuation *c, ink_hrtime atimeout_in, int callback_event = EVENT_INTER… 270 …Event *schedule_every_local(Continuation *c, ink_hrtime aperiod, int callback_event = EVENT_INTERV…
|
H A D | I_Event.h | 165 void schedule_imm(int callback_event = EVENT_IMMEDIATE); 176 void schedule_at(ink_hrtime atimeout_at, int callback_event = EVENT_INTERVAL); 187 void schedule_in(ink_hrtime atimeout_in, int callback_event = EVENT_INTERVAL); 198 void schedule_every(ink_hrtime aperiod, int callback_event = EVENT_INTERVAL); 212 int callback_event = 0; variable
|
H A D | UnixEvent.cc | 37 callback_event = acallback_event; in schedule_imm() 54 callback_event = acallback_event; in schedule_at() 72 callback_event = acallback_event; in schedule_in() 89 callback_event = acallback_event; in schedule_every()
|
H A D | UnixEventProcessor.cc | 309 e->callback_event = event_code; in make_event_for_scheduling() 414 nev->callback_event = ev->callback_event; in initThreadState() 417 ev->continuation->handleEvent(ev->callback_event, nev); in initThreadState()
|
/dports/devel/grpc130/grpc-1.30.2/src/python/grpcio_tests/tests/unit/ |
H A D | _auth_test.py | 42 callback_event = threading.Event() 47 callback_event.set() 51 self.assertTrue(callback_event.wait(1.0)) 54 callback_event = threading.Event() 58 callback_event.set() 62 self.assertTrue(callback_event.wait(1.0)) 68 callback_event = threading.Event() 73 callback_event.set() 77 self.assertTrue(callback_event.wait(1.0))
|
/dports/devel/grpc134/grpc-1.34.1/src/python/grpcio_tests/tests/unit/ |
H A D | _auth_test.py | 42 callback_event = threading.Event() 47 callback_event.set() 51 self.assertTrue(callback_event.wait(1.0)) 54 callback_event = threading.Event() 58 callback_event.set() 62 self.assertTrue(callback_event.wait(1.0)) 68 callback_event = threading.Event() 73 callback_event.set() 77 self.assertTrue(callback_event.wait(1.0))
|
/dports/devel/grpc/grpc-1.42.0/src/python/grpcio_tests/tests/unit/ |
H A D | _auth_test.py | 42 callback_event = threading.Event() 47 callback_event.set() 51 self.assertTrue(callback_event.wait(1.0)) 54 callback_event = threading.Event() 58 callback_event.set() 62 self.assertTrue(callback_event.wait(1.0)) 68 callback_event = threading.Event() 73 callback_event.set() 77 self.assertTrue(callback_event.wait(1.0))
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/python/grpcio_tests/tests/unit/ |
H A D | _auth_test.py | 42 callback_event = threading.Event() 47 callback_event.set() 51 self.assertTrue(callback_event.wait(1.0)) 54 callback_event = threading.Event() 58 callback_event.set() 62 self.assertTrue(callback_event.wait(1.0)) 68 callback_event = threading.Event() 73 callback_event.set() 77 self.assertTrue(callback_event.wait(1.0))
|
/dports/math/py-or-tools/or-tools-9.2/ortools/math_opt/validators/ |
H A D | callback_validator.cc | 254 const CallbackEventProto callback_event, in ValidateCallbackResultProto() argument 259 CHECK_OK(IsEventRegistered(callback_event, callback_registration)); in ValidateCallbackResultProto() 262 if (callback_event != CALLBACK_EVENT_MIP_NODE && in ValidateCallbackResultProto() 263 callback_event != CALLBACK_EVENT_MIP_SOLUTION) { in ValidateCallbackResultProto() 266 callback_event, "(", ProtoEnumToString(callback_event), ")")); in ValidateCallbackResultProto() 276 if (callback_event != CALLBACK_EVENT_MIP_NODE) { in ValidateCallbackResultProto() 280 callback_event, "(", ProtoEnumToString(callback_event), ")")); in ValidateCallbackResultProto()
|
/dports/devel/avr-gdb/gdb-7.3.1/gdb/gdbserver/ |
H A D | event-loop.c | 154 struct callback_event struct 159 struct callback_event *next; argument 166 struct callback_event *first; 167 struct callback_event *last; 260 struct callback_event *event_ptr; in append_callback_event() 281 struct callback_event **p; in delete_callback_event() 285 struct callback_event *event_ptr = *p; in delete_callback_event() 306 struct callback_event *event_ptr; in process_callback()
|
/dports/devel/gdb761/gdb-7.6.1/gdb/gdbserver/ |
H A D | event-loop.c | 136 struct callback_event struct 141 struct callback_event *next; argument 148 struct callback_event *first; 149 struct callback_event *last; 207 struct callback_event *event_ptr; in append_callback_event() 228 struct callback_event **p; in delete_callback_event() 232 struct callback_event *event_ptr = *p; in delete_callback_event() 253 struct callback_event *event_ptr; in process_callback()
|
/dports/devel/py-numba/numba-0.51.2/numba/cuda/tests/cudadrv/ |
H A D | test_streams.py | 33 callback_event = threading.Event() 34 stream.add_callback(callback, callback_event) 35 self.assertTrue(callback_event.wait(1.0))
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/hv/ |
H A D | hv_fcopy.c | 74 tasklet_schedule(&((struct vmbus_channel *)channel)->callback_event); in fcopy_poll_wrapper() 393 tasklet_disable(&channel->callback_event); in hv_fcopy_pre_suspend() 414 tasklet_enable(&channel->callback_event); in hv_fcopy_pre_resume()
|
H A D | hv_snapshot.c | 83 tasklet_schedule(&((struct vmbus_channel *)channel)->callback_event); in vss_poll_wrapper() 420 tasklet_disable(&channel->callback_event); in hv_vss_pre_suspend() 442 tasklet_enable(&channel->callback_event); in hv_vss_pre_resume()
|
H A D | hv_kvp.c | 116 tasklet_schedule(&((struct vmbus_channel *)channel)->callback_event); in kvp_poll_wrapper() 163 tasklet_schedule(&kvp_transaction.recv_channel->callback_event); in kvp_host_handshake_func() 788 tasklet_disable(&channel->callback_event); in hv_kvp_pre_suspend() 811 tasklet_enable(&channel->callback_event); in hv_kvp_pre_resume()
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/hv/ |
H A D | hv_fcopy.c | 74 tasklet_schedule(&((struct vmbus_channel *)channel)->callback_event); in fcopy_poll_wrapper() 393 tasklet_disable(&channel->callback_event); in hv_fcopy_pre_suspend() 414 tasklet_enable(&channel->callback_event); in hv_fcopy_pre_resume()
|
H A D | hv_snapshot.c | 83 tasklet_schedule(&((struct vmbus_channel *)channel)->callback_event); in vss_poll_wrapper() 420 tasklet_disable(&channel->callback_event); in hv_vss_pre_suspend() 442 tasklet_enable(&channel->callback_event); in hv_vss_pre_resume()
|
H A D | hv_kvp.c | 116 tasklet_schedule(&((struct vmbus_channel *)channel)->callback_event); in kvp_poll_wrapper() 163 tasklet_schedule(&kvp_transaction.recv_channel->callback_event); in kvp_host_handshake_func() 788 tasklet_disable(&channel->callback_event); in hv_kvp_pre_suspend() 811 tasklet_enable(&channel->callback_event); in hv_kvp_pre_resume()
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/hv/ |
H A D | hv_fcopy.c | 74 tasklet_schedule(&((struct vmbus_channel *)channel)->callback_event); in fcopy_poll_wrapper() 393 tasklet_disable(&channel->callback_event); in hv_fcopy_pre_suspend() 414 tasklet_enable(&channel->callback_event); in hv_fcopy_pre_resume()
|
H A D | hv_snapshot.c | 83 tasklet_schedule(&((struct vmbus_channel *)channel)->callback_event); in vss_poll_wrapper() 420 tasklet_disable(&channel->callback_event); in hv_vss_pre_suspend() 442 tasklet_enable(&channel->callback_event); in hv_vss_pre_resume()
|
H A D | hv_kvp.c | 116 tasklet_schedule(&((struct vmbus_channel *)channel)->callback_event); in kvp_poll_wrapper() 163 tasklet_schedule(&kvp_transaction.recv_channel->callback_event); in kvp_host_handshake_func() 788 tasklet_disable(&channel->callback_event); in hv_kvp_pre_suspend() 811 tasklet_enable(&channel->callback_event); in hv_kvp_pre_resume()
|
/dports/devel/p5-POE/POE-1.368/t/90_regression/ |
H A D | averell-callback-ret.t | 37 callback_event => sub { return 42 },
|