| /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/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_org/chrome/browser/ui/views/location_bar/ |
| zoom_bubble_view_browsertest.cc | 58 scoped_ptr<FullscreenNotificationObserver> waiter(
62 waiter->Wait();
76 scoped_ptr<FullscreenNotificationObserver> waiter(
79 waiter->Wait();
102 scoped_ptr<FullscreenNotificationObserver> waiter(
105 waiter->Wait();
143 scoped_ptr<FullscreenNotificationObserver> waiter(
146 waiter->Wait();
|
| /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/net/http/ |
| http_stream_factory_impl_unittest.cc | 572 StreamRequestWaiter waiter; local
576 &waiter, BoundNetLog()));
577 waiter.WaitForStream();
613 StreamRequestWaiter waiter; local
617 &waiter, BoundNetLog()));
618 waiter.WaitForStream();
623 SSLConfig used_ssl_config = waiter.used_ssl_config();
666 StreamRequestWaiter waiter; local
671 &waiter, BoundNetLog()));
672 waiter.WaitForStream()
710 StreamRequestWaiter waiter; local
740 StreamRequestWaiter waiter; local
789 StreamRequestWaiter waiter; local
834 StreamRequestWaiter waiter; local
885 StreamRequestWaiter waiter; local
936 StreamRequestWaiter waiter; local
984 StreamRequestWaiter waiter; local
1048 StreamRequestWaiter waiter; local
1188 StreamRequestWaiter waiter; 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...] |
| /external/chromium_org/base/synchronization/ |
| waitable_event.h | 102 class Waiter {
104 // Signal the waiter to wake up.
106 // Consider the case of a Waiter which is in multiple WaitableEvent's
108 // signaled at the same time. Now, each will wake only the first waiter in
111 // to dequeue the waiter from the other wait-list in time), two auto-resets
112 // will have happened, but only one waiter has been signaled!
114 // Because of this, a Waiter may "reject" a wake by returning false. In
126 virtual ~Waiter() {}
148 bool Dequeue(Waiter* waiter, void* tag)
[all...] |
| waitable_event_posix.cc | 21 // waiter is either an async wait, in which case we have a Task and the
31 // firing a waiter and so we can store that pointer to find out which event
82 // This is a synchronous waiter. The thread is waiting on the given condition
85 class SyncWaiter : public WaitableEvent::Waiter {
262 // enqueued our waiter in them all.
302 // The locks of the WaitableEvents have been taken in order and the Waiter has
306 // None of the WaitableEvent locks are held. The Waiter has not been enqueued
313 size_t count, Waiter* waiter) {
325 const size_t r = EnqueueMany(waitables + 1, count - 1, waiter);
[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...] |
| /external/chromium_org/tools/gn/ |
| item_tree.cc | 167 ItemNode* waiter = i->first; local
169 // Our node should be unresolved in the waiter.
170 DCHECK(waiter->unresolved_dependencies().find(node) !=
171 waiter->unresolved_dependencies().end());
172 waiter->MarkDirectDependencyResolved(node);
175 if ((waiter->state() == ItemNode::DEFINED ||
176 waiter->state() == ItemNode::PENDING_DEPS) &&
177 waiter->unresolved_dependencies().empty())
178 MarkItemResolvedLocked(waiter);
|
| /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
|
| /external/chromium_org/media/base/ |
| bind_to_loop_unittest.cc | 51 base::WaitableEvent waiter(false, false);
53 &base::WaitableEvent::Signal, base::Unretained(&waiter)));
55 EXPECT_FALSE(waiter.IsSignaled());
57 EXPECT_TRUE(waiter.IsSignaled());
|
| /external/chromium_org/chrome/browser/chromeos/app_mode/ |
| kiosk_app_manager_browsertest.cc | 280 AppDataLoadWaiter waiter(manager());
281 waiter.Wait();
282 EXPECT_TRUE(waiter.loaded());
297 AppDataLoadWaiter waiter(manager());
298 waiter.Wait();
299 EXPECT_FALSE(waiter.loaded());
310 AppDataLoadWaiter waiter(manager());
311 waiter.Wait();
312 EXPECT_TRUE(waiter.loaded());
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| 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...] |
| /external/chromium_org/chrome/browser/ui/views/frame/ |
| immersive_mode_controller_ash_browsertest.cc | 391 scoped_ptr<FullscreenNotificationObserver> waiter(
396 waiter->Wait();
403 waiter.reset(new FullscreenNotificationObserver());
406 waiter->Wait();
414 waiter.reset(new FullscreenNotificationObserver());
417 waiter->Wait();
418 waiter.reset(new FullscreenNotificationObserver());
420 waiter->Wait();
|
| browser_non_client_frame_view_ash_browsertest.cc | 105 scoped_ptr<FullscreenNotificationObserver> waiter(
109 waiter->Wait();
120 scoped_ptr<FullscreenNotificationObserver> waiter(
123 waiter->Wait();
|
| /external/chromium_org/content/browser/accessibility/ |
| accessibility_win_browsertest.cc | 150 AccessibilityNotificationWaiter waiter(
155 waiter.WaitForNotification();
504 scoped_ptr<AccessibilityNotificationWaiter> waiter(
509 waiter->WaitForNotification();
517 waiter.reset(new AccessibilityNotificationWaiter(
522 waiter->WaitForNotification();
549 scoped_ptr<AccessibilityNotificationWaiter> waiter(
554 waiter->WaitForNotification();
576 scoped_ptr<AccessibilityNotificationWaiter> waiter(
582 waiter->WaitForNotification()
[all...] |
| /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/chromium_org/chrome/browser/chromeos/login/ |
| screen_locker_browsertest.cc | 38 class Waiter : public content::NotificationObserver {
40 explicit Waiter(Browser* browser)
51 virtual ~Waiter() {
84 DISALLOW_COPY_AND_ASSIGN(Waiter);
178 Waiter waiter(browser());
180 waiter.Wait(false /* not locked */, true /* full screen */);
185 Waiter waiter(browser());
188 waiter.Wait(true /* locked */, false /* full screen */)
[all...] |
| /external/chromium_org/chrome/browser/ui/app_list/search/ |
| history_unittest.cc | 30 // store on the blocking pool. The waiter waits on the main message loop until
70 // The flush and disk write happens on the blocking pool. The waiter waits
133 HistoryDataLoadWaiter waiter(history_->data_.get());
134 waiter.Wait(1000);
139 StoreFlushWaiter waiter(history_->store_.get());
140 waiter.Wait(1000);
|
| /external/chromium_org/remoting/client/jni/ |
| chromoting_jni_runtime.h | 98 // Detaches JVM from the current thread, then signals. Doesn't own |waiter|.
99 void DetachFromVmAndSignal(base::WaitableEvent* waiter);
|
| /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);
|
| /external/chromium_org/media/audio/ |
| cross_process_notification_unittest.cc | 107 CrossProcessNotification::WaitForMultiple waiter(notifiers_);
109 int signaled = waiter.Wait();
336 CrossProcessNotification::WaitForMultiple waiter(&pairs.b());
339 int index = waiter.Wait();
358 // thread(s) to catch the signaled event, we define the |waiter| inside
360 CrossProcessNotification::WaitForMultiple waiter(&pairs.b());
361 int index = waiter.Wait();
|
