Index: chrome/browser/media/router/mojo/media_route_controller.cc |
diff --git a/chrome/browser/media/router/mojo/media_route_controller.cc b/chrome/browser/media/router/mojo/media_route_controller.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..d737a5f172da1d8145d94128756b6b39c319b9c7 |
--- /dev/null |
+++ b/chrome/browser/media/router/mojo/media_route_controller.cc |
@@ -0,0 +1,80 @@ |
+// Copyright 2017 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+#include "chrome/browser/media/router/mojo/media_route_controller.h" |
+ |
+#include <utility> |
+ |
+#include "chrome/browser/media/router/media_route_status_observer.h" |
+#include "chrome/browser/media/router/media_router.h" |
+#include "chrome/browser/media/router/media_status.h" |
+#include "chrome/browser/media/router/mojo/media_router.mojom.h" |
+#include "mojo/public/cpp/bindings/interface_request.h" |
+ |
+namespace media_router { |
+ |
+MediaRouteController::MediaRouteController(MediaRoute::Id route_id, |
+ mojom::MediaRouteProvider* provider, |
+ base::Closure destroyer_callback) |
+ : destroyer_callback_(destroyer_callback), |
+ provider_(provider), |
+ route_id_(route_id) { |
+ provider_->CreateMediaRouteController( |
imcheng
2017/03/06 23:11:41
A couple of questions.
1) Can the initialization
takumif
2017/03/08 04:24:02
Yes, both are possible. Doing so.
|
+ route_id_, mojo::MakeRequest<mojom::MediaController>(&media_controller_), |
+ base::Bind(&MediaRouteController::OnControllerSet, |
+ base::Unretained(this))); |
+} |
+MediaRouteController::~MediaRouteController() {} |
+ |
+void MediaRouteController::OnControllerSet(bool success) { |
+ if (success) { |
+ mojom::MediaStatusObserverPtr observer; |
+ binding_ = base::MakeUnique<mojo::Binding<mojom::MediaStatusObserver>>( |
+ this, mojo::MakeRequest<mojom::MediaStatusObserver>(&observer)); |
+ binding_->set_connection_error_handler(destroyer_callback_); |
+ provider_->SetMediaRouteStatusObserver(route_id_, std::move(observer)); |
+ } else { |
+ destroyer_callback_.Run(); |
+ // |this| gets destroyed here! |
+ } |
+} |
+ |
+void MediaRouteController::Play() { |
+ media_controller_->Play(); |
+} |
+ |
+void MediaRouteController::Pause() { |
+ media_controller_->Pause(); |
+} |
+ |
+void MediaRouteController::Seek(uint32_t time) { |
+ media_controller_->Seek(time); |
+} |
+ |
+void MediaRouteController::SetMute(bool mute) { |
+ media_controller_->SetMute(mute); |
+} |
+ |
+void MediaRouteController::SetVolume(float volume) { |
+ media_controller_->SetVolume(volume); |
+} |
+ |
+void MediaRouteController::AddObserver(MediaRouteStatusObserver* observer) { |
+ observers_.insert(observer); |
+} |
+ |
+void MediaRouteController::RemoveObserver(MediaRouteStatusObserver* observer) { |
+ observers_.erase(observer); |
+ if (observers_.empty()) { |
+ destroyer_callback_.Run(); |
+ // |this| gets destroyed here! |
+ } |
+} |
+ |
+void MediaRouteController::OnMediaStatusUpdated(const MediaStatus& status) { |
+ for (MediaRouteStatusObserver* observer : observers_) |
+ observer->OnMediaRouteStatusUpdated(status); |
+} |
+ |
+} // namespace media_router |