| /external/libmojo/mojo/edk/system/ |
| D | awakable_list_unittest.cc | 30 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 1); in TEST()
34 awakable_list.Remove(thread.waiter()); in TEST()
43 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_WRITABLE, 2); in TEST()
54 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 3); in TEST()
71 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 1); in TEST()
76 awakable_list.Remove(thread.waiter()); in TEST()
85 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_WRITABLE, 2); in TEST()
89 awakable_list.Remove(thread.waiter()); in TEST()
91 awakable_list.Remove(thread.waiter()); in TEST()
101 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 3); in TEST()
[all …]
|
| D | waiter_unittest.cc | 57 Waiter* waiter() { return &waiter_; } in waiter() function in mojo::edk::__anon318e51650111::WaitingThread
102 thread.waiter()->Awake(MOJO_RESULT_OK, 1); in TEST()
112 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 2); in TEST()
125 thread.waiter()->Awake(1, 3); in TEST()
138 thread.waiter()->Awake(2, 4); in TEST()
163 thread.waiter()->Awake(MOJO_RESULT_OK, 5); in TEST()
173 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 6); in TEST()
186 thread.waiter()->Awake(1, 7); in TEST()
199 thread.waiter()->Awake(2, 8); in TEST()
212 Waiter waiter; in TEST() local
[all …]
|
| D | waiter_test_utils.h | 53 Waiter* waiter() { return &waiter_; } in waiter() function
|
| D | BUILD.gn | 66 "waiter.cc",
67 "waiter.h",
|
| D | core.cc | 1113 Waiter waiter; in WaitManyInternal() local
1114 waiter.Init(); in WaitManyInternal()
1120 &waiter, signals[i], i, signals_states ? &signals_states[i] : nullptr); in WaitManyInternal()
1133 rv = waiter.Wait(deadline, &uintptr_result); in WaitManyInternal()
1142 &waiter, signals_states ? &signals_states[i] : nullptr); in WaitManyInternal()
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| D | WaitingThread.java | 65 private Thread waiter; field in WaitingThread
119 return this.waiter; in getThread()
147 if (this.waiter != null) { in await()
151 "\nwaiter: " + this.waiter); in await()
157 this.waiter = Thread.currentThread(); in await()
170 this.waiter = null; in await()
186 if (this.waiter == null) { in wakeup()
|
| D | ConnPoolByRoute.java | 689 WaitingThread waiter = iwth.next();
691 waiter.wakeup();
|
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| D | RequestFutureTarget.java | 46 private final Waiter waiter; field in RequestFutureTarget
62 …Target(Handler mainHandler, int width, int height, boolean assertBackgroundThread, Waiter waiter) { in RequestFutureTarget() argument
67 this.waiter = waiter; in RequestFutureTarget()
83 waiter.notifyAll(this); in cancel()
172 waiter.notifyAll(this); in onLoadFailed()
183 waiter.notifyAll(this); in onResourceReady()
200 waiter.waitForTimeout(this, 0); in doGet()
202 waiter.waitForTimeout(this, timeoutMillis); in doGet()
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | NonBlockingThreadPool.h | 141 EventCount::Waiter* waiter = &waiters_[thread_id]; in WorkerLoop() local
160 if (!WaitForWork(waiter, &t)) { in WorkerLoop()
195 bool WaitForWork(EventCount::Waiter* waiter, Task* t) { in WaitForWork() argument
199 ec_.Prewait(waiter); in WaitForWork()
203 ec_.CancelWait(waiter); in WaitForWork()
212 ec_.CancelWait(waiter); in WaitForWork()
232 ec_.CommitWait(waiter); in WaitForWork()
|
| /external/autotest/server/cros/dynamic_suite/ |
| D | job_status.py | 241 waiter = _JobResultWaiter(afe, tko)
242 waiter.add_jobs(afe.get_jobs(parent_job_id=parent_job_id))
243 for result in waiter.wait_for_results():
246 waiter.add_jobs(new_jobs)
264 waiter = _JobResultWaiter(afe, tko)
265 waiter.add_jobs(jobs)
266 for result in waiter.wait_for_results():
269 waiter.add_jobs(new_jobs)
|
| /external/linux-kselftest/tools/testing/selftests/futex/functional/ |
| D | futex_requeue_pi_signal_restart.c | 125 pthread_t waiter; in main() local
159 res = create_rt_thread(&waiter, waiterfn, NULL, SCHED_FIFO, 1); in main()
178 pthread_kill(waiter, SIGUSR1); in main()
209 pthread_kill(waiter, SIGUSR1); in main()
211 pthread_join(waiter, NULL); in main()
|
| D | futex_requeue_pi.c | 286 pthread_t waiter[THREAD_MAX], waker, blocker; in unit_test() local
323 if (create_rt_thread(&waiter[i], waiterfn, (void *)&args[i], in unit_test()
342 pthread_join(waiter[i], in unit_test()
|
| /external/libchrome/base/synchronization/ |
| D | waitable_event_posix.cc | 322 size_t count, Waiter* waiter) { in EnqueueMany() argument
334 const size_t r = EnqueueMany(waitables + 1, count - 1, waiter); in EnqueueMany()
338 waitables[0].first->Enqueue(waiter); in EnqueueMany()
393 void WaitableEvent::Enqueue(Waiter* waiter) { in Enqueue() argument
394 kernel_->waiters_.push_back(waiter); in Enqueue()
401 bool WaitableEvent::WaitableEventKernel::Dequeue(Waiter* waiter, void* tag) { in Dequeue() argument
404 if (*i == waiter && (*i)->Compare(tag)) { in Dequeue()
|
| D | waitable_event.h | 162 bool Dequeue(Waiter* waiter, void* tag);
182 size_t count, Waiter* waiter);
186 void Enqueue(Waiter* waiter);
|
| /external/ltp/testcases/kernel/ipc/semaphore/ |
| D | sem02.c | 61 void *waiter(void *);
102 rc = pthread_create(&pt[i], &attr, waiter, retval[i]); in main()
124 void *waiter(void *foo) in waiter() function
|
| /external/dng_sdk/source/ |
| D | dng_pthread.cpp | 59 struct waiter { struct
60 struct waiter *prev; argument
61 struct waiter *next; argument
87 waiter *head_waiter; // List of threads waiting on this condition
88 waiter *tail_waiter; // Used to get FIFO, rather than LIFO, behavior for pthread_cond_signal
576 waiter this_wait; in cond_wait_internal()
687 waiter *first; in dng_pthread_cond_signal()
719 waiter *first; in dng_pthread_cond_broadcast()
734 waiter *next = first->next; in dng_pthread_cond_broadcast()
|
| /external/dnsmasq/src/ |
| D | log.c | 385 struct timespec waiter; in my_syslog() local
386 waiter.tv_sec = 0; in my_syslog()
387 waiter.tv_nsec = 1000000 << (d - 1); /* 1 ms */ in my_syslog()
388 nanosleep(&waiter, NULL); in my_syslog()
|
| D | util.c | 504 struct timespec waiter; in retry_send() local
507 waiter.tv_sec = 0; in retry_send()
508 waiter.tv_nsec = 10000; in retry_send()
509 nanosleep(&waiter, NULL); in retry_send()
|
| /external/python/cpython2/Lib/ |
| D | threading.py | 334 waiter = _allocate_lock()
335 waiter.acquire()
336 self.__waiters.append(waiter)
340 waiter.acquire()
352 gotit = waiter.acquire(0)
364 self.__waiters.remove(waiter)
393 for waiter in waiters:
394 waiter.release()
396 __waiters.remove(waiter)
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractServiceTest.java | 349 Thread waiter = new Thread() { in testAwaitTerminated() local
354 waiter.start(); in testAwaitTerminated()
358 waiter.join(LONG_TIMEOUT_MILLIS); // ensure that the await in the other thread is triggered in testAwaitTerminated()
359 assertFalse(waiter.isAlive()); in testAwaitTerminated()
365 Thread waiter = new Thread() { in testAwaitTerminated_FailedService() local
375 waiter.start(); in testAwaitTerminated_FailedService()
381 waiter.join(LONG_TIMEOUT_MILLIS); in testAwaitTerminated_FailedService()
382 assertFalse(waiter.isAlive()); in testAwaitTerminated_FailedService()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_broadcast/ |
| D | 4-2.c | 125 static void *waiter(void *arg) in waiter() function
220 ret = pthread_create(&th_waiter[i], NULL, waiter, NULL); in main()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_signal/ |
| D | 4-2.c | 160 void *waiter(void *arg) in waiter() function
266 if ((ret = pthread_create(&th_waiter, NULL, waiter, NULL))) { in main()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_wait/ |
| D | 4-1.c | 162 void *waiter(void *arg) in waiter() function
289 if ((ret = pthread_create(&th_waiter, NULL, waiter, NULL))) { in main()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_timedwait/ |
| D | 4-3.c | 136 void *waiter(void *arg) in waiter() function
278 if ((ret = pthread_create(&th_waiter, NULL, waiter, NULL))) { in main()
|
| /external/ltp/testcases/open_posix_testsuite/functional/threads/pi_test/ |
| D | README | 38 the first mode, the waiter will set the mutex to ENOTRECOVERABLE
39 state, while in the second mode, the waiter needs to call
57 a waiter, P(TB)>P(TL), TL will boost to TB's priority until it
|