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

Side by Side Diff: device/geolocation/geolocation_provider_impl_unittest.cc

Issue 2849613002: Use ScopedTaskEnvironment instead of MessageLoopForUI in device tests. (Closed)
Patch Set: self-review Created 3 years, 7 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
« no previous file with comments | « no previous file | device/geolocation/wifi_data_provider_chromeos_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 "device/geolocation/geolocation_provider_impl.h" 5 #include "device/geolocation/geolocation_provider_impl.h"
6 6
7 #include <memory> 7 #include <memory>
8 8
9 #include "base/at_exit.h" 9 #include "base/at_exit.h"
10 #include "base/bind.h" 10 #include "base/bind.h"
11 #include "base/bind_helpers.h" 11 #include "base/bind_helpers.h"
12 #include "base/location.h" 12 #include "base/location.h"
13 #include "base/macros.h" 13 #include "base/macros.h"
14 #include "base/memory/ptr_util.h" 14 #include "base/memory/ptr_util.h"
15 #include "base/memory/ref_counted.h" 15 #include "base/memory/ref_counted.h"
16 #include "base/run_loop.h" 16 #include "base/run_loop.h"
17 #include "base/single_thread_task_runner.h" 17 #include "base/single_thread_task_runner.h"
18 #include "base/strings/string16.h" 18 #include "base/strings/string16.h"
19 #include "base/test/scoped_task_environment.h"
20 #include "base/threading/thread_checker.h"
19 #include "base/time/time.h" 21 #include "base/time/time.h"
20 #include "device/geolocation/access_token_store.h" 22 #include "device/geolocation/access_token_store.h"
21 #include "device/geolocation/fake_location_provider.h" 23 #include "device/geolocation/fake_location_provider.h"
22 #include "testing/gmock/include/gmock/gmock.h" 24 #include "testing/gmock/include/gmock/gmock.h"
23 #include "testing/gtest/include/gtest/gtest.h" 25 #include "testing/gtest/include/gtest/gtest.h"
24 26
25 using testing::MakeMatcher; 27 using testing::MakeMatcher;
26 using testing::Matcher; 28 using testing::Matcher;
27 using testing::MatcherInterface; 29 using testing::MatcherInterface;
28 using testing::MatchResultListener; 30 using testing::MatchResultListener;
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after
91 return MakeMatcher(new GeopositionEqMatcher(expected)); 93 return MakeMatcher(new GeopositionEqMatcher(expected));
92 } 94 }
93 95
94 void DummyFunction(const LocationProvider* provider, 96 void DummyFunction(const LocationProvider* provider,
95 const Geoposition& position) {} 97 const Geoposition& position) {}
96 98
97 } // namespace 99 } // namespace
98 100
99 class GeolocationProviderTest : public testing::Test { 101 class GeolocationProviderTest : public testing::Test {
100 protected: 102 protected:
101 GeolocationProviderTest() : arbitrator_(new FakeLocationProvider) { 103 GeolocationProviderTest()
104 : scoped_task_environment_(
105 base::test::ScopedTaskEnvironment::MainThreadType::UI),
106 arbitrator_(new FakeLocationProvider) {
102 provider()->SetArbitratorForTesting(base::WrapUnique(arbitrator_)); 107 provider()->SetArbitratorForTesting(base::WrapUnique(arbitrator_));
103 } 108 }
104 109
105 ~GeolocationProviderTest() override {} 110 ~GeolocationProviderTest() override {}
106 111
107 GeolocationProviderImpl* provider() { 112 GeolocationProviderImpl* provider() {
108 return GeolocationProviderImpl::GetInstance(); 113 return GeolocationProviderImpl::GetInstance();
109 } 114 }
110 115
111 FakeLocationProvider* arbitrator() { return arbitrator_; } 116 FakeLocationProvider* arbitrator() { return arbitrator_; }
112 117
113 // Called on test thread. 118 // Called on test thread.
114 bool ProvidersStarted(); 119 bool ProvidersStarted();
115 void SendMockLocation(const Geoposition& position); 120 void SendMockLocation(const Geoposition& position);
116 121
117 private: 122 private:
118 // Called on provider thread. 123 // Called on provider thread.
119 void GetProvidersStarted(); 124 void GetProvidersStarted();
120 125
121 // |at_exit| must be initialized before all other variables so that it is 126 // |at_exit| must be initialized before all other variables so that it is
122 // available to register with Singletons and can handle tear down when the 127 // available to register with Singletons and can handle tear down when the
123 // test completes. 128 // test completes.
124 base::ShadowingAtExitManager at_exit_; 129 base::ShadowingAtExitManager at_exit_;
125 130
126 base::MessageLoopForUI message_loop_; 131 base::test::ScopedTaskEnvironment scoped_task_environment_;
132
133 base::ThreadChecker thread_checker_;
127 134
128 // Owned by the GeolocationProviderImpl class. 135 // Owned by the GeolocationProviderImpl class.
129 FakeLocationProvider* arbitrator_; 136 FakeLocationProvider* arbitrator_;
130 137
131 // True if |arbitrator_| is started. 138 // True if |arbitrator_| is started.
132 bool is_started_; 139 bool is_started_;
133 140
134 DISALLOW_COPY_AND_ASSIGN(GeolocationProviderTest); 141 DISALLOW_COPY_AND_ASSIGN(GeolocationProviderTest);
135 }; 142 };
136 143
137 bool GeolocationProviderTest::ProvidersStarted() { 144 bool GeolocationProviderTest::ProvidersStarted() {
138 DCHECK(provider()->IsRunning()); 145 DCHECK(provider()->IsRunning());
139 DCHECK(base::MessageLoop::current() == &message_loop_); 146 DCHECK(thread_checker_.CalledOnValidThread());
140 147
141 provider()->task_runner()->PostTaskAndReply( 148 provider()->task_runner()->PostTaskAndReply(
142 FROM_HERE, base::Bind(&GeolocationProviderTest::GetProvidersStarted, 149 FROM_HERE, base::Bind(&GeolocationProviderTest::GetProvidersStarted,
143 base::Unretained(this)), 150 base::Unretained(this)),
144 base::MessageLoop::QuitWhenIdleClosure()); 151 base::MessageLoop::QuitWhenIdleClosure());
145 base::RunLoop().Run(); 152 base::RunLoop().Run();
146 return is_started_; 153 return is_started_;
147 } 154 }
148 155
149 void GeolocationProviderTest::GetProvidersStarted() { 156 void GeolocationProviderTest::GetProvidersStarted() {
150 DCHECK(provider()->task_runner()->BelongsToCurrentThread()); 157 DCHECK(provider()->task_runner()->BelongsToCurrentThread());
151 is_started_ = arbitrator()->state() != FakeLocationProvider::STOPPED; 158 is_started_ = arbitrator()->state() != FakeLocationProvider::STOPPED;
152 } 159 }
153 160
154 void GeolocationProviderTest::SendMockLocation(const Geoposition& position) { 161 void GeolocationProviderTest::SendMockLocation(const Geoposition& position) {
155 DCHECK(provider()->IsRunning()); 162 DCHECK(provider()->IsRunning());
156 DCHECK(base::MessageLoop::current() == &message_loop_); 163 DCHECK(thread_checker_.CalledOnValidThread());
157 provider()->task_runner()->PostTask( 164 provider()->task_runner()->PostTask(
158 FROM_HERE, 165 FROM_HERE,
159 base::Bind(&GeolocationProviderImpl::OnLocationUpdate, 166 base::Bind(&GeolocationProviderImpl::OnLocationUpdate,
160 base::Unretained(provider()), arbitrator_, position)); 167 base::Unretained(provider()), arbitrator_, position));
161 } 168 }
162 169
163 // Regression test for http://crbug.com/59377 170 // Regression test for http://crbug.com/59377
164 TEST_F(GeolocationProviderTest, OnPermissionGrantedWithoutObservers) { 171 TEST_F(GeolocationProviderTest, OnPermissionGrantedWithoutObservers) {
165 // Clear |provider|'s arbitrator so the default arbitrator can be used. 172 // Clear |provider|'s arbitrator so the default arbitrator can be used.
166 provider()->SetArbitratorForTesting(nullptr); 173 provider()->SetArbitratorForTesting(nullptr);
(...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after
242 base::Bind(&MockGeolocationObserver::OnLocationUpdate, 249 base::Bind(&MockGeolocationObserver::OnLocationUpdate,
243 base::Unretained(&mock_observer)); 250 base::Unretained(&mock_observer));
244 std::unique_ptr<GeolocationProvider::Subscription> subscription = 251 std::unique_ptr<GeolocationProvider::Subscription> subscription =
245 provider()->AddLocationUpdateCallback(callback, false); 252 provider()->AddLocationUpdateCallback(callback, false);
246 subscription.reset(); 253 subscription.reset();
247 // Wait for the providers to be stopped now that all clients are gone. 254 // Wait for the providers to be stopped now that all clients are gone.
248 EXPECT_FALSE(ProvidersStarted()); 255 EXPECT_FALSE(ProvidersStarted());
249 } 256 }
250 257
251 } // namespace device 258 } // namespace device
OLDNEW
« no previous file with comments | « no previous file | device/geolocation/wifi_data_provider_chromeos_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698