| /third_party/musl/libc-test/src/regression/ |
| H A 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/ |
| H A D | sem_sleepingbarber.c | 33 static int waiting = 0; variable
61 if (waiting == 0) { in barbers()
63 ("There are no more customers waiting, barber will sleep.\n"); in barbers()
77 if (waiting >= 1) in barbers()
78 waiting--; in barbers()
80 ("A customer sits in the barber's chair and get a hair cut. %d customers left waiting.\n", in barbers()
81 waiting); in barbers()
108 if (waiting < CHAIR_NUM) { in customers()
109 waiting = waiting in customers()
[all...] |
| /third_party/python/Python/ |
| H A D | condvar.h | 22 * already waiting in a PyCOND_WAIT() call. It _could_ cause
25 * The same applies to PyCOND_BROADCAST(), if N threads are waiting
27 * those already waiting.
98 waiting. It corresponds to listing 2 in:
147 cv->waiting = 0; in PyCOND_INIT()
164 cv->waiting++; in _PyCOND_WAIT_MS()
173 --cv->waiting; in _PyCOND_WAIT_MS()
178 * just means an extra spurious wakeup for a waiting thread. in _PyCOND_WAIT_MS()
179 * ('waiting' corresponds to the semaphore's "negative" count and in _PyCOND_WAIT_MS()
180 * we may end up with e.g. (waiting in _PyCOND_WAIT_MS()
225 int waiting = cv->waiting; PyCOND_BROADCAST() local
[all...] |
| /third_party/libwebsockets/minimal-examples-lowlevel/raw/minimal-raw-client/ |
| H A D | main.c | 34 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()
111 // lwsl_hexdump_info(buf, waiting); in callback_raw_test()
112 if (!waiting) in callback_raw_test()
116 if (lws_write(wsi, buf, (unsigned int)waiting, LWS_WRITE_RAW) != waiting) { in callback_raw_test()
161 waiting = lws_snprintf((char *)buf, sizeof(buf), "GET / HTTP/1.1\xaHost: libwebsockets.org\xa\xa"); in system_notify_cb()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/ |
| H A D | conditionvariable.h | 41 // notify_one() notifies and potentially unblocks one waiting fiber or thread.
44 // notify_all() notifies and potentially unblocks all waiting fibers and/or
80 containers::list<Scheduler::Fiber*> waiting; member in marl::ConditionVariable
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 in wait_until()
[all...] |
| /third_party/node/src/inspector/ |
| H A D | worker_inspector.cc | 17 bool waiting, in WorkerStartedRequest()
21 waiting_(waiting) {} in WorkerStartedRequest()
40 const WorkerInfo& info, bool waiting) { in Report()
42 delegate->WorkerCreated(info.title, info.url, waiting, info.worker_thread); in Report()
76 std::shared_ptr<MainThreadHandle> worker_thread, bool waiting) { in WorkerStarted()
78 new WorkerStartedRequest(id_, url_, worker_thread, waiting, name_)); in WorkerStarted()
94 bool waiting) { in WorkerStarted()
99 Report(delegate.second, info, waiting); in WorkerStarted()
13 WorkerStartedRequest( uint64_t id, const std::string& url, std::shared_ptr<node::inspector::MainThreadHandle> worker_thread, bool waiting, const std::string& name) WorkerStartedRequest() argument
39 Report(const std::unique_ptr<WorkerDelegate>& delegate, const WorkerInfo& info, bool waiting) Report() argument
75 WorkerStarted( std::shared_ptr<MainThreadHandle> worker_thread, bool waiting) WorkerStarted() argument
92 WorkerStarted(uint64_t session_id, const WorkerInfo& info, bool waiting) WorkerStarted() argument
|
| H A D | worker_agent.cc | 19 bool waiting,
40 bool waiting,
42 workers_->WorkerCreated(title, url, waiting, target);
125 bool waiting, in WorkerCreated()
135 frontend->attachedToWorker(id, WorkerInfo(id, title, url), waiting); in WorkerCreated()
123 WorkerCreated(const std::string& title, const std::string& url, bool waiting, std::shared_ptr<MainThreadHandle> target) WorkerCreated() argument
|
| H A D | worker_inspector.h | 24 bool waiting,
68 bool waiting);
92 void WorkerStarted(uint64_t session_id, const WorkerInfo& info, bool waiting);
|
| /third_party/pulseaudio/src/pulsecore/ |
| H A 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()
174 if (pa_atomic_load(&f->data->waiting)) { in pa_fdsem_post()
212 pa_atomic_inc(&f->data->waiting); in pa_fdsem_wait()
239 pa_assert_se(pa_atomic_dec(&f->data->waiting) >= 1); in pa_fdsem_wait()
272 pa_atomic_inc(&f->data->waiting); in pa_fdsem_before_poll()
275 pa_assert_se(pa_atomic_dec(&f->data->waiting) >= 1); in pa_fdsem_before_poll()
284 pa_assert_se(pa_atomic_dec(&f->data->waiting) >= 1); in pa_fdsem_after_poll()
|
| /third_party/libwebsockets/minimal-examples/raw/minimal-raw-netcat/ |
| H A 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()
107 // lwsl_hexdump_info(buf, waiting); in callback_raw_test()
110 if (lws_write(wsi, buf, (unsigned int)waiting, LWS_WRITE_RAW) != waiting) { in callback_raw_test()
|
| /third_party/node/test/parallel/ |
| H A D | test-inspector-async-hook-setup-at-signal.js | 13 let waiting = setInterval(waitUntilDebugged, 50);
18 clearInterval(waiting);
26 process._rawDebug('Signal received, waiting for debugger setup');
27 waiting = setInterval(() => { debugger; }, 50);
32 clearInterval(waiting);
|
| H A D | test-cluster-dgram-reuse.js | 17 let waiting = 2;
19 if (--waiting === 0)
|
| H A D | test-cluster-dgram-ipv6only.js | 20 let waiting = 2;
22 if (--waiting === 0)
|
| H A D | test-https-agent-disable-session-reuse.js | 30 let waiting = TOTAL_REQS;
43 if (--waiting !== 0)
|
| H A D | test-dns-multi-channel.js | 19 let waiting = servers.length;
34 if (--waiting === 0) ready();
|
| H A D | test-https-agent-sni.js | 16 let waiting = TOTAL;
19 if (--waiting === 0) server.close();
|
| H A D | test-inspect-async-hook-setup-at-inspect.js | 13 const waiting = setInterval(() => { debugger; }, 50);
17 clearInterval(waiting);
|
| H A D | test-tls-connect-given-socket.js | 40 let waiting = 2;
52 if (--waiting === 0)
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/sigaction/ |
| H A 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/python/Lib/test/ |
| H A D | test_thread.py | 68 verbose_print("waiting for tasks to complete...")
104 verbose_print("waiting for all tasks to complete")
162 self.waiting = 0
169 self.waiting = self.waiting + 1
170 if self.waiting == self.num_threads:
171 self.waiting = self.num_threads - 1
177 self.waiting = self.waiting - 1
178 if self.waiting
[all...] |
| /third_party/mesa3d/src/gallium/tests/unit/ |
| H A 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/skia/third_party/externals/swiftshader/src/Common/ |
| H A D | DebugAndroid.cpp | 33 volatile int waiting = 1; in AndroidEnterDebugger() local
34 while (waiting) { in AndroidEnterDebugger()
|
| /third_party/pulseaudio/src/modules/rtp/ |
| H A D | rtsp_client.c | 68 uint8_t waiting; member
214 if (c->waiting && pa_streq(s2, "RTSP/1.0 200 OK")) { in line_callback()
220 c->waiting = 0; in line_callback()
222 } else if (c->waiting && pa_streq(s2, "RTSP/1.0 401 Unauthorized")) { in line_callback()
228 c->waiting = 0; in line_callback()
230 } else if (c->waiting) { in line_callback()
392 c->waiting = 1; in pa_rtsp_connect()
520 c->waiting = 1; in rtsp_exec()
|
| /third_party/libwebsockets/lib/system/async-dns/ |
| H A D | async-dns.c | 312 dns->waiting.head) { in callback_async_dns()
438 lws_dll2_get_head(&dns->waiting)) { in lws_adns_dump()
552 lws_dll2_foreach_safe(&dns->waiting, NULL, clean); in lws_async_dns_deinit()
592 lws_dll2_foreach_safe(&dns->waiting, wsi, cancel); in lws_async_dns_cancel()
626 if (lws_dll2_foreach_safe(&dns->waiting, in lws_async_dns_get_new_tid()
808 q = lws_adns_get_query(dns, qtype, &dns->waiting, 0, name); in lws_async_dns_query()
887 lws_dll2_add_head(&q->list, &dns->waiting); in lws_async_dns_query()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/src/ |
| H A D | scheduler.cpp | 325 "WaitingFibers::next() called when there' no waiting fibers"); in next()
333 MARL_ASSERT(added, "WaitingFibers::add() fiber already waiting"); in add()
475 work.waiting.add(*timeout, currentFiber); in suspend()
523 work.waiting.erase(fiber); in enqueue()
531 MARL_ASSERT(!work.waiting.contains(fiber), in enqueue()
532 "fiber is unexpectedly in the waiting list"); in enqueue()
581 return work.num > 0 || work.waiting || shutdown; in run()
613 if (work.waiting) { in waitForWork()
620 while (auto fiber = work.waiting.take(now)) { in enqueueFiberTimeouts()
742 : tasks(allocator), fibers(allocator), waiting(allocato in Work()
[all...] |