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); | 25 controller_->RemoveObserver(this); |
|
takumif
2017/03/29 02:34:49
No longer necessary because the controller won't u
| |
| 24 controller_ = nullptr; | 26 controller_ = nullptr; |
| 25 OnControllerInvalidated(); | 27 OnControllerInvalidated(); |
| 26 } | 28 } |
| 27 | 29 |
| 28 void MediaRouteController::Observer::OnControllerInvalidated() {} | 30 void MediaRouteController::Observer::OnControllerInvalidated() {} |
| 29 | 31 |
| 30 MediaRouteController::MediaRouteController( | 32 MediaRouteController::MediaRouteController( |
| 31 const MediaRoute::Id& route_id, | 33 const MediaRoute::Id& route_id, |
| 32 mojom::MediaControllerPtr media_controller) | 34 mojom::MediaControllerPtr media_controller, |
| 33 : route_id_(route_id), media_controller_(std::move(media_controller)) { | 35 MediaRouter* media_router) |
| 36 : route_id_(route_id), | |
| 37 media_controller_(std::move(media_controller)), | |
| 38 media_router_(media_router), | |
|
dcheng
2017/03/27 22:15:26
Shall we DCHECK(media_router)?
takumif
2017/03/29 02:34:49
Done.
| |
| 39 binding_(this) { | |
| 34 DCHECK(media_controller_.is_bound()); | 40 DCHECK(media_controller_.is_bound()); |
| 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))); |
|
imcheng
2017/03/28 01:18:37
Suggest adding a OnMojoConnectionError method that
takumif
2017/03/29 02:34:49
I'm not sure if we need OnMojoConnectionError() an
imcheng
2017/03/31 01:30:24
Right now we have MR::RemoveInvalidRouteController
| |
| 37 } | 43 } |
| 38 | 44 |
| 39 void MediaRouteController::Play() { | 45 void MediaRouteController::Play() { |
| 40 media_controller_->Play(); | 46 media_controller_->Play(); |
| 41 } | 47 } |
| 42 | 48 |
| 43 void MediaRouteController::Pause() { | 49 void MediaRouteController::Pause() { |
| 44 media_controller_->Pause(); | 50 media_controller_->Pause(); |
| 45 } | 51 } |
| 46 | 52 |
| 47 void MediaRouteController::Seek(base::TimeDelta time) { | 53 void MediaRouteController::Seek(base::TimeDelta time) { |
| 48 media_controller_->Seek(time); | 54 media_controller_->Seek(time); |
| 49 } | 55 } |
| 50 | 56 |
| 51 void MediaRouteController::SetMute(bool mute) { | 57 void MediaRouteController::SetMute(bool mute) { |
| 52 media_controller_->SetMute(mute); | 58 media_controller_->SetMute(mute); |
| 53 } | 59 } |
| 54 | 60 |
| 55 void MediaRouteController::SetVolume(float volume) { | 61 void MediaRouteController::SetVolume(float volume) { |
| 56 media_controller_->SetVolume(volume); | 62 media_controller_->SetVolume(volume); |
| 57 } | 63 } |
| 58 | 64 |
| 59 void MediaRouteController::OnMediaStatusUpdated(const MediaStatus& status) { | 65 void MediaRouteController::OnMediaStatusUpdated(const MediaStatus& status) { |
| 60 for (Observer& observer : observers_) | 66 for (Observer& observer : observers_) |
| 61 observer.OnMediaStatusUpdated(status); | 67 observer.OnMediaStatusUpdated(status); |
| 62 } | 68 } |
| 63 | 69 |
| 64 void MediaRouteController::Invalidate() { | 70 void MediaRouteController::Invalidate() { |
|
imcheng
2017/03/28 01:18:37
To make this API a bit more safe from implementati
takumif
2017/03/29 02:34:49
Added is_valid_ that gets set to false in Invalida
| |
| 65 for (Observer& observer : observers_) | 71 for (Observer& observer : observers_) |
| 66 observer.InvalidateController(); | 72 observer.InvalidateController(); |
| 67 // |this| is deleted here! | 73 // |this| is deleted here! |
| 68 } | 74 } |
| 69 | 75 |
| 70 MediaRouteController::~MediaRouteController() {} | 76 mojom::MediaStatusObserverPtr MediaRouteController::BindObserverPtr() { |
| 77 return binding_.CreateInterfacePtrAndBind(); | |
|
imcheng
2017/03/28 01:18:37
Did you mean to store it in a variable and return
takumif
2017/03/29 02:34:49
Yes. I'm surprised that this even compiled.
| |
| 78 binding_.set_connection_error_handler( | |
| 79 base::Bind(&MediaRouteController::Invalidate, base::Unretained(this))); | |
| 80 } | |
| 81 | |
| 82 MediaRouteController::~MediaRouteController() { | |
| 83 media_router_->OnRouteControllerDestroyed(route_id_); | |
| 84 } | |
| 71 | 85 |
| 72 void MediaRouteController::AddObserver(Observer* observer) { | 86 void MediaRouteController::AddObserver(Observer* observer) { |
| 73 observers_.AddObserver(observer); | 87 observers_.AddObserver(observer); |
| 74 } | 88 } |
| 75 | 89 |
| 76 void MediaRouteController::RemoveObserver(Observer* observer) { | 90 void MediaRouteController::RemoveObserver(Observer* observer) { |
| 77 observers_.RemoveObserver(observer); | 91 observers_.RemoveObserver(observer); |
| 78 } | 92 } |
| 79 | 93 |
| 80 } // namespace media_router | 94 } // namespace media_router |
| OLD | NEW |