/external/chromium_org/mojo/system/ |
H A D | waiter_list.h | 34 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 D | simple_dispatcher.cc | 29 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 D | 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()); // Doubl [all...] |
H A D | 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, 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 D | waiter_unittest.cc | 9 #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 D | 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;
|
H A D | 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)); 382 mp->RemoveWaiter(0, &waiter); [all...] |
H A D | 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)); 227 EXPECT_EQ(456, waiter 264 Waiter waiter; local 380 Waiter waiter; local [all...] |
H A D | data_pipe_consumer_dispatcher.cc | 91 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 D | data_pipe_producer_dispatcher.cc | 76 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 D | message_pipe_dispatcher.cc | 88 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 D | data_pipe.h | 43 MojoResult ProducerAddWaiter(Waiter* waiter, 46 void ProducerRemoveWaiter(Waiter* waiter); 61 MojoResult ConsumerAddWaiter(Waiter* waiter, 64 void ConsumerRemoveWaiter(Waiter* waiter);
|
H A D | dispatcher.h | 70 // 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 D | data_pipe.cc | 94 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 D | data_pipe_consumer_dispatcher.h | 43 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter, 46 virtual void RemoveWaiterImplNoLock(Waiter* waiter) OVERRIDE;
|
H A D | data_pipe_producer_dispatcher.h | 45 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter, 48 virtual void RemoveWaiterImplNoLock(Waiter* waiter) OVERRIDE;
|
/external/chromium_org/mojo/public/tests/ |
H A D | 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 54 if (*it == waiter) { 62 delete waiter; 72 Waiter* waiter local [all...] |
/external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
H A D | 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) {
|
/external/chromium_org/chrome/browser/ui/views/location_bar/ |
H A D | 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();
|
/external/chromium_org/chrome/browser/ui/views/frame/ |
H A D | 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 [all...] |
/external/chromium_org/net/http/ |
H A D | 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 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 D | waitable_event.h | 106 // 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 D | waitable_event.h | 104 // 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 D | 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, 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 D | screen_locker_browsertest.cc | 187 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...] |