| 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 #ifndef CONTENT_BROWSER_PRESENTATION_PRESENTATION_SERVICE_IMPL_H_ | 5 #ifndef CONTENT_BROWSER_PRESENTATION_PRESENTATION_SERVICE_IMPL_H_ |
| 6 #define CONTENT_BROWSER_PRESENTATION_PRESENTATION_SERVICE_IMPL_H_ | 6 #define CONTENT_BROWSER_PRESENTATION_PRESENTATION_SERVICE_IMPL_H_ |
| 7 | 7 |
| 8 #include <deque> | 8 #include <deque> |
| 9 | 9 |
| 10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
| (...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 102 | 102 |
| 103 // Indicates if this context has any pending callbacks. | 103 // Indicates if this context has any pending callbacks. |
| 104 bool HasPendingCallbacks() const; | 104 bool HasPendingCallbacks() const; |
| 105 | 105 |
| 106 private: | 106 private: |
| 107 std::string presentation_url_; | 107 std::string presentation_url_; |
| 108 ScopedVector<ScreenAvailabilityMojoCallback> callbacks_; | 108 ScopedVector<ScreenAvailabilityMojoCallback> callbacks_; |
| 109 scoped_ptr<bool> available_ptr_; | 109 scoped_ptr<bool> available_ptr_; |
| 110 }; | 110 }; |
| 111 | 111 |
| 112 class CONTENT_EXPORT DefaultSessionStartContext { |
| 113 public: |
| 114 DefaultSessionStartContext(); |
| 115 ~DefaultSessionStartContext(); |
| 116 |
| 117 // Adds a callback. May invoke the callback immediately if |session| using |
| 118 // default presentation URL was already started. |
| 119 void AddCallback(const DefaultSessionMojoCallback& callback); |
| 120 |
| 121 // Sets the session info. Maybe invoke callbacks queued with AddCallback(). |
| 122 void set_session(const PresentationSessionInfo& session); |
| 123 |
| 124 private: |
| 125 // Flush all queued callbacks by invoking them with null |
| 126 // PresentationSessionInfoPtr. |
| 127 void Reset(); |
| 128 |
| 129 ScopedVector<DefaultSessionMojoCallback> callbacks_; |
| 130 scoped_ptr<PresentationSessionInfo> session_; |
| 131 }; |
| 132 |
| 112 // Context for a StartSession request. | 133 // Context for a StartSession request. |
| 113 class CONTENT_EXPORT StartSessionRequest { | 134 class CONTENT_EXPORT StartSessionRequest { |
| 114 public: | 135 public: |
| 115 StartSessionRequest(const std::string& presentation_url, | 136 StartSessionRequest(const std::string& presentation_url, |
| 116 const std::string& presentation_id, | 137 const std::string& presentation_id, |
| 117 const NewSessionMojoCallback& callback); | 138 const NewSessionMojoCallback& callback); |
| 118 ~StartSessionRequest(); | 139 ~StartSessionRequest(); |
| 119 | 140 |
| 120 // Retrieves the pending callback from this request, transferring ownership | 141 // Retrieves the pending callback from this request, transferring ownership |
| 121 // to the caller. | 142 // to the caller. |
| (...skipping 17 matching lines...) Expand all Loading... |
| 139 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, | 160 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, |
| 140 ThisRenderFrameDeleted); | 161 ThisRenderFrameDeleted); |
| 141 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, | 162 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, |
| 142 NotThisRenderFrameDeleted); | 163 NotThisRenderFrameDeleted); |
| 143 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, | 164 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, |
| 144 SetDefaultPresentationUrl); | 165 SetDefaultPresentationUrl); |
| 145 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, | 166 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, |
| 146 SetSameDefaultPresentationUrl); | 167 SetSameDefaultPresentationUrl); |
| 147 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, | 168 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, |
| 148 ClearDefaultPresentationUrl); | 169 ClearDefaultPresentationUrl); |
| 170 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, |
| 171 ListenForDefaultSessionStart); |
| 172 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, |
| 173 ListenForDefaultSessionStartAfterSet); |
| 174 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, |
| 175 DefaultSessionStartReset); |
| 149 | 176 |
| 150 // |render_frame_host|: The RFH this instance is associated with. | 177 // |render_frame_host|: The RFH this instance is associated with. |
| 151 // |web_contents|: The WebContents to observe. | 178 // |web_contents|: The WebContents to observe. |
| 152 // |delegate|: Where Presentation API requests are delegated to. Not owned | 179 // |delegate|: Where Presentation API requests are delegated to. Not owned |
| 153 // by this class. | 180 // by this class. |
| 154 PresentationServiceImpl( | 181 PresentationServiceImpl( |
| 155 RenderFrameHost* render_frame_host, | 182 RenderFrameHost* render_frame_host, |
| 156 WebContents* web_contents, | 183 WebContents* web_contents, |
| 157 PresentationServiceDelegate* delegate); | 184 PresentationServiceDelegate* delegate); |
| 158 | 185 |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 190 | 217 |
| 191 // WebContentsObserver override. | 218 // WebContentsObserver override. |
| 192 void DidNavigateAnyFrame( | 219 void DidNavigateAnyFrame( |
| 193 content::RenderFrameHost* render_frame_host, | 220 content::RenderFrameHost* render_frame_host, |
| 194 const content::LoadCommittedDetails& details, | 221 const content::LoadCommittedDetails& details, |
| 195 const content::FrameNavigateParams& params) override; | 222 const content::FrameNavigateParams& params) override; |
| 196 void RenderFrameDeleted(content::RenderFrameHost* render_frame_host) override; | 223 void RenderFrameDeleted(content::RenderFrameHost* render_frame_host) override; |
| 197 | 224 |
| 198 // PresentationServiceDelegate::Observer | 225 // PresentationServiceDelegate::Observer |
| 199 void OnDelegateDestroyed() override; | 226 void OnDelegateDestroyed() override; |
| 227 void OnDefaultPresentationStarted(const PresentationSessionInfo& session) |
| 228 override; |
| 200 | 229 |
| 201 // Finds the callback from |pending_session_cbs_| using |request_session_id|. | 230 // Finds the callback from |pending_session_cbs_| using |request_session_id|. |
| 202 // If it exists, invoke it with |session| and |error|, then erase it from | 231 // If it exists, invoke it with |session| and |error|, then erase it from |
| 203 // |pending_session_cbs_|. | 232 // |pending_session_cbs_|. |
| 204 void RunAndEraseNewSessionMojoCallback( | 233 void RunAndEraseNewSessionMojoCallback( |
| 205 int request_session_id, | 234 int request_session_id, |
| 206 presentation::PresentationSessionInfoPtr session, | 235 presentation::PresentationSessionInfoPtr session, |
| 207 presentation::PresentationErrorPtr error); | 236 presentation::PresentationErrorPtr error); |
| 208 | 237 |
| 209 // Sets |default_presentation_url_| to |presentation_url| and informs the | 238 // Sets |default_presentation_url_| to |presentation_url| and informs the |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 249 | 278 |
| 250 // Invokes |callback| with an error. | 279 // Invokes |callback| with an error. |
| 251 static void InvokeNewSessionMojoCallbackWithError( | 280 static void InvokeNewSessionMojoCallbackWithError( |
| 252 const NewSessionMojoCallback& callback); | 281 const NewSessionMojoCallback& callback); |
| 253 | 282 |
| 254 // Gets the ScreenAvailabilityContext for |presentation_url|, or creates one | 283 // Gets the ScreenAvailabilityContext for |presentation_url|, or creates one |
| 255 // if it does not exist. | 284 // if it does not exist. |
| 256 ScreenAvailabilityContext* GetOrCreateAvailabilityContext( | 285 ScreenAvailabilityContext* GetOrCreateAvailabilityContext( |
| 257 const std::string& presentation_url); | 286 const std::string& presentation_url); |
| 258 | 287 |
| 259 RenderFrameHost* render_frame_host_; | 288 // Returns true if this object is associated with |render_frame_host|. |
| 289 bool FrameMatches(content::RenderFrameHost* render_frame_host) const; |
| 290 |
| 260 PresentationServiceDelegate* delegate_; | 291 PresentationServiceDelegate* delegate_; |
| 261 | 292 |
| 262 // Map from presentation URL to its ScreenAvailabilityContext state machine. | 293 // Map from presentation URL to its ScreenAvailabilityContext state machine. |
| 263 base::hash_map<std::string, linked_ptr<ScreenAvailabilityContext>> | 294 base::hash_map<std::string, linked_ptr<ScreenAvailabilityContext>> |
| 264 availability_contexts_; | 295 availability_contexts_; |
| 265 | 296 |
| 266 std::string default_presentation_url_; | 297 std::string default_presentation_url_; |
| 267 std::string default_presentation_id_; | 298 std::string default_presentation_id_; |
| 268 | 299 |
| 269 // We only allow one StartSession request to be processed at a time. | 300 // We only allow one StartSession request to be processed at a time. |
| 270 // StartSession requests are queued here. When a request has been processed, | 301 // StartSession requests are queued here. When a request has been processed, |
| 271 // it is removed from head of the queue. | 302 // it is removed from head of the queue. |
| 272 std::deque<linked_ptr<StartSessionRequest>> queued_start_session_requests_; | 303 std::deque<linked_ptr<StartSessionRequest>> queued_start_session_requests_; |
| 273 | 304 |
| 274 // Indicates that a StartSession request is currently being processed. | 305 // Indicates that a StartSession request is currently being processed. |
| 275 bool is_start_session_pending_; | 306 bool is_start_session_pending_; |
| 276 | 307 |
| 277 int next_request_session_id_; | 308 int next_request_session_id_; |
| 278 base::hash_map<int, linked_ptr<NewSessionMojoCallback>> pending_session_cbs_; | 309 base::hash_map<int, linked_ptr<NewSessionMojoCallback>> pending_session_cbs_; |
| 279 | 310 |
| 311 scoped_ptr<DefaultSessionStartContext> default_session_start_context_; |
| 312 |
| 280 // RAII binding of |this| to an Presentation interface request. | 313 // RAII binding of |this| to an Presentation interface request. |
| 281 // The binding is removed when binding_ is cleared or goes out of scope. | 314 // The binding is removed when binding_ is cleared or goes out of scope. |
| 282 scoped_ptr<mojo::Binding<presentation::PresentationService>> binding_; | 315 scoped_ptr<mojo::Binding<presentation::PresentationService>> binding_; |
| 283 | 316 |
| 317 // ID of the RenderFrameHost this object is associated with. |
| 318 int render_process_id_; |
| 319 int render_frame_id_; |
| 320 |
| 284 // NOTE: Weak pointers must be invalidated before all other member variables. | 321 // NOTE: Weak pointers must be invalidated before all other member variables. |
| 285 base::WeakPtrFactory<PresentationServiceImpl> weak_factory_; | 322 base::WeakPtrFactory<PresentationServiceImpl> weak_factory_; |
| 286 | 323 |
| 287 DISALLOW_COPY_AND_ASSIGN(PresentationServiceImpl); | 324 DISALLOW_COPY_AND_ASSIGN(PresentationServiceImpl); |
| 288 }; | 325 }; |
| 289 | 326 |
| 290 } // namespace content | 327 } // namespace content |
| 291 | 328 |
| 292 #endif // CONTENT_BROWSER_PRESENTATION_PRESENTATION_SERVICE_IMPL_H_ | 329 #endif // CONTENT_BROWSER_PRESENTATION_PRESENTATION_SERVICE_IMPL_H_ |
| OLD | NEW |