| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 |
| OLD | NEW |