Chromium Code Reviews| 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..ad1595abe4a3de9b9c840d7438415ea24b2c91ff |
| --- /dev/null |
| +++ b/chrome/browser/media/router/mojo/media_route_controller.cc |
| @@ -0,0 +1,81 @@ |
| +// 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> |
| + |
| +namespace media_router { |
| + |
| +MediaRouteController::Observer::Observer( |
| + scoped_refptr<MediaRouteController> controller) |
| + : controller_(std::move(controller)) { |
| + controller_->AddObserver(this); |
| +} |
| + |
| +MediaRouteController::Observer::~Observer() { |
| + if (controller_) |
| + controller_->RemoveObserver(this); |
| +} |
| + |
| +void MediaRouteController::Observer::OnControllerInvalidated() { |
| + controller_ = nullptr; |
| +} |
| + |
| +MediaRouteController::MediaRouteController( |
| + const MediaRoute::Id& route_id, |
| + mojom::MediaControllerPtr media_controller, |
| + const base::Closure& destructor_callback) |
| + : route_id_(route_id), |
| + media_controller_(std::move(media_controller)), |
| + destructor_callback_(destructor_callback) { |
| + DCHECK(media_controller_.is_bound()); |
| + media_controller_.set_connection_error_handler(base::Bind( |
| + &MediaRouteController::OnControllerInvalidated, base::Unretained(this))); |
| +} |
| + |
| +void MediaRouteController::Play() { |
| + media_controller_->Play(); |
| +} |
| + |
| +void MediaRouteController::Pause() { |
| + media_controller_->Pause(); |
| +} |
| + |
| +void MediaRouteController::Seek(base::TimeDelta 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::OnMediaStatusUpdated(const MediaStatus& status) { |
| + for (Observer& observer : observers_) |
| + observer.OnMediaStatusUpdated(status); |
| +} |
| + |
| +void MediaRouteController::OnControllerInvalidated() { |
| + for (Observer& observer : observers_) |
| + observer.OnControllerInvalidated(); |
| + // |this| is deleted here! |
| +} |
| + |
| +MediaRouteController::~MediaRouteController() { |
| + destructor_callback_.Run(); |
|
mark a. foltz
2017/03/17 23:55:04
What does this do? If there is some cleanup that
takumif
2017/03/20 22:10:45
Replacing this line with
router_->OnRouteControlle
mark a. foltz
2017/03/21 00:05:21
The design based on notifying observers before the
|
| +} |
| + |
| +void MediaRouteController::AddObserver(Observer* observer) { |
| + observers_.AddObserver(observer); |
| +} |
| + |
| +void MediaRouteController::RemoveObserver(Observer* observer) { |
| + observers_.RemoveObserver(observer); |
| +} |
| + |
| +} // namespace media_router |