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

Side by Side Diff: components/arc/arc_bridge_service.cc

Issue 2062333002: mojo::Callback -> base::Callback (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: rebase Created 4 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
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 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 "components/arc/arc_bridge_service.h" 5 #include "components/arc/arc_bridge_service.h"
6 6
7 #include <utility> 7 #include <utility>
8 8
9 #include "base/command_line.h" 9 #include "base/command_line.h"
10 #include "base/sequenced_task_runner.h" 10 #include "base/sequenced_task_runner.h"
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after
101 observer_list_.RemoveObserver(observer); 101 observer_list_.RemoveObserver(observer);
102 } 102 }
103 103
104 void ArcBridgeService::OnAppInstanceReady(mojom::AppInstancePtr app_ptr) { 104 void ArcBridgeService::OnAppInstanceReady(mojom::AppInstancePtr app_ptr) {
105 DCHECK(CalledOnValidThread()); 105 DCHECK(CalledOnValidThread());
106 temporary_app_ptr_ = std::move(app_ptr); 106 temporary_app_ptr_ = std::move(app_ptr);
107 temporary_app_ptr_.QueryVersion(base::Bind( 107 temporary_app_ptr_.QueryVersion(base::Bind(
108 &ArcBridgeService::OnAppVersionReady, weak_factory_.GetWeakPtr())); 108 &ArcBridgeService::OnAppVersionReady, weak_factory_.GetWeakPtr()));
109 } 109 }
110 110
111 void ArcBridgeService::OnAppVersionReady(int32_t version) { 111 void ArcBridgeService::OnAppVersionReady(uint32_t version) {
112 DCHECK(CalledOnValidThread()); 112 DCHECK(CalledOnValidThread());
113 app_ptr_ = std::move(temporary_app_ptr_); 113 app_ptr_ = std::move(temporary_app_ptr_);
114 app_ptr_.set_connection_error_handler(base::Bind( 114 app_ptr_.set_connection_error_handler(base::Bind(
115 &ArcBridgeService::CloseAppChannel, weak_factory_.GetWeakPtr())); 115 &ArcBridgeService::CloseAppChannel, weak_factory_.GetWeakPtr()));
116 FOR_EACH_OBSERVER(Observer, observer_list(), OnAppInstanceReady()); 116 FOR_EACH_OBSERVER(Observer, observer_list(), OnAppInstanceReady());
117 } 117 }
118 118
119 void ArcBridgeService::CloseAppChannel() { 119 void ArcBridgeService::CloseAppChannel() {
120 DCHECK(CalledOnValidThread()); 120 DCHECK(CalledOnValidThread());
121 if (!app_ptr_) 121 if (!app_ptr_)
122 return; 122 return;
123 123
124 app_ptr_.reset(); 124 app_ptr_.reset();
125 FOR_EACH_OBSERVER(Observer, observer_list(), OnAppInstanceClosed()); 125 FOR_EACH_OBSERVER(Observer, observer_list(), OnAppInstanceClosed());
126 } 126 }
127 127
128 void ArcBridgeService::OnAudioInstanceReady(mojom::AudioInstancePtr audio_ptr) { 128 void ArcBridgeService::OnAudioInstanceReady(mojom::AudioInstancePtr audio_ptr) {
129 DCHECK(CalledOnValidThread()); 129 DCHECK(CalledOnValidThread());
130 temporary_audio_ptr_ = std::move(audio_ptr); 130 temporary_audio_ptr_ = std::move(audio_ptr);
131 temporary_audio_ptr_.QueryVersion(base::Bind( 131 temporary_audio_ptr_.QueryVersion(base::Bind(
132 &ArcBridgeService::OnAudioVersionReady, weak_factory_.GetWeakPtr())); 132 &ArcBridgeService::OnAudioVersionReady, weak_factory_.GetWeakPtr()));
133 } 133 }
134 134
135 void ArcBridgeService::OnAudioVersionReady(int32_t version) { 135 void ArcBridgeService::OnAudioVersionReady(uint32_t version) {
136 DCHECK(CalledOnValidThread()); 136 DCHECK(CalledOnValidThread());
137 audio_ptr_ = std::move(temporary_audio_ptr_); 137 audio_ptr_ = std::move(temporary_audio_ptr_);
138 audio_ptr_.set_connection_error_handler(base::Bind( 138 audio_ptr_.set_connection_error_handler(base::Bind(
139 &ArcBridgeService::CloseAudioChannel, weak_factory_.GetWeakPtr())); 139 &ArcBridgeService::CloseAudioChannel, weak_factory_.GetWeakPtr()));
140 FOR_EACH_OBSERVER(Observer, observer_list(), OnAudioInstanceReady()); 140 FOR_EACH_OBSERVER(Observer, observer_list(), OnAudioInstanceReady());
141 } 141 }
142 142
143 void ArcBridgeService::CloseAudioChannel() { 143 void ArcBridgeService::CloseAudioChannel() {
144 if (!audio_ptr_) 144 if (!audio_ptr_)
145 return; 145 return;
146 146
147 audio_ptr_.reset(); 147 audio_ptr_.reset();
148 FOR_EACH_OBSERVER(Observer, observer_list(), OnAudioInstanceClosed()); 148 FOR_EACH_OBSERVER(Observer, observer_list(), OnAudioInstanceClosed());
149 } 149 }
150 150
151 void ArcBridgeService::OnAuthInstanceReady(mojom::AuthInstancePtr auth_ptr) { 151 void ArcBridgeService::OnAuthInstanceReady(mojom::AuthInstancePtr auth_ptr) {
152 DCHECK(CalledOnValidThread()); 152 DCHECK(CalledOnValidThread());
153 temporary_auth_ptr_ = std::move(auth_ptr); 153 temporary_auth_ptr_ = std::move(auth_ptr);
154 temporary_auth_ptr_.QueryVersion(base::Bind( 154 temporary_auth_ptr_.QueryVersion(base::Bind(
155 &ArcBridgeService::OnAuthVersionReady, weak_factory_.GetWeakPtr())); 155 &ArcBridgeService::OnAuthVersionReady, weak_factory_.GetWeakPtr()));
156 } 156 }
157 157
158 void ArcBridgeService::OnAuthVersionReady(int32_t version) { 158 void ArcBridgeService::OnAuthVersionReady(uint32_t version) {
159 DCHECK(CalledOnValidThread()); 159 DCHECK(CalledOnValidThread());
160 auth_ptr_ = std::move(temporary_auth_ptr_); 160 auth_ptr_ = std::move(temporary_auth_ptr_);
161 auth_ptr_.set_connection_error_handler(base::Bind( 161 auth_ptr_.set_connection_error_handler(base::Bind(
162 &ArcBridgeService::CloseAuthChannel, weak_factory_.GetWeakPtr())); 162 &ArcBridgeService::CloseAuthChannel, weak_factory_.GetWeakPtr()));
163 FOR_EACH_OBSERVER(Observer, observer_list(), OnAuthInstanceReady()); 163 FOR_EACH_OBSERVER(Observer, observer_list(), OnAuthInstanceReady());
164 } 164 }
165 165
166 void ArcBridgeService::CloseAuthChannel() { 166 void ArcBridgeService::CloseAuthChannel() {
167 DCHECK(CalledOnValidThread()); 167 DCHECK(CalledOnValidThread());
168 if (!auth_ptr_) 168 if (!auth_ptr_)
169 return; 169 return;
170 170
171 auth_ptr_.reset(); 171 auth_ptr_.reset();
172 FOR_EACH_OBSERVER(Observer, observer_list(), OnAuthInstanceClosed()); 172 FOR_EACH_OBSERVER(Observer, observer_list(), OnAuthInstanceClosed());
173 } 173 }
174 174
175 void ArcBridgeService::OnBluetoothInstanceReady( 175 void ArcBridgeService::OnBluetoothInstanceReady(
176 mojom::BluetoothInstancePtr bluetooth_ptr) { 176 mojom::BluetoothInstancePtr bluetooth_ptr) {
177 DCHECK(CalledOnValidThread()); 177 DCHECK(CalledOnValidThread());
178 temporary_bluetooth_ptr_ = std::move(bluetooth_ptr); 178 temporary_bluetooth_ptr_ = std::move(bluetooth_ptr);
179 temporary_bluetooth_ptr_.QueryVersion(base::Bind( 179 temporary_bluetooth_ptr_.QueryVersion(base::Bind(
180 &ArcBridgeService::OnBluetoothVersionReady, weak_factory_.GetWeakPtr())); 180 &ArcBridgeService::OnBluetoothVersionReady, weak_factory_.GetWeakPtr()));
181 } 181 }
182 182
183 void ArcBridgeService::OnBluetoothVersionReady(int32_t version) { 183 void ArcBridgeService::OnBluetoothVersionReady(uint32_t version) {
184 DCHECK(CalledOnValidThread()); 184 DCHECK(CalledOnValidThread());
185 bluetooth_ptr_ = std::move(temporary_bluetooth_ptr_); 185 bluetooth_ptr_ = std::move(temporary_bluetooth_ptr_);
186 bluetooth_ptr_.set_connection_error_handler(base::Bind( 186 bluetooth_ptr_.set_connection_error_handler(base::Bind(
187 &ArcBridgeService::CloseBluetoothChannel, weak_factory_.GetWeakPtr())); 187 &ArcBridgeService::CloseBluetoothChannel, weak_factory_.GetWeakPtr()));
188 FOR_EACH_OBSERVER(Observer, observer_list(), OnBluetoothInstanceReady()); 188 FOR_EACH_OBSERVER(Observer, observer_list(), OnBluetoothInstanceReady());
189 } 189 }
190 190
191 void ArcBridgeService::CloseBluetoothChannel() { 191 void ArcBridgeService::CloseBluetoothChannel() {
192 DCHECK(CalledOnValidThread()); 192 DCHECK(CalledOnValidThread());
193 if (!bluetooth_ptr_) 193 if (!bluetooth_ptr_)
194 return; 194 return;
195 195
196 bluetooth_ptr_.reset(); 196 bluetooth_ptr_.reset();
197 FOR_EACH_OBSERVER(Observer, observer_list(), OnBluetoothInstanceClosed()); 197 FOR_EACH_OBSERVER(Observer, observer_list(), OnBluetoothInstanceClosed());
198 } 198 }
199 199
200 void ArcBridgeService::OnClipboardInstanceReady( 200 void ArcBridgeService::OnClipboardInstanceReady(
201 mojom::ClipboardInstancePtr clipboard_ptr) { 201 mojom::ClipboardInstancePtr clipboard_ptr) {
202 DCHECK(CalledOnValidThread()); 202 DCHECK(CalledOnValidThread());
203 temporary_clipboard_ptr_ = std::move(clipboard_ptr); 203 temporary_clipboard_ptr_ = std::move(clipboard_ptr);
204 temporary_clipboard_ptr_.QueryVersion(base::Bind( 204 temporary_clipboard_ptr_.QueryVersion(base::Bind(
205 &ArcBridgeService::OnClipboardVersionReady, weak_factory_.GetWeakPtr())); 205 &ArcBridgeService::OnClipboardVersionReady, weak_factory_.GetWeakPtr()));
206 } 206 }
207 207
208 void ArcBridgeService::OnClipboardVersionReady(int32_t version) { 208 void ArcBridgeService::OnClipboardVersionReady(uint32_t version) {
209 DCHECK(CalledOnValidThread()); 209 DCHECK(CalledOnValidThread());
210 clipboard_ptr_ = std::move(temporary_clipboard_ptr_); 210 clipboard_ptr_ = std::move(temporary_clipboard_ptr_);
211 clipboard_ptr_.set_connection_error_handler(base::Bind( 211 clipboard_ptr_.set_connection_error_handler(base::Bind(
212 &ArcBridgeService::CloseClipboardChannel, weak_factory_.GetWeakPtr())); 212 &ArcBridgeService::CloseClipboardChannel, weak_factory_.GetWeakPtr()));
213 FOR_EACH_OBSERVER(Observer, observer_list(), OnClipboardInstanceReady()); 213 FOR_EACH_OBSERVER(Observer, observer_list(), OnClipboardInstanceReady());
214 } 214 }
215 215
216 void ArcBridgeService::CloseClipboardChannel() { 216 void ArcBridgeService::CloseClipboardChannel() {
217 DCHECK(CalledOnValidThread()); 217 DCHECK(CalledOnValidThread());
218 if (!clipboard_ptr_) 218 if (!clipboard_ptr_)
219 return; 219 return;
220 220
221 clipboard_ptr_.reset(); 221 clipboard_ptr_.reset();
222 FOR_EACH_OBSERVER(Observer, observer_list(), OnClipboardInstanceClosed()); 222 FOR_EACH_OBSERVER(Observer, observer_list(), OnClipboardInstanceClosed());
223 } 223 }
224 224
225 void ArcBridgeService::OnCrashCollectorInstanceReady( 225 void ArcBridgeService::OnCrashCollectorInstanceReady(
226 mojom::CrashCollectorInstancePtr crash_collector_ptr) { 226 mojom::CrashCollectorInstancePtr crash_collector_ptr) {
227 DCHECK(CalledOnValidThread()); 227 DCHECK(CalledOnValidThread());
228 temporary_crash_collector_ptr_ = std::move(crash_collector_ptr); 228 temporary_crash_collector_ptr_ = std::move(crash_collector_ptr);
229 temporary_crash_collector_ptr_.QueryVersion( 229 temporary_crash_collector_ptr_.QueryVersion(
230 base::Bind(&ArcBridgeService::OnCrashCollectorVersionReady, 230 base::Bind(&ArcBridgeService::OnCrashCollectorVersionReady,
231 weak_factory_.GetWeakPtr())); 231 weak_factory_.GetWeakPtr()));
232 } 232 }
233 233
234 void ArcBridgeService::OnCrashCollectorVersionReady(int32_t version) { 234 void ArcBridgeService::OnCrashCollectorVersionReady(uint32_t version) {
235 DCHECK(CalledOnValidThread()); 235 DCHECK(CalledOnValidThread());
236 crash_collector_ptr_ = std::move(temporary_crash_collector_ptr_); 236 crash_collector_ptr_ = std::move(temporary_crash_collector_ptr_);
237 crash_collector_ptr_.set_connection_error_handler( 237 crash_collector_ptr_.set_connection_error_handler(
238 base::Bind(&ArcBridgeService::CloseCrashCollectorChannel, 238 base::Bind(&ArcBridgeService::CloseCrashCollectorChannel,
239 weak_factory_.GetWeakPtr())); 239 weak_factory_.GetWeakPtr()));
240 FOR_EACH_OBSERVER(Observer, observer_list(), OnCrashCollectorInstanceReady()); 240 FOR_EACH_OBSERVER(Observer, observer_list(), OnCrashCollectorInstanceReady());
241 } 241 }
242 242
243 void ArcBridgeService::CloseCrashCollectorChannel() { 243 void ArcBridgeService::CloseCrashCollectorChannel() {
244 DCHECK(CalledOnValidThread()); 244 DCHECK(CalledOnValidThread());
245 if (!crash_collector_ptr_) 245 if (!crash_collector_ptr_)
246 return; 246 return;
247 247
248 crash_collector_ptr_.reset(); 248 crash_collector_ptr_.reset();
249 FOR_EACH_OBSERVER(Observer, observer_list(), 249 FOR_EACH_OBSERVER(Observer, observer_list(),
250 OnCrashCollectorInstanceClosed()); 250 OnCrashCollectorInstanceClosed());
251 } 251 }
252 252
253 void ArcBridgeService::OnFileSystemInstanceReady( 253 void ArcBridgeService::OnFileSystemInstanceReady(
254 mojom::FileSystemInstancePtr file_system_ptr) { 254 mojom::FileSystemInstancePtr file_system_ptr) {
255 DCHECK(CalledOnValidThread()); 255 DCHECK(CalledOnValidThread());
256 temporary_file_system_ptr_ = std::move(file_system_ptr); 256 temporary_file_system_ptr_ = std::move(file_system_ptr);
257 temporary_file_system_ptr_.QueryVersion( 257 temporary_file_system_ptr_.QueryVersion(
258 base::Bind(&ArcBridgeService::OnFileSystemVersionReady, 258 base::Bind(&ArcBridgeService::OnFileSystemVersionReady,
259 weak_factory_.GetWeakPtr())); 259 weak_factory_.GetWeakPtr()));
260 } 260 }
261 261
262 void ArcBridgeService::OnFileSystemVersionReady(int32_t version) { 262 void ArcBridgeService::OnFileSystemVersionReady(uint32_t version) {
263 DCHECK(CalledOnValidThread()); 263 DCHECK(CalledOnValidThread());
264 file_system_ptr_ = std::move(temporary_file_system_ptr_); 264 file_system_ptr_ = std::move(temporary_file_system_ptr_);
265 file_system_ptr_.set_connection_error_handler( 265 file_system_ptr_.set_connection_error_handler(
266 base::Bind(&ArcBridgeService::CloseFileSystemChannel, 266 base::Bind(&ArcBridgeService::CloseFileSystemChannel,
267 weak_factory_.GetWeakPtr())); 267 weak_factory_.GetWeakPtr()));
268 FOR_EACH_OBSERVER(Observer, observer_list(), OnFileSystemInstanceReady()); 268 FOR_EACH_OBSERVER(Observer, observer_list(), OnFileSystemInstanceReady());
269 } 269 }
270 270
271 void ArcBridgeService::CloseFileSystemChannel() { 271 void ArcBridgeService::CloseFileSystemChannel() {
272 DCHECK(CalledOnValidThread()); 272 DCHECK(CalledOnValidThread());
273 if (!file_system_ptr_) 273 if (!file_system_ptr_)
274 return; 274 return;
275 275
276 file_system_ptr_.reset(); 276 file_system_ptr_.reset();
277 FOR_EACH_OBSERVER(Observer, observer_list(), 277 FOR_EACH_OBSERVER(Observer, observer_list(),
278 OnFileSystemInstanceClosed()); 278 OnFileSystemInstanceClosed());
279 } 279 }
280 280
281 void ArcBridgeService::OnImeInstanceReady(mojom::ImeInstancePtr ime_ptr) { 281 void ArcBridgeService::OnImeInstanceReady(mojom::ImeInstancePtr ime_ptr) {
282 DCHECK(CalledOnValidThread()); 282 DCHECK(CalledOnValidThread());
283 temporary_ime_ptr_ = std::move(ime_ptr); 283 temporary_ime_ptr_ = std::move(ime_ptr);
284 temporary_ime_ptr_.QueryVersion(base::Bind( 284 temporary_ime_ptr_.QueryVersion(base::Bind(
285 &ArcBridgeService::OnImeVersionReady, weak_factory_.GetWeakPtr())); 285 &ArcBridgeService::OnImeVersionReady, weak_factory_.GetWeakPtr()));
286 } 286 }
287 287
288 void ArcBridgeService::OnImeVersionReady(int32_t version) { 288 void ArcBridgeService::OnImeVersionReady(uint32_t version) {
289 DCHECK(CalledOnValidThread()); 289 DCHECK(CalledOnValidThread());
290 ime_ptr_ = std::move(temporary_ime_ptr_); 290 ime_ptr_ = std::move(temporary_ime_ptr_);
291 ime_ptr_.set_connection_error_handler(base::Bind( 291 ime_ptr_.set_connection_error_handler(base::Bind(
292 &ArcBridgeService::CloseImeChannel, weak_factory_.GetWeakPtr())); 292 &ArcBridgeService::CloseImeChannel, weak_factory_.GetWeakPtr()));
293 FOR_EACH_OBSERVER(Observer, observer_list(), OnImeInstanceReady()); 293 FOR_EACH_OBSERVER(Observer, observer_list(), OnImeInstanceReady());
294 } 294 }
295 295
296 void ArcBridgeService::CloseImeChannel() { 296 void ArcBridgeService::CloseImeChannel() {
297 DCHECK(CalledOnValidThread()); 297 DCHECK(CalledOnValidThread());
298 if (!ime_ptr_) 298 if (!ime_ptr_)
299 return; 299 return;
300 300
301 ime_ptr_.reset(); 301 ime_ptr_.reset();
302 FOR_EACH_OBSERVER(Observer, observer_list(), OnImeInstanceClosed()); 302 FOR_EACH_OBSERVER(Observer, observer_list(), OnImeInstanceClosed());
303 } 303 }
304 304
305 void ArcBridgeService::OnIntentHelperInstanceReady( 305 void ArcBridgeService::OnIntentHelperInstanceReady(
306 mojom::IntentHelperInstancePtr intent_helper_ptr) { 306 mojom::IntentHelperInstancePtr intent_helper_ptr) {
307 DCHECK(CalledOnValidThread()); 307 DCHECK(CalledOnValidThread());
308 temporary_intent_helper_ptr_ = std::move(intent_helper_ptr); 308 temporary_intent_helper_ptr_ = std::move(intent_helper_ptr);
309 temporary_intent_helper_ptr_.QueryVersion( 309 temporary_intent_helper_ptr_.QueryVersion(
310 base::Bind(&ArcBridgeService::OnIntentHelperVersionReady, 310 base::Bind(&ArcBridgeService::OnIntentHelperVersionReady,
311 weak_factory_.GetWeakPtr())); 311 weak_factory_.GetWeakPtr()));
312 } 312 }
313 313
314 void ArcBridgeService::OnIntentHelperVersionReady(int32_t version) { 314 void ArcBridgeService::OnIntentHelperVersionReady(uint32_t version) {
315 DCHECK(CalledOnValidThread()); 315 DCHECK(CalledOnValidThread());
316 intent_helper_ptr_ = std::move(temporary_intent_helper_ptr_); 316 intent_helper_ptr_ = std::move(temporary_intent_helper_ptr_);
317 intent_helper_ptr_.set_connection_error_handler(base::Bind( 317 intent_helper_ptr_.set_connection_error_handler(base::Bind(
318 &ArcBridgeService::CloseIntentHelperChannel, weak_factory_.GetWeakPtr())); 318 &ArcBridgeService::CloseIntentHelperChannel, weak_factory_.GetWeakPtr()));
319 FOR_EACH_OBSERVER(Observer, observer_list(), OnIntentHelperInstanceReady()); 319 FOR_EACH_OBSERVER(Observer, observer_list(), OnIntentHelperInstanceReady());
320 } 320 }
321 321
322 void ArcBridgeService::CloseIntentHelperChannel() { 322 void ArcBridgeService::CloseIntentHelperChannel() {
323 DCHECK(CalledOnValidThread()); 323 DCHECK(CalledOnValidThread());
324 if (!intent_helper_ptr_) 324 if (!intent_helper_ptr_)
325 return; 325 return;
326 326
327 intent_helper_ptr_.reset(); 327 intent_helper_ptr_.reset();
328 FOR_EACH_OBSERVER(Observer, observer_list(), OnIntentHelperInstanceClosed()); 328 FOR_EACH_OBSERVER(Observer, observer_list(), OnIntentHelperInstanceClosed());
329 } 329 }
330 330
331 void ArcBridgeService::OnMetricsInstanceReady( 331 void ArcBridgeService::OnMetricsInstanceReady(
332 mojom::MetricsInstancePtr metrics_ptr) { 332 mojom::MetricsInstancePtr metrics_ptr) {
333 DCHECK(CalledOnValidThread()); 333 DCHECK(CalledOnValidThread());
334 temporary_metrics_ptr_ = std::move(metrics_ptr); 334 temporary_metrics_ptr_ = std::move(metrics_ptr);
335 temporary_metrics_ptr_.QueryVersion(base::Bind( 335 temporary_metrics_ptr_.QueryVersion(base::Bind(
336 &ArcBridgeService::OnMetricsVersionReady, weak_factory_.GetWeakPtr())); 336 &ArcBridgeService::OnMetricsVersionReady, weak_factory_.GetWeakPtr()));
337 } 337 }
338 338
339 void ArcBridgeService::OnMetricsVersionReady(int32_t version) { 339 void ArcBridgeService::OnMetricsVersionReady(uint32_t version) {
340 DCHECK(CalledOnValidThread()); 340 DCHECK(CalledOnValidThread());
341 metrics_ptr_ = std::move(temporary_metrics_ptr_); 341 metrics_ptr_ = std::move(temporary_metrics_ptr_);
342 metrics_ptr_.set_connection_error_handler(base::Bind( 342 metrics_ptr_.set_connection_error_handler(base::Bind(
343 &ArcBridgeService::CloseMetricsChannel, weak_factory_.GetWeakPtr())); 343 &ArcBridgeService::CloseMetricsChannel, weak_factory_.GetWeakPtr()));
344 FOR_EACH_OBSERVER(Observer, observer_list(), OnMetricsInstanceReady()); 344 FOR_EACH_OBSERVER(Observer, observer_list(), OnMetricsInstanceReady());
345 } 345 }
346 346
347 void ArcBridgeService::CloseMetricsChannel() { 347 void ArcBridgeService::CloseMetricsChannel() {
348 DCHECK(CalledOnValidThread()); 348 DCHECK(CalledOnValidThread());
349 if (!metrics_ptr_) 349 if (!metrics_ptr_)
350 return; 350 return;
351 351
352 metrics_ptr_.reset(); 352 metrics_ptr_.reset();
353 FOR_EACH_OBSERVER(Observer, observer_list(), OnMetricsInstanceClosed()); 353 FOR_EACH_OBSERVER(Observer, observer_list(), OnMetricsInstanceClosed());
354 } 354 }
355 355
356 void ArcBridgeService::OnNetInstanceReady(mojom::NetInstancePtr net_ptr) { 356 void ArcBridgeService::OnNetInstanceReady(mojom::NetInstancePtr net_ptr) {
357 DCHECK(CalledOnValidThread()); 357 DCHECK(CalledOnValidThread());
358 temporary_net_ptr_ = std::move(net_ptr); 358 temporary_net_ptr_ = std::move(net_ptr);
359 temporary_net_ptr_.QueryVersion(base::Bind( 359 temporary_net_ptr_.QueryVersion(base::Bind(
360 &ArcBridgeService::OnNetVersionReady, weak_factory_.GetWeakPtr())); 360 &ArcBridgeService::OnNetVersionReady, weak_factory_.GetWeakPtr()));
361 } 361 }
362 362
363 void ArcBridgeService::OnNetVersionReady(int32_t version) { 363 void ArcBridgeService::OnNetVersionReady(uint32_t version) {
364 DCHECK(CalledOnValidThread()); 364 DCHECK(CalledOnValidThread());
365 net_ptr_ = std::move(temporary_net_ptr_); 365 net_ptr_ = std::move(temporary_net_ptr_);
366 net_ptr_.set_connection_error_handler(base::Bind( 366 net_ptr_.set_connection_error_handler(base::Bind(
367 &ArcBridgeService::CloseNetChannel, weak_factory_.GetWeakPtr())); 367 &ArcBridgeService::CloseNetChannel, weak_factory_.GetWeakPtr()));
368 FOR_EACH_OBSERVER(Observer, observer_list(), OnNetInstanceReady()); 368 FOR_EACH_OBSERVER(Observer, observer_list(), OnNetInstanceReady());
369 } 369 }
370 370
371 void ArcBridgeService::CloseNetChannel() { 371 void ArcBridgeService::CloseNetChannel() {
372 DCHECK(CalledOnValidThread()); 372 DCHECK(CalledOnValidThread());
373 if (!net_ptr_) 373 if (!net_ptr_)
374 return; 374 return;
375 375
376 net_ptr_.reset(); 376 net_ptr_.reset();
377 FOR_EACH_OBSERVER(Observer, observer_list(), OnNetInstanceClosed()); 377 FOR_EACH_OBSERVER(Observer, observer_list(), OnNetInstanceClosed());
378 } 378 }
379 379
380 void ArcBridgeService::OnNotificationsInstanceReady( 380 void ArcBridgeService::OnNotificationsInstanceReady(
381 mojom::NotificationsInstancePtr notifications_ptr) { 381 mojom::NotificationsInstancePtr notifications_ptr) {
382 DCHECK(CalledOnValidThread()); 382 DCHECK(CalledOnValidThread());
383 temporary_notifications_ptr_ = std::move(notifications_ptr); 383 temporary_notifications_ptr_ = std::move(notifications_ptr);
384 temporary_notifications_ptr_.QueryVersion( 384 temporary_notifications_ptr_.QueryVersion(
385 base::Bind(&ArcBridgeService::OnNotificationsVersionReady, 385 base::Bind(&ArcBridgeService::OnNotificationsVersionReady,
386 weak_factory_.GetWeakPtr())); 386 weak_factory_.GetWeakPtr()));
387 } 387 }
388 388
389 void ArcBridgeService::OnNotificationsVersionReady(int32_t version) { 389 void ArcBridgeService::OnNotificationsVersionReady(uint32_t version) {
390 DCHECK(CalledOnValidThread()); 390 DCHECK(CalledOnValidThread());
391 notifications_ptr_ = std::move(temporary_notifications_ptr_); 391 notifications_ptr_ = std::move(temporary_notifications_ptr_);
392 notifications_ptr_.set_connection_error_handler( 392 notifications_ptr_.set_connection_error_handler(
393 base::Bind(&ArcBridgeService::CloseNotificationsChannel, 393 base::Bind(&ArcBridgeService::CloseNotificationsChannel,
394 weak_factory_.GetWeakPtr())); 394 weak_factory_.GetWeakPtr()));
395 FOR_EACH_OBSERVER(Observer, observer_list(), OnNotificationsInstanceReady()); 395 FOR_EACH_OBSERVER(Observer, observer_list(), OnNotificationsInstanceReady());
396 } 396 }
397 397
398 void ArcBridgeService::CloseNotificationsChannel() { 398 void ArcBridgeService::CloseNotificationsChannel() {
399 DCHECK(CalledOnValidThread()); 399 DCHECK(CalledOnValidThread());
400 if (!notifications_ptr_) 400 if (!notifications_ptr_)
401 return; 401 return;
402 402
403 notifications_ptr_.reset(); 403 notifications_ptr_.reset();
404 FOR_EACH_OBSERVER(Observer, observer_list(), OnNotificationsInstanceClosed()); 404 FOR_EACH_OBSERVER(Observer, observer_list(), OnNotificationsInstanceClosed());
405 } 405 }
406 406
407 void ArcBridgeService::OnObbMounterInstanceReady( 407 void ArcBridgeService::OnObbMounterInstanceReady(
408 mojom::ObbMounterInstancePtr obb_mounter_ptr) { 408 mojom::ObbMounterInstancePtr obb_mounter_ptr) {
409 DCHECK(CalledOnValidThread()); 409 DCHECK(CalledOnValidThread());
410 temporary_obb_mounter_ptr_ = std::move(obb_mounter_ptr); 410 temporary_obb_mounter_ptr_ = std::move(obb_mounter_ptr);
411 temporary_obb_mounter_ptr_.QueryVersion(base::Bind( 411 temporary_obb_mounter_ptr_.QueryVersion(base::Bind(
412 &ArcBridgeService::OnObbMounterVersionReady, 412 &ArcBridgeService::OnObbMounterVersionReady,
413 weak_factory_.GetWeakPtr())); 413 weak_factory_.GetWeakPtr()));
414 } 414 }
415 415
416 void ArcBridgeService::OnObbMounterVersionReady(int32_t version) { 416 void ArcBridgeService::OnObbMounterVersionReady(uint32_t version) {
417 DCHECK(CalledOnValidThread()); 417 DCHECK(CalledOnValidThread());
418 obb_mounter_ptr_ = std::move(temporary_obb_mounter_ptr_); 418 obb_mounter_ptr_ = std::move(temporary_obb_mounter_ptr_);
419 obb_mounter_ptr_.set_connection_error_handler(base::Bind( 419 obb_mounter_ptr_.set_connection_error_handler(base::Bind(
420 &ArcBridgeService::CloseObbMounterChannel, 420 &ArcBridgeService::CloseObbMounterChannel,
421 weak_factory_.GetWeakPtr())); 421 weak_factory_.GetWeakPtr()));
422 FOR_EACH_OBSERVER(Observer, observer_list(), OnObbMounterInstanceReady()); 422 FOR_EACH_OBSERVER(Observer, observer_list(), OnObbMounterInstanceReady());
423 } 423 }
424 424
425 void ArcBridgeService::CloseObbMounterChannel() { 425 void ArcBridgeService::CloseObbMounterChannel() {
426 if (!obb_mounter_ptr_) 426 if (!obb_mounter_ptr_)
427 return; 427 return;
428 428
429 obb_mounter_ptr_.reset(); 429 obb_mounter_ptr_.reset();
430 FOR_EACH_OBSERVER(Observer, observer_list(), OnObbMounterInstanceClosed()); 430 FOR_EACH_OBSERVER(Observer, observer_list(), OnObbMounterInstanceClosed());
431 } 431 }
432 432
433 void ArcBridgeService::OnPolicyInstanceReady( 433 void ArcBridgeService::OnPolicyInstanceReady(
434 mojom::PolicyInstancePtr policy_ptr) { 434 mojom::PolicyInstancePtr policy_ptr) {
435 DCHECK(CalledOnValidThread()); 435 DCHECK(CalledOnValidThread());
436 temporary_policy_ptr_ = std::move(policy_ptr); 436 temporary_policy_ptr_ = std::move(policy_ptr);
437 temporary_policy_ptr_.QueryVersion(base::Bind( 437 temporary_policy_ptr_.QueryVersion(base::Bind(
438 &ArcBridgeService::OnPolicyVersionReady, weak_factory_.GetWeakPtr())); 438 &ArcBridgeService::OnPolicyVersionReady, weak_factory_.GetWeakPtr()));
439 } 439 }
440 440
441 void ArcBridgeService::OnPolicyVersionReady(int32_t version) { 441 void ArcBridgeService::OnPolicyVersionReady(uint32_t version) {
442 DCHECK(CalledOnValidThread()); 442 DCHECK(CalledOnValidThread());
443 policy_ptr_ = std::move(temporary_policy_ptr_); 443 policy_ptr_ = std::move(temporary_policy_ptr_);
444 policy_ptr_.set_connection_error_handler(base::Bind( 444 policy_ptr_.set_connection_error_handler(base::Bind(
445 &ArcBridgeService::ClosePolicyChannel, weak_factory_.GetWeakPtr())); 445 &ArcBridgeService::ClosePolicyChannel, weak_factory_.GetWeakPtr()));
446 FOR_EACH_OBSERVER(Observer, observer_list(), OnPolicyInstanceReady()); 446 FOR_EACH_OBSERVER(Observer, observer_list(), OnPolicyInstanceReady());
447 } 447 }
448 448
449 void ArcBridgeService::ClosePolicyChannel() { 449 void ArcBridgeService::ClosePolicyChannel() {
450 DCHECK(CalledOnValidThread()); 450 DCHECK(CalledOnValidThread());
451 if (!policy_ptr_) 451 if (!policy_ptr_)
452 return; 452 return;
453 453
454 policy_ptr_.reset(); 454 policy_ptr_.reset();
455 FOR_EACH_OBSERVER(Observer, observer_list(), OnPolicyInstanceClosed()); 455 FOR_EACH_OBSERVER(Observer, observer_list(), OnPolicyInstanceClosed());
456 } 456 }
457 457
458 void ArcBridgeService::OnPowerInstanceReady(mojom::PowerInstancePtr power_ptr) { 458 void ArcBridgeService::OnPowerInstanceReady(mojom::PowerInstancePtr power_ptr) {
459 DCHECK(CalledOnValidThread()); 459 DCHECK(CalledOnValidThread());
460 temporary_power_ptr_ = std::move(power_ptr); 460 temporary_power_ptr_ = std::move(power_ptr);
461 temporary_power_ptr_.QueryVersion(base::Bind( 461 temporary_power_ptr_.QueryVersion(base::Bind(
462 &ArcBridgeService::OnPowerVersionReady, weak_factory_.GetWeakPtr())); 462 &ArcBridgeService::OnPowerVersionReady, weak_factory_.GetWeakPtr()));
463 } 463 }
464 464
465 void ArcBridgeService::OnPowerVersionReady(int32_t version) { 465 void ArcBridgeService::OnPowerVersionReady(uint32_t version) {
466 DCHECK(CalledOnValidThread()); 466 DCHECK(CalledOnValidThread());
467 power_ptr_ = std::move(temporary_power_ptr_); 467 power_ptr_ = std::move(temporary_power_ptr_);
468 power_ptr_.set_connection_error_handler(base::Bind( 468 power_ptr_.set_connection_error_handler(base::Bind(
469 &ArcBridgeService::ClosePowerChannel, weak_factory_.GetWeakPtr())); 469 &ArcBridgeService::ClosePowerChannel, weak_factory_.GetWeakPtr()));
470 FOR_EACH_OBSERVER(Observer, observer_list(), OnPowerInstanceReady()); 470 FOR_EACH_OBSERVER(Observer, observer_list(), OnPowerInstanceReady());
471 } 471 }
472 472
473 void ArcBridgeService::ClosePowerChannel() { 473 void ArcBridgeService::ClosePowerChannel() {
474 DCHECK(CalledOnValidThread()); 474 DCHECK(CalledOnValidThread());
475 if (!power_ptr_) 475 if (!power_ptr_)
476 return; 476 return;
477 477
478 power_ptr_.reset(); 478 power_ptr_.reset();
479 FOR_EACH_OBSERVER(Observer, observer_list(), OnPowerInstanceClosed()); 479 FOR_EACH_OBSERVER(Observer, observer_list(), OnPowerInstanceClosed());
480 } 480 }
481 481
482 void ArcBridgeService::OnProcessInstanceReady( 482 void ArcBridgeService::OnProcessInstanceReady(
483 mojom::ProcessInstancePtr process_ptr) { 483 mojom::ProcessInstancePtr process_ptr) {
484 DCHECK(CalledOnValidThread()); 484 DCHECK(CalledOnValidThread());
485 temporary_process_ptr_ = std::move(process_ptr); 485 temporary_process_ptr_ = std::move(process_ptr);
486 temporary_process_ptr_.QueryVersion(base::Bind( 486 temporary_process_ptr_.QueryVersion(base::Bind(
487 &ArcBridgeService::OnProcessVersionReady, weak_factory_.GetWeakPtr())); 487 &ArcBridgeService::OnProcessVersionReady, weak_factory_.GetWeakPtr()));
488 } 488 }
489 489
490 void ArcBridgeService::OnProcessVersionReady(int32_t version) { 490 void ArcBridgeService::OnProcessVersionReady(uint32_t version) {
491 DCHECK(CalledOnValidThread()); 491 DCHECK(CalledOnValidThread());
492 process_ptr_ = std::move(temporary_process_ptr_); 492 process_ptr_ = std::move(temporary_process_ptr_);
493 process_ptr_.set_connection_error_handler(base::Bind( 493 process_ptr_.set_connection_error_handler(base::Bind(
494 &ArcBridgeService::CloseProcessChannel, weak_factory_.GetWeakPtr())); 494 &ArcBridgeService::CloseProcessChannel, weak_factory_.GetWeakPtr()));
495 FOR_EACH_OBSERVER(Observer, observer_list(), OnProcessInstanceReady()); 495 FOR_EACH_OBSERVER(Observer, observer_list(), OnProcessInstanceReady());
496 } 496 }
497 497
498 void ArcBridgeService::CloseProcessChannel() { 498 void ArcBridgeService::CloseProcessChannel() {
499 DCHECK(CalledOnValidThread()); 499 DCHECK(CalledOnValidThread());
500 if (!process_ptr_) 500 if (!process_ptr_)
501 return; 501 return;
502 502
503 process_ptr_.reset(); 503 process_ptr_.reset();
504 FOR_EACH_OBSERVER(Observer, observer_list(), OnProcessInstanceClosed()); 504 FOR_EACH_OBSERVER(Observer, observer_list(), OnProcessInstanceClosed());
505 } 505 }
506 506
507 void ArcBridgeService::OnStorageManagerInstanceReady( 507 void ArcBridgeService::OnStorageManagerInstanceReady(
508 mojom::StorageManagerInstancePtr storage_manager_ptr) { 508 mojom::StorageManagerInstancePtr storage_manager_ptr) {
509 DCHECK(CalledOnValidThread()); 509 DCHECK(CalledOnValidThread());
510 temporary_storage_manager_ptr_ = std::move(storage_manager_ptr); 510 temporary_storage_manager_ptr_ = std::move(storage_manager_ptr);
511 temporary_storage_manager_ptr_.QueryVersion(base::Bind( 511 temporary_storage_manager_ptr_.QueryVersion(base::Bind(
512 &ArcBridgeService::OnStorageManagerVersionReady, 512 &ArcBridgeService::OnStorageManagerVersionReady,
513 weak_factory_.GetWeakPtr())); 513 weak_factory_.GetWeakPtr()));
514 } 514 }
515 515
516 void ArcBridgeService::OnStorageManagerVersionReady(int32_t version) { 516 void ArcBridgeService::OnStorageManagerVersionReady(uint32_t version) {
517 DCHECK(CalledOnValidThread()); 517 DCHECK(CalledOnValidThread());
518 storage_manager_ptr_ = std::move(temporary_storage_manager_ptr_); 518 storage_manager_ptr_ = std::move(temporary_storage_manager_ptr_);
519 storage_manager_ptr_.set_connection_error_handler(base::Bind( 519 storage_manager_ptr_.set_connection_error_handler(base::Bind(
520 &ArcBridgeService::CloseStorageManagerChannel, 520 &ArcBridgeService::CloseStorageManagerChannel,
521 weak_factory_.GetWeakPtr())); 521 weak_factory_.GetWeakPtr()));
522 FOR_EACH_OBSERVER( 522 FOR_EACH_OBSERVER(
523 Observer, observer_list(), OnStorageManagerInstanceReady()); 523 Observer, observer_list(), OnStorageManagerInstanceReady());
524 } 524 }
525 525
526 void ArcBridgeService::CloseStorageManagerChannel() { 526 void ArcBridgeService::CloseStorageManagerChannel() {
527 DCHECK(CalledOnValidThread()); 527 DCHECK(CalledOnValidThread());
528 if (!storage_manager_ptr_) 528 if (!storage_manager_ptr_)
529 return; 529 return;
530 530
531 storage_manager_ptr_.reset(); 531 storage_manager_ptr_.reset();
532 FOR_EACH_OBSERVER( 532 FOR_EACH_OBSERVER(
533 Observer, observer_list(), OnStorageManagerInstanceClosed()); 533 Observer, observer_list(), OnStorageManagerInstanceClosed());
534 } 534 }
535 535
536 void ArcBridgeService::OnVideoInstanceReady(mojom::VideoInstancePtr video_ptr) { 536 void ArcBridgeService::OnVideoInstanceReady(mojom::VideoInstancePtr video_ptr) {
537 DCHECK(CalledOnValidThread()); 537 DCHECK(CalledOnValidThread());
538 temporary_video_ptr_ = std::move(video_ptr); 538 temporary_video_ptr_ = std::move(video_ptr);
539 temporary_video_ptr_.QueryVersion(base::Bind( 539 temporary_video_ptr_.QueryVersion(base::Bind(
540 &ArcBridgeService::OnVideoVersionReady, weak_factory_.GetWeakPtr())); 540 &ArcBridgeService::OnVideoVersionReady, weak_factory_.GetWeakPtr()));
541 } 541 }
542 542
543 void ArcBridgeService::OnVideoVersionReady(int32_t version) { 543 void ArcBridgeService::OnVideoVersionReady(uint32_t version) {
544 DCHECK(CalledOnValidThread()); 544 DCHECK(CalledOnValidThread());
545 video_ptr_ = std::move(temporary_video_ptr_); 545 video_ptr_ = std::move(temporary_video_ptr_);
546 video_ptr_.set_connection_error_handler(base::Bind( 546 video_ptr_.set_connection_error_handler(base::Bind(
547 &ArcBridgeService::CloseVideoChannel, weak_factory_.GetWeakPtr())); 547 &ArcBridgeService::CloseVideoChannel, weak_factory_.GetWeakPtr()));
548 FOR_EACH_OBSERVER(Observer, observer_list(), OnVideoInstanceReady()); 548 FOR_EACH_OBSERVER(Observer, observer_list(), OnVideoInstanceReady());
549 } 549 }
550 550
551 void ArcBridgeService::CloseVideoChannel() { 551 void ArcBridgeService::CloseVideoChannel() {
552 DCHECK(CalledOnValidThread()); 552 DCHECK(CalledOnValidThread());
553 if (!video_ptr_) 553 if (!video_ptr_)
554 return; 554 return;
555 555
556 video_ptr_.reset(); 556 video_ptr_.reset();
557 FOR_EACH_OBSERVER(Observer, observer_list(), OnVideoInstanceClosed()); 557 FOR_EACH_OBSERVER(Observer, observer_list(), OnVideoInstanceClosed());
558 } 558 }
559 559
560 void ArcBridgeService::OnWindowManagerInstanceReady( 560 void ArcBridgeService::OnWindowManagerInstanceReady(
561 mojom::WindowManagerInstancePtr window_manager_ptr) { 561 mojom::WindowManagerInstancePtr window_manager_ptr) {
562 DCHECK(CalledOnValidThread()); 562 DCHECK(CalledOnValidThread());
563 temporary_window_manager_ptr_ = std::move(window_manager_ptr); 563 temporary_window_manager_ptr_ = std::move(window_manager_ptr);
564 temporary_window_manager_ptr_.QueryVersion(base::Bind( 564 temporary_window_manager_ptr_.QueryVersion(base::Bind(
565 &ArcBridgeService::OnWindowManagerVersionReady, 565 &ArcBridgeService::OnWindowManagerVersionReady,
566 weak_factory_.GetWeakPtr())); 566 weak_factory_.GetWeakPtr()));
567 } 567 }
568 568
569 void ArcBridgeService::OnWindowManagerVersionReady(int32_t version) { 569 void ArcBridgeService::OnWindowManagerVersionReady(uint32_t version) {
570 DCHECK(CalledOnValidThread()); 570 DCHECK(CalledOnValidThread());
571 window_manager_ptr_ = std::move(temporary_window_manager_ptr_); 571 window_manager_ptr_ = std::move(temporary_window_manager_ptr_);
572 window_manager_ptr_.set_connection_error_handler(base::Bind( 572 window_manager_ptr_.set_connection_error_handler(base::Bind(
573 &ArcBridgeService::CloseWindowManagerChannel, 573 &ArcBridgeService::CloseWindowManagerChannel,
574 weak_factory_.GetWeakPtr())); 574 weak_factory_.GetWeakPtr()));
575 FOR_EACH_OBSERVER(Observer, observer_list(), OnWindowManagerInstanceReady()); 575 FOR_EACH_OBSERVER(Observer, observer_list(), OnWindowManagerInstanceReady());
576 } 576 }
577 577
578 void ArcBridgeService::CloseWindowManagerChannel() { 578 void ArcBridgeService::CloseWindowManagerChannel() {
579 if (!window_manager_ptr_) 579 if (!window_manager_ptr_)
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after
625 CloseObbMounterChannel(); 625 CloseObbMounterChannel();
626 ClosePolicyChannel(); 626 ClosePolicyChannel();
627 ClosePowerChannel(); 627 ClosePowerChannel();
628 CloseProcessChannel(); 628 CloseProcessChannel();
629 CloseStorageManagerChannel(); 629 CloseStorageManagerChannel();
630 CloseVideoChannel(); 630 CloseVideoChannel();
631 CloseWindowManagerChannel(); 631 CloseWindowManagerChannel();
632 } 632 }
633 633
634 } // namespace arc 634 } // namespace arc
OLDNEW
« no previous file with comments | « components/arc/arc_bridge_service.h ('k') | components/autofill/content/public/cpp/autofill_types_struct_traits_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698