| /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();
|
| login_ui_keyboard_browsertest.cc | 165 FocusPODWaiter waiter; local
167 waiter.Wait();
|
| /external/chromium_org/mojo/system/ |
| message_pipe_unittest.cc | 10 #include "mojo/system/waiter.h"
410 Waiter waiter; local
418 waiter.Init();
421 mp->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 0, &hss));
425 waiter.Init();
430 &waiter,
439 waiter.Init();
441 mp->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 1, nullptr));
442 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, nullptr))
[all...] |
| 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...] |
| 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);
|
| waiter_test_utils.h | 17 #include "mojo/system/waiter.h"
23 // This is a very simple thread that has a |Waiter|, on which it waits
25 // |Waiter| on creation, but the caller must start the thread with |Start()|. It
34 // waiter_list.AddWaiter(thread.waiter(), ...);
36 // ... some stuff to wake the waiter ...
37 // waiter_list.RemoveWaiter(thread.waiter());
42 // |Waiter::Init()|, |AddWaiter()|, and |RemoveWaiter()| are done in the main
43 // (test) thread, not the waiter thread (as would actually happen in real code).
54 Waiter* waiter() { return &waiter_; function in class:mojo::system::test::SimpleWaiterThread
[all...] |
| local_data_pipe_unittest.cc | 12 #include "mojo/system/waiter.h"
224 Waiter waiter; local
229 waiter.Init();
233 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 12, &hss));
238 waiter.Init();
242 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 34, &hss));
253 // Adding a waiter should now succeed.
254 waiter.Init();
257 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 56, nullptr))
379 Waiter waiter; local
510 Waiter waiter; local
616 Waiter waiter; local
765 Waiter waiter; local
[all...] |
| 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...] |
| channel_unittest.cc | 18 #include "mojo/system/waiter.h"
253 Waiter waiter; local
254 waiter.Init();
257 mp->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));
266 waiter.Wait(MOJO_DEADLINE_INDEFINITE, nullptr));
268 mp->RemoveWaiter(0, &waiter, &hss);
306 Waiter waiter; local
307 waiter.Init()
[all...] |
| core.cc | 25 #include "mojo/system/waiter.h"
47 // |Dispatcher|s for the handles that it wants to wait on with a |Waiter|
48 // object; this |Waiter| object may be created on the stack of that thread or be
50 // The |Dispatcher| then adds the |Waiter| to a |WaiterList| that's either owned
52 // |MessagePipe|). To signal/wake a |Waiter|, the object in question -- either a
68 // INF. |Waiter| locks
569 // TODO(vtl): Should make the waiter live (permanently) in TLS.
570 Waiter waiter; local
571 waiter.Init()
[all...] |
| 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...] |
| /art/test/059-finalizer-throw/src/ |
| Main.java | 25 static Object waiter = new Object(); field in class:Main
|
| /external/chromium_org/media/filters/ |
| video_frame_scheduler_impl_unittest.cc | 45 WaitableMessageLoopEvent waiter; local
47 FROM_HERE, waiter.GetClosure(), base::TimeDelta::FromMilliseconds(ms));
48 waiter.RunAndWait();
|
| /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/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/net/socket/ |
| websocket_endpoint_lock_manager_unittest.cc | 83 class FakeWaiter : public WebSocketEndpointLockManager::Waiter {
138 FakeWaiter waiter; local
139 EXPECT_EQ(OK, instance()->LockEndpoint(DummyEndpoint(), &waiter));
140 EXPECT_FALSE(waiter.called());
202 FakeWaiter waiter; local
205 EXPECT_EQ(OK, instance()->LockEndpoint(DummyEndpoint(), &waiter));
211 // When ownership of the endpoint is passed to a new waiter, the new waiter can
|
| /external/chromium_org/content/browser/accessibility/ |
| dump_accessibility_tree_browsertest.cc | 209 // waiter that returns on any event; we'll stop when we get the text we're
212 scoped_ptr<AccessibilityNotificationWaiter> waiter; local
214 waiter.reset(new AccessibilityNotificationWaiter(
217 waiter.reset(new AccessibilityNotificationWaiter(
231 waiter->WaitForNotification();
|
| /external/dnsmasq/src/ |
| log.c | 385 struct timespec waiter; local
386 waiter.tv_sec = 0;
387 waiter.tv_nsec = 1000000 << (d - 1); /* 1 ms */
388 nanosleep(&waiter, NULL);
|
| util.c | 475 struct timespec waiter; local
478 waiter.tv_sec = 0;
479 waiter.tv_nsec = 10000;
480 nanosleep(&waiter, NULL);
|
| /external/chromium_org/chrome/browser/extensions/ |
| extension_gcm_app_handler_unittest.cc | 72 class Waiter {
74 Waiter() {}
75 ~Waiter() {}
99 base::Bind(&Waiter::OnIOLoopPump, base::Unretained(this)));
117 base::Bind(&Waiter::OnIOLoopPumpCompleted, base::Unretained(this)));
126 base::Bind(&Waiter::PumpIOLoopCompleted, base::Unretained(this)));
131 DISALLOW_COPY_AND_ASSIGN(Waiter);
136 FakeExtensionGCMAppHandler(Profile* profile, Waiter* waiter)
138 waiter_(waiter),
380 Waiter* waiter() { return &waiter_; } function in class:extensions::ExtensionGCMAppHandlerTest
[all...] |
| /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...] |
| /cts/tests/tests/display/src/android/display/cts/ |
| VirtualDisplayTest.java | 263 Runnable waiter = new Runnable() { local
271 synchronized (waiter) {
273 mHandler.post(waiter);
275 waiter.wait(TIMEOUT);
|
| /cts/tests/tests/media/src/android/media/cts/ |
| EncodeVirtualDisplayTest.java | 570 Runnable waiter = new Runnable() { local
578 synchronized (waiter) {
580 mUiHandler.post(waiter);
582 waiter.wait(UI_TIMEOUT_MS);
|
| /external/chromium_org/third_party/libaddressinput/src/java/testlibs/ |
| httpclient-4.1.1.jar | |
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/ |
| org.apache.commons.httpclient_3.1.0.v201005080502.jar | |
