| /third_party/boost/libs/thread/test/sync/conditions/condition_variable_any/ |
| D | lost_notif_pass.cpp | 47 bool waiting; variable
56 return waiting; in threadIsWaiting()
69 waiting = false; in test_posix_wait_function()
93 waiting = true; in timed_wait_absolute_without_pred()
103 waiting = true; in timed_wait_absolute_with_pred()
112 waiting = true; in timed_wait_relative_without_pred()
122 waiting = true; in timed_wait_relative_with_pred()
140 waiting = false; in test_chrono_wait_function()
164 waiting = true; in wait_until_system_without_pred()
174 waiting = true; in wait_until_system_with_pred()
[all …]
|
| /third_party/boost/libs/thread/test/sync/conditions/condition_variable/ |
| D | lost_notif_pass.cpp | 47 bool waiting; variable
56 return waiting; in threadIsWaiting()
69 waiting = false; in test_posix_wait_function()
93 waiting = true; in timed_wait_absolute_without_pred()
103 waiting = true; in timed_wait_absolute_with_pred()
112 waiting = true; in timed_wait_relative_without_pred()
122 waiting = true; in timed_wait_relative_with_pred()
140 waiting = false; in test_chrono_wait_function()
164 waiting = true; in wait_until_system_without_pred()
174 waiting = true; in wait_until_system_with_pred()
[all …]
|
| /third_party/musl/libc-test/src/regression/ |
| D | pthread_cond_wait-cancel_ignored.c | 12 static int waiting; variable
16 waiting = 0; in cleanup()
24 waiting = 1; in waiter()
27 while (waiting) pthread_cond_wait(&cv, &mx); in waiter()
39 while (!waiting) pthread_cond_wait(&cv, &mx); in main()
46 while (waiting && !pthread_cond_timedwait(&cv, &mx, &ts)); in main()
47 waiting = 0; in main()
|
| /third_party/ltp/testcases/open_posix_testsuite/functional/semaphores/ |
| D | sem_sleepingbarber.c | 33 static int waiting = 0; variable
61 if (waiting == 0) { in barbers()
77 if (waiting >= 1) in barbers()
78 waiting--; in barbers()
81 waiting); in barbers()
108 if (waiting < CHAIR_NUM) { in customers()
109 waiting = waiting + 1; in customers()
116 CusID, waiting); in customers()
|
| /third_party/python/Python/ |
| D | condvar.h | 147 cv->waiting = 0; in PyCOND_INIT()
164 cv->waiting++; in _PyCOND_WAIT_MS()
173 --cv->waiting; in _PyCOND_WAIT_MS()
211 if (cv->waiting > 0) { in PyCOND_SIGNAL()
216 cv->waiting--; in PyCOND_SIGNAL()
225 int waiting = cv->waiting; in PyCOND_BROADCAST() local
226 if (waiting > 0) { in PyCOND_BROADCAST()
227 cv->waiting = 0; in PyCOND_BROADCAST()
228 return ReleaseSemaphore(cv->sem, waiting, NULL) ? 0 : -1; in PyCOND_BROADCAST()
|
| /third_party/flutter/skia/third_party/externals/sdl/src/thread/generic/ |
| D | SDL_syscond.c | 34 int waiting; member
51 cond->waiting = cond->signals = 0; in SDL_CreateCond()
92 if (cond->waiting > cond->signals) { in SDL_CondSignal()
116 if (cond->waiting > cond->signals) { in SDL_CondBroadcast()
119 num_waiting = (cond->waiting - cond->signals); in SDL_CondBroadcast()
120 cond->signals = cond->waiting; in SDL_CondBroadcast()
173 ++cond->waiting; in SDL_CondWaitTimeout()
204 --cond->waiting; in SDL_CondWaitTimeout()
|
| /third_party/flutter/skia/third_party/externals/sdl/src/thread/psp/ |
| D | SDL_syscond.c | 36 int waiting; member
53 cond->waiting = cond->signals = 0; in SDL_CreateCond()
94 if (cond->waiting > cond->signals) { in SDL_CondSignal()
118 if (cond->waiting > cond->signals) { in SDL_CondBroadcast()
121 num_waiting = (cond->waiting - cond->signals); in SDL_CondBroadcast()
122 cond->signals = cond->waiting; in SDL_CondBroadcast()
175 ++cond->waiting; in SDL_CondWaitTimeout()
206 --cond->waiting; in SDL_CondWaitTimeout()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/ |
| D | conditionvariable.h | 80 containers::list<Scheduler::Fiber*> waiting; variable
88 : waiting(allocator) {} in ConditionVariable()
96 if (waiting.size() > 0) { in notify_one()
97 (*waiting.begin())->notify(); // Only wake one fiber. in notify_one()
112 for (auto fiber : waiting) { in notify_all()
131 auto it = waiting.emplace_front(fiber); in wait()
137 waiting.erase(it); in wait()
172 auto it = waiting.emplace_front(fiber); in wait_until()
178 waiting.erase(it); in wait_until()
|
| /third_party/node/src/inspector/ |
| D | worker_inspector.cc | 17 bool waiting) in WorkerStartedRequest() argument
20 waiting_(waiting) {} in WorkerStartedRequest()
38 const WorkerInfo& info, bool waiting) { in Report() argument
40 delegate->WorkerCreated(info.title, info.url, waiting, info.worker_thread); in Report()
72 std::shared_ptr<MainThreadHandle> worker_thread, bool waiting) { in WorkerStarted() argument
74 new WorkerStartedRequest(id_, url_, worker_thread, waiting)); in WorkerStarted()
90 bool waiting) { in WorkerStarted() argument
95 Report(delegate.second, info, waiting); in WorkerStarted()
|
| D | worker_agent.cc | 19 bool waiting,
40 bool waiting, in WorkerCreated() argument
42 workers_->WorkerCreated(title, url, waiting, target); in WorkerCreated()
125 bool waiting, in WorkerCreated() argument
135 frontend->attachedToWorker(id, WorkerInfo(id, title, url), waiting); in WorkerCreated()
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | fdsem.c | 76 pa_atomic_store(&f->data->waiting, 0); in pa_fdsem_new()
118 pa_atomic_store(&f->data->waiting, 0); in pa_fdsem_new_shm()
184 if (pa_atomic_load(&f->data->waiting)) { in pa_fdsem_post()
230 pa_atomic_inc(&f->data->waiting); in pa_fdsem_wait()
267 pa_assert_se(pa_atomic_dec(&f->data->waiting) >= 1); in pa_fdsem_wait()
300 pa_atomic_inc(&f->data->waiting); in pa_fdsem_before_poll()
303 pa_assert_se(pa_atomic_dec(&f->data->waiting) >= 1); in pa_fdsem_before_poll()
312 pa_assert_se(pa_atomic_dec(&f->data->waiting) >= 1); in pa_fdsem_after_poll()
|
| /third_party/gstreamer/gstplugins_base/tests/validate/giosrc/ |
| D | read-growing-file.validatetest | 3 # The second branch reads it with giosrc and does some tests like waiting for the
4 # `done-waiting-signal` signals on the source etc...
24 wait, signal-name=waiting-data, target-element-name=giosrc
30 wait, signal-name=waiting-data, target-element-name=giosrc
32 wait, signal-name=done-waiting-data, target-element-name=giosrc, non-blocking=true
37 wait, signal-name=waiting-data, target-element-name=giosrc
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/sigaction/ |
| D | 11-1.c | 31 static volatile int waiting = 1; variable
38 waiting = 0; in handler()
91 waiting = 1; in main()
93 while (waiting) { in main()
|
| /third_party/libwebsockets/minimal-examples/raw/minimal-raw-netcat/ |
| D | minimal-raw-netcat.c | 36 static int waiting, interrupted; variable
68 waiting = (int)read(0, buf, sizeof(buf)); in callback_raw_test()
69 lwsl_notice("raw file read %d\n", waiting); in callback_raw_test()
70 if (waiting < 0) in callback_raw_test()
110 if (lws_write(wsi, buf, (unsigned int)waiting, LWS_WRITE_RAW) != waiting) { in callback_raw_test()
|
| /third_party/python/Lib/test/ |
| D | test_thread.py | 160 self.waiting = 0
167 self.waiting = self.waiting + 1
168 if self.waiting == self.num_threads:
169 self.waiting = self.num_threads - 1
175 self.waiting = self.waiting - 1
176 if self.waiting == 0:
|
| /third_party/gstreamer/gstreamer/docs/random/wtay/ |
| D | poll-timeout | 9 waiting for id:
48 /* if it's busy waiting in poll, write to the fd */
66 waiting for id:
114 /* if it's busy waiting in poll, write to the fd */
121 /* was not waiting, just mark unscheduled */
|
| /third_party/flutter/flutter/packages/flutter/test/widgets/ |
| D | async_test.dart | 67 … expect(find.text('AsyncSnapshot<String>(ConnectionState.waiting, null, null)'), findsOneWidget);
75 … expect(find.text('AsyncSnapshot<String>(ConnectionState.waiting, null, null)'), findsOneWidget);
91 … expect(find.text('AsyncSnapshot<String>(ConnectionState.waiting, null, null)'), findsOneWidget);
95 … expect(find.text('AsyncSnapshot<String>(ConnectionState.waiting, null, null)'), findsOneWidget);
106 … expect(find.text('AsyncSnapshot<String>(ConnectionState.waiting, null, null)'), findsOneWidget);
116 … expect(find.text('AsyncSnapshot<String>(ConnectionState.waiting, null, null)'), findsOneWidget);
147 expect(find.text('AsyncSnapshot<String>(ConnectionState.waiting, I, null)'), findsOneWidget);
161 … expect(find.text('AsyncSnapshot<String>(ConnectionState.waiting, null, null)'), findsOneWidget);
169 … expect(find.text('AsyncSnapshot<String>(ConnectionState.waiting, null, null)'), findsOneWidget);
182 … expect(find.text('AsyncSnapshot<String>(ConnectionState.waiting, null, null)'), findsOneWidget);
[all …]
|
| /third_party/mesa3d/src/gallium/tests/unit/ |
| D | pipe_barrier_test.c | 54 static volatile int waiting = 0; variable
80 p_atomic_inc(&waiting); in thread_function()
84 CHECK(p_atomic_read(&waiting) == NUM_THREADS); in thread_function()
|
| /third_party/boost/libs/fiber/doc/ |
| D | condition_variables.qbk | 25 again to resume waiting. In the simplest case, this condition is just a
45 `wait()` will atomically add the fiber to the set of fibers waiting on the
66 to wake one waiting fiber or all the waiting fibers respectively.
215 [[Precondition:] [All fibers waiting on `*this` have been notified by a call to
226 [[Effects:] [If any fibers are currently __blocked__ waiting on `*this` in a
229 [[Note:] [It is arbitrary which waiting fiber is resumed.]]
237 [[Effects:] [If any fibers are currently __blocked__ waiting on `*this` in a
240 [[Note:] [This is why a waiting fiber must ['also] check for the desired
242 retry the wait until that state is reached. A fiber waiting on a
256 fiber is currently waiting on `*this`, or the execution of the
[all …]
|
| D | barrier.qbk | 15 fiber has reached the barrier, all the waiting fibers can proceed, and the
40 participating fibers. Although conceptually all waiting fibers awaken
45 will reach the `wait()` call.] The rest of the waiting fibers will
88 the `initial`-th fiber calls `wait`, all waiting fibers are unblocked, and
90 [[Returns:] [`true` for exactly one fiber from each batch of waiting fibers,
|
| /third_party/boost/doc/html/boost_asio/example/cpp14/operations/ |
| D | composed_7.cpp | 67 enum { starting, waiting, writing }; in async_write_messages() enumerator
130 state = waiting; in async_write_messages()
136 case waiting: in async_write_messages()
|
| /third_party/boost/libs/asio/example/cpp14/operations/ |
| D | composed_7.cpp | 67 enum { starting, waiting, writing }; in async_write_messages() enumerator
130 state = waiting; in async_write_messages()
136 case waiting: in async_write_messages()
|
| /third_party/skia/third_party/externals/swiftshader/src/Common/ |
| D | DebugAndroid.cpp | 33 volatile int waiting = 1; in AndroidEnterDebugger() local
34 while (waiting) { in AndroidEnterDebugger()
|
| /third_party/python/Doc/library/ |
| D | asyncio-sync.rst | 80 waiting for the lock to be unlocked, only one coroutine
84 the first coroutine that started waiting on the lock.
125 print('waiting for it ...')
156 All tasks waiting for event to be set will be immediately
227 Wake up at most *n* tasks (1 by default) waiting on this
228 condition. The method is no-op if no tasks are waiting.
240 Wake up all tasks waiting on this condition.
242 This method acts like :meth:`notify`, but wakes up all waiting
287 that it is zero, it blocks, waiting until some task calls
335 Can wake up a task waiting to acquire the semaphore.
|
| /third_party/boost/libs/thread/doc/ |
| D | barrier.qbk | 13 arrived. Once the `n`-th thread has reached the barrier, all the waiting threads can proceed, and t…
72 [[Precondition:] [No threads are waiting on `*this`.]]
87 …. When the `count`-th thread calls `wait`, the barrier is reset and all waiting threads are unblo…
90 [[Returns:] [`true` for exactly one thread from each batch of waiting threads, `false` otherwise.]]
112 …. When the `count`-th thread calls `wait`, the barrier is reset and all waiting threads are unblo…
|