| /external/chromium_org/mojo/system/ |
| message_pipe_unittest.cc | 10 #include "mojo/system/waiter.h"
360 Waiter waiter; local
367 waiter.Init();
369 mp->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_WRITABLE, 0));
370 waiter.Init();
373 &waiter,
378 waiter.Init();
380 mp->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_READABLE, 1));
381 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0))
[all...] |
| waiter_list.h | 17 class Waiter;
19 // |WaiterList| tracks all the |Waiter|s that are waiting on a given
34 void AddWaiter(Waiter* waiter, MojoWaitFlags flags, MojoResult wake_result);
35 void RemoveWaiter(Waiter* waiter);
39 WaiterInfo(Waiter* waiter, MojoWaitFlags flags, MojoResult wake_result)
40 : waiter(waiter), flags(flags), wake_result(wake_result) {
42 Waiter* waiter; member in struct:mojo::system::WaiterList::WaiterInfo
[all...] |
| waiter_test_utils.h | 14 #include "mojo/system/waiter.h"
20 // This is a very simple thread that has a |Waiter|, on which it waits
22 // |Waiter| on creation, but the caller must start the thread with |Start()|. It
31 // waiter_list.AddWaiter(thread.waiter(), ...);
33 // ... some stuff to wake the waiter ...
34 // waiter_list.RemoveWaiter(thread.waiter());
39 // |Waiter::Init()|, |AddWaiter()|, and |RemoveWaiter()| are done in the main
40 // (test) thread, not the waiter thread (as would actually happen in real code).
51 Waiter* waiter() { return &waiter_; function in class:mojo::system::test::SimpleWaiterThread
[all...] |
| waiter_unittest.cc | 9 #include "mojo/system/waiter.h"
59 Waiter* waiter() { return &waiter_; } function in class:mojo::system::__anon8765::WaitingThread
80 Waiter waiter_; // Thread-safe.
100 thread.waiter()->Awake(0);
109 thread.waiter()->Awake(MOJO_RESULT_CANCELLED);
122 thread.waiter()->Awake(1);
135 thread.waiter()->Awake(1);
158 thread.waiter()->Awake(0);
167 thread.waiter()->Awake(MOJO_RESULT_CANCELLED)
205 Waiter waiter; local
[all...] |
| core_impl.cc | 19 #include "mojo/system/waiter.h"
42 // |Dispatcher|s for the handles that it wants to wait on with a |Waiter|
43 // object; this |Waiter| object may be created on the stack of that thread or be
45 // The |Dispatcher| then adds the |Waiter| to a |WaiterList| that's either owned
47 // |MessagePipe|). To signal/wake a |Waiter|, the object in question -- either a
63 // INF. |Waiter| locks
533 // TODO(vtl): Should make the waiter live (permanently) in TLS.
534 Waiter waiter; local
535 waiter.Init()
[all...] |
| multiprocess_message_pipe_unittest.cc | 27 #include "mojo/system/waiter.h"
135 Waiter waiter; local
136 waiter.Init();
138 MojoResult add_result = mp->AddWaiter(0, &waiter, flags, MOJO_RESULT_OK);
144 MojoResult wait_result = waiter.Wait(MOJO_DEADLINE_INDEFINITE);
145 mp->RemoveWaiter(0, &waiter);
|
| remote_message_pipe_posix_unittest.cc | 24 #include "mojo/system/waiter.h"
173 Waiter waiter; local
189 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do
191 waiter.Init();
193 mp_1->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 123));
203 EXPECT_EQ(123, waiter.Wait(MOJO_DEADLINE_INDEFINITE));
204 mp_1->RemoveWaiter(1, &waiter);
217 waiter.Init();
219 mp_0->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_READABLE, 456))
264 Waiter waiter; local
380 Waiter waiter; local
[all...] |
| /art/test/059-finalizer-throw/src/ |
| Main.java | 25 static Object waiter = new Object(); field in class:Main
|
| /dalvik/tests/059-finalizer-throw/src/ |
| Main.java | 11 static Object waiter = new Object(); field in class:Main
|
| /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/chromium_org/mojo/public/tests/ |
| simple_bindings_support.cc | 41 Waiter* waiter = new Waiter(); local
42 waiter->handle = handle;
43 waiter->flags = flags;
44 waiter->callback = callback;
45 waiters_.push_back(waiter);
46 return waiter;
50 Waiter* waiter = static_cast<Waiter*>(async_wait_id) local
72 Waiter* waiter = *it; local
[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) {
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/uicc/ |
| AdnRecordCache.java | 312 Message waiter = waiters.get(i); local
314 AsyncResult.forMessage(waiter, ar.result, ar.exception);
315 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);
|
| /external/chromium_org/net/http/ |
| http_stream_factory_impl_unittest.cc | 628 StreamRequestWaiter waiter; local
632 &waiter, BoundNetLog()));
633 waiter.WaitForStream();
669 StreamRequestWaiter waiter; local
673 &waiter, BoundNetLog()));
674 waiter.WaitForStream();
679 SSLConfig used_ssl_config = waiter.used_ssl_config();
722 StreamRequestWaiter waiter; local
727 &waiter, BoundNetLog()));
728 waiter.WaitForStream()
766 StreamRequestWaiter waiter; local
796 StreamRequestWaiter waiter; local
845 StreamRequestWaiter waiter; local
890 StreamRequestWaiter waiter; local
941 StreamRequestWaiter waiter; local
992 StreamRequestWaiter waiter; local
1040 StreamRequestWaiter waiter; local
1104 StreamRequestWaiter waiter; local
1244 StreamRequestWaiter waiter; local
[all...] |
| /cts/tests/tests/display/src/android/display/cts/ |
| VirtualDisplayTest.java | 222 Runnable waiter = new Runnable() { local
230 synchronized (waiter) {
232 mHandler.post(waiter);
234 waiter.wait(TIMEOUT);
|
| /external/chromium_org/ui/compositor/ |
| compositor.cc | 120 DrawWaiterForTest waiter; local
121 waiter.wait_for_commit_ = false;
122 waiter.WaitImpl(compositor);
127 DrawWaiterForTest waiter; local
128 waiter.wait_for_commit_ = true;
129 waiter.WaitImpl(compositor);
|
| /frameworks/base/core/tests/coretests/src/android/hardware/display/ |
| VirtualDisplayTest.java | 316 Runnable waiter = new Runnable() { local
324 synchronized (waiter) {
326 mHandler.post(waiter);
328 waiter.wait(TIMEOUT);
|
| /cts/tests/tests/media/src/android/media/cts/ |
| EncodeVirtualDisplayTest.java | 516 Runnable waiter = new Runnable() { local
524 synchronized (waiter) {
526 mUiHandler.post(waiter);
528 waiter.wait(UI_TIMEOUT_MS);
|
| /external/kernel-headers/original/linux/ |
| module.h | 326 struct task_struct *waiter; member in struct:module
416 wake_up_process(module->waiter);
|
| /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...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| 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...] |
| SynchronousQueue.java | 204 volatile Thread waiter; // to control park/unpark field in class:SynchronousQueue.TransferStack.SNode
231 Thread w = waiter;
233 waiter = null;
361 if (m == null) // waiter is gone
384 * When a node/thread is about to block, it sets its waiter
387 * 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...] |
| /packages/apps/Launcher2/src/com/android/launcher2/ |
| LauncherModel.java | 382 Runnable waiter = new Runnable() { local
391 synchronized(waiter) {
392 runOnWorkerThread(waiter);
401 waiter.wait();
[all...] |
