Searched refs:stop_event (Results 1 – 11 of 11) sorted by relevance
| /third_party/boost/libs/mpl/example/fsm/ |
| D | player.cpp | 29 struct stop_event : event<stop_event> {}; struct in player
50 bool do_stop(stop_event const&) { std::cout << "player::do_stop\n"; return true; } in do_stop()
59 , transition<playing, stop_event, stopped, &player::do_stop>
62 , transition<paused, stop_event, stopped, &player::do_stop>
74 p.process_event(player::stop_event()); in main()
|
| /third_party/grpc/examples/python/cancellation/ |
| D | server.py | 44 stop_event = threading.Event()
48 stop_event.set()
55 request.ideal_hamming_distance, stop_event,
66 stop_event = threading.Event()
70 stop_event.set()
76 stop_event,
|
| D | search.py | 101 stop_event, argument
129 if stop_event.is_set():
|
| D | README.md | 101 stop_event = threading.Event()
104 stop_event.set()
106 secret = _find_secret(stop_event)
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _signal_handling_test.py | 77 stop_event = threading.Event()
81 stop_event.set()
85 stop_event.wait()
93 stop_event = threading.Event()
97 stop_event.set()
101 stop_event.wait()
|
| /third_party/glib/glib/ |
| D | gpoll.c | 371 GPollFD stop_event = { 0, }; in g_poll() local
418 stop_event.fd = (gint64)CreateEventW (NULL, TRUE, FALSE, NULL); in g_poll()
420 stop_event.fd = (gint)CreateEventW (NULL, TRUE, FALSE, NULL); in g_poll()
422 stop_event.events = G_IO_IN; in g_poll()
435 fill_poll_thread_data (fds + fds_idx, thread_fds, timeout, &stop_event, &threads_data[i]); in g_poll()
456 if (!SetEvent ((HANDLE)stop_event.fd)) in g_poll()
487 CloseHandle ((HANDLE)stop_event.fd); in g_poll()
|
| /third_party/grpc/src/python/grpcio_tests/tests/stress/ |
| D | client.py | 121 stop_event = threading.Event()
137 exception_queue, stop_event)
151 stop_event.set()
|
| D | test_runner.py | 37 def __init__(self, stub, test_cases, hist, exception_queue, stop_event): argument
40 self._stop_event = stop_event
|
| /third_party/python/Lib/multiprocessing/ |
| D | managers.py | 168 self.stop_event = threading.Event()
175 while not self.stop_event.is_set():
176 self.stop_event.wait(1)
249 while not self.stop_event.is_set():
371 self.stop_event.set()
|
| /third_party/python/Doc/howto/ |
| D | logging-cookbook.rst | 1528 def listener_process(q, stop_event, config):
1549 stop_event.wait()
1689 stop_event = Event()
1691 args=(q, stop_event, config_listener))
1700 stop_event.set()
|
| /third_party/libinput/test/ |
| D | test-touchpad.c | 4453 struct libinput_event_pointer *stop_event; in START_TEST() local
4477 stop_event = litest_is_axis_event(libinput_get_event(li), in START_TEST()
4480 libinput_event_destroy(libinput_event_pointer_get_base_event(stop_event)); in START_TEST()
|