Home
last modified time | relevance | path

Searched refs:waiter (Results 1 – 25 of 69) sorted by relevance

123

/external/chromium_org/mojo/system/
Dwaiter_list_unittest.cc31 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 0); in TEST()
34 waiter_list.RemoveWaiter(thread.waiter()); // Double-remove okay. in TEST()
42 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_WRITABLE, 1); in TEST()
52 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 2); in TEST()
68 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 0); in TEST()
73 waiter_list.RemoveWaiter(thread.waiter()); in TEST()
81 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_WRITABLE, 1); in TEST()
85 waiter_list.RemoveWaiter(thread.waiter()); in TEST()
86 waiter_list.RemoveWaiter(thread.waiter()); // Double-remove okay. in TEST()
95 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 2); in TEST()
[all …]
Dwaiter_unittest.cc59 Waiter* waiter() { return &waiter_; } in waiter() function in mojo::system::__anon27ef372c0111::WaitingThread
100 thread.waiter()->Awake(0); in TEST()
109 thread.waiter()->Awake(MOJO_RESULT_CANCELLED); in TEST()
122 thread.waiter()->Awake(1); in TEST()
135 thread.waiter()->Awake(1); in TEST()
158 thread.waiter()->Awake(0); in TEST()
167 thread.waiter()->Awake(MOJO_RESULT_CANCELLED); in TEST()
180 thread.waiter()->Awake(1); in TEST()
193 thread.waiter()->Awake(1); in TEST()
205 Waiter waiter; in TEST() local
[all …]
Dmessage_pipe_unittest.cc360 Waiter waiter; in TEST() local
367 waiter.Init(); in TEST()
369 mp->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_WRITABLE, 0)); in TEST()
370 waiter.Init(); in TEST()
373 &waiter, in TEST()
378 waiter.Init(); in TEST()
380 mp->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_READABLE, 1)); in TEST()
381 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0)); in TEST()
382 mp->RemoveWaiter(0, &waiter); in TEST()
393 waiter.Init(); in TEST()
[all …]
Dremote_message_pipe_posix_unittest.cc173 Waiter waiter; in TEST_F() local
191 waiter.Init(); in TEST_F()
193 mp_1->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 123)); in TEST_F()
203 EXPECT_EQ(123, waiter.Wait(MOJO_DEADLINE_INDEFINITE)); in TEST_F()
204 mp_1->RemoveWaiter(1, &waiter); in TEST_F()
217 waiter.Init(); in TEST_F()
219 mp_0->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_READABLE, 456)); in TEST_F()
227 EXPECT_EQ(456, waiter.Wait(MOJO_DEADLINE_INDEFINITE)); in TEST_F()
228 mp_0->RemoveWaiter(0, &waiter); in TEST_F()
245 waiter.Init(); in TEST_F()
[all …]
Dwaiter_list.cc25 it->waiter->Awake(it->wake_result); in AwakeWaitersForStateChange()
27 it->waiter->Awake(MOJO_RESULT_FAILED_PRECONDITION); in AwakeWaitersForStateChange()
34 it->waiter->Awake(MOJO_RESULT_CANCELLED); in CancelAllWaiters()
39 void WaiterList::AddWaiter(Waiter* waiter, in AddWaiter() argument
42 waiters_.push_back(WaiterInfo(waiter, flags, wake_result)); in AddWaiter()
45 void WaiterList::RemoveWaiter(Waiter* waiter) { in RemoveWaiter() argument
51 if (maybe_delete->waiter == waiter) in RemoveWaiter()
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) in WaiterInfo()
40 : waiter(waiter), flags(flags), wake_result(wake_result) {} in WaiterInfo()
42 Waiter* waiter; member
Dsimple_dispatcher.cc29 MojoResult SimpleDispatcher::AddWaiterImplNoLock(Waiter* waiter, in AddWaiterImplNoLock() argument
39 waiter_list_.AddWaiter(waiter, flags, wake_result); in AddWaiterImplNoLock()
43 void SimpleDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) { in RemoveWaiterImplNoLock() argument
45 waiter_list_.RemoveWaiter(waiter); in RemoveWaiterImplNoLock()
Ddata_pipe.cc94 MojoResult DataPipe::ProducerAddWaiter(Waiter* waiter, in ProducerAddWaiter() argument
105 producer_waiter_list_->AddWaiter(waiter, flags, wake_result); in ProducerAddWaiter()
109 void DataPipe::ProducerRemoveWaiter(Waiter* waiter) { in ProducerRemoveWaiter() argument
112 producer_waiter_list_->RemoveWaiter(waiter); in ProducerRemoveWaiter()
196 MojoResult DataPipe::ConsumerAddWaiter(Waiter* waiter, in ConsumerAddWaiter() argument
207 consumer_waiter_list_->AddWaiter(waiter, flags, wake_result); in ConsumerAddWaiter()
211 void DataPipe::ConsumerRemoveWaiter(Waiter* waiter) { in ConsumerRemoveWaiter() argument
214 consumer_waiter_list_->RemoveWaiter(waiter); in ConsumerRemoveWaiter()
Ddata_pipe_producer_dispatcher.cc76 Waiter* waiter, in AddWaiterImplNoLock() argument
80 return data_pipe_->ProducerAddWaiter(waiter, flags, wake_result); in AddWaiterImplNoLock()
83 void DataPipeProducerDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) { in RemoveWaiterImplNoLock() argument
85 data_pipe_->ProducerRemoveWaiter(waiter); in RemoveWaiterImplNoLock()
Dmessage_pipe_dispatcher.cc88 MojoResult MessagePipeDispatcher::AddWaiterImplNoLock(Waiter* waiter, in AddWaiterImplNoLock() argument
92 return message_pipe_->AddWaiter(port_, waiter, flags, wake_result); in AddWaiterImplNoLock()
95 void MessagePipeDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) { in RemoveWaiterImplNoLock() argument
97 message_pipe_->RemoveWaiter(port_, waiter); in RemoveWaiterImplNoLock()
Ddata_pipe_consumer_dispatcher.cc91 Waiter* waiter, in AddWaiterImplNoLock() argument
95 return data_pipe_->ConsumerAddWaiter(waiter, flags, wake_result); in AddWaiterImplNoLock()
98 void DataPipeConsumerDispatcher::RemoveWaiterImplNoLock(Waiter* waiter) { in RemoveWaiterImplNoLock() argument
100 data_pipe_->ConsumerRemoveWaiter(waiter); in RemoveWaiterImplNoLock()
Ddata_pipe.h43 MojoResult ProducerAddWaiter(Waiter* waiter,
46 void ProducerRemoveWaiter(Waiter* waiter);
61 MojoResult ConsumerAddWaiter(Waiter* waiter,
64 void ConsumerRemoveWaiter(Waiter* waiter);
Ddispatcher.h82 MojoResult AddWaiter(Waiter* waiter,
85 void RemoveWaiter(Waiter* waiter);
135 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
138 virtual void RemoveWaiterImplNoLock(Waiter* waiter);
/external/chromium_org/mojo/public/tests/
Dsimple_bindings_support.cc41 Waiter* waiter = new Waiter(); in AsyncWait() local
42 waiter->handle = handle; in AsyncWait()
43 waiter->flags = flags; in AsyncWait()
44 waiter->callback = callback; in AsyncWait()
45 waiters_.push_back(waiter); in AsyncWait()
46 return waiter; in AsyncWait()
50 Waiter* waiter = static_cast<Waiter*>(async_wait_id); in CancelWait() local
54 if (*it == waiter) { in CancelWait()
62 delete waiter; in CancelWait()
72 Waiter* waiter = *it; in Process() local
[all …]
/external/chromium_org/net/http/
Dhttp_stream_factory_impl_unittest.cc628 StreamRequestWaiter waiter; in TEST_P() local
632 &waiter, BoundNetLog())); in TEST_P()
633 waiter.WaitForStream(); in TEST_P()
669 StreamRequestWaiter waiter; in TEST_P() local
673 &waiter, BoundNetLog())); in TEST_P()
674 waiter.WaitForStream(); in TEST_P()
679 SSLConfig used_ssl_config = waiter.used_ssl_config(); in TEST_P()
722 StreamRequestWaiter waiter; in TEST_P() local
727 &waiter, BoundNetLog())); in TEST_P()
728 waiter.WaitForStream(); in TEST_P()
[all …]
/external/chromium_org/chrome/browser/ui/views/frame/
Dbrowser_non_client_frame_view_ash_browsertest.cc74 scoped_ptr<FullscreenNotificationObserver> waiter( in IN_PROC_BROWSER_TEST_F() local
78 waiter->Wait(); in IN_PROC_BROWSER_TEST_F()
89 scoped_ptr<FullscreenNotificationObserver> waiter( in IN_PROC_BROWSER_TEST_F() local
92 waiter->Wait(); in IN_PROC_BROWSER_TEST_F()
127 scoped_ptr<FullscreenNotificationObserver> waiter( in IN_PROC_BROWSER_TEST_F() local
130 waiter->Wait(); in IN_PROC_BROWSER_TEST_F()
133 scoped_ptr<FullscreenNotificationObserver> waiter( in IN_PROC_BROWSER_TEST_F() local
137 waiter->Wait(); in IN_PROC_BROWSER_TEST_F()
161 scoped_ptr<FullscreenNotificationObserver> waiter( in IN_PROC_BROWSER_TEST_F() local
165 waiter->Wait(); in IN_PROC_BROWSER_TEST_F()
[all …]
/external/apache-http/src/org/apache/http/impl/conn/tsccm/
DWaitingThread.java60 private Thread waiter; field in WaitingThread
114 return this.waiter; in getThread()
142 if (this.waiter != null) { in await()
146 "\nwaiter: " + this.waiter); in await()
152 this.waiter = Thread.currentThread(); in await()
165 this.waiter = null; in await()
181 if (this.waiter == null) { in wakeup()
/external/chromium_org/chrome/browser/ui/views/location_bar/
Dzoom_bubble_view_browsertest.cc40 scoped_ptr<FullscreenNotificationObserver> waiter( in IN_PROC_BROWSER_TEST_F() local
44 waiter->Wait(); in IN_PROC_BROWSER_TEST_F()
58 scoped_ptr<FullscreenNotificationObserver> waiter( in IN_PROC_BROWSER_TEST_F() local
61 waiter->Wait(); in IN_PROC_BROWSER_TEST_F()
79 scoped_ptr<FullscreenNotificationObserver> waiter( in IN_PROC_BROWSER_TEST_F() local
82 waiter->Wait(); in IN_PROC_BROWSER_TEST_F()
120 scoped_ptr<FullscreenNotificationObserver> waiter( in IN_PROC_BROWSER_TEST_F() local
123 waiter->Wait(); in IN_PROC_BROWSER_TEST_F()
/external/chromium_org/chrome/browser/chromeos/login/
Dscreen_locker_browsertest.cc187 Waiter waiter(browser()); in IN_PROC_BROWSER_TEST_F() local
189 waiter.Wait(false /* not locked */, true /* full screen */); in IN_PROC_BROWSER_TEST_F()
195 Waiter waiter(browser()); in IN_PROC_BROWSER_TEST_F() local
198 waiter.Wait(true /* locked */, true /* full screen */); in IN_PROC_BROWSER_TEST_F()
208 Waiter waiter(browser()); in IN_PROC_BROWSER_TEST_F() local
210 waiter.Wait(false /* not locked */, false /* fullscreen */); in IN_PROC_BROWSER_TEST_F()
218 Waiter waiter(browser()); in IN_PROC_BROWSER_TEST_F() local
223 waiter.Wait(false /* not locked */, true /* fullscreen */); in IN_PROC_BROWSER_TEST_F()
229 Waiter waiter(browser()); in IN_PROC_BROWSER_TEST_F() local
232 waiter.Wait(true /* locked */, false /* full screen */); in IN_PROC_BROWSER_TEST_F()
/external/chromium_org/chrome/browser/chromeos/app_mode/
Dkiosk_app_manager_browsertest.cc343 AppDataLoadWaiter waiter(manager()); in IN_PROC_BROWSER_TEST_F() local
344 waiter.Wait(); in IN_PROC_BROWSER_TEST_F()
345 EXPECT_TRUE(waiter.loaded()); in IN_PROC_BROWSER_TEST_F()
373 AppDataLoadWaiter waiter(manager()); in IN_PROC_BROWSER_TEST_F() local
374 waiter.Wait(); in IN_PROC_BROWSER_TEST_F()
375 EXPECT_TRUE(waiter.loaded()); in IN_PROC_BROWSER_TEST_F()
388 waiter.Wait(); in IN_PROC_BROWSER_TEST_F()
389 EXPECT_TRUE(waiter.loaded()); in IN_PROC_BROWSER_TEST_F()
402 AppDataLoadWaiter waiter(manager()); in IN_PROC_BROWSER_TEST_F() local
403 waiter.Wait(); in IN_PROC_BROWSER_TEST_F()
[all …]
/external/kernel-headers/original/linux/
Dsync.h171 struct sync_fence_waiter *waiter);
185 static inline void sync_fence_waiter_init(struct sync_fence_waiter *waiter, in sync_fence_waiter_init() argument
188 waiter->callback = callback; in sync_fence_waiter_init()
311 struct sync_fence_waiter *waiter);
325 struct sync_fence_waiter *waiter);
/external/chromium/base/synchronization/
Dwaitable_event_posix.cc307 size_t count, Waiter* waiter) { in EnqueueMany() argument
319 const size_t r = EnqueueMany(waitables + 1, count - 1, waiter); in EnqueueMany()
323 waitables[0].first->Enqueue(waiter); in EnqueueMany()
379 void WaitableEvent::Enqueue(Waiter* waiter) { in Enqueue() argument
380 kernel_->waiters_.push_back(waiter); in Enqueue()
387 bool WaitableEvent::WaitableEventKernel::Dequeue(Waiter* waiter, void* tag) { in Dequeue() argument
390 if (*i == waiter && (*i)->Compare(tag)) { in Dequeue()
/external/chromium_org/base/synchronization/
Dwaitable_event_posix.cc313 size_t count, Waiter* waiter) { in EnqueueMany() argument
325 const size_t r = EnqueueMany(waitables + 1, count - 1, waiter); in EnqueueMany()
329 waitables[0].first->Enqueue(waiter); in EnqueueMany()
385 void WaitableEvent::Enqueue(Waiter* waiter) { in Enqueue() argument
386 kernel_->waiters_.push_back(waiter); in Enqueue()
393 bool WaitableEvent::WaitableEventKernel::Dequeue(Waiter* waiter, void* tag) { in Dequeue() argument
396 if (*i == waiter && (*i)->Compare(tag)) { in Dequeue()
Dwaitable_event.h148 bool Dequeue(Waiter* waiter, void* tag);
168 size_t count, Waiter* waiter);
172 void Enqueue(Waiter* waiter);
/external/chromium_org/content/browser/accessibility/
Daccessibility_win_browsertest.cc150 AccessibilityNotificationWaiter waiter( in LoadInitialAccessibilityTreeFromHtml() local
155 waiter.WaitForNotification(); in LoadInitialAccessibilityTreeFromHtml()
504 scoped_ptr<AccessibilityNotificationWaiter> waiter( in IN_PROC_BROWSER_TEST_F() local
509 waiter->WaitForNotification(); in IN_PROC_BROWSER_TEST_F()
517 waiter.reset(new AccessibilityNotificationWaiter( in IN_PROC_BROWSER_TEST_F()
522 waiter->WaitForNotification(); in IN_PROC_BROWSER_TEST_F()
549 scoped_ptr<AccessibilityNotificationWaiter> waiter( in IN_PROC_BROWSER_TEST_F() local
554 waiter->WaitForNotification(); in IN_PROC_BROWSER_TEST_F()
576 scoped_ptr<AccessibilityNotificationWaiter> waiter( in IN_PROC_BROWSER_TEST_F() local
582 waiter->WaitForNotification(); in IN_PROC_BROWSER_TEST_F()
[all …]

123