Index: components/arc/arc_bridge_service.cc |
diff --git a/components/arc/arc_bridge_service.cc b/components/arc/arc_bridge_service.cc |
index 2d10d8a468d1e9ed5c41ae273a15c436f1e980ce..2c09144041d094cc7a17f039e3fc34e76b23cb48 100644 |
--- a/components/arc/arc_bridge_service.cc |
+++ b/components/arc/arc_bridge_service.cc |
@@ -203,6 +203,29 @@ void ArcBridgeService::CloseSettingsChannel() { |
FOR_EACH_OBSERVER(Observer, observer_list(), OnSettingsInstanceClosed()); |
} |
+void ArcBridgeService::OnVideoInstanceReady(VideoInstancePtr video_ptr) { |
+ DCHECK(CalledOnValidThread()); |
+ temporary_video_ptr_ = std::move(video_ptr); |
+ temporary_video_ptr_.QueryVersion(base::Bind( |
+ &ArcBridgeService::OnVideoVersionReady, weak_factory_.GetWeakPtr())); |
+} |
+ |
+void ArcBridgeService::OnVideoVersionReady(int32_t version) { |
+ video_ptr_ = std::move(temporary_video_ptr_); |
+ FOR_EACH_OBSERVER(Observer, observer_list(), OnVideoInstanceReady()); |
+ video_ptr_.set_connection_error_handler(base::Bind( |
+ &ArcBridgeService::CloseVideoChannel, weak_factory_.GetWeakPtr())); |
+} |
+ |
+void ArcBridgeService::CloseVideoChannel() { |
+ DCHECK(CalledOnValidThread()); |
+ if (!video_ptr_) |
+ return; |
+ |
+ video_ptr_.reset(); |
+ FOR_EACH_OBSERVER(Observer, observer_list(), OnVideoInstanceClosed()); |
+} |
+ |
void ArcBridgeService::SetState(State state) { |
DCHECK(CalledOnValidThread()); |
// DCHECK on enum classes not supported. |
@@ -231,6 +254,7 @@ void ArcBridgeService::CloseAllChannels() { |
ClosePowerChannel(); |
CloseProcessChannel(); |
CloseSettingsChannel(); |
+ CloseVideoChannel(); |
} |
} // namespace arc |