| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/presentation_service_delegate_impl.h" | 5 #include "chrome/browser/media/router/presentation_service_delegate_impl.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 #include <unordered_map> | 8 #include <unordered_map> |
| 9 #include <utility> | 9 #include <utility> |
| 10 #include <vector> | 10 #include <vector> |
| (...skipping 14 matching lines...) Expand all Loading... |
| 25 #include "chrome/browser/media/router/offscreen_presentation_manager_factory.h" | 25 #include "chrome/browser/media/router/offscreen_presentation_manager_factory.h" |
| 26 #include "chrome/browser/media/router/presentation_media_sinks_observer.h" | 26 #include "chrome/browser/media/router/presentation_media_sinks_observer.h" |
| 27 #include "chrome/browser/media/router/route_message.h" | 27 #include "chrome/browser/media/router/route_message.h" |
| 28 #include "chrome/browser/media/router/route_message_observer.h" | 28 #include "chrome/browser/media/router/route_message_observer.h" |
| 29 #include "chrome/browser/media/router/route_request_result.h" | 29 #include "chrome/browser/media/router/route_request_result.h" |
| 30 #include "chrome/browser/sessions/session_tab_helper.h" | 30 #include "chrome/browser/sessions/session_tab_helper.h" |
| 31 #include "content/public/browser/browser_context.h" | 31 #include "content/public/browser/browser_context.h" |
| 32 #include "content/public/browser/presentation_screen_availability_listener.h" | 32 #include "content/public/browser/presentation_screen_availability_listener.h" |
| 33 #include "content/public/browser/render_frame_host.h" | 33 #include "content/public/browser/render_frame_host.h" |
| 34 #include "content/public/browser/render_process_host.h" | 34 #include "content/public/browser/render_process_host.h" |
| 35 #include "content/public/common/presentation_session.h" | 35 #include "content/public/common/presentation_info.h" |
| 36 #include "url/gurl.h" | 36 #include "url/gurl.h" |
| 37 | 37 |
| 38 #if !defined(OS_ANDROID) | 38 #if !defined(OS_ANDROID) |
| 39 #include "chrome/browser/profiles/profile.h" | 39 #include "chrome/browser/profiles/profile.h" |
| 40 #include "chrome/common/pref_names.h" | 40 #include "chrome/common/pref_names.h" |
| 41 #include "components/prefs/pref_service.h" | 41 #include "components/prefs/pref_service.h" |
| 42 #endif | 42 #endif |
| 43 | 43 |
| 44 DEFINE_WEB_CONTENTS_USER_DATA_KEY( | 44 DEFINE_WEB_CONTENTS_USER_DATA_KEY( |
| 45 media_router::PresentationServiceDelegateImpl); | 45 media_router::PresentationServiceDelegateImpl); |
| (...skipping 18 matching lines...) Expand all Loading... |
| 64 url::Origin GetLastCommittedURLForFrame( | 64 url::Origin GetLastCommittedURLForFrame( |
| 65 RenderFrameHostId render_frame_host_id) { | 65 RenderFrameHostId render_frame_host_id) { |
| 66 RenderFrameHost* render_frame_host = RenderFrameHost::FromID( | 66 RenderFrameHost* render_frame_host = RenderFrameHost::FromID( |
| 67 render_frame_host_id.first, render_frame_host_id.second); | 67 render_frame_host_id.first, render_frame_host_id.second); |
| 68 DCHECK(render_frame_host); | 68 DCHECK(render_frame_host); |
| 69 return render_frame_host->GetLastCommittedOrigin(); | 69 return render_frame_host->GetLastCommittedOrigin(); |
| 70 } | 70 } |
| 71 | 71 |
| 72 // Observes messages originating from the MediaSink connected to a MediaRoute | 72 // Observes messages originating from the MediaSink connected to a MediaRoute |
| 73 // that represents a presentation. Converts the messages into | 73 // that represents a presentation. Converts the messages into |
| 74 // content::PresentationSessionMessages and dispatches them via the provided | 74 // content::PresentationConnectionMessages and dispatches them via the provided |
| 75 // PresentationSessionMessageCallback. | 75 // PresentationConnectionMessageCallback. |
| 76 class PresentationSessionMessagesObserver : public RouteMessageObserver { | 76 class PresentationConnectionMessagesObserver : public RouteMessageObserver { |
| 77 public: | 77 public: |
| 78 // |message_cb|: The callback to invoke whenever messages are received. | 78 // |message_cb|: The callback to invoke whenever messages are received. |
| 79 // |route_id|: ID of MediaRoute to listen for messages. | 79 // |route_id|: ID of MediaRoute to listen for messages. |
| 80 PresentationSessionMessagesObserver( | 80 PresentationConnectionMessagesObserver( |
| 81 MediaRouter* router, | 81 MediaRouter* router, |
| 82 const MediaRoute::Id& route_id, | 82 const MediaRoute::Id& route_id, |
| 83 const content::PresentationConnectionMessageCallback& message_cb) | 83 const content::PresentationConnectionMessageCallback& message_cb) |
| 84 : RouteMessageObserver(router, route_id), message_cb_(message_cb) { | 84 : RouteMessageObserver(router, route_id), message_cb_(message_cb) { |
| 85 DCHECK(!message_cb_.is_null()); | 85 DCHECK(!message_cb_.is_null()); |
| 86 } | 86 } |
| 87 | 87 |
| 88 ~PresentationSessionMessagesObserver() final {} | 88 ~PresentationConnectionMessagesObserver() final {} |
| 89 | 89 |
| 90 void OnMessagesReceived(const std::vector<RouteMessage>& messages) final { | 90 void OnMessagesReceived(const std::vector<RouteMessage>& messages) final { |
| 91 DVLOG(2) << __func__ << ", number of messages : " << messages.size(); | 91 DVLOG(2) << __func__ << ", number of messages : " << messages.size(); |
| 92 // TODO(mfoltz): Remove RouteMessage and replace with move-only | 92 // TODO(mfoltz): Remove RouteMessage and replace with move-only |
| 93 // PresentationConnectionMessage. | 93 // PresentationConnectionMessage. |
| 94 std::vector<content::PresentationConnectionMessage> presentation_messages; | 94 std::vector<content::PresentationConnectionMessage> presentation_messages; |
| 95 for (const RouteMessage& message : messages) { | 95 for (const RouteMessage& message : messages) { |
| 96 if (message.type == RouteMessage::TEXT && message.text) { | 96 if (message.type == RouteMessage::TEXT && message.text) { |
| 97 presentation_messages.emplace_back(message.text.value()); | 97 presentation_messages.emplace_back(message.text.value()); |
| 98 } else if (message.type == RouteMessage::BINARY && message.binary) { | 98 } else if (message.type == RouteMessage::BINARY && message.binary) { |
| 99 presentation_messages.emplace_back(message.binary.value()); | 99 presentation_messages.emplace_back(message.binary.value()); |
| 100 } else { | 100 } else { |
| 101 NOTREACHED() << "Unknown route message type"; | 101 NOTREACHED() << "Unknown route message type"; |
| 102 } | 102 } |
| 103 } | 103 } |
| 104 message_cb_.Run(std::move(presentation_messages)); | 104 message_cb_.Run(std::move(presentation_messages)); |
| 105 } | 105 } |
| 106 | 106 |
| 107 private: | 107 private: |
| 108 const content::PresentationConnectionMessageCallback message_cb_; | 108 const content::PresentationConnectionMessageCallback message_cb_; |
| 109 | 109 |
| 110 DISALLOW_COPY_AND_ASSIGN(PresentationSessionMessagesObserver); | 110 DISALLOW_COPY_AND_ASSIGN(PresentationConnectionMessagesObserver); |
| 111 }; | 111 }; |
| 112 | 112 |
| 113 } // namespace | 113 } // namespace |
| 114 | 114 |
| 115 // Used by PresentationServiceDelegateImpl to manage | 115 // Used by PresentationServiceDelegateImpl to manage |
| 116 // listeners and default presentation info in a render frame. | 116 // listeners and default presentation info in a render frame. |
| 117 // Its lifetime: | 117 // Its lifetime: |
| 118 // * Create an instance with |render_frame_host_id_| if no instance with the | 118 // * Create an instance with |render_frame_host_id_| if no instance with the |
| 119 // same |render_frame_host_id_| exists in: | 119 // same |render_frame_host_id_| exists in: |
| 120 // PresentationFrameManager::OnPresentationSessionStarted | 120 // PresentationFrameManager::OnPresentationConnection |
| 121 // PresentationFrameManager::OnDefaultPresentationSessionStarted | 121 // PresentationFrameManager::OnDefaultPresentationStarted |
| 122 // PresentationFrameManager::SetScreenAvailabilityListener | 122 // PresentationFrameManager::SetScreenAvailabilityListener |
| 123 // * Destroy the instance in: | 123 // * Destroy the instance in: |
| 124 // PresentationFrameManager::Reset | 124 // PresentationFrameManager::Reset |
| 125 class PresentationFrame { | 125 class PresentationFrame { |
| 126 public: | 126 public: |
| 127 PresentationFrame(const RenderFrameHostId& render_frame_host_id, | 127 PresentationFrame(const RenderFrameHostId& render_frame_host_id, |
| 128 content::WebContents* web_contents, | 128 content::WebContents* web_contents, |
| 129 MediaRouter* router); | 129 MediaRouter* router); |
| 130 ~PresentationFrame(); | 130 ~PresentationFrame(); |
| 131 | 131 |
| 132 // Mirror corresponding APIs in PresentationServiceDelegateImpl. | 132 // Mirror corresponding APIs in PresentationServiceDelegateImpl. |
| 133 bool SetScreenAvailabilityListener( | 133 bool SetScreenAvailabilityListener( |
| 134 content::PresentationScreenAvailabilityListener* listener); | 134 content::PresentationScreenAvailabilityListener* listener); |
| 135 bool RemoveScreenAvailabilityListener( | 135 bool RemoveScreenAvailabilityListener( |
| 136 content::PresentationScreenAvailabilityListener* listener); | 136 content::PresentationScreenAvailabilityListener* listener); |
| 137 bool HasScreenAvailabilityListenerForTest( | 137 bool HasScreenAvailabilityListenerForTest( |
| 138 const MediaSource::Id& source_id) const; | 138 const MediaSource::Id& source_id) const; |
| 139 std::string GetDefaultPresentationId() const; | 139 std::string GetDefaultPresentationId() const; |
| 140 void ListenForConnectionStateChange( | 140 void ListenForConnectionStateChange( |
| 141 const content::PresentationSessionInfo& connection, | 141 const content::PresentationInfo& connection, |
| 142 const content::PresentationConnectionStateChangedCallback& | 142 const content::PresentationConnectionStateChangedCallback& |
| 143 state_changed_cb); | 143 state_changed_cb); |
| 144 void ListenForSessionMessages( | 144 void ListenForConnectionMessages( |
| 145 const content::PresentationSessionInfo& session, | 145 const content::PresentationInfo& presentation_info, |
| 146 const content::PresentationConnectionMessageCallback& message_cb); | 146 const content::PresentationConnectionMessageCallback& message_cb); |
| 147 | 147 |
| 148 void Reset(); | 148 void Reset(); |
| 149 void RemoveConnection(const std::string& presentation_id, | 149 void RemoveConnection(const std::string& presentation_id, |
| 150 const MediaRoute::Id& route_id); | 150 const MediaRoute::Id& route_id); |
| 151 | 151 |
| 152 const MediaRoute::Id GetRouteId(const std::string& presentation_id) const; | 152 const MediaRoute::Id GetRouteId(const std::string& presentation_id) const; |
| 153 | 153 |
| 154 void OnPresentationSessionStarted( | 154 void OnPresentationConnection( |
| 155 const content::PresentationSessionInfo& session, | 155 const content::PresentationInfo& presentation_info, |
| 156 const MediaRoute& route); | 156 const MediaRoute& route); |
| 157 void OnPresentationServiceDelegateDestroyed() const; | 157 void OnPresentationServiceDelegateDestroyed() const; |
| 158 | 158 |
| 159 bool IsOffscreenPresentation(const std::string& presentation_id) const; | 159 bool IsOffscreenPresentation(const std::string& presentation_id) const; |
| 160 void ConnectToPresentation( | 160 void ConnectToPresentation( |
| 161 const content::PresentationSessionInfo& session, | 161 const content::PresentationInfo& presentation_info, |
| 162 content::PresentationConnectionPtr controller_connection_ptr, | 162 content::PresentationConnectionPtr controller_connection_ptr, |
| 163 content::PresentationConnectionRequest receiver_connection_request); | 163 content::PresentationConnectionRequest receiver_connection_request); |
| 164 | 164 |
| 165 private: | 165 private: |
| 166 MediaSource GetMediaSourceFromListener( | 166 MediaSource GetMediaSourceFromListener( |
| 167 content::PresentationScreenAvailabilityListener* listener) const; | 167 content::PresentationScreenAvailabilityListener* listener) const; |
| 168 base::SmallMap<std::map<std::string, MediaRoute>> presentation_id_to_route_; | 168 base::SmallMap<std::map<std::string, MediaRoute>> presentation_id_to_route_; |
| 169 base::SmallMap< | 169 base::SmallMap< |
| 170 std::map<std::string, std::unique_ptr<PresentationMediaSinksObserver>>> | 170 std::map<std::string, std::unique_ptr<PresentationMediaSinksObserver>>> |
| 171 url_to_sinks_observer_; | 171 url_to_sinks_observer_; |
| 172 std::unordered_map< | 172 std::unordered_map< |
| 173 MediaRoute::Id, | 173 MediaRoute::Id, |
| 174 std::unique_ptr<PresentationConnectionStateSubscription>> | 174 std::unique_ptr<PresentationConnectionStateSubscription>> |
| 175 connection_state_subscriptions_; | 175 connection_state_subscriptions_; |
| 176 std::unordered_map< | 176 std::unordered_map<MediaRoute::Id, |
| 177 MediaRoute::Id, | 177 std::unique_ptr<PresentationConnectionMessagesObserver>> |
| 178 std::unique_ptr<PresentationSessionMessagesObserver>> | 178 connection_messages_observers_; |
| 179 session_messages_observers_; | |
| 180 std::unordered_map<MediaRoute::Id, | 179 std::unordered_map<MediaRoute::Id, |
| 181 std::unique_ptr<BrowserPresentationConnectionProxy>> | 180 std::unique_ptr<BrowserPresentationConnectionProxy>> |
| 182 browser_connection_proxies_; | 181 browser_connection_proxies_; |
| 183 | 182 |
| 184 RenderFrameHostId render_frame_host_id_; | 183 RenderFrameHostId render_frame_host_id_; |
| 185 | 184 |
| 186 // References to the owning WebContents, and the corresponding MediaRouter. | 185 // References to the owning WebContents, and the corresponding MediaRouter. |
| 187 content::WebContents* web_contents_; | 186 content::WebContents* web_contents_; |
| 188 MediaRouter* router_; | 187 MediaRouter* router_; |
| 189 }; | 188 }; |
| 190 | 189 |
| 191 PresentationFrame::PresentationFrame( | 190 PresentationFrame::PresentationFrame( |
| 192 const RenderFrameHostId& render_frame_host_id, | 191 const RenderFrameHostId& render_frame_host_id, |
| 193 content::WebContents* web_contents, | 192 content::WebContents* web_contents, |
| 194 MediaRouter* router) | 193 MediaRouter* router) |
| 195 : render_frame_host_id_(render_frame_host_id), | 194 : render_frame_host_id_(render_frame_host_id), |
| 196 web_contents_(web_contents), | 195 web_contents_(web_contents), |
| 197 router_(router) { | 196 router_(router) { |
| 198 DCHECK(web_contents_); | 197 DCHECK(web_contents_); |
| 199 DCHECK(router_); | 198 DCHECK(router_); |
| 200 } | 199 } |
| 201 | 200 |
| 202 PresentationFrame::~PresentationFrame() { | 201 PresentationFrame::~PresentationFrame() { |
| 203 } | 202 } |
| 204 | 203 |
| 205 void PresentationFrame::OnPresentationSessionStarted( | 204 void PresentationFrame::OnPresentationConnection( |
| 206 const content::PresentationSessionInfo& session, | 205 const content::PresentationInfo& presentation_info, |
| 207 const MediaRoute& route) { | 206 const MediaRoute& route) { |
| 208 presentation_id_to_route_.insert( | 207 presentation_id_to_route_.insert( |
| 209 std::make_pair(session.presentation_id, route)); | 208 std::make_pair(presentation_info.presentation_id, route)); |
| 210 } | 209 } |
| 211 | 210 |
| 212 const MediaRoute::Id PresentationFrame::GetRouteId( | 211 const MediaRoute::Id PresentationFrame::GetRouteId( |
| 213 const std::string& presentation_id) const { | 212 const std::string& presentation_id) const { |
| 214 auto it = presentation_id_to_route_.find(presentation_id); | 213 auto it = presentation_id_to_route_.find(presentation_id); |
| 215 return it != presentation_id_to_route_.end() ? it->second.media_route_id() | 214 return it != presentation_id_to_route_.end() ? it->second.media_route_id() |
| 216 : ""; | 215 : ""; |
| 217 } | 216 } |
| 218 | 217 |
| 219 bool PresentationFrame::SetScreenAvailabilityListener( | 218 bool PresentationFrame::SetScreenAvailabilityListener( |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 262 if (IsOffscreenPresentation(pid_route.first)) { | 261 if (IsOffscreenPresentation(pid_route.first)) { |
| 263 offscreen_presentation_manager->UnregisterOffscreenPresentationController( | 262 offscreen_presentation_manager->UnregisterOffscreenPresentationController( |
| 264 pid_route.first, render_frame_host_id_); | 263 pid_route.first, render_frame_host_id_); |
| 265 } | 264 } |
| 266 router_->DetachRoute(pid_route.second.media_route_id()); | 265 router_->DetachRoute(pid_route.second.media_route_id()); |
| 267 } | 266 } |
| 268 | 267 |
| 269 presentation_id_to_route_.clear(); | 268 presentation_id_to_route_.clear(); |
| 270 url_to_sinks_observer_.clear(); | 269 url_to_sinks_observer_.clear(); |
| 271 connection_state_subscriptions_.clear(); | 270 connection_state_subscriptions_.clear(); |
| 272 session_messages_observers_.clear(); | 271 connection_messages_observers_.clear(); |
| 273 browser_connection_proxies_.clear(); | 272 browser_connection_proxies_.clear(); |
| 274 } | 273 } |
| 275 | 274 |
| 276 void PresentationFrame::RemoveConnection(const std::string& presentation_id, | 275 void PresentationFrame::RemoveConnection(const std::string& presentation_id, |
| 277 const MediaRoute::Id& route_id) { | 276 const MediaRoute::Id& route_id) { |
| 278 // Remove the presentation id mapping so a later call to Reset is a no-op. | 277 // Remove the presentation id mapping so a later call to Reset is a no-op. |
| 279 presentation_id_to_route_.erase(presentation_id); | 278 presentation_id_to_route_.erase(presentation_id); |
| 280 | 279 |
| 281 // We no longer need to observe route messages. | 280 // We no longer need to observe route messages. |
| 282 session_messages_observers_.erase(route_id); | 281 connection_messages_observers_.erase(route_id); |
| 283 | 282 |
| 284 browser_connection_proxies_.erase(route_id); | 283 browser_connection_proxies_.erase(route_id); |
| 285 // We keep the PresentationConnectionStateChangedCallback registered with MR | 284 // We keep the PresentationConnectionStateChangedCallback registered with MR |
| 286 // so the MRP can tell us when terminate() completed. | 285 // so the MRP can tell us when terminate() completed. |
| 287 } | 286 } |
| 288 | 287 |
| 289 void PresentationFrame::ListenForConnectionStateChange( | 288 void PresentationFrame::ListenForConnectionStateChange( |
| 290 const content::PresentationSessionInfo& connection, | 289 const content::PresentationInfo& connection, |
| 291 const content::PresentationConnectionStateChangedCallback& | 290 const content::PresentationConnectionStateChangedCallback& |
| 292 state_changed_cb) { | 291 state_changed_cb) { |
| 293 auto it = presentation_id_to_route_.find(connection.presentation_id); | 292 auto it = presentation_id_to_route_.find(connection.presentation_id); |
| 294 if (it == presentation_id_to_route_.end()) { | 293 if (it == presentation_id_to_route_.end()) { |
| 295 DLOG(ERROR) << __func__ << "route id not found for presentation: " | 294 DLOG(ERROR) << __func__ << "route id not found for presentation: " |
| 296 << connection.presentation_id; | 295 << connection.presentation_id; |
| 297 return; | 296 return; |
| 298 } | 297 } |
| 299 | 298 |
| 300 const MediaRoute::Id& route_id = it->second.media_route_id(); | 299 const MediaRoute::Id& route_id = it->second.media_route_id(); |
| 301 if (connection_state_subscriptions_.find(route_id) != | 300 if (connection_state_subscriptions_.find(route_id) != |
| 302 connection_state_subscriptions_.end()) { | 301 connection_state_subscriptions_.end()) { |
| 303 DLOG(ERROR) << __func__ | 302 DLOG(ERROR) << __func__ |
| 304 << "Already listening connection state change for route: " | 303 << "Already listening connection state change for route: " |
| 305 << route_id; | 304 << route_id; |
| 306 return; | 305 return; |
| 307 } | 306 } |
| 308 | 307 |
| 309 connection_state_subscriptions_.insert(std::make_pair( | 308 connection_state_subscriptions_.insert(std::make_pair( |
| 310 route_id, router_->AddPresentationConnectionStateChangedCallback( | 309 route_id, router_->AddPresentationConnectionStateChangedCallback( |
| 311 route_id, state_changed_cb))); | 310 route_id, state_changed_cb))); |
| 312 } | 311 } |
| 313 | 312 |
| 314 void PresentationFrame::ListenForSessionMessages( | 313 void PresentationFrame::ListenForConnectionMessages( |
| 315 const content::PresentationSessionInfo& session, | 314 const content::PresentationInfo& presentation_info, |
| 316 const content::PresentationConnectionMessageCallback& message_cb) { | 315 const content::PresentationConnectionMessageCallback& message_cb) { |
| 317 auto it = presentation_id_to_route_.find(session.presentation_id); | 316 auto it = presentation_id_to_route_.find(presentation_info.presentation_id); |
| 318 if (it == presentation_id_to_route_.end()) { | 317 if (it == presentation_id_to_route_.end()) { |
| 319 DVLOG(2) << "ListenForSessionMessages: no route for " | 318 DVLOG(2) << "ListenForConnectionMessages: no route for " |
| 320 << session.presentation_id; | 319 << presentation_info.presentation_id; |
| 321 return; | 320 return; |
| 322 } | 321 } |
| 323 | 322 |
| 324 if (it->second.is_offscreen_presentation()) { | 323 if (it->second.is_offscreen_presentation()) { |
| 325 DVLOG(2) << "ListenForSessionMessages: do not listen for offscreen " | 324 DVLOG(2) << "ListenForConnectionMessages: do not listen for offscreen " |
| 326 << "presentation [id]: " << session.presentation_id; | 325 << "presentation [id]: " << presentation_info.presentation_id; |
| 327 return; | 326 return; |
| 328 } | 327 } |
| 329 | 328 |
| 330 const MediaRoute::Id& route_id = it->second.media_route_id(); | 329 const MediaRoute::Id& route_id = it->second.media_route_id(); |
| 331 if (session_messages_observers_.find(route_id) != | 330 if (connection_messages_observers_.find(route_id) != |
| 332 session_messages_observers_.end()) { | 331 connection_messages_observers_.end()) { |
| 333 DLOG(ERROR) << __func__ | 332 DLOG(ERROR) << __func__ |
| 334 << "Already listening for session messages for route: " | 333 << "Already listening for connection messages for route: " |
| 335 << route_id; | 334 << route_id; |
| 336 return; | 335 return; |
| 337 } | 336 } |
| 338 | 337 |
| 339 session_messages_observers_.insert(std::make_pair( | 338 connection_messages_observers_.insert(std::make_pair( |
| 340 route_id, base::MakeUnique<PresentationSessionMessagesObserver>( | 339 route_id, base::MakeUnique<PresentationConnectionMessagesObserver>( |
| 341 router_, route_id, message_cb))); | 340 router_, route_id, message_cb))); |
| 342 } | 341 } |
| 343 | 342 |
| 344 MediaSource PresentationFrame::GetMediaSourceFromListener( | 343 MediaSource PresentationFrame::GetMediaSourceFromListener( |
| 345 content::PresentationScreenAvailabilityListener* listener) const { | 344 content::PresentationScreenAvailabilityListener* listener) const { |
| 346 // If the default presentation URL is empty then fall back to tab mirroring. | 345 // If the default presentation URL is empty then fall back to tab mirroring. |
| 347 return listener->GetAvailabilityUrl().is_empty() | 346 return listener->GetAvailabilityUrl().is_empty() |
| 348 ? MediaSourceForTab(SessionTabHelper::IdForTab(web_contents_)) | 347 ? MediaSourceForTab(SessionTabHelper::IdForTab(web_contents_)) |
| 349 : MediaSourceForPresentationUrl(listener->GetAvailabilityUrl()); | 348 : MediaSourceForPresentationUrl(listener->GetAvailabilityUrl()); |
| 350 } | 349 } |
| 351 | 350 |
| 352 bool PresentationFrame::IsOffscreenPresentation( | 351 bool PresentationFrame::IsOffscreenPresentation( |
| 353 const std::string& presentation_id) const { | 352 const std::string& presentation_id) const { |
| 354 const auto it = presentation_id_to_route_.find(presentation_id); | 353 const auto it = presentation_id_to_route_.find(presentation_id); |
| 355 if (it == presentation_id_to_route_.end()) { | 354 if (it == presentation_id_to_route_.end()) { |
| 356 DLOG(WARNING) << "No route for [presentation_id]: " << presentation_id; | 355 DLOG(WARNING) << "No route for [presentation_id]: " << presentation_id; |
| 357 return false; | 356 return false; |
| 358 } | 357 } |
| 359 | 358 |
| 360 return it->second.is_offscreen_presentation(); | 359 return it->second.is_offscreen_presentation(); |
| 361 } | 360 } |
| 362 | 361 |
| 363 void PresentationFrame::ConnectToPresentation( | 362 void PresentationFrame::ConnectToPresentation( |
| 364 const content::PresentationSessionInfo& session, | 363 const content::PresentationInfo& presentation_info, |
| 365 content::PresentationConnectionPtr controller_connection_ptr, | 364 content::PresentationConnectionPtr controller_connection_ptr, |
| 366 content::PresentationConnectionRequest receiver_connection_request) { | 365 content::PresentationConnectionRequest receiver_connection_request) { |
| 367 const auto pid_route_it = | 366 const auto pid_route_it = |
| 368 presentation_id_to_route_.find(session.presentation_id); | 367 presentation_id_to_route_.find(presentation_info.presentation_id); |
| 369 | 368 |
| 370 if (pid_route_it == presentation_id_to_route_.end()) { | 369 if (pid_route_it == presentation_id_to_route_.end()) { |
| 371 DLOG(WARNING) << "No route for [presentation_id]: " | 370 DLOG(WARNING) << "No route for [presentation_id]: " |
| 372 << session.presentation_id; | 371 << presentation_info.presentation_id; |
| 373 return; | 372 return; |
| 374 } | 373 } |
| 375 | 374 |
| 376 if (IsOffscreenPresentation(session.presentation_id)) { | 375 if (IsOffscreenPresentation(presentation_info.presentation_id)) { |
| 377 auto* const offscreen_presentation_manager = | 376 auto* const offscreen_presentation_manager = |
| 378 OffscreenPresentationManagerFactory::GetOrCreateForWebContents( | 377 OffscreenPresentationManagerFactory::GetOrCreateForWebContents( |
| 379 web_contents_); | 378 web_contents_); |
| 380 offscreen_presentation_manager->RegisterOffscreenPresentationController( | 379 offscreen_presentation_manager->RegisterOffscreenPresentationController( |
| 381 session.presentation_id, session.presentation_url, | 380 presentation_info.presentation_id, presentation_info.presentation_url, |
| 382 render_frame_host_id_, std::move(controller_connection_ptr), | 381 render_frame_host_id_, std::move(controller_connection_ptr), |
| 383 std::move(receiver_connection_request)); | 382 std::move(receiver_connection_request)); |
| 384 } else { | 383 } else { |
| 385 DVLOG(2) | 384 DVLOG(2) |
| 386 << "Creating BrowserPresentationConnectionProxy for [presentation_id]: " | 385 << "Creating BrowserPresentationConnectionProxy for [presentation_id]: " |
| 387 << session.presentation_id; | 386 << presentation_info.presentation_id; |
| 388 MediaRoute::Id route_id = pid_route_it->second.media_route_id(); | 387 MediaRoute::Id route_id = pid_route_it->second.media_route_id(); |
| 389 auto* proxy = new BrowserPresentationConnectionProxy( | 388 auto* proxy = new BrowserPresentationConnectionProxy( |
| 390 router_, route_id, std::move(receiver_connection_request), | 389 router_, route_id, std::move(receiver_connection_request), |
| 391 std::move(controller_connection_ptr)); | 390 std::move(controller_connection_ptr)); |
| 392 | 391 |
| 393 browser_connection_proxies_.insert( | 392 browser_connection_proxies_.insert( |
| 394 std::make_pair(route_id, base::WrapUnique(proxy))); | 393 std::make_pair(route_id, base::WrapUnique(proxy))); |
| 395 } | 394 } |
| 396 } | 395 } |
| 397 | 396 |
| 398 // Used by PresentationServiceDelegateImpl to manage PresentationFrames. | 397 // Used by PresentationServiceDelegateImpl to manage PresentationFrames. |
| 399 class PresentationFrameManager { | 398 class PresentationFrameManager { |
| 400 public: | 399 public: |
| 401 PresentationFrameManager(content::WebContents* web_contents, | 400 PresentationFrameManager(content::WebContents* web_contents, |
| 402 MediaRouter* router); | 401 MediaRouter* router); |
| 403 ~PresentationFrameManager(); | 402 ~PresentationFrameManager(); |
| 404 | 403 |
| 405 // Mirror corresponding APIs in PresentationServiceDelegateImpl. | 404 // Mirror corresponding APIs in PresentationServiceDelegateImpl. |
| 406 bool SetScreenAvailabilityListener( | 405 bool SetScreenAvailabilityListener( |
| 407 const RenderFrameHostId& render_frame_host_id, | 406 const RenderFrameHostId& render_frame_host_id, |
| 408 content::PresentationScreenAvailabilityListener* listener); | 407 content::PresentationScreenAvailabilityListener* listener); |
| 409 bool RemoveScreenAvailabilityListener( | 408 bool RemoveScreenAvailabilityListener( |
| 410 const RenderFrameHostId& render_frame_host_id, | 409 const RenderFrameHostId& render_frame_host_id, |
| 411 content::PresentationScreenAvailabilityListener* listener); | 410 content::PresentationScreenAvailabilityListener* listener); |
| 412 void ListenForConnectionStateChange( | 411 void ListenForConnectionStateChange( |
| 413 const RenderFrameHostId& render_frame_host_id, | 412 const RenderFrameHostId& render_frame_host_id, |
| 414 const content::PresentationSessionInfo& connection, | 413 const content::PresentationInfo& connection, |
| 415 const content::PresentationConnectionStateChangedCallback& | 414 const content::PresentationConnectionStateChangedCallback& |
| 416 state_changed_cb); | 415 state_changed_cb); |
| 417 void ListenForSessionMessages( | 416 void ListenForConnectionMessages( |
| 418 const RenderFrameHostId& render_frame_host_id, | 417 const RenderFrameHostId& render_frame_host_id, |
| 419 const content::PresentationSessionInfo& session, | 418 const content::PresentationInfo& presentation_info, |
| 420 const content::PresentationConnectionMessageCallback& message_cb); | 419 const content::PresentationConnectionMessageCallback& message_cb); |
| 421 | 420 |
| 422 // Sets or clears the default presentation request and callback for the given | 421 // Sets or clears the default presentation request and callback for the given |
| 423 // frame. Also sets / clears the default presentation requests for the owning | 422 // frame. Also sets / clears the default presentation requests for the owning |
| 424 // tab WebContents. | 423 // tab WebContents. |
| 425 void SetDefaultPresentationUrls( | 424 void SetDefaultPresentationUrls( |
| 426 const RenderFrameHostId& render_frame_host_id, | 425 const RenderFrameHostId& render_frame_host_id, |
| 427 const std::vector<GURL>& default_presentation_urls, | 426 const std::vector<GURL>& default_presentation_urls, |
| 428 const content::PresentationSessionStartedCallback& callback); | 427 const content::PresentationConnectionCallback& callback); |
| 429 void AddDelegateObserver(const RenderFrameHostId& render_frame_host_id, | 428 void AddDelegateObserver(const RenderFrameHostId& render_frame_host_id, |
| 430 DelegateObserver* observer); | 429 DelegateObserver* observer); |
| 431 void RemoveDelegateObserver(const RenderFrameHostId& render_frame_host_id); | 430 void RemoveDelegateObserver(const RenderFrameHostId& render_frame_host_id); |
| 432 void AddDefaultPresentationRequestObserver( | 431 void AddDefaultPresentationRequestObserver( |
| 433 PresentationServiceDelegateImpl::DefaultPresentationRequestObserver* | 432 PresentationServiceDelegateImpl::DefaultPresentationRequestObserver* |
| 434 observer); | 433 observer); |
| 435 void RemoveDefaultPresentationRequestObserver( | 434 void RemoveDefaultPresentationRequestObserver( |
| 436 PresentationServiceDelegateImpl::DefaultPresentationRequestObserver* | 435 PresentationServiceDelegateImpl::DefaultPresentationRequestObserver* |
| 437 observer); | 436 observer); |
| 438 void Reset(const RenderFrameHostId& render_frame_host_id); | 437 void Reset(const RenderFrameHostId& render_frame_host_id); |
| 439 void RemoveConnection(const RenderFrameHostId& render_frame_host_id, | 438 void RemoveConnection(const RenderFrameHostId& render_frame_host_id, |
| 440 const MediaRoute::Id& route_id, | 439 const MediaRoute::Id& route_id, |
| 441 const std::string& presentation_id); | 440 const std::string& presentation_id); |
| 442 bool HasScreenAvailabilityListenerForTest( | 441 bool HasScreenAvailabilityListenerForTest( |
| 443 const RenderFrameHostId& render_frame_host_id, | 442 const RenderFrameHostId& render_frame_host_id, |
| 444 const MediaSource::Id& source_id) const; | 443 const MediaSource::Id& source_id) const; |
| 445 void SetMediaRouterForTest(MediaRouter* router); | 444 void SetMediaRouterForTest(MediaRouter* router); |
| 446 | 445 |
| 447 void OnPresentationSessionStarted( | 446 void OnPresentationConnection( |
| 448 const RenderFrameHostId& render_frame_host_id, | 447 const RenderFrameHostId& render_frame_host_id, |
| 449 const content::PresentationSessionInfo& session, | 448 const content::PresentationInfo& presentation_info, |
| 450 const MediaRoute& route); | 449 const MediaRoute& route); |
| 451 void OnDefaultPresentationSessionStarted( | 450 void OnDefaultPresentationStarted( |
| 452 const PresentationRequest& request, | 451 const PresentationRequest& request, |
| 453 const content::PresentationSessionInfo& session, | 452 const content::PresentationInfo& presentation_info, |
| 454 const MediaRoute& route); | 453 const MediaRoute& route); |
| 455 | 454 |
| 456 void ConnectToPresentation( | 455 void ConnectToPresentation( |
| 457 const RenderFrameHostId& render_frame_host_id, | 456 const RenderFrameHostId& render_frame_host_id, |
| 458 const content::PresentationSessionInfo& session, | 457 const content::PresentationInfo& presentation_info, |
| 459 content::PresentationConnectionPtr controller_connection_ptr, | 458 content::PresentationConnectionPtr controller_connection_ptr, |
| 460 content::PresentationConnectionRequest receiver_connection_request); | 459 content::PresentationConnectionRequest receiver_connection_request); |
| 461 | 460 |
| 462 const MediaRoute::Id GetRouteId(const RenderFrameHostId& render_frame_host_id, | 461 const MediaRoute::Id GetRouteId(const RenderFrameHostId& render_frame_host_id, |
| 463 const std::string& presentation_id) const; | 462 const std::string& presentation_id) const; |
| 464 | 463 |
| 465 const PresentationRequest* default_presentation_request() const { | 464 const PresentationRequest* default_presentation_request() const { |
| 466 return default_presentation_request_.get(); | 465 return default_presentation_request_.get(); |
| 467 } | 466 } |
| 468 | 467 |
| (...skipping 16 matching lines...) Expand all Loading... |
| 485 // Maps a frame identifier to a PresentationFrame object for frames | 484 // Maps a frame identifier to a PresentationFrame object for frames |
| 486 // that are using presentation API. | 485 // that are using presentation API. |
| 487 std::unordered_map<RenderFrameHostId, std::unique_ptr<PresentationFrame>, | 486 std::unordered_map<RenderFrameHostId, std::unique_ptr<PresentationFrame>, |
| 488 RenderFrameHostIdHasher> | 487 RenderFrameHostIdHasher> |
| 489 presentation_frames_; | 488 presentation_frames_; |
| 490 | 489 |
| 491 // Default presentation request for the owning tab WebContents. | 490 // Default presentation request for the owning tab WebContents. |
| 492 std::unique_ptr<PresentationRequest> default_presentation_request_; | 491 std::unique_ptr<PresentationRequest> default_presentation_request_; |
| 493 | 492 |
| 494 // Callback to invoke when default presentation has started. | 493 // Callback to invoke when default presentation has started. |
| 495 content::PresentationSessionStartedCallback | 494 content::PresentationConnectionCallback |
| 496 default_presentation_started_callback_; | 495 default_presentation_started_callback_; |
| 497 | 496 |
| 498 // References to the observers listening for changes to this tab WebContent's | 497 // References to the observers listening for changes to this tab WebContent's |
| 499 // default presentation. | 498 // default presentation. |
| 500 base::ObserverList< | 499 base::ObserverList< |
| 501 PresentationServiceDelegateImpl::DefaultPresentationRequestObserver> | 500 PresentationServiceDelegateImpl::DefaultPresentationRequestObserver> |
| 502 default_presentation_request_observers_; | 501 default_presentation_request_observers_; |
| 503 | 502 |
| 504 // References to the owning WebContents, and the corresponding MediaRouter. | 503 // References to the owning WebContents, and the corresponding MediaRouter. |
| 505 MediaRouter* router_; | 504 MediaRouter* router_; |
| 506 content::WebContents* web_contents_; | 505 content::WebContents* web_contents_; |
| 507 }; | 506 }; |
| 508 | 507 |
| 509 PresentationFrameManager::PresentationFrameManager( | 508 PresentationFrameManager::PresentationFrameManager( |
| 510 content::WebContents* web_contents, | 509 content::WebContents* web_contents, |
| 511 MediaRouter* router) | 510 MediaRouter* router) |
| 512 : router_(router), web_contents_(web_contents) { | 511 : router_(router), web_contents_(web_contents) { |
| 513 DCHECK(web_contents_); | 512 DCHECK(web_contents_); |
| 514 DCHECK(router_); | 513 DCHECK(router_); |
| 515 } | 514 } |
| 516 | 515 |
| 517 PresentationFrameManager::~PresentationFrameManager() {} | 516 PresentationFrameManager::~PresentationFrameManager() {} |
| 518 | 517 |
| 519 void PresentationFrameManager::OnPresentationSessionStarted( | 518 void PresentationFrameManager::OnPresentationConnection( |
| 520 const RenderFrameHostId& render_frame_host_id, | 519 const RenderFrameHostId& render_frame_host_id, |
| 521 const content::PresentationSessionInfo& session, | 520 const content::PresentationInfo& presentation_info, |
| 522 const MediaRoute& route) { | 521 const MediaRoute& route) { |
| 523 auto* presentation_frame = GetOrAddPresentationFrame(render_frame_host_id); | 522 auto* presentation_frame = GetOrAddPresentationFrame(render_frame_host_id); |
| 524 presentation_frame->OnPresentationSessionStarted(session, route); | 523 presentation_frame->OnPresentationConnection(presentation_info, route); |
| 525 } | 524 } |
| 526 | 525 |
| 527 void PresentationFrameManager::OnDefaultPresentationSessionStarted( | 526 void PresentationFrameManager::OnDefaultPresentationStarted( |
| 528 const PresentationRequest& request, | 527 const PresentationRequest& request, |
| 529 const content::PresentationSessionInfo& session, | 528 const content::PresentationInfo& presentation_info, |
| 530 const MediaRoute& route) { | 529 const MediaRoute& route) { |
| 531 OnPresentationSessionStarted(request.render_frame_host_id(), session, route); | 530 OnPresentationConnection(request.render_frame_host_id(), presentation_info, |
| 531 route); |
| 532 | 532 |
| 533 if (default_presentation_request_ && | 533 if (default_presentation_request_ && |
| 534 default_presentation_request_->Equals(request)) { | 534 default_presentation_request_->Equals(request)) { |
| 535 default_presentation_started_callback_.Run(session); | 535 default_presentation_started_callback_.Run(presentation_info); |
| 536 } | 536 } |
| 537 } | 537 } |
| 538 | 538 |
| 539 void PresentationFrameManager::ConnectToPresentation( | 539 void PresentationFrameManager::ConnectToPresentation( |
| 540 const RenderFrameHostId& render_frame_host_id, | 540 const RenderFrameHostId& render_frame_host_id, |
| 541 const content::PresentationSessionInfo& session, | 541 const content::PresentationInfo& presentation_info, |
| 542 content::PresentationConnectionPtr controller_connection_ptr, | 542 content::PresentationConnectionPtr controller_connection_ptr, |
| 543 content::PresentationConnectionRequest receiver_connection_request) { | 543 content::PresentationConnectionRequest receiver_connection_request) { |
| 544 auto* presentation_frame = GetOrAddPresentationFrame(render_frame_host_id); | 544 auto* presentation_frame = GetOrAddPresentationFrame(render_frame_host_id); |
| 545 presentation_frame->ConnectToPresentation( | 545 presentation_frame->ConnectToPresentation( |
| 546 session, std::move(controller_connection_ptr), | 546 presentation_info, std::move(controller_connection_ptr), |
| 547 std::move(receiver_connection_request)); | 547 std::move(receiver_connection_request)); |
| 548 } | 548 } |
| 549 | 549 |
| 550 const MediaRoute::Id PresentationFrameManager::GetRouteId( | 550 const MediaRoute::Id PresentationFrameManager::GetRouteId( |
| 551 const RenderFrameHostId& render_frame_host_id, | 551 const RenderFrameHostId& render_frame_host_id, |
| 552 const std::string& presentation_id) const { | 552 const std::string& presentation_id) const { |
| 553 const auto it = presentation_frames_.find(render_frame_host_id); | 553 const auto it = presentation_frames_.find(render_frame_host_id); |
| 554 return it != presentation_frames_.end() | 554 return it != presentation_frames_.end() |
| 555 ? it->second->GetRouteId(presentation_id) : MediaRoute::Id(); | 555 ? it->second->GetRouteId(presentation_id) : MediaRoute::Id(); |
| 556 } | 556 } |
| (...skipping 18 matching lines...) Expand all Loading... |
| 575 bool PresentationFrameManager::HasScreenAvailabilityListenerForTest( | 575 bool PresentationFrameManager::HasScreenAvailabilityListenerForTest( |
| 576 const RenderFrameHostId& render_frame_host_id, | 576 const RenderFrameHostId& render_frame_host_id, |
| 577 const MediaSource::Id& source_id) const { | 577 const MediaSource::Id& source_id) const { |
| 578 const auto it = presentation_frames_.find(render_frame_host_id); | 578 const auto it = presentation_frames_.find(render_frame_host_id); |
| 579 return it != presentation_frames_.end() && | 579 return it != presentation_frames_.end() && |
| 580 it->second->HasScreenAvailabilityListenerForTest(source_id); | 580 it->second->HasScreenAvailabilityListenerForTest(source_id); |
| 581 } | 581 } |
| 582 | 582 |
| 583 void PresentationFrameManager::ListenForConnectionStateChange( | 583 void PresentationFrameManager::ListenForConnectionStateChange( |
| 584 const RenderFrameHostId& render_frame_host_id, | 584 const RenderFrameHostId& render_frame_host_id, |
| 585 const content::PresentationSessionInfo& connection, | 585 const content::PresentationInfo& connection, |
| 586 const content::PresentationConnectionStateChangedCallback& | 586 const content::PresentationConnectionStateChangedCallback& |
| 587 state_changed_cb) { | 587 state_changed_cb) { |
| 588 const auto it = presentation_frames_.find(render_frame_host_id); | 588 const auto it = presentation_frames_.find(render_frame_host_id); |
| 589 if (it != presentation_frames_.end()) | 589 if (it != presentation_frames_.end()) |
| 590 it->second->ListenForConnectionStateChange(connection, state_changed_cb); | 590 it->second->ListenForConnectionStateChange(connection, state_changed_cb); |
| 591 } | 591 } |
| 592 | 592 |
| 593 void PresentationFrameManager::ListenForSessionMessages( | 593 void PresentationFrameManager::ListenForConnectionMessages( |
| 594 const RenderFrameHostId& render_frame_host_id, | 594 const RenderFrameHostId& render_frame_host_id, |
| 595 const content::PresentationSessionInfo& session, | 595 const content::PresentationInfo& presentation_info, |
| 596 const content::PresentationConnectionMessageCallback& message_cb) { | 596 const content::PresentationConnectionMessageCallback& message_cb) { |
| 597 const auto it = presentation_frames_.find(render_frame_host_id); | 597 const auto it = presentation_frames_.find(render_frame_host_id); |
| 598 if (it == presentation_frames_.end()) { | 598 if (it == presentation_frames_.end()) { |
| 599 DVLOG(2) << "ListenForSessionMessages: PresentationFrame does not exist " | 599 DVLOG(2) << "ListenForConnectionMessages: PresentationFrame does not exist " |
| 600 << "for: (" << render_frame_host_id.first << ", " | 600 << "for: (" << render_frame_host_id.first << ", " |
| 601 << render_frame_host_id.second << ")"; | 601 << render_frame_host_id.second << ")"; |
| 602 return; | 602 return; |
| 603 } | 603 } |
| 604 it->second->ListenForSessionMessages(session, message_cb); | 604 it->second->ListenForConnectionMessages(presentation_info, message_cb); |
| 605 } | 605 } |
| 606 | 606 |
| 607 void PresentationFrameManager::SetDefaultPresentationUrls( | 607 void PresentationFrameManager::SetDefaultPresentationUrls( |
| 608 const RenderFrameHostId& render_frame_host_id, | 608 const RenderFrameHostId& render_frame_host_id, |
| 609 const std::vector<GURL>& default_presentation_urls, | 609 const std::vector<GURL>& default_presentation_urls, |
| 610 const content::PresentationSessionStartedCallback& callback) { | 610 const content::PresentationConnectionCallback& callback) { |
| 611 if (!IsMainFrame(render_frame_host_id)) | 611 if (!IsMainFrame(render_frame_host_id)) |
| 612 return; | 612 return; |
| 613 | 613 |
| 614 if (default_presentation_urls.empty()) { | 614 if (default_presentation_urls.empty()) { |
| 615 ClearDefaultPresentationRequest(); | 615 ClearDefaultPresentationRequest(); |
| 616 } else { | 616 } else { |
| 617 DCHECK(!callback.is_null()); | 617 DCHECK(!callback.is_null()); |
| 618 const auto& frame_origin = | 618 const auto& frame_origin = |
| 619 GetLastCommittedURLForFrame(render_frame_host_id); | 619 GetLastCommittedURLForFrame(render_frame_host_id); |
| 620 PresentationRequest request(render_frame_host_id, default_presentation_urls, | 620 PresentationRequest request(render_frame_host_id, default_presentation_urls, |
| (...skipping 138 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 759 void PresentationServiceDelegateImpl::Reset(int render_process_id, | 759 void PresentationServiceDelegateImpl::Reset(int render_process_id, |
| 760 int render_frame_id) { | 760 int render_frame_id) { |
| 761 RenderFrameHostId render_frame_host_id(render_process_id, render_frame_id); | 761 RenderFrameHostId render_frame_host_id(render_process_id, render_frame_id); |
| 762 frame_manager_->Reset(render_frame_host_id); | 762 frame_manager_->Reset(render_frame_host_id); |
| 763 } | 763 } |
| 764 | 764 |
| 765 void PresentationServiceDelegateImpl::SetDefaultPresentationUrls( | 765 void PresentationServiceDelegateImpl::SetDefaultPresentationUrls( |
| 766 int render_process_id, | 766 int render_process_id, |
| 767 int render_frame_id, | 767 int render_frame_id, |
| 768 const std::vector<GURL>& default_presentation_urls, | 768 const std::vector<GURL>& default_presentation_urls, |
| 769 const content::PresentationSessionStartedCallback& callback) { | 769 const content::PresentationConnectionCallback& callback) { |
| 770 RenderFrameHostId render_frame_host_id(render_process_id, render_frame_id); | 770 RenderFrameHostId render_frame_host_id(render_process_id, render_frame_id); |
| 771 frame_manager_->SetDefaultPresentationUrls( | 771 frame_manager_->SetDefaultPresentationUrls( |
| 772 render_frame_host_id, default_presentation_urls, callback); | 772 render_frame_host_id, default_presentation_urls, callback); |
| 773 } | 773 } |
| 774 | 774 |
| 775 void PresentationServiceDelegateImpl::OnJoinRouteResponse( | 775 void PresentationServiceDelegateImpl::OnJoinRouteResponse( |
| 776 int render_process_id, | 776 int render_process_id, |
| 777 int render_frame_id, | 777 int render_frame_id, |
| 778 const GURL& presentation_url, | 778 const GURL& presentation_url, |
| 779 const std::string& presentation_id, | 779 const std::string& presentation_id, |
| 780 const content::PresentationSessionStartedCallback& success_cb, | 780 const content::PresentationConnectionCallback& success_cb, |
| 781 const content::PresentationSessionErrorCallback& error_cb, | 781 const content::PresentationConnectionErrorCallback& error_cb, |
| 782 const RouteRequestResult& result) { | 782 const RouteRequestResult& result) { |
| 783 if (!result.route()) { | 783 if (!result.route()) { |
| 784 error_cb.Run(content::PresentationError( | 784 error_cb.Run(content::PresentationError( |
| 785 content::PRESENTATION_ERROR_NO_PRESENTATION_FOUND, result.error())); | 785 content::PRESENTATION_ERROR_NO_PRESENTATION_FOUND, result.error())); |
| 786 } else { | 786 } else { |
| 787 DVLOG(1) << "OnJoinRouteResponse: " | 787 DVLOG(1) << "OnJoinRouteResponse: " |
| 788 << "route_id: " << result.route()->media_route_id() | 788 << "route_id: " << result.route()->media_route_id() |
| 789 << ", presentation URL: " << presentation_url | 789 << ", presentation URL: " << presentation_url |
| 790 << ", presentation ID: " << presentation_id; | 790 << ", presentation ID: " << presentation_id; |
| 791 DCHECK_EQ(presentation_id, result.presentation_id()); | 791 DCHECK_EQ(presentation_id, result.presentation_id()); |
| 792 content::PresentationSessionInfo session(presentation_url, | 792 content::PresentationInfo presentation_info(presentation_url, |
| 793 result.presentation_id()); | 793 result.presentation_id()); |
| 794 frame_manager_->OnPresentationSessionStarted( | 794 frame_manager_->OnPresentationConnection( |
| 795 RenderFrameHostId(render_process_id, render_frame_id), session, | 795 RenderFrameHostId(render_process_id, render_frame_id), |
| 796 *result.route()); | 796 presentation_info, *result.route()); |
| 797 success_cb.Run(session); | 797 success_cb.Run(presentation_info); |
| 798 } | 798 } |
| 799 } | 799 } |
| 800 | 800 |
| 801 void PresentationServiceDelegateImpl::OnStartSessionSucceeded( | 801 void PresentationServiceDelegateImpl::OnStartPresentationSucceeded( |
| 802 int render_process_id, | 802 int render_process_id, |
| 803 int render_frame_id, | 803 int render_frame_id, |
| 804 const content::PresentationSessionStartedCallback& success_cb, | 804 const content::PresentationConnectionCallback& success_cb, |
| 805 const content::PresentationSessionInfo& new_session, | 805 const content::PresentationInfo& new_presentation_info, |
| 806 const MediaRoute& route) { | 806 const MediaRoute& route) { |
| 807 DVLOG(1) << "OnStartSessionSucceeded: " | 807 DVLOG(1) << "OnStartPresentationSucceeded: " |
| 808 << "route_id: " << route.media_route_id() | 808 << "route_id: " << route.media_route_id() |
| 809 << ", presentation URL: " << new_session.presentation_url | 809 << ", presentation URL: " << new_presentation_info.presentation_url |
| 810 << ", presentation ID: " << new_session.presentation_id; | 810 << ", presentation ID: " << new_presentation_info.presentation_id; |
| 811 frame_manager_->OnPresentationSessionStarted( | 811 frame_manager_->OnPresentationConnection( |
| 812 RenderFrameHostId(render_process_id, render_frame_id), new_session, | 812 RenderFrameHostId(render_process_id, render_frame_id), |
| 813 route); | 813 new_presentation_info, route); |
| 814 success_cb.Run(new_session); | 814 success_cb.Run(new_presentation_info); |
| 815 } | 815 } |
| 816 | 816 |
| 817 void PresentationServiceDelegateImpl::StartSession( | 817 void PresentationServiceDelegateImpl::StartPresentation( |
| 818 int render_process_id, | 818 int render_process_id, |
| 819 int render_frame_id, | 819 int render_frame_id, |
| 820 const std::vector<GURL>& presentation_urls, | 820 const std::vector<GURL>& presentation_urls, |
| 821 const content::PresentationSessionStartedCallback& success_cb, | 821 const content::PresentationConnectionCallback& success_cb, |
| 822 const content::PresentationSessionErrorCallback& error_cb) { | 822 const content::PresentationConnectionErrorCallback& error_cb) { |
| 823 if (presentation_urls.empty()) { | 823 if (presentation_urls.empty()) { |
| 824 error_cb.Run(content::PresentationError(content::PRESENTATION_ERROR_UNKNOWN, | 824 error_cb.Run(content::PresentationError(content::PRESENTATION_ERROR_UNKNOWN, |
| 825 "Invalid presentation arguments.")); | 825 "Invalid presentation arguments.")); |
| 826 return; | 826 return; |
| 827 } | 827 } |
| 828 | 828 |
| 829 // TODO(crbug.com/670848): Improve handling of invalid URLs in | 829 // TODO(crbug.com/670848): Improve handling of invalid URLs in |
| 830 // PresentationService::start(). | 830 // PresentationService::start(). |
| 831 if (presentation_urls.empty() || | 831 if (presentation_urls.empty() || |
| 832 std::find_if_not(presentation_urls.begin(), presentation_urls.end(), | 832 std::find_if_not(presentation_urls.begin(), presentation_urls.end(), |
| 833 IsValidPresentationUrl) != presentation_urls.end()) { | 833 IsValidPresentationUrl) != presentation_urls.end()) { |
| 834 error_cb.Run(content::PresentationError( | 834 error_cb.Run(content::PresentationError( |
| 835 content::PRESENTATION_ERROR_NO_PRESENTATION_FOUND, | 835 content::PRESENTATION_ERROR_NO_PRESENTATION_FOUND, |
| 836 "Invalid presentation URL.")); | 836 "Invalid presentation URL.")); |
| 837 return; | 837 return; |
| 838 } | 838 } |
| 839 | 839 |
| 840 RenderFrameHostId render_frame_host_id(render_process_id, render_frame_id); | 840 RenderFrameHostId render_frame_host_id(render_process_id, render_frame_id); |
| 841 std::unique_ptr<CreatePresentationConnectionRequest> request( | 841 std::unique_ptr<CreatePresentationConnectionRequest> request( |
| 842 new CreatePresentationConnectionRequest( | 842 new CreatePresentationConnectionRequest( |
| 843 render_frame_host_id, presentation_urls, | 843 render_frame_host_id, presentation_urls, |
| 844 GetLastCommittedURLForFrame(render_frame_host_id), | 844 GetLastCommittedURLForFrame(render_frame_host_id), |
| 845 base::Bind(&PresentationServiceDelegateImpl::OnStartSessionSucceeded, | 845 base::Bind( |
| 846 weak_factory_.GetWeakPtr(), render_process_id, | 846 &PresentationServiceDelegateImpl::OnStartPresentationSucceeded, |
| 847 render_frame_id, success_cb), | 847 weak_factory_.GetWeakPtr(), render_process_id, render_frame_id, |
| 848 success_cb), |
| 848 error_cb)); | 849 error_cb)); |
| 849 MediaRouterDialogController* controller = | 850 MediaRouterDialogController* controller = |
| 850 MediaRouterDialogController::GetOrCreateForWebContents(web_contents_); | 851 MediaRouterDialogController::GetOrCreateForWebContents(web_contents_); |
| 851 if (!controller->ShowMediaRouterDialogForPresentation(std::move(request))) { | 852 if (!controller->ShowMediaRouterDialogForPresentation(std::move(request))) { |
| 852 LOG(ERROR) << "Media router dialog already exists. Ignoring StartSession."; | 853 LOG(ERROR) |
| 854 << "Media router dialog already exists. Ignoring StartPresentation."; |
| 853 error_cb.Run(content::PresentationError(content::PRESENTATION_ERROR_UNKNOWN, | 855 error_cb.Run(content::PresentationError(content::PRESENTATION_ERROR_UNKNOWN, |
| 854 "Unable to create dialog.")); | 856 "Unable to create dialog.")); |
| 855 return; | 857 return; |
| 856 } | 858 } |
| 857 } | 859 } |
| 858 | 860 |
| 859 void PresentationServiceDelegateImpl::JoinSession( | 861 void PresentationServiceDelegateImpl::ReconnectPresentation( |
| 860 int render_process_id, | 862 int render_process_id, |
| 861 int render_frame_id, | 863 int render_frame_id, |
| 862 const std::vector<GURL>& presentation_urls, | 864 const std::vector<GURL>& presentation_urls, |
| 863 const std::string& presentation_id, | 865 const std::string& presentation_id, |
| 864 const content::PresentationSessionStartedCallback& success_cb, | 866 const content::PresentationConnectionCallback& success_cb, |
| 865 const content::PresentationSessionErrorCallback& error_cb) { | 867 const content::PresentationConnectionErrorCallback& error_cb) { |
| 866 DVLOG(2) << "PresentationServiceDelegateImpl::JoinSession"; | 868 DVLOG(2) << "PresentationServiceDelegateImpl::ReconnectPresentation"; |
| 867 if (presentation_urls.empty()) { | 869 if (presentation_urls.empty()) { |
| 868 error_cb.Run(content::PresentationError( | 870 error_cb.Run(content::PresentationError( |
| 869 content::PRESENTATION_ERROR_NO_PRESENTATION_FOUND, | 871 content::PRESENTATION_ERROR_NO_PRESENTATION_FOUND, |
| 870 "Invalid presentation arguments.")); | 872 "Invalid presentation arguments.")); |
| 871 return; | 873 return; |
| 872 } | 874 } |
| 873 | 875 |
| 874 const url::Origin& origin = GetLastCommittedURLForFrame( | 876 const url::Origin& origin = GetLastCommittedURLForFrame( |
| 875 RenderFrameHostId(render_process_id, render_frame_id)); | 877 RenderFrameHostId(render_process_id, render_frame_id)); |
| 876 | 878 |
| 877 #if !defined(OS_ANDROID) | 879 #if !defined(OS_ANDROID) |
| 878 if (IsAutoJoinPresentationId(presentation_id) && | 880 if (IsAutoJoinPresentationId(presentation_id) && |
| 879 ShouldCancelAutoJoinForOrigin(origin)) { | 881 ShouldCancelAutoJoinForOrigin(origin)) { |
| 880 error_cb.Run(content::PresentationError( | 882 error_cb.Run(content::PresentationError( |
| 881 content::PRESENTATION_ERROR_SESSION_REQUEST_CANCELLED, | 883 content::PRESENTATION_ERROR_PRESENTATION_REQUEST_CANCELLED, |
| 882 "Auto-join request cancelled by user preferences.")); | 884 "Auto-join request cancelled by user preferences.")); |
| 883 return; | 885 return; |
| 884 } | 886 } |
| 885 #endif // !defined(OS_ANDROID) | 887 #endif // !defined(OS_ANDROID) |
| 886 | 888 |
| 887 // TODO(crbug.com/627655): Handle multiple URLs. | 889 // TODO(crbug.com/627655): Handle multiple URLs. |
| 888 const GURL& presentation_url = presentation_urls[0]; | 890 const GURL& presentation_url = presentation_urls[0]; |
| 889 bool incognito = web_contents_->GetBrowserContext()->IsOffTheRecord(); | 891 bool incognito = web_contents_->GetBrowserContext()->IsOffTheRecord(); |
| 890 std::vector<MediaRouteResponseCallback> route_response_callbacks; | 892 std::vector<MediaRouteResponseCallback> route_response_callbacks; |
| 891 route_response_callbacks.push_back( | 893 route_response_callbacks.push_back( |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 927 DVLOG(1) << "No active route for: " << presentation_id; | 929 DVLOG(1) << "No active route for: " << presentation_id; |
| 928 return; | 930 return; |
| 929 } | 931 } |
| 930 router_->TerminateRoute(route_id); | 932 router_->TerminateRoute(route_id); |
| 931 frame_manager_->RemoveConnection(rfh_id, presentation_id, route_id); | 933 frame_manager_->RemoveConnection(rfh_id, presentation_id, route_id); |
| 932 } | 934 } |
| 933 | 935 |
| 934 void PresentationServiceDelegateImpl::ListenForConnectionMessages( | 936 void PresentationServiceDelegateImpl::ListenForConnectionMessages( |
| 935 int render_process_id, | 937 int render_process_id, |
| 936 int render_frame_id, | 938 int render_frame_id, |
| 937 const content::PresentationSessionInfo& session, | 939 const content::PresentationInfo& presentation_info, |
| 938 const content::PresentationConnectionMessageCallback& message_cb) { | 940 const content::PresentationConnectionMessageCallback& message_cb) { |
| 939 frame_manager_->ListenForSessionMessages( | 941 frame_manager_->ListenForConnectionMessages( |
| 940 RenderFrameHostId(render_process_id, render_frame_id), session, | 942 RenderFrameHostId(render_process_id, render_frame_id), presentation_info, |
| 941 message_cb); | 943 message_cb); |
| 942 } | 944 } |
| 943 | 945 |
| 944 void PresentationServiceDelegateImpl::SendMessage( | 946 void PresentationServiceDelegateImpl::SendMessage( |
| 945 int render_process_id, | 947 int render_process_id, |
| 946 int render_frame_id, | 948 int render_frame_id, |
| 947 const content::PresentationSessionInfo& session, | 949 const content::PresentationInfo& presentation_info, |
| 948 content::PresentationConnectionMessage message, | 950 content::PresentationConnectionMessage message, |
| 949 const SendMessageCallback& send_message_cb) { | 951 const SendMessageCallback& send_message_cb) { |
| 950 const MediaRoute::Id& route_id = frame_manager_->GetRouteId( | 952 const MediaRoute::Id& route_id = frame_manager_->GetRouteId( |
| 951 RenderFrameHostId(render_process_id, render_frame_id), | 953 RenderFrameHostId(render_process_id, render_frame_id), |
| 952 session.presentation_id); | 954 presentation_info.presentation_id); |
| 953 if (route_id.empty()) { | 955 if (route_id.empty()) { |
| 954 DVLOG(1) << "No active route for " << session.presentation_id; | 956 DVLOG(1) << "No active route for " << presentation_info.presentation_id; |
| 955 send_message_cb.Run(false); | 957 send_message_cb.Run(false); |
| 956 return; | 958 return; |
| 957 } | 959 } |
| 958 | 960 |
| 959 if (message.is_binary()) { | 961 if (message.is_binary()) { |
| 960 router_->SendRouteBinaryMessage( | 962 router_->SendRouteBinaryMessage( |
| 961 route_id, | 963 route_id, |
| 962 base::MakeUnique<std::vector<uint8_t>>(std::move(message.data.value())), | 964 base::MakeUnique<std::vector<uint8_t>>(std::move(message.data.value())), |
| 963 send_message_cb); | 965 send_message_cb); |
| 964 } else { | 966 } else { |
| 965 router_->SendRouteMessage(route_id, message.message.value(), | 967 router_->SendRouteMessage(route_id, message.message.value(), |
| 966 send_message_cb); | 968 send_message_cb); |
| 967 } | 969 } |
| 968 } | 970 } |
| 969 | 971 |
| 970 void PresentationServiceDelegateImpl::ListenForConnectionStateChange( | 972 void PresentationServiceDelegateImpl::ListenForConnectionStateChange( |
| 971 int render_process_id, | 973 int render_process_id, |
| 972 int render_frame_id, | 974 int render_frame_id, |
| 973 const content::PresentationSessionInfo& connection, | 975 const content::PresentationInfo& connection, |
| 974 const content::PresentationConnectionStateChangedCallback& | 976 const content::PresentationConnectionStateChangedCallback& |
| 975 state_changed_cb) { | 977 state_changed_cb) { |
| 976 frame_manager_->ListenForConnectionStateChange( | 978 frame_manager_->ListenForConnectionStateChange( |
| 977 RenderFrameHostId(render_process_id, render_frame_id), connection, | 979 RenderFrameHostId(render_process_id, render_frame_id), connection, |
| 978 state_changed_cb); | 980 state_changed_cb); |
| 979 } | 981 } |
| 980 | 982 |
| 981 void PresentationServiceDelegateImpl::ConnectToPresentation( | 983 void PresentationServiceDelegateImpl::ConnectToPresentation( |
| 982 int render_process_id, | 984 int render_process_id, |
| 983 int render_frame_id, | 985 int render_frame_id, |
| 984 const content::PresentationSessionInfo& session, | 986 const content::PresentationInfo& presentation_info, |
| 985 content::PresentationConnectionPtr controller_connection_ptr, | 987 content::PresentationConnectionPtr controller_connection_ptr, |
| 986 content::PresentationConnectionRequest receiver_connection_request) { | 988 content::PresentationConnectionRequest receiver_connection_request) { |
| 987 RenderFrameHostId render_frame_host_id(render_process_id, render_frame_id); | 989 RenderFrameHostId render_frame_host_id(render_process_id, render_frame_id); |
| 988 frame_manager_->ConnectToPresentation(render_frame_host_id, session, | 990 frame_manager_->ConnectToPresentation(render_frame_host_id, presentation_info, |
| 989 std::move(controller_connection_ptr), | 991 std::move(controller_connection_ptr), |
| 990 std::move(receiver_connection_request)); | 992 std::move(receiver_connection_request)); |
| 991 } | 993 } |
| 992 | 994 |
| 993 void PresentationServiceDelegateImpl::OnRouteResponse( | 995 void PresentationServiceDelegateImpl::OnRouteResponse( |
| 994 const PresentationRequest& presentation_request, | 996 const PresentationRequest& presentation_request, |
| 995 const RouteRequestResult& result) { | 997 const RouteRequestResult& result) { |
| 996 if (!result.route() || | 998 if (!result.route() || |
| 997 !base::ContainsValue(presentation_request.presentation_urls(), | 999 !base::ContainsValue(presentation_request.presentation_urls(), |
| 998 result.presentation_url())) { | 1000 result.presentation_url())) { |
| 999 return; | 1001 return; |
| 1000 } | 1002 } |
| 1001 | 1003 |
| 1002 content::PresentationSessionInfo session_info(result.presentation_url(), | 1004 content::PresentationInfo presentation_info(result.presentation_url(), |
| 1003 result.presentation_id()); | 1005 result.presentation_id()); |
| 1004 frame_manager_->OnDefaultPresentationSessionStarted( | 1006 frame_manager_->OnDefaultPresentationStarted( |
| 1005 presentation_request, session_info, *result.route()); | 1007 presentation_request, presentation_info, *result.route()); |
| 1006 } | 1008 } |
| 1007 | 1009 |
| 1008 void PresentationServiceDelegateImpl::AddDefaultPresentationRequestObserver( | 1010 void PresentationServiceDelegateImpl::AddDefaultPresentationRequestObserver( |
| 1009 DefaultPresentationRequestObserver* observer) { | 1011 DefaultPresentationRequestObserver* observer) { |
| 1010 frame_manager_->AddDefaultPresentationRequestObserver(observer); | 1012 frame_manager_->AddDefaultPresentationRequestObserver(observer); |
| 1011 } | 1013 } |
| 1012 | 1014 |
| 1013 void PresentationServiceDelegateImpl::RemoveDefaultPresentationRequestObserver( | 1015 void PresentationServiceDelegateImpl::RemoveDefaultPresentationRequestObserver( |
| 1014 DefaultPresentationRequestObserver* observer) { | 1016 DefaultPresentationRequestObserver* observer) { |
| 1015 frame_manager_->RemoveDefaultPresentationRequestObserver(observer); | 1017 frame_manager_->RemoveDefaultPresentationRequestObserver(observer); |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1051 const base::ListValue* origins = | 1053 const base::ListValue* origins = |
| 1052 Profile::FromBrowserContext(web_contents_->GetBrowserContext()) | 1054 Profile::FromBrowserContext(web_contents_->GetBrowserContext()) |
| 1053 ->GetPrefs() | 1055 ->GetPrefs() |
| 1054 ->GetList(prefs::kMediaRouterTabMirroringSources); | 1056 ->GetList(prefs::kMediaRouterTabMirroringSources); |
| 1055 return origins && | 1057 return origins && |
| 1056 origins->Find(base::Value(origin.Serialize())) != origins->end(); | 1058 origins->Find(base::Value(origin.Serialize())) != origins->end(); |
| 1057 } | 1059 } |
| 1058 #endif // !defined(OS_ANDROID) | 1060 #endif // !defined(OS_ANDROID) |
| 1059 | 1061 |
| 1060 } // namespace media_router | 1062 } // namespace media_router |
| OLD | NEW |