| /external/skqp/src/compute/skc/ |
| D | scheduler.cpp | 108 } waiting; member
148 scheduler->waiting.indices = (skc_ushort*) in skc_scheduler_create()
151 scheduler->waiting.size = size + 1; // the ring has an extra slot in skc_scheduler_create()
152 scheduler->waiting.head = 0; in skc_scheduler_create()
153 scheduler->waiting.tail = 0; in skc_scheduler_create()
166 skc_runtime_host_perm_free(runtime,scheduler->waiting.indices); in skc_scheduler_dispose()
247 std::unique_lock<std::mutex> lock(scheduler->waiting.mutex); in skc_scheduler_append()
252 scheduler->waiting.indices[scheduler->waiting.tail] = command; in skc_scheduler_append()
255 if (++scheduler->waiting.tail == scheduler->waiting.size) in skc_scheduler_append()
256 scheduler->waiting.tail = 0; in skc_scheduler_append()
[all …]
|
| /external/ltp/testcases/open_posix_testsuite/functional/semaphores/ |
| D | sem_sleepingbarber.c | 33 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()
|
| /external/python/cpython3/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()
|
| /external/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()
111 for (auto fiber : waiting) { in notify_all()
130 auto it = waiting.emplace_front(fiber); in wait()
136 waiting.erase(it); in wait()
171 auto it = waiting.emplace_front(fiber); in wait_until()
177 waiting.erase(it); in wait_until()
|
| /external/autotest/client/bin/self-test/tests/ |
| D | 111-barrier-unordered-20x-out | 8 barrier: 127.0.0.1#P10 was released, waiting for close
16 barrier: 127.0.0.1#P11 was released, waiting for close
24 barrier: 127.0.0.1#P12 was released, waiting for close
32 barrier: 127.0.0.1#P13 was released, waiting for close
40 barrier: 127.0.0.1#P14 was released, waiting for close
48 barrier: 127.0.0.1#P15 was released, waiting for close
56 barrier: 127.0.0.1#P16 was released, waiting for close
64 barrier: 127.0.0.1#P17 was released, waiting for close
72 barrier: 127.0.0.1#P18 was released, waiting for close
80 barrier: 127.0.0.1#P19 was released, waiting for close
[all …]
|
| D | 110-barrier-unordered-10x-out | 8 barrier: 127.0.0.1#P10 was released, waiting for close
18 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P10 (127.0.0.1:33419)
19 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P2 (127.0.0.1:33414)
20 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P3 (127.0.0.1:33417)
21 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P4 (127.0.0.1:33418)
22 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P5 (127.0.0.1:33411)
23 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P6 (127.0.0.1:33415)
24 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P7 (127.0.0.1:33412)
25 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P8 (127.0.0.1:33416)
26 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P9 (127.0.0.1:33413)
[all …]
|
| D | 112-barrier-unordered-40x-out | 8 barrier: 127.0.0.1#P10 was released, waiting for close
16 barrier: 127.0.0.1#P11 was released, waiting for close
24 barrier: 127.0.0.1#P12 was released, waiting for close
32 barrier: 127.0.0.1#P13 was released, waiting for close
40 barrier: 127.0.0.1#P14 was released, waiting for close
48 barrier: 127.0.0.1#P15 was released, waiting for close
56 barrier: 127.0.0.1#P16 was released, waiting for close
64 barrier: 127.0.0.1#P17 was released, waiting for close
72 barrier: 127.0.0.1#P18 was released, waiting for close
80 barrier: 127.0.0.1#P19 was released, waiting for close
[all …]
|
| D | 105-barrier-5x-master-middle-out | 11 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P2 (ADDR:PORT)
19 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P3 (ADDR:PORT)
27 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P4 (ADDR:PORT)
35 barrier: 127.0.0.1#P1 client now waiting: 127.0.0.1#P5 (ADDR:PORT)
59 barrier: 127.0.0.1#P2 was released, waiting for close
61 barrier: 127.0.0.1#P3 was released, waiting for close
64 barrier: 127.0.0.1#P4 was released, waiting for close
66 barrier: 127.0.0.1#P5 was released, waiting for close
|
| D | 113-barrier-unordered-100x-out | 8 barrier: 127.0.0.1#P100 was released, waiting for close
16 barrier: 127.0.0.1#P10 was released, waiting for close
24 barrier: 127.0.0.1#P11 was released, waiting for close
32 barrier: 127.0.0.1#P12 was released, waiting for close
40 barrier: 127.0.0.1#P13 was released, waiting for close
48 barrier: 127.0.0.1#P14 was released, waiting for close
56 barrier: 127.0.0.1#P15 was released, waiting for close
64 barrier: 127.0.0.1#P16 was released, waiting for close
72 barrier: 127.0.0.1#P17 was released, waiting for close
80 barrier: 127.0.0.1#P18 was released, waiting for close
[all …]
|
| /external/toolchain-utils/bestflags/ |
| D | steering.py | 45 waiting = generations
68 while waiting:
87 generation = next(gen for gen in waiting if gen.UpdateTask(task))
95 waiting.remove(generation)
107 waiting.append(new_generation)
|
| /external/squashfs-tools/squashfs-tools/ |
| D | unsquashfs_info.c | 100 int sig, err, waiting = 0; in info_thrd() local
120 if(sig == SIGQUIT && !waiting) { in info_thrd()
126 waiting = 1; in info_thrd()
131 waiting = 0; in info_thrd()
|
| D | info.c | 137 int sig, err, waiting = 0; in info_thrd() local
157 if(sig == SIGQUIT && !waiting) { in info_thrd()
162 waiting = 1; in info_thrd()
167 waiting = 0; in info_thrd()
|
| /external/rust/crates/regex-automata/src/ |
| D | minimize.rs | 46 waiting: Vec<StateSet<S>>, field
55 .field("waiting", &self.waiting) in fmt()
79 let waiting = vec![partitions[0].clone()]; in new() localVariable
81 Minimizer { dfa, in_transitions, partitions, waiting } in new()
90 while let Some(set) = self.waiting.pop() { in run()
113 self.waiting[i] = x; in run()
114 self.waiting.push(y); in run()
118 self.waiting.push(x); in run()
120 self.waiting.push(y); in run()
204 self.waiting.iter().position(|s| s == set) in find_waiting()
|
| /external/libwebsockets/minimal-examples/raw/minimal-raw-netcat/ |
| D | minimal-raw-netcat.c | 34 static int waiting, interrupted; variable
66 waiting = read(0, buf, sizeof(buf)); in callback_raw_test()
67 lwsl_notice("raw file read %d\n", waiting); in callback_raw_test()
68 if (waiting < 0) in callback_raw_test()
108 if (lws_write(wsi, buf, waiting, LWS_WRITE_RAW) != waiting) { in callback_raw_test()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/sigaction/ |
| D | 11-1.c | 31 static volatile int waiting = 1; variable
38 waiting = 0; in handler()
88 waiting = 1; in main()
90 while (waiting) { in main()
|
| /external/python/cpython2/Lib/test/ |
| D | test_thread.py | 164 self.waiting = 0
171 self.waiting = self.waiting + 1
172 if self.waiting == self.num_threads:
173 self.waiting = self.num_threads - 1
179 self.waiting = self.waiting - 1
180 if self.waiting == 0:
|
| /external/python/cpython3/Lib/test/ |
| D | test_thread.py | 158 self.waiting = 0
165 self.waiting = self.waiting + 1
166 if self.waiting == self.num_threads:
167 self.waiting = self.num_threads - 1
173 self.waiting = self.waiting - 1
174 if self.waiting == 0:
|
| /external/wpa_supplicant_8/hs20/server/www/ |
| D | terms.php | 54 $waiting = true; variable
64 $waiting = $row[0] == 1; variable
68 if (!$waiting)
|
| /external/python/cpython2/Demo/threads/ |
| D | sync.py | 293 self.waiting = 0 # num waiters subject to current release
323 self.waiting = self.waiting - 1
329 if self.waiting == self.pending == 0:
344 self.waiting = self.waiting + self.pending
348 self.torelease = self.waiting
350 self.torelease = min( self.waiting,
|
| /external/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()
|
| /external/libevent/ |
| D | evthread_win32.c | 238 int waiting = 1; in evthread_win32_cond_wait() local
261 waiting = 0; in evthread_win32_cond_wait()
266 waiting = 0; in evthread_win32_cond_wait()
273 waiting = 0; in evthread_win32_cond_wait()
287 } while (waiting); in evthread_win32_cond_wait()
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-sync.rst | 77 waiting for the lock to be unlocked, only one coroutine
81 the first coroutine that started waiting on the lock.
120 print('waiting for it ...')
151 All tasks waiting for event to be set will be immediately
220 Wake up at most *n* tasks (1 by default) waiting on this
221 condition. The method is no-op if no tasks are waiting.
233 Wake up all tasks waiting on this condition.
235 This method acts like :meth:`notify`, but wakes up all waiting
280 that it is zero, it blocks, waiting until some task calls
326 Can wake up a task waiting to acquire the semaphore.
|
| /external/swiftshader/src/Common/ |
| D | DebugAndroid.cpp | 33 volatile int waiting = 1; in AndroidEnterDebugger() local
34 while (waiting) { in AndroidEnterDebugger()
|
| /external/rust/crates/tokio/src/process/ |
| D | windows.rs | 46 waiting: Option<Waiting>, field
77 waiting: None, in spawn_child()
107 if let Some(ref mut w) = inner.waiting { in poll()
138 inner.waiting = Some(Waiting { in poll()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test-resources/stacktraces/timeout/ |
| D | testStacktraceIsRecoveredFromLexicalBlockWhenTriggeredByChild.txt | 1 kotlinx.coroutines.TimeoutCancellationException: Timed out waiting for 200 ms
5 Caused by: kotlinx.coroutines.TimeoutCancellationException: Timed out waiting for 200 ms
|