| /libcore/luni/src/test/java/libcore/java/lang/ |
| OldAndroidMonitorTest.java | 106 Waiter waiter; field in class:OldAndroidMonitorTest.Interrupter
108 Interrupter(String name, Waiter waiter) {
110 this.waiter = waiter;
123 waiter.spin = true;
124 // System.out.println("InterruptTest: starting waiter");
125 waiter.start();
133 /* Waiter is spinning, and its monitor should still be thin
273 Waiter waiter = new Waiter("InterruptTest Waiter"); local
[all...] |
| /external/valgrind/unittest/ |
| wine.supp | 24 fun:WindowsSemaphoreTests::Waiter
|
| racecheck_unittest.cc | 122 // Waiter: Waker:
136 usleep(200000); // Make sure the waiter blocks.
145 void Waiter() {
158 Waiter();
171 // Waiter: Waker:
184 usleep(100000); // Make sure the waiter blocks.
188 COND = 1; // We are done! Tell the Waiter.
191 void Waiter() {
203 Waiter();
243 // test05: FP. Synchronization via CondVar, but waiter does not block. {{{
[all...] |
| windows_tests.cc | 511 void Waiter(int *var, HANDLE sem) {
528 tp.Add(NewCallback(Waiter, &VAR, sem));
550 tp.Add(NewCallback(Waiter, &VAR, h1));
567 void Waiter(int *var, HANDLE h) {
590 tp.Add(NewCallback(Waiter, &VAR, h1));
|
| posix_tests.cc | 120 void Waiter() {
137 MyThreadArray t(Poster, Waiter);
1101 void Waiter() {
1119 MyThreadArray t(Waiter, Waker);
|
| /frameworks/base/core/java/android/database/sqlite/ |
| SQLiteConnectionPool.java | 596 final ConnectionWaiter waiter; local
619 // No connections available. Enqueue a waiter in priority order.
622 waiter = obtainConnectionWaiterLocked(Thread.currentThread(), startTime,
628 waiter.mNext = successor;
635 predecessor.mNext = waiter;
637 mConnectionWaiterQueue = waiter;
640 nonce = waiter.mNonce;
649 if (waiter.mNonce == nonce) {
650 cancelConnectionWaiterLocked(waiter);
660 long nextBusyTimeoutTime = waiter.mStartTime + busyTimeoutMillis
785 ConnectionWaiter waiter = mConnectionWaiterQueue; local
922 ConnectionWaiter waiter = mConnectionWaiterQueue; local
969 ConnectionWaiter waiter = mConnectionWaiterPool; local
[all...] |
| /external/chromium/base/synchronization/ |
| waitable_event.h | 104 class Waiter {
106 // Signal the waiter to wake up.
108 // Consider the case of a Waiter which is in multiple WaitableEvent's
110 // signaled at the same time. Now, each will wake only the first waiter in
113 // to dequeue the waiter from the other wait-list in time), two auto-resets
114 // will have happened, but only one waiter has been signaled!
116 // Because of this, a Waiter may "reject" a wake by returning false. In
128 virtual ~Waiter() {}
151 bool Dequeue(Waiter* waiter, void* tag)
[all...] |
| waitable_event_posix.cc | 18 // waiter is either an async wait, in which case we have a Task and the
28 // firing a waiter and so we can store that pointer to find out which event
79 // This is a synchronous waiter. The thread is waiting on the given condition
82 class SyncWaiter : public WaitableEvent::Waiter {
256 // enqueued our waiter in them all.
296 // The locks of the WaitableEvents have been taken in order and the Waiter has
300 // None of the WaitableEvent locks are held. The Waiter has not been enqueued
307 size_t count, Waiter* waiter) {
319 const size_t r = EnqueueMany(waitables + 1, count - 1, waiter);
[all...] |
| waitable_event_watcher_posix.cc | 49 // This is an asynchronous waiter which posts a task to a MessageLoop when
52 class AsyncWaiter : public WaitableEvent::Waiter {
205 // We have no kernel. This means that we never enqueued a Waiter on an
224 // fired, freed and the memory reused for a different Waiter which was
225 // enqueued in the same wait-list. We would think that that waiter was our
232 // still exists. So if we find a waiter with the correct pointer value, and
235 // Case 2: the waiter hasn't been signaled yet; it was still on the wait
237 // have been enqueued with the MessageLoop because the waiter was never
245 // Case 3: the waiter isn't on the wait-list, thus it was signaled. It may
247 // task on the MessageLoop, but to delete it instead. The Waiter delete
[all...] |
| /external/kernel-headers/original/linux/ |
| sync.h | 171 struct sync_fence_waiter *waiter);
174 * struct sync_fence_waiter - metadata for asynchronous waiter on a fence
185 static inline void sync_fence_waiter_init(struct sync_fence_waiter *waiter,
188 waiter->callback = callback;
303 * @waiter: waiter callback struck
308 * @waiter should be initialized with sync_fence_waiter_init().
311 struct sync_fence_waiter *waiter);
316 * @waiter: waiter callback struc
[all...] |
| module.h | 326 struct task_struct *waiter; member in struct:module
416 wake_up_process(module->waiter);
|
| /external/chromium/chrome/browser/chromeos/login/ |
| screen_locker_browsertest.cc | 32 class Waiter : public NotificationObserver {
34 explicit Waiter(Browser* browser)
47 ~Waiter() {
75 CHROMEGTK_CALLBACK_1(Waiter, gboolean, OnWindowStateEvent,
86 DISALLOW_COPY_AND_ASSIGN(Waiter);
89 gboolean Waiter::OnWindowStateEvent(GtkWidget* widget,
231 Waiter waiter(browser());
233 waiter.Wait(false /* not locked */, true /* full screen */);
238 Waiter waiter(browser())
[all...] |
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| WaitingThread.java | 60 private Thread waiter; field in class:WaitingThread
114 return this.waiter;
142 if (this.waiter != null) {
146 "\nwaiter: " + this.waiter);
152 this.waiter = Thread.currentThread();
165 this.waiter = null;
181 if (this.waiter == null) {
|
| /dalvik/tests/059-finalizer-throw/src/ |
| Main.java | 11 static Object waiter = new Object(); field in class:Main
|
| /external/valgrind/main/drd/tests/ |
| tsan_unittest.cpp | 362 // Waiter: Waker:
376 usleep(100000); // Make sure the waiter blocks.
385 void Waiter() {
398 Waiter();
411 // Waiter: Waker:
424 usleep(100000); // Make sure the waiter blocks.
428 COND = 1; // We are done! Tell the Waiter.
431 void Waiter() {
443 Waiter();
483 // test05: FP. Synchronization via CondVar, but waiter does not block. {{{
[all...] |
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/ |
| AdnRecordCache.java | 313 Message waiter = waiters.get(i); local
315 AsyncResult.forMessage(waiter, ar.result, ar.exception);
316 waiter.sendToTarget();
|
| /external/dnsmasq/src/ |
| log.c | 385 struct timespec waiter; local
386 waiter.tv_sec = 0;
387 waiter.tv_nsec = 1000000 << (d - 1); /* 1 ms */
388 nanosleep(&waiter, NULL);
|
| util.c | 475 struct timespec waiter; local
478 waiter.tv_sec = 0;
479 waiter.tv_nsec = 10000;
480 nanosleep(&waiter, NULL);
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| SynchronousQueue.java | 203 volatile Thread waiter; // to control park/unpark field in class:SynchronousQueue.TransferStack.SNode
230 Thread w = waiter;
232 waiter = null;
359 if (m == null) // waiter is gone
382 * When a node/thread is about to block, it sets its waiter
385 * fulfiller noticing that waiter is non-null so should be
424 else if (s.waiter == null)
425 s.waiter = w; // establish waiter so can park next iter
447 s.waiter = null; // forget threa
509 volatile Thread waiter; \/\/ to control park\/unpark field in class:SynchronousQueue.TransferQueue.QNode
[all...] |
| Exchanger.java | 257 public volatile Thread waiter; field in class:Exchanger.Node
323 LockSupport.unpark(you.waiter);
451 * When a node/thread is about to block, it sets its waiter field
453 * parking, thus covering race vs fulfiller noticing that waiter
472 else if (node.waiter == null) // Set up to block next
473 node.waiter = w;
507 else if (node.waiter == null)
508 node.waiter = w;
542 LockSupport.unpark(you.waiter);
|
| LinkedTransferQueue.java | 389 * is apparently the first waiter in the queue. See above for
424 volatile Thread waiter; // null until waiting field in class:LinkedTransferQueue.Node
454 * Sets item to self and waiter to null, to avoid garbage
458 * mechanics that extract items. Similarly, clearing waiter
501 LockSupport.unpark(waiter);
523 (k.getDeclaredField("waiter"));
601 LockSupport.unpark(p.waiter);
[all...] |
| /external/chromium/chrome/browser/automation/ |
| testing_automation_provider_views.cc | 165 // The waiter will respond to the IPC and delete itself when done.
195 // Otherwise, register this reply message with the waiter,
|
| /bionic/libstdc++/src/ |
| one_time_construction.cpp | 80 __bionic_cmpxchg(pending, waiting, &gv->state); // Indicate there is a waiter
|
| /frameworks/support/volley/tests/src/com/android/volley/ |
| RequestQueueTest.java | 141 // Leave one permit available so the waiter can find it.
|
| /ndk/sources/cxx-stl/gabi++/src/ |
| one_time_construction.cc | 85 // we must indicate that there is a waiter, then
|
