| /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/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/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/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/libwebsockets/minimal-examples-lowlevel/raw/minimal-raw-client/ |
| 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()
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/node/src/inspector/ |
| D | worker_inspector.cc | 17 bool waiting, in WorkerStartedRequest() argument
21 waiting_(waiting) {} in WorkerStartedRequest()
40 const WorkerInfo& info, bool waiting) { in Report() argument
42 delegate->WorkerCreated(info.title, info.url, waiting, info.worker_thread); in Report()
76 std::shared_ptr<MainThreadHandle> worker_thread, bool waiting) { in WorkerStarted() argument
78 new WorkerStartedRequest(id_, url_, worker_thread, waiting, name_)); in WorkerStarted()
94 bool waiting) { in WorkerStarted() argument
99 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()
|
| 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/ |
| 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/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/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/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/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/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/pulseaudio/src/modules/rtp/ |
| 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/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/node/test/parallel/ |
| D | test-cluster-dgram-reuse.js | 17 let waiting = 2; variable
19 if (--waiting === 0)
|
| D | test-cluster-dgram-ipv6only.js | 20 let waiting = 2; variable
22 if (--waiting === 0)
|
| D | test-https-agent-disable-session-reuse.js | 30 let waiting = TOTAL_REQS;
43 if (--waiting !== 0)
|
| D | test-cluster-send-deadlock.js | 64 let waiting = 2; variable
66 if (--waiting === 0)
|
| D | test-https-agent-sni.js | 16 let waiting = TOTAL; variable
19 if (--waiting === 0) server.close();
|
| D | test-dns-multi-channel.js | 19 let waiting = servers.length; variable
34 if (--waiting === 0) ready();
|
| D | test-tls-connect-given-socket.js | 40 let waiting = 2; variable
52 if (--waiting === 0)
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/src/ |
| D | scheduler.cpp | 475 work.waiting.add(*timeout, currentFiber); in suspend()
523 work.waiting.erase(fiber); in enqueue()
531 MARL_ASSERT(!work.waiting.contains(fiber), 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(allocator) {} in Work()
747 if (waiting) { in wait()
748 mutex.wait_until_locked(added, waiting.next(), f); in wait()
|
| /third_party/ltp/testcases/misc/math/fptests/ |
| D | fptest02.c | 84 int waiting[EVENTMX]; /* array of waiting processors */ variable
228 waiting[++nwaiting] = p; in addwaiting()
238 return (waiting[nwaiting--]); in getwaiting()
|