Searched refs:waiter (Results 1 - 25 of 68) sorted by relevance

123

/external/chromium_org/mojo/system/
H A Dwaiter_list.h34 void AddWaiter(Waiter* waiter, MojoWaitFlags flags, MojoResult wake_result);
35 void RemoveWaiter(Waiter* waiter);
39 WaiterInfo(Waiter* waiter, MojoWaitFlags flags, MojoResult wake_result) argument
40 : waiter(waiter), flags(flags), wake_result(wake_result) {}
42 Waiter* waiter; member in struct:mojo::system::WaiterList::WaiterInfo
H A Dsimple_dispatcher.cc29 MojoResult SimpleDispatcher::AddWaiterImplNoLock(Waiter* waiter, argument
39 waiter_list_.AddWaiter(waiter, flags, wake_result);
43 void SimpleDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) { argument
45 waiter_list_.RemoveWaiter(waiter);
H A Dwaiter_list_unittest.cc13 #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()); // Doubl
[all...]
H A Dwaiter_list.cc8 #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, argument
42 waiters_.push_back(WaiterInfo(waiter, flags, wake_result));
45 void WaiterList::RemoveWaiter(Waiter* waiter) { argument
47 // so we need to scan the entire list and remove all occurrences of |waiter|.
51 if (maybe_delete->waiter == waiter)
[all...]
H A Dwaiter_unittest.cc9 #include "mojo/system/waiter.h"
59 Waiter* waiter() { return &waiter_; } function in class:mojo::system::__anon9075::WaitingThread
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);
180 thread.waiter()->Awake(1);
193 thread.waiter()
205 Waiter waiter; local
[all...]
H A Dsimple_dispatcher.h20 // in core_impl.cc). This class implements the standard waiter-signalling
44 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
47 virtual void RemoveWaiterImplNoLock(Waiter* waiter) OVERRIDE;
H A Dmessage_pipe_unittest.cc10 #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));
382 mp->RemoveWaiter(0, &waiter);
[all...]
H A Dremote_message_pipe_posix_unittest.cc24 #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));
227 EXPECT_EQ(456, waiter
264 Waiter waiter; local
380 Waiter waiter; local
[all...]
H A Ddata_pipe_consumer_dispatcher.cc91 Waiter* waiter,
95 return data_pipe_->ConsumerAddWaiter(waiter, flags, wake_result);
98 void DataPipeConsumerDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) { argument
100 data_pipe_->ConsumerRemoveWaiter(waiter);
90 AddWaiterImplNoLock( Waiter* waiter, MojoWaitFlags flags, MojoResult wake_result) argument
H A Ddata_pipe_producer_dispatcher.cc76 Waiter* waiter,
80 return data_pipe_->ProducerAddWaiter(waiter, flags, wake_result);
83 void DataPipeProducerDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) { argument
85 data_pipe_->ProducerRemoveWaiter(waiter);
75 AddWaiterImplNoLock( Waiter* waiter, MojoWaitFlags flags, MojoResult wake_result) argument
H A Dmessage_pipe_dispatcher.cc88 MojoResult MessagePipeDispatcher::AddWaiterImplNoLock(Waiter* waiter, argument
92 return message_pipe_->AddWaiter(port_, waiter, flags, wake_result);
95 void MessagePipeDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) { argument
97 message_pipe_->RemoveWaiter(port_, waiter);
H A Ddata_pipe.h43 MojoResult ProducerAddWaiter(Waiter* waiter,
46 void ProducerRemoveWaiter(Waiter* waiter);
61 MojoResult ConsumerAddWaiter(Waiter* waiter,
64 void ConsumerRemoveWaiter(Waiter* waiter);
H A Ddispatcher.h70 // Adds a waiter to this dispatcher. The waiter will be woken up when this
77 // - |MOJO_RESULT_OK| if the waiter was added;
82 MojoResult AddWaiter(Waiter* waiter,
85 void RemoveWaiter(Waiter* waiter);
135 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
138 virtual void RemoveWaiterImplNoLock(Waiter* waiter);
H A Ddata_pipe.cc94 MojoResult DataPipe::ProducerAddWaiter(Waiter* waiter, argument
105 producer_waiter_list_->AddWaiter(waiter, flags, wake_result);
109 void DataPipe::ProducerRemoveWaiter(Waiter* waiter) { argument
112 producer_waiter_list_->RemoveWaiter(waiter);
196 MojoResult DataPipe::ConsumerAddWaiter(Waiter* waiter, argument
207 consumer_waiter_list_->AddWaiter(waiter, flags, wake_result);
211 void DataPipe::ConsumerRemoveWaiter(Waiter* waiter) { argument
214 consumer_waiter_list_->RemoveWaiter(waiter);
H A Ddata_pipe_consumer_dispatcher.h43 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
46 virtual void RemoveWaiterImplNoLock(Waiter* waiter) OVERRIDE;
H A Ddata_pipe_producer_dispatcher.h45 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
48 virtual void RemoveWaiterImplNoLock(Waiter* waiter) OVERRIDE;
/external/chromium_org/mojo/public/tests/
H A Dsimple_bindings_support.cc41 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
54 if (*it == waiter) {
62 delete waiter;
72 Waiter* waiter local
[all...]
/external/apache-http/src/org/apache/http/impl/conn/tsccm/
H A DWaitingThread.java60 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) {
/external/chromium_org/chrome/browser/ui/views/location_bar/
H A Dzoom_bubble_view_browsertest.cc40 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();
/external/chromium_org/chrome/browser/ui/views/frame/
H A Dbrowser_non_client_frame_view_ash_browsertest.cc74 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
[all...]
/external/chromium_org/net/http/
H A Dhttp_stream_factory_impl_unittest.cc628 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
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/
H A Dwaitable_event.h106 // Signal the waiter to wake up.
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!
151 bool Dequeue(Waiter* waiter, void* tag);
167 size_t count, Waiter* waiter);
171 void Enqueue(Waiter* waiter);
/external/chromium_org/base/synchronization/
H A Dwaitable_event.h104 // Signal the waiter to wake up.
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!
148 bool Dequeue(Waiter* waiter, void* tag);
168 size_t count, Waiter* waiter);
172 void Enqueue(Waiter* waiter);
/external/kernel-headers/original/linux/
H A Dsync.h171 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, argument
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 callbac
[all...]
/external/chromium_org/chrome/browser/chromeos/login/
H A Dscreen_locker_browsertest.cc187 Waiter waiter(browser());
189 waiter.Wait(false /* not locked */, true /* full screen */);
195 Waiter waiter(browser());
198 waiter.Wait(true /* locked */, true /* full screen */);
208 Waiter waiter(browser());
210 waiter.Wait(false /* not locked */, false /* fullscreen */);
218 Waiter waiter(browser());
223 waiter.Wait(false /* not locked */, true /* fullscreen */);
229 Waiter waiter(browser());
232 waiter
[all...]

Completed in 1167 milliseconds

123