Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(226)

Side by Side Diff: content/browser/presentation/presentation_service_impl.h

Issue 1314413005: [Presentation API] 1-UA presentation support + presenter APIs. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Addressed mfoltz's comments rebase (forgot to upload as separate patchsets, sorry) Created 5 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 #include <map> 9 #include <map>
10 #include <string> 10 #include <string>
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after
91 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, 91 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest,
92 MaxPendingJoinSessionRequests); 92 MaxPendingJoinSessionRequests);
93 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, 93 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest,
94 ListenForSessionStateChange); 94 ListenForSessionStateChange);
95 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest, 95 FRIEND_TEST_ALL_PREFIXES(PresentationServiceImplTest,
96 ListenForSessionStateChangeFails); 96 ListenForSessionStateChangeFails);
97 97
98 // Maximum number of pending JoinSession requests at any given time. 98 // Maximum number of pending JoinSession requests at any given time.
99 static const int kMaxNumQueuedSessionRequests = 10; 99 static const int kMaxNumQueuedSessionRequests = 10;
100 100
101 using DefaultSessionMojoCallback = 101 using PresentationSessionMojoCallback =
whywhat 2015/10/07 13:25:53 nit: Could this rename be done separately maybe? I
imcheng 2015/10/17 01:00:22 I am changing this in a separate CL I am currently
102 mojo::Callback<void(presentation::PresentationSessionInfoPtr)>; 102 mojo::Callback<void(presentation::PresentationSessionInfoPtr)>;
103 using SessionStateCallback = 103 using SessionStateCallback =
104 mojo::Callback<void(presentation::PresentationSessionInfoPtr, 104 mojo::Callback<void(presentation::PresentationSessionInfoPtr,
105 presentation::PresentationSessionState)>; 105 presentation::PresentationSessionState)>;
106 using SessionMessagesCallback = 106 using SessionMessagesCallback =
107 mojo::Callback<void(mojo::Array<presentation::SessionMessagePtr>)>; 107 mojo::Callback<void(mojo::Array<presentation::SessionMessagePtr>)>;
108 using SendMessageMojoCallback = mojo::Callback<void(bool)>; 108 using SendMessageMojoCallback = mojo::Callback<void(bool)>;
109 109
110 // Listener implementation owned by PresentationServiceImpl. An instance of 110 // Listener implementation owned by PresentationServiceImpl. An instance of
111 // this is created when PresentationRequest.getAvailability() is resolved. 111 // this is created when PresentationRequest.getAvailability() is resolved.
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
144 PresentationServiceImpl* const service_; 144 PresentationServiceImpl* const service_;
145 }; 145 };
146 146
147 class CONTENT_EXPORT DefaultSessionStartContext { 147 class CONTENT_EXPORT DefaultSessionStartContext {
148 public: 148 public:
149 DefaultSessionStartContext(); 149 DefaultSessionStartContext();
150 ~DefaultSessionStartContext(); 150 ~DefaultSessionStartContext();
151 151
152 // Adds a callback. May invoke the callback immediately if |session| using 152 // Adds a callback. May invoke the callback immediately if |session| using
153 // default presentation URL was already started. 153 // default presentation URL was already started.
154 void AddCallback(const DefaultSessionMojoCallback& callback); 154 void AddCallback(const PresentationSessionMojoCallback& callback);
155 155
156 // Sets the session info. Maybe invoke callbacks queued with AddCallback(). 156 // Sets the session info. Maybe invoke callbacks queued with AddCallback().
157 void set_session(const PresentationSessionInfo& session); 157 void set_session(const PresentationSessionInfo& session);
158 158
159 private: 159 private:
160 // Flush all queued callbacks by invoking them with null 160 // Flush all queued callbacks by invoking them with null
161 // PresentationSessionInfoPtr. 161 // PresentationSessionInfoPtr.
162 void Reset(); 162 void Reset();
163 163
164 ScopedVector<DefaultSessionMojoCallback> callbacks_; 164 ScopedVector<PresentationSessionMojoCallback> callbacks_;
165 scoped_ptr<PresentationSessionInfo> session_; 165 scoped_ptr<PresentationSessionInfo> session_;
166 }; 166 };
167 167
168 // Ensures the provided NewSessionMojoCallback is invoked exactly once 168 // Ensures the provided NewSessionMojoCallback is invoked exactly once
169 // before it goes out of scope. 169 // before it goes out of scope.
170 class NewSessionMojoCallbackWrapper { 170 class NewSessionMojoCallbackWrapper {
171 public: 171 public:
172 explicit NewSessionMojoCallbackWrapper( 172 explicit NewSessionMojoCallbackWrapper(
173 const NewSessionMojoCallback& callback); 173 const NewSessionMojoCallback& callback);
174 ~NewSessionMojoCallbackWrapper(); 174 ~NewSessionMojoCallbackWrapper();
(...skipping 15 matching lines...) Expand all
190 RenderFrameHost* render_frame_host, 190 RenderFrameHost* render_frame_host,
191 WebContents* web_contents, 191 WebContents* web_contents,
192 PresentationServiceDelegate* delegate); 192 PresentationServiceDelegate* delegate);
193 193
194 // PresentationService implementation. 194 // PresentationService implementation.
195 void SetDefaultPresentationURL(const mojo::String& url) override; 195 void SetDefaultPresentationURL(const mojo::String& url) override;
196 void SetClient(presentation::PresentationServiceClientPtr client) override; 196 void SetClient(presentation::PresentationServiceClientPtr client) override;
197 void ListenForScreenAvailability(const mojo::String& url) override; 197 void ListenForScreenAvailability(const mojo::String& url) override;
198 void StopListeningForScreenAvailability(const mojo::String& url) override; 198 void StopListeningForScreenAvailability(const mojo::String& url) override;
199 void ListenForDefaultSessionStart( 199 void ListenForDefaultSessionStart(
200 const DefaultSessionMojoCallback& callback) override; 200 const PresentationSessionMojoCallback& callback) override;
201 void StartSession( 201 void StartSession(
202 const mojo::String& presentation_url, 202 const mojo::String& presentation_url,
203 const NewSessionMojoCallback& callback) override; 203 const NewSessionMojoCallback& callback) override;
204 void JoinSession( 204 void JoinSession(
205 const mojo::String& presentation_url, 205 const mojo::String& presentation_url,
206 const mojo::String& presentation_id, 206 const mojo::String& presentation_id,
207 const NewSessionMojoCallback& callback) override; 207 const NewSessionMojoCallback& callback) override;
208 void SendSessionMessage(presentation::PresentationSessionInfoPtr session_info, 208 void SendSessionMessage(presentation::PresentationSessionInfoPtr session_info,
209 presentation::SessionMessagePtr session_message, 209 presentation::SessionMessagePtr session_message,
210 const SendMessageMojoCallback& callback) override; 210 const SendMessageMojoCallback& callback) override;
211 void CloseSession( 211 void CloseSession(
212 const mojo::String& presentation_url, 212 const mojo::String& presentation_url,
213 const mojo::String& presentation_id) override; 213 const mojo::String& presentation_id) override;
214 void ListenForSessionStateChange( 214 void ListenForSessionStateChange(
215 presentation::PresentationSessionInfoPtr session) override; 215 presentation::PresentationSessionInfoPtr session) override;
216 void ListenForSessionMessages( 216 void ListenForSessionMessages(
217 presentation::PresentationSessionInfoPtr session) override; 217 presentation::PresentationSessionInfoPtr session) override;
218 void GetPresentationReceiverSession(
219 const PresentationSessionMojoCallback& callback) override;
218 220
219 // Creates a binding between this object and |request|. 221 // Creates a binding between this object and |request|.
220 void Bind(mojo::InterfaceRequest<presentation::PresentationService> request); 222 void Bind(mojo::InterfaceRequest<presentation::PresentationService> request);
221 223
222 // WebContentsObserver override. 224 // WebContentsObserver override.
223 void DidNavigateAnyFrame( 225 void DidNavigateAnyFrame(
224 content::RenderFrameHost* render_frame_host, 226 content::RenderFrameHost* render_frame_host,
225 const content::LoadCommittedDetails& details, 227 const content::LoadCommittedDetails& details,
226 const content::FrameNavigateParams& params) override; 228 const content::FrameNavigateParams& params) override;
227 void RenderFrameDeleted(content::RenderFrameHost* render_frame_host) override; 229 void RenderFrameDeleted(content::RenderFrameHost* render_frame_host) override;
(...skipping 25 matching lines...) Expand all
253 void OnStartSessionError( 255 void OnStartSessionError(
254 int request_session_id, 256 int request_session_id,
255 const PresentationError& error); 257 const PresentationError& error);
256 void OnJoinSessionSucceeded( 258 void OnJoinSessionSucceeded(
257 int request_session_id, 259 int request_session_id,
258 const PresentationSessionInfo& session_info); 260 const PresentationSessionInfo& session_info);
259 void OnJoinSessionError( 261 void OnJoinSessionError(
260 int request_session_id, 262 int request_session_id,
261 const PresentationError& error); 263 const PresentationError& error);
262 void OnSendMessageCallback(bool sent); 264 void OnSendMessageCallback(bool sent);
265 void OnGetPresentationReceiverSession(
266 const content::PresentationSessionInfo* session_info);
263 267
264 // Passed to embedder's implementation of PresentationServiceDelegate for 268 // Passed to embedder's implementation of PresentationServiceDelegate for
265 // later invocation when session messages arrive. 269 // later invocation when session messages arrive.
266 void OnSessionMessages( 270 void OnSessionMessages(
267 const content::PresentationSessionInfo& session, 271 const content::PresentationSessionInfo& session,
268 const ScopedVector<PresentationSessionMessage>& messages, 272 const ScopedVector<PresentationSessionMessage>& messages,
269 bool pass_ownership); 273 bool pass_ownership);
270 274
271 // Associates a JoinSession |callback| with a unique request ID and 275 // Associates a JoinSession |callback| with a unique request ID and
272 // stores it in a map. 276 // stores it in a map.
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after
309 313
310 // RAII binding of |this| to an Presentation interface request. 314 // RAII binding of |this| to an Presentation interface request.
311 // The binding is removed when binding_ is cleared or goes out of scope. 315 // The binding is removed when binding_ is cleared or goes out of scope.
312 scoped_ptr<mojo::Binding<presentation::PresentationService>> binding_; 316 scoped_ptr<mojo::Binding<presentation::PresentationService>> binding_;
313 317
314 // There can be only one send message request at a time. 318 // There can be only one send message request at a time.
315 scoped_ptr<SendMessageMojoCallback> send_message_callback_; 319 scoped_ptr<SendMessageMojoCallback> send_message_callback_;
316 320
317 scoped_ptr<SessionMessagesCallback> on_session_messages_callback_; 321 scoped_ptr<SessionMessagesCallback> on_session_messages_callback_;
318 322
323 PresentationSessionMojoCallback receiver_session_callback_;
324
319 // ID of the RenderFrameHost this object is associated with. 325 // ID of the RenderFrameHost this object is associated with.
320 int render_process_id_; 326 int render_process_id_;
321 int render_frame_id_; 327 int render_frame_id_;
322 328
323 // NOTE: Weak pointers must be invalidated before all other member variables. 329 // NOTE: Weak pointers must be invalidated before all other member variables.
324 base::WeakPtrFactory<PresentationServiceImpl> weak_factory_; 330 base::WeakPtrFactory<PresentationServiceImpl> weak_factory_;
325 331
326 DISALLOW_COPY_AND_ASSIGN(PresentationServiceImpl); 332 DISALLOW_COPY_AND_ASSIGN(PresentationServiceImpl);
327 }; 333 };
328 334
329 } // namespace content 335 } // namespace content
330 336
331 #endif // CONTENT_BROWSER_PRESENTATION_PRESENTATION_SERVICE_IMPL_H_ 337 #endif // CONTENT_BROWSER_PRESENTATION_PRESENTATION_SERVICE_IMPL_H_
OLDNEW
« no previous file with comments | « chrome/browser/media/router/render_frame_host_helper.h ('k') | content/browser/presentation/presentation_service_impl.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698