| /external/chromium_org/mojo/system/ |
| 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...] |
| simple_dispatcher.cc | 29 MojoResult SimpleDispatcher::AddWaiterImplNoLock(Waiter* waiter,
39 waiter_list_.AddWaiter(waiter, flags, wake_result);
43 void SimpleDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) {
45 waiter_list_.RemoveWaiter(waiter);
|
| waiter_list_unittest.cc | 13 #include "mojo/system/waiter.h"
31 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 0);
34 waiter_list.RemoveWaiter(thread.waiter()); // Double-remove okay.
42 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_WRITABLE, 1);
52 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 2);
68 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 0);
73 waiter_list.RemoveWaiter(thread.waiter());
81 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_WRITABLE, 1);
85 waiter_list.RemoveWaiter(thread.waiter());
86 waiter_list.RemoveWaiter(thread.waiter()); // Double-remove okay
[all...] |
| waiter_list.cc | 8 #include "mojo/system/waiter.h"
25 it->waiter->Awake(it->wake_result);
27 it->waiter->Awake(MOJO_RESULT_FAILED_PRECONDITION);
34 it->waiter->Awake(MOJO_RESULT_CANCELLED);
39 void WaiterList::AddWaiter(Waiter* waiter,
42 waiters_.push_back(WaiterInfo(waiter, flags, wake_result));
45 void WaiterList::RemoveWaiter(Waiter* waiter) {
47 // so we need to scan the entire list and remove all occurrences of |waiter|
[all...] |
| simple_dispatcher.h | 20 // in core_impl.cc). This class implements the standard waiter-signalling
44 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
47 virtual void RemoveWaiterImplNoLock(Waiter* waiter) OVERRIDE;
|
| waiter_unittest.cc | 9 #include "mojo/system/waiter.h"
59 Waiter* waiter() { return &waiter_; } function in class:mojo::system::__anon11481::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...] |
| 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...] |
| 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...] |
| data_pipe_consumer_dispatcher.h | 43 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
46 virtual void RemoveWaiterImplNoLock(Waiter* waiter) OVERRIDE;
|
| data_pipe_producer_dispatcher.h | 45 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
48 virtual void RemoveWaiterImplNoLock(Waiter* waiter) OVERRIDE;
|
| message_pipe_dispatcher.h | 44 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
47 virtual void RemoveWaiterImplNoLock(Waiter* waiter) OVERRIDE;
|
| message_pipe_endpoint.h | 23 class Waiter;
70 virtual MojoResult AddWaiter(Waiter* waiter,
73 virtual void RemoveWaiter(Waiter* waiter);
|
| data_pipe.h | 18 class Waiter;
43 MojoResult ProducerAddWaiter(Waiter* waiter,
46 void ProducerRemoveWaiter(Waiter* waiter);
61 MojoResult ConsumerAddWaiter(Waiter* waiter,
64 void ConsumerRemoveWaiter(Waiter* waiter);
|
| data_pipe_consumer_dispatcher.cc | 91 Waiter* waiter,
95 return data_pipe_->ConsumerAddWaiter(waiter, flags, wake_result);
98 void DataPipeConsumerDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) {
100 data_pipe_->ConsumerRemoveWaiter(waiter);
|
| data_pipe_producer_dispatcher.cc | 76 Waiter* waiter,
80 return data_pipe_->ProducerAddWaiter(waiter, flags, wake_result);
83 void DataPipeProducerDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) {
85 data_pipe_->ProducerRemoveWaiter(waiter);
|
| message_pipe_dispatcher.cc | 88 MojoResult MessagePipeDispatcher::AddWaiterImplNoLock(Waiter* waiter,
92 return message_pipe_->AddWaiter(port_, waiter, flags, wake_result);
95 void MessagePipeDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) {
97 message_pipe_->RemoveWaiter(port_, waiter);
|
| /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/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/frame/ |
| browser_non_client_frame_view_ash_browsertest.cc | 74 scoped_ptr<FullscreenNotificationObserver> waiter(
78 waiter->Wait();
89 scoped_ptr<FullscreenNotificationObserver> waiter(
92 waiter->Wait();
127 scoped_ptr<FullscreenNotificationObserver> waiter(
130 waiter->Wait();
133 scoped_ptr<FullscreenNotificationObserver> waiter(
137 waiter->Wait();
161 scoped_ptr<FullscreenNotificationObserver> waiter(
165 waiter->Wait()
[all...] |
| /external/chromium_org/chrome/browser/ui/views/location_bar/ |
| zoom_bubble_view_browsertest.cc | 40 scoped_ptr<FullscreenNotificationObserver> waiter(
44 waiter->Wait();
58 scoped_ptr<FullscreenNotificationObserver> waiter(
61 waiter->Wait();
79 scoped_ptr<FullscreenNotificationObserver> waiter(
82 waiter->Wait();
120 scoped_ptr<FullscreenNotificationObserver> waiter(
123 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 | 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...] |
| /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...] |
| /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...] |
