| /external/chromium_org/mojo/system/ |
| waiter_list.h | 19 class Waiter;
22 // |WaiterList| tracks all the |Waiter|s that are waiting on a given
36 void AddWaiter(Waiter* waiter, MojoHandleSignals signals, uint32_t context);
37 void RemoveWaiter(Waiter* waiter);
41 WaiterInfo(Waiter* waiter, MojoHandleSignals signals, uint32_t context)
42 : waiter(waiter), signals(signals), context(context) {
44 Waiter* waiter; member in struct:mojo::system::WaiterList::WaiterInfo
[all...] |
| waiter_list.cc | 9 #include "mojo/system/waiter.h"
25 it->waiter->Awake(MOJO_RESULT_OK, it->context);
27 it->waiter->Awake(MOJO_RESULT_FAILED_PRECONDITION, it->context);
34 it->waiter->Awake(MOJO_RESULT_CANCELLED, it->context);
39 void WaiterList::AddWaiter(Waiter* waiter,
42 waiters_.push_back(WaiterInfo(waiter, signals, context));
45 void WaiterList::RemoveWaiter(Waiter* waiter) {
47 // so we need to scan the entire list and remove all occurrences of |waiter|
[all...] |
| waiter_list_unittest.cc | 16 #include "mojo/system/waiter.h"
32 waiter_list.AddWaiter(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 1);
36 waiter_list.RemoveWaiter(thread.waiter());
45 waiter_list.AddWaiter(thread.waiter(), MOJO_HANDLE_SIGNAL_WRITABLE, 2);
56 waiter_list.AddWaiter(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 3);
73 waiter_list.AddWaiter(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 1);
78 waiter_list.RemoveWaiter(thread.waiter());
87 waiter_list.AddWaiter(thread.waiter(), MOJO_HANDLE_SIGNAL_WRITABLE, 2);
91 waiter_list.RemoveWaiter(thread.waiter());
93 waiter_list.RemoveWaiter(thread.waiter());
[all...] |
| simple_dispatcher.cc | 29 Waiter* waiter,
47 waiter_list_.AddWaiter(waiter, signals, context);
52 Waiter* waiter,
55 waiter_list_.RemoveWaiter(waiter);
|
| simple_dispatcher.h | 20 // in core.cc). This class implements the standard waiter-signalling mechanism
35 Waiter* waiter,
40 Waiter* waiter,
|
| waiter_unittest.cc | 10 #include "mojo/system/waiter.h"
61 Waiter* waiter() { return &waiter_; } function in class:mojo::system::__anon13494::WaitingThread
84 Waiter waiter_; // Thread-safe.
106 thread.waiter()->Awake(MOJO_RESULT_OK, 1);
116 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 2);
129 thread.waiter()->Awake(1, 3);
142 thread.waiter()->Awake(2, 4);
167 thread.waiter()->Awake(MOJO_RESULT_OK, 5);
177 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 6)
216 Waiter waiter; local
[all...] |
| message_pipe_test_utils.cc | 12 #include "mojo/system/waiter.h"
21 Waiter waiter; local
22 waiter.Init();
24 MojoResult add_result = mp->AddWaiter(0, &waiter, signals, 0, signals_state);
30 MojoResult wait_result = waiter.Wait(MOJO_DEADLINE_INDEFINITE, nullptr);
31 mp->RemoveWaiter(0, &waiter, signals_state);
|
| remote_message_pipe_unittest.cc | 36 #include "mojo/system/waiter.h"
182 Waiter waiter; local
198 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do
200 waiter.Init();
203 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));
214 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context));
217 mp1->RemoveWaiter(1, &waiter, &hss);
236 waiter.Init();
239 mp0->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, nullptr))
297 Waiter waiter; local
448 Waiter waiter; local
513 Waiter waiter; local
684 Waiter waiter; local
821 Waiter waiter; local
967 Waiter waiter; local
[all...] |
| data_pipe_consumer_dispatcher.h | 49 Waiter* waiter,
54 Waiter* waiter,
|
| data_pipe_producer_dispatcher.h | 50 Waiter* waiter,
55 Waiter* waiter,
|
| local_message_pipe_endpoint.h | 40 virtual MojoResult AddWaiter(Waiter* waiter,
44 virtual void RemoveWaiter(Waiter* waiter,
|
| message_pipe_endpoint.h | 26 class Waiter;
68 virtual MojoResult AddWaiter(Waiter* waiter,
72 virtual void RemoveWaiter(Waiter* waiter, HandleSignalsState* signals_state);
|
| /external/chromium_org/ui/compositor/test/ |
| draw_waiter_for_test.cc | 13 DrawWaiterForTest waiter; local
14 waiter.wait_for_commit_ = false;
15 waiter.WaitImpl(compositor);
20 DrawWaiterForTest waiter; local
21 waiter.wait_for_commit_ = true;
22 waiter.WaitImpl(compositor);
|
| /external/chromium_org/mojo/public/cpp/bindings/ |
| interface_impl.h | 76 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
77 instance->internal_state()->Bind(handle.Pass(), true, waiter);
86 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
87 instance->internal_state()->Bind(handle.Pass(), false, waiter);
106 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
107 instance->internal_state()->BindProxy(ptr, true, waiter);
116 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
117 instance->internal_state()->BindProxy(ptr, false, waiter);
137 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
138 return BindToPipe(instance, request->PassMessagePipe(), waiter);
[all...] |
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| WaitingThread.java | 65 private Thread waiter; field in class:WaitingThread
119 return this.waiter;
147 if (this.waiter != null) {
151 "\nwaiter: " + this.waiter);
157 this.waiter = Thread.currentThread();
170 this.waiter = null;
186 if (this.waiter == null) {
|
| /external/chromium_org/chrome/browser/chromeos/login/ |
| screenshot_testing_mixin.cc | 47 base::RunLoop waiter; local
48 animation_waiter_quitter_ = waiter.QuitClosure();
53 waiter.Run();
|
| /external/chromium_org/content/browser/accessibility/ |
| accessibility_mode_browsertest.cc | 79 AccessibilityNotificationWaiter waiter(shell());
82 waiter.WaitForNotification();
92 AccessibilityNotificationWaiter waiter(shell());
96 waiter.WaitForNotification();
105 AccessibilityNotificationWaiter waiter(shell());
109 waiter.WaitForNotification();
|
| accessibility_ipc_error_browsertest.cc | 62 AccessibilityNotificationWaiter waiter(
64 waiter.WaitForNotification();
79 AccessibilityNotificationWaiter waiter(
84 waiter.WaitForNotification();
93 AccessibilityNotificationWaiter waiter(
98 waiter.WaitForNotification();
99 tree = &waiter.GetAXTree();
143 AccessibilityNotificationWaiter waiter(
145 waiter.WaitForNotification();
171 AccessibilityNotificationWaiter waiter(
[all...] |
| android_hit_testing_browsertest.cc | 44 AccessibilityNotificationWaiter waiter(
58 waiter.WaitForNotification();
|
| /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();
|
| /external/chromium_org/device/serial/ |
| async_waiter.cc | 28 void AsyncWaiter::WaitComplete(void* waiter, MojoResult result) {
29 static_cast<AsyncWaiter*>(waiter)->WaitCompleteInternal(result);
|
| async_waiter.h | 28 static void WaitComplete(void* waiter, MojoResult result);
|
| /external/chromium_org/net/http/ |
| http_stream_factory_impl_unittest.cc | 613 StreamRequestWaiter waiter; local
617 &waiter, BoundNetLog()));
618 waiter.WaitForStream();
654 StreamRequestWaiter waiter; local
658 &waiter, BoundNetLog()));
659 waiter.WaitForStream();
664 SSLConfig used_ssl_config = waiter.used_ssl_config();
707 StreamRequestWaiter waiter; local
712 &waiter, BoundNetLog()));
713 waiter.WaitForStream()
751 StreamRequestWaiter waiter; local
781 StreamRequestWaiter waiter; local
830 StreamRequestWaiter waiter; local
875 StreamRequestWaiter waiter; local
926 StreamRequestWaiter waiter; local
974 StreamRequestWaiter waiter; local
1019 StreamRequestWaiter waiter; local
1083 StreamRequestWaiter waiter; local
1279 StreamRequestWaiter waiter; local
[all...] |
| /external/chromium_org/mojo/public/cpp/bindings/lib/ |
| interface_impl_internal.h | 59 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
61 ptr->Bind(pipe.handle0.Pass(), waiter);
62 Bind(pipe.handle1.Pass(), instance_bound_to_pipe, waiter);
67 const MojoAsyncWaiter* waiter) {
75 router_ = new Router(handle.Pass(), filters.Pass(), waiter);
|
| /external/chromium_org/chrome/test/remoting/ |
| fullscreen_browsertest.cc | 8 #include "chrome/test/remoting/waiter.h"
21 ConditionalTimeoutWaiter waiter(
27 bool result = waiter.Wait();
|
