Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 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 "chrome/browser/media/router/mojo/media_route_controller.h" | 5 #include "chrome/browser/media/router/mojo/media_route_controller.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "chrome/browser/media/router/media_router.h" | |
| 10 | |
| 9 namespace media_router { | 11 namespace media_router { |
| 10 | 12 |
| 11 MediaRouteController::Observer::Observer( | 13 MediaRouteController::Observer::Observer( |
| 12 scoped_refptr<MediaRouteController> controller) | 14 scoped_refptr<MediaRouteController> controller) |
| 13 : controller_(std::move(controller)) { | 15 : controller_(std::move(controller)) { |
| 14 controller_->AddObserver(this); | 16 controller_->AddObserver(this); |
| 15 } | 17 } |
| 16 | 18 |
| 17 MediaRouteController::Observer::~Observer() { | 19 MediaRouteController::Observer::~Observer() { |
| 18 if (controller_) | 20 if (controller_) |
| 19 controller_->RemoveObserver(this); | 21 controller_->RemoveObserver(this); |
| 20 } | 22 } |
| 21 | 23 |
| 22 void MediaRouteController::Observer::InvalidateController() { | 24 void MediaRouteController::Observer::InvalidateController() { |
| 23 controller_->RemoveObserver(this); | |
| 24 controller_ = nullptr; | 25 controller_ = nullptr; |
| 25 OnControllerInvalidated(); | 26 OnControllerInvalidated(); |
| 26 } | 27 } |
| 27 | 28 |
| 28 void MediaRouteController::Observer::OnControllerInvalidated() {} | 29 void MediaRouteController::Observer::OnControllerInvalidated() {} |
| 29 | 30 |
| 30 MediaRouteController::MediaRouteController( | 31 MediaRouteController::MediaRouteController( |
| 31 const MediaRoute::Id& route_id, | 32 const MediaRoute::Id& route_id, |
| 32 mojom::MediaControllerPtr media_controller) | 33 mojom::MediaControllerPtr media_controller, |
| 33 : route_id_(route_id), media_controller_(std::move(media_controller)) { | 34 MediaRouter* media_router) |
| 35 : route_id_(route_id), | |
| 36 media_controller_(std::move(media_controller)), | |
| 37 media_router_(media_router), | |
| 38 binding_(this) { | |
| 34 DCHECK(media_controller_.is_bound()); | 39 DCHECK(media_controller_.is_bound()); |
| 40 DCHECK(media_router); | |
| 35 media_controller_.set_connection_error_handler( | 41 media_controller_.set_connection_error_handler( |
| 36 base::Bind(&MediaRouteController::Invalidate, base::Unretained(this))); | 42 base::Bind(&MediaRouteController::Invalidate, base::Unretained(this))); |
| 37 } | 43 } |
| 38 | 44 |
| 39 void MediaRouteController::Play() { | 45 void MediaRouteController::Play() { |
| 46 DCHECK(is_valid_); | |
| 40 media_controller_->Play(); | 47 media_controller_->Play(); |
| 41 } | 48 } |
| 42 | 49 |
| 43 void MediaRouteController::Pause() { | 50 void MediaRouteController::Pause() { |
| 51 DCHECK(is_valid_); | |
| 44 media_controller_->Pause(); | 52 media_controller_->Pause(); |
| 45 } | 53 } |
| 46 | 54 |
| 47 void MediaRouteController::Seek(base::TimeDelta time) { | 55 void MediaRouteController::Seek(base::TimeDelta time) { |
| 56 DCHECK(is_valid_); | |
| 48 media_controller_->Seek(time); | 57 media_controller_->Seek(time); |
| 49 } | 58 } |
| 50 | 59 |
| 51 void MediaRouteController::SetMute(bool mute) { | 60 void MediaRouteController::SetMute(bool mute) { |
| 61 DCHECK(is_valid_); | |
| 52 media_controller_->SetMute(mute); | 62 media_controller_->SetMute(mute); |
| 53 } | 63 } |
| 54 | 64 |
| 55 void MediaRouteController::SetVolume(float volume) { | 65 void MediaRouteController::SetVolume(float volume) { |
| 66 DCHECK(is_valid_); | |
| 56 media_controller_->SetVolume(volume); | 67 media_controller_->SetVolume(volume); |
| 57 } | 68 } |
| 58 | 69 |
| 59 void MediaRouteController::OnMediaStatusUpdated(const MediaStatus& status) { | 70 void MediaRouteController::OnMediaStatusUpdated(const MediaStatus& status) { |
| 71 if (!is_valid_) | |
| 72 return; | |
| 73 | |
| 60 for (Observer& observer : observers_) | 74 for (Observer& observer : observers_) |
| 61 observer.OnMediaStatusUpdated(status); | 75 observer.OnMediaStatusUpdated(status); |
| 62 } | 76 } |
| 63 | 77 |
| 64 void MediaRouteController::Invalidate() { | 78 void MediaRouteController::Invalidate() { |
| 79 is_valid_ = false; | |
|
mark a. foltz
2017/03/30 23:03:28
Is the concern that the OnMediaStatusUpdated will
takumif
2017/04/04 03:19:50
Yes, and addition of new observers during or after
| |
| 80 media_router_->DetachRouteController(route_id_, this); | |
| 65 for (Observer& observer : observers_) | 81 for (Observer& observer : observers_) |
| 66 observer.InvalidateController(); | 82 observer.InvalidateController(); |
| 67 // |this| is deleted here! | 83 // |this| is deleted here! |
| 68 } | 84 } |
| 69 | 85 |
| 70 MediaRouteController::~MediaRouteController() {} | 86 mojom::MediaStatusObserverPtr MediaRouteController::BindObserverPtr() { |
| 87 DCHECK(is_valid_); | |
| 88 mojom::MediaStatusObserverPtr observer_ptr = | |
| 89 binding_.CreateInterfacePtrAndBind(); | |
| 90 binding_.set_connection_error_handler( | |
| 91 base::Bind(&MediaRouteController::Invalidate, base::Unretained(this))); | |
| 92 | |
| 93 return observer_ptr; | |
| 94 } | |
| 95 | |
| 96 MediaRouteController::~MediaRouteController() { | |
| 97 if (is_valid_) | |
|
mark a. foltz
2017/03/30 23:03:28
DCHECK(!is_valid_)?
takumif
2017/04/04 03:19:50
is_valid_ would be true here if the controller was
| |
| 98 media_router_->DetachRouteController(route_id_, this); | |
| 99 } | |
| 71 | 100 |
| 72 void MediaRouteController::AddObserver(Observer* observer) { | 101 void MediaRouteController::AddObserver(Observer* observer) { |
| 102 DCHECK(is_valid_); | |
| 73 observers_.AddObserver(observer); | 103 observers_.AddObserver(observer); |
| 74 } | 104 } |
| 75 | 105 |
| 76 void MediaRouteController::RemoveObserver(Observer* observer) { | 106 void MediaRouteController::RemoveObserver(Observer* observer) { |
| 107 DCHECK(is_valid_); | |
| 77 observers_.RemoveObserver(observer); | 108 observers_.RemoveObserver(observer); |
| 78 } | 109 } |
| 79 | 110 |
| 80 } // namespace media_router | 111 } // namespace media_router |
| OLD | NEW |