| /third_party/glib/glib/ |
| D | gwakeup.c | 73 HANDLE wakeup; in g_wakeup_new() local
75 wakeup = CreateEvent (NULL, TRUE, FALSE, NULL); in g_wakeup_new()
77 if (wakeup == NULL) in g_wakeup_new()
81 return (GWakeup *) wakeup; in g_wakeup_new()
85 g_wakeup_get_pollfd (GWakeup *wakeup, in g_wakeup_get_pollfd() argument
88 poll_fd->fd = (gintptr) wakeup; in g_wakeup_get_pollfd()
93 g_wakeup_acknowledge (GWakeup *wakeup) in g_wakeup_acknowledge() argument
95 ResetEvent ((HANDLE) wakeup); in g_wakeup_acknowledge()
99 g_wakeup_signal (GWakeup *wakeup) in g_wakeup_signal() argument
101 SetEvent ((HANDLE) wakeup); in g_wakeup_signal()
[all …]
|
| D | gwakeup.h | 28 void g_wakeup_free (GWakeup *wakeup);
30 void g_wakeup_get_pollfd (GWakeup *wakeup,
32 void g_wakeup_signal (GWakeup *wakeup);
33 void g_wakeup_acknowledge (GWakeup *wakeup);
|
| D | glib-private.h | 99 void (* g_wakeup_free) (GWakeup *wakeup);
100 void (* g_wakeup_get_pollfd) (GWakeup *wakeup,
102 void (* g_wakeup_signal) (GWakeup *wakeup);
103 void (* g_wakeup_acknowledge) (GWakeup *wakeup);
|
| /third_party/glib/glib/tests/ |
| D | gwakeuptest.c | 12 check_signaled (GWakeup *wakeup) in check_signaled() argument
16 g_wakeup_get_pollfd (wakeup, &fd); in check_signaled()
21 wait_for_signaled (GWakeup *wakeup) in wait_for_signaled() argument
25 g_wakeup_get_pollfd (wakeup, &fd); in wait_for_signaled()
32 GWakeup *wakeup; in test_semantics() local
38 wakeup = g_wakeup_new (); in test_semantics()
39 g_assert (!check_signaled (wakeup)); in test_semantics()
41 g_wakeup_signal (wakeup); in test_semantics()
42 g_assert (check_signaled (wakeup)); in test_semantics()
44 g_wakeup_acknowledge (wakeup); in test_semantics()
[all …]
|
| /third_party/ltp/testcases/realtime/func/prio-wake/ |
| D | prio-wake.c | 23 * Test priority ordered wakeup with pthread_cond_*
31 * - Once all the threads finish execution, the start and wakeup times
33 * - The output must indicate that the thread wakeup happened in a
102 struct array wakeup = { NULL, 0 }; variable
158 wakeup.arr[wakeup.counter++] = mypri; in worker_thread()
182 wakeup.arr = malloc(rt_threads * sizeof(int)); in main()
183 wakeup.counter = 0; in main()
185 printf("Priority Ordered Wakeup\n"); in main()
222 for (i = 0; i < (wakeup.counter - 1); i++) { in main()
223 if (wakeup.arr[i] < wakeup.arr[i + 1]) { in main()
[all …]
|
| /third_party/grpc/test/cpp/common/ |
| D | timer_test.cc | 73 // We expect to get 1 wakeup per second. Sometimes we also get a wakeup in TEST_F()
95 // We expect to get 1 wakeup/second + 1 wakeup for the expired timer + maybe 1 in TEST_F()
96 // wakeup during initialization. i.e. in 1.5 seconds we expect 2 or 3 wakeups. in TEST_F()
122 // We expect to get 1 wakeup/second + 1 wakeup for per timer fired + maybe 1 in TEST_F()
123 // wakeup during initialization. i.e. in 1.5 seconds we expect 11 or 12 in TEST_F()
155 // We expect to get 1 wakeup/second + 1 wakeup per timer fired + maybe 1 in TEST_F()
156 // wakeup during initialization. i.e. in 1.5 seconds we expect 6 or 7 wakeups. in TEST_F()
|
| /third_party/curl/tests/data/ |
| D | test1564 | 5 wakeup
16 wakeup
25 wakeup before poll with no easy handles
|
| D | test1565 | 8 wakeup
25 wakeup
34 wakeup from another thread
|
| /third_party/boost/libs/fiber/doc/ |
| D | rationale.qbk | 73 [heading spurious wakeup]
75 Spurious wakeup can happen when using
78 signaled while the awaited condition may still be false. Spurious wakeup can
80 `std::condition_variable` wakeup completely predictable would slow down all
84 __condition__ is not subject to spurious wakeup. Nonetheless it is
|
| /third_party/glib/gio/ |
| D | gcancellable.c | 53 GWakeup *wakeup; member
69 if (cancellable->priv->wakeup)
70 GLIB_PRIVATE_CALL (g_wakeup_free) (cancellable->priv->wakeup);
276 if (priv->wakeup) in g_cancellable_reset()
277 GLIB_PRIVATE_CALL (g_wakeup_acknowledge) (priv->wakeup); in g_cancellable_reset()
409 if (cancellable->priv->wakeup == NULL) in g_cancellable_make_pollfd()
411 cancellable->priv->wakeup = GLIB_PRIVATE_CALL (g_wakeup_new) (); in g_cancellable_make_pollfd()
414 GLIB_PRIVATE_CALL (g_wakeup_signal) (cancellable->priv->wakeup); in g_cancellable_make_pollfd()
417 GLIB_PRIVATE_CALL (g_wakeup_get_pollfd) (cancellable->priv->wakeup, pollfd); in g_cancellable_make_pollfd()
458 GLIB_PRIVATE_CALL (g_wakeup_free) (priv->wakeup); in g_cancellable_release_fd()
[all …]
|
| /third_party/python/Modules/ |
| D | signalmodule.c | 115 } wakeup = {.fd = INVALID_FD, .warn_on_full_buffer = 1, .use_send = 0}; variable
125 } wakeup = {.fd = INVALID_FD, .warn_on_full_buffer = 1}; variable
258 "signal wakeup fd:\n"); in report_wakeup_write_error()
276 "signal wakeup fd:\n"); in report_wakeup_send_error()
298 /* And then write to the wakeup fd *after* setting all the globals and in trip_signal()
299 doing the _PyEval_SignalReceived. We used to write to the wakeup fd in trip_signal()
303 - main thread blocks on select([wakeup.fd], ...) in trip_signal()
305 - trip_signal writes to the wakeup fd in trip_signal()
308 - the main thread empties the wakeup fd in trip_signal()
319 fd = Py_SAFE_DOWNCAST(wakeup.fd, SOCKET_T, int); in trip_signal()
[all …]
|
| /third_party/curl/tests/libtest/ |
| D | lib1564.c | 47 /* no wakeup */ in test()
62 /* try a single wakeup */ in test()
79 /* previous wakeup should not wake up this */ in test()
94 /* try lots of wakeup */ in test()
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/internal/ |
| D | waiter.cc | 91 return true; // Consumed a wakeup, we are done. in Wait()
184 // Loop until we find a wakeup to consume or timeout. in Wait()
208 // Consume a wakeup and we're done. in Wait()
255 // Loop until we timeout or consume a wakeup. in Wait()
267 // Successfully consumed a wakeup, we're done. in Wait()
290 // Post a wakeup. in Post()
378 // Loop until we find a wakeup to consume or timeout. in Wait()
399 // Consume a wakeup and we're done. in Wait()
|
| /third_party/python/Python/ |
| D | condvar.h | 23 * the wakeup of a subsequent thread to try a PyCOND_WAIT(),
29 * specific other thread will get the wakeup signal
141 * is only needed to catch those "lost wakeup" events and in PyCOND_INIT()
166 /* "lost wakeup bug" would occur if the caller were interrupted here, in _PyCOND_WAIT_MS()
178 * just means an extra spurious wakeup for a waiting thread. in _PyCOND_WAIT_MS()
213 * a delay between notify and actual wakeup of the target thread in PyCOND_SIGNAL()
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/sigaction/ |
| D | 17-2.c | 28 static volatile sig_atomic_t wakeup = 1; variable
33 wakeup++; in handler()
50 while (wakeup == 1) { in main()
|
| D | 17-22.c | 28 static volatile sig_atomic_t wakeup = 1; variable
33 wakeup++; in handler()
50 while (wakeup == 1) { in main()
|
| D | 17-8.c | 28 static volatile sig_atomic_t wakeup = 1; variable
33 wakeup++; in handler()
50 while (wakeup == 1) { in main()
|
| D | 17-15.c | 28 static volatile sig_atomic_t wakeup = 1; variable
33 wakeup++; in handler()
50 while (wakeup == 1) { in main()
|
| D | 17-17.c | 28 static volatile sig_atomic_t wakeup = 1; variable
33 wakeup++; in handler()
50 while (wakeup == 1) { in main()
|
| D | 17-19.c | 28 static volatile sig_atomic_t wakeup = 1; variable
32 wakeup++; in handler()
49 while (wakeup == 1) { in main()
|
| D | 17-14.c | 28 static volatile sig_atomic_t wakeup = 1; variable
33 wakeup++; in handler()
50 while (wakeup == 1) { in main()
|
| D | 17-9.c | 28 static volatile sig_atomic_t wakeup = 1; variable
33 wakeup++; in handler()
50 while (wakeup == 1) { in main()
|
| D | 17-7.c | 28 static volatile sig_atomic_t wakeup = 1; variable
33 wakeup++; in handler()
50 while (wakeup == 1) { in main()
|
| D | 17-20.c | 28 static volatile sig_atomic_t wakeup = 1; variable
33 wakeup++; in handler()
50 while (wakeup == 1) { in main()
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/sigaction/templates/ |
| D | template_17-1.in | 28 static volatile sig_atomic_t wakeup = 1;
33 wakeup++;
50 while(wakeup == 1) {
|