Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(328)

Side by Side Diff: content/public/test/nested_message_pump_android.cc

Issue 17076008: content_shell: Move BrowserTestSystemMessageHandler and use it in layout tests for Android (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "content/test/browser_test_message_pump_android.h" 5 #include "content/public/test/nested_message_pump_android.h"
6 6
7 #include "base/android/jni_android.h" 7 #include "base/android/jni_android.h"
8 #include "base/android/scoped_java_ref.h" 8 #include "base/android/scoped_java_ref.h"
9 #include "base/lazy_instance.h" 9 #include "base/lazy_instance.h"
10 #include "base/logging.h" 10 #include "base/logging.h"
11 #include "base/synchronization/waitable_event.h" 11 #include "base/synchronization/waitable_event.h"
12 #include "base/time.h" 12 #include "base/time.h"
13 #include "jni/BrowserTestSystemMessageHandler_jni.h" 13 #include "jni/NestedSystemMessageHandler_jni.h"
14 14
15 namespace { 15 namespace {
16 16
17 base::LazyInstance<base::android::ScopedJavaGlobalRef<jobject> > 17 base::LazyInstance<base::android::ScopedJavaGlobalRef<jobject> >
18 g_message_handler_obj = LAZY_INSTANCE_INITIALIZER; 18 g_message_handler_obj = LAZY_INSTANCE_INITIALIZER;
19 19
20 } // namespace 20 } // namespace
21 21
22 22
23 namespace content { 23 namespace content {
24 24
25 struct BrowserTestMessagePumpAndroid::RunState { 25 struct NestedMessagePumpAndroid::RunState {
26 RunState(base::MessagePump::Delegate* delegate, int run_depth) 26 RunState(base::MessagePump::Delegate* delegate, int run_depth)
27 : delegate(delegate), 27 : delegate(delegate),
28 run_depth(run_depth), 28 run_depth(run_depth),
29 should_quit(false), 29 should_quit(false),
30 waitable_event(false, false) { 30 waitable_event(false, false) {
31 } 31 }
32 32
33 base::MessagePump::Delegate* delegate; 33 base::MessagePump::Delegate* delegate;
34 34
35 // Used to count how many Run() invocations are on the stack. 35 // Used to count how many Run() invocations are on the stack.
36 int run_depth; 36 int run_depth;
37 37
38 // Used to flag that the current Run() invocation should return ASAP. 38 // Used to flag that the current Run() invocation should return ASAP.
39 bool should_quit; 39 bool should_quit;
40 40
41 // Used to sleep until there is more work to do. 41 // Used to sleep until there is more work to do.
42 base::WaitableEvent waitable_event; 42 base::WaitableEvent waitable_event;
43 43
44 // The time at which we should call DoDelayedWork. 44 // The time at which we should call DoDelayedWork.
45 base::TimeTicks delayed_work_time; 45 base::TimeTicks delayed_work_time;
46 }; 46 };
47 47
48 BrowserTestMessagePumpAndroid::BrowserTestMessagePumpAndroid() 48 NestedMessagePumpAndroid::NestedMessagePumpAndroid()
49 : state_(NULL) { 49 : state_(NULL) {
50 } 50 }
51 51
52 BrowserTestMessagePumpAndroid::~BrowserTestMessagePumpAndroid() { 52 NestedMessagePumpAndroid::~NestedMessagePumpAndroid() {
53 } 53 }
54 54
55 void BrowserTestMessagePumpAndroid::Run(Delegate* delegate) { 55 void NestedMessagePumpAndroid::Run(Delegate* delegate) {
56 RunState state(delegate, state_ ? state_->run_depth + 1 : 1); 56 RunState state(delegate, state_ ? state_->run_depth + 1 : 1);
57 RunState* previous_state = state_; 57 RunState* previous_state = state_;
58 state_ = &state; 58 state_ = &state;
59 59
60 JNIEnv* env = base::android::AttachCurrentThread(); 60 JNIEnv* env = base::android::AttachCurrentThread();
61 DCHECK(env); 61 DCHECK(env);
62 62
63 // Need to cap the wait time to allow task processing on the java 63 // Need to cap the wait time to allow task processing on the java
64 // side. Otherwise, a long wait time on the native will starve java 64 // side. Otherwise, a long wait time on the native will starve java
65 // tasks. 65 // tasks.
(...skipping 18 matching lines...) Expand all
84 did_work = state_->delegate->DoIdleWork(); 84 did_work = state_->delegate->DoIdleWork();
85 if (state_->should_quit) 85 if (state_->should_quit)
86 break; 86 break;
87 87
88 if (did_work) 88 if (did_work)
89 continue; 89 continue;
90 90
91 // No native tasks to process right now. Process tasks from the Java 91 // No native tasks to process right now. Process tasks from the Java
92 // System message handler. This will return when the java message queue 92 // System message handler. This will return when the java message queue
93 // is idle. 93 // is idle.
94 bool ret = Java_BrowserTestSystemMessageHandler_runNestedLoopTillIdle(env, 94 bool ret = Java_NestedSystemMessageHandler_runNestedLoopTillIdle(env,
95 g_message_handler_obj.Get().obj()); 95 g_message_handler_obj.Get().obj());
96 CHECK(ret) << "Error running java message loop, tests will likely fail."; 96 CHECK(ret) << "Error running java message loop, tests will likely fail.";
97 97
98 if (state_->delayed_work_time.is_null()) { 98 if (state_->delayed_work_time.is_null()) {
99 state_->waitable_event.TimedWait(max_delay); 99 state_->waitable_event.TimedWait(max_delay);
100 } else { 100 } else {
101 base::TimeDelta delay = 101 base::TimeDelta delay =
102 state_->delayed_work_time - base::TimeTicks::Now(); 102 state_->delayed_work_time - base::TimeTicks::Now();
103 if (delay > max_delay) 103 if (delay > max_delay)
104 delay = max_delay; 104 delay = max_delay;
105 if (delay > base::TimeDelta()) { 105 if (delay > base::TimeDelta()) {
106 state_->waitable_event.TimedWait(delay); 106 state_->waitable_event.TimedWait(delay);
107 } else { 107 } else {
108 // It looks like delayed_work_time indicates a time in the past, so we 108 // It looks like delayed_work_time indicates a time in the past, so we
109 // need to call DoDelayedWork now. 109 // need to call DoDelayedWork now.
110 state_->delayed_work_time = base::TimeTicks(); 110 state_->delayed_work_time = base::TimeTicks();
111 } 111 }
112 } 112 }
113 } 113 }
114 114
115 state_ = previous_state; 115 state_ = previous_state;
116 } 116 }
117 117
118 void BrowserTestMessagePumpAndroid::Start( 118 void NestedMessagePumpAndroid::Start(
119 base::MessagePump::Delegate* delegate) { 119 base::MessagePump::Delegate* delegate) {
120 JNIEnv* env = base::android::AttachCurrentThread(); 120 JNIEnv* env = base::android::AttachCurrentThread();
121 DCHECK(env); 121 DCHECK(env);
122 g_message_handler_obj.Get().Reset( 122 g_message_handler_obj.Get().Reset(
123 Java_BrowserTestSystemMessageHandler_create(env)); 123 Java_NestedSystemMessageHandler_create(env));
124 124
125 base::MessagePumpForUI::Start(delegate); 125 base::MessagePumpForUI::Start(delegate);
126 } 126 }
127 127
128 void BrowserTestMessagePumpAndroid::Quit() { 128 void NestedMessagePumpAndroid::Quit() {
129 if (state_) { 129 if (state_) {
130 state_->should_quit = true; 130 state_->should_quit = true;
131 state_->waitable_event.Signal(); 131 state_->waitable_event.Signal();
132 return; 132 return;
133 } 133 }
134 base::MessagePumpForUI::Quit(); 134 base::MessagePumpForUI::Quit();
135 } 135 }
136 136
137 void BrowserTestMessagePumpAndroid::ScheduleWork() { 137 void NestedMessagePumpAndroid::ScheduleWork() {
138 if (state_) { 138 if (state_) {
139 state_->waitable_event.Signal(); 139 state_->waitable_event.Signal();
140 return; 140 return;
141 } 141 }
142 142
143 base::MessagePumpForUI::ScheduleWork(); 143 base::MessagePumpForUI::ScheduleWork();
144 } 144 }
145 145
146 void BrowserTestMessagePumpAndroid::ScheduleDelayedWork( 146 void NestedMessagePumpAndroid::ScheduleDelayedWork(
147 const base::TimeTicks& delayed_work_time) { 147 const base::TimeTicks& delayed_work_time) {
148 if (state_) { 148 if (state_) {
149 // We know that we can't be blocked on Wait right now since this method can 149 // We know that we can't be blocked on Wait right now since this method can
150 // only be called on the same thread as Run, so we only need to update our 150 // only be called on the same thread as Run, so we only need to update our
151 // record of how long to sleep when we do sleep. 151 // record of how long to sleep when we do sleep.
152 state_->delayed_work_time = delayed_work_time; 152 state_->delayed_work_time = delayed_work_time;
153 return; 153 return;
154 } 154 }
155 155
156 base::MessagePumpForUI::ScheduleDelayedWork(delayed_work_time); 156 base::MessagePumpForUI::ScheduleDelayedWork(delayed_work_time);
157 } 157 }
158 158
159 // static 159 // static
160 bool BrowserTestMessagePumpAndroid::RegisterJni(JNIEnv* env) { 160 bool NestedMessagePumpAndroid::RegisterJni(JNIEnv* env) {
161 return RegisterNativesImpl(env); 161 return RegisterNativesImpl(env);
162 } 162 }
163 163
164 } // namespace content 164 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698