[PresentationAPI] Implementing send() from WebPresentationClient to the PresentationService.

content/renderer/presentation/presentation_dispatcher.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/renderer/presentation/presentation_dispatcher.h"
 
 #include "base/logging.h"
 #include "content/common/presentation/presentation_service.mojom.h"
 #include "content/public/common/service_registry.h"
 #include "content/public/renderer/render_frame.h"
@@ skipping 114 matching lines @@
   // OnSessionCreated() is called. |callback| needs to be alive and also needs
   // to be destroyed so we transfer its ownership to the mojo callback.
   presentation_service_->JoinSession(
       presentationUrl.utf8(),
       presentationId.utf8(),
       base::Bind(&PresentationDispatcher::OnSessionCreated,
           base::Unretained(this),
           base::Owned(callback)));
 }
 
+void PresentationDispatcher::send(
+    const blink::WebString& presentationUrl,
+    const blink::WebString& presentationId,
+    const blink::WebString& message) {
+  message_request_queue_.push(make_linked_ptr(
+      new MessageRequest(
+          presentationUrl.utf8(),
+          presentationId.utf8(),
+          message.utf8())));
+  // Start processing request if only one in the queue.
+  if (message_request_queue_.size() == 1)
+    DoSendStringMessage(presentationUrl.utf8(),

[whywhat, 2015/04/13 13:31:21]

use {} for multiline if branches.

[USE s.singapati at gmail.com, 2015/04/14 17:51:51]

Done.

+                        presentationId.utf8(),
+                        message.utf8());
+}
+
+void PresentationDispatcher::send(
+    const blink::WebString& presentationUrl,
+    const blink::WebString& presentationId,
+    const char* data,
+    size_t length) {
+  // TODO(s.singapati): Handle ArrayBuffer data.
+}
+
+void PresentationDispatcher::DoSendStringMessage(
+    const std::string& presentation_url,
+    const std::string& presentation_id,
+    const std::string& message) {
+  ConnectToPresentationServiceIfNeeded();
+  presentation_service_->SendStringMessage(
+      presentation_url,
+      presentation_id,
+      message,
+      base::Bind(&PresentationDispatcher::HandleSendMessageRequests,
+                 base::Unretained(this)));
+}
+
+void PresentationDispatcher::HandleSendMessageRequests() {
+  DCHECK(!message_request_queue_.empty());

[mark a. foltz, 2015/04/10 19:03:18]

It seems like the realistic situation described below would cause this DCHECK to
fire.

Instead what about:

if (message_request_queue_.empty())
  return;

[USE s.singapati at gmail.com, 2015/04/14 17:51:51]

Done.

+  // In normal cases, message_request_queue_ should not be empty at this point
+  // of time, but when FrameWillClose() is invoked before receiving the
+  // callback for previous send mojo call, queue would have been emptied.
+  if (!message_request_queue_.empty())
+    message_request_queue_.pop();
+
+  if (!message_request_queue_.empty()) {
+    const linked_ptr<MessageRequest>& request = message_request_queue_.front();
+    DoSendStringMessage(request->presentation_url,
+                        request->presentation_id,
+                        request->message);
+  }
+}
+
+void PresentationDispatcher::RemoveAllMessageRequests() {
+  while (!message_request_queue_.empty())

[whywhat, 2015/04/13 13:31:21]

I think you just can do message_request_queue_.swap(MessageRequestQueue());
I also don't think this deserves its own method yet.

[USE s.singapati at gmail.com, 2015/04/14 17:51:51]

Done. Had to use std::swap(). message_request_queue_.swap() did not work
somehow.

+    message_request_queue_.pop();
+}
+
 void PresentationDispatcher::closeSession(
     const blink::WebString& presentationUrl,
     const blink::WebString& presentationId) {
   ConnectToPresentationServiceIfNeeded();
 
   presentation_service_->CloseSession(
       presentationUrl.utf8(),
       presentationId.utf8());
 }
 
 void PresentationDispatcher::DidChangeDefaultPresentation() {
   GURL presentation_url(GetPresentationURLFromFrame(render_frame()));
 
   ConnectToPresentationServiceIfNeeded();
   presentation_service_->SetDefaultPresentationURL(
       presentation_url.spec(), mojo::String());
 }
 
+void PresentationDispatcher::FrameWillClose() {
+  // Remove all pending send message requests.
+  RemoveAllMessageRequests();
+}
+
 void PresentationDispatcher::OnScreenAvailabilityChanged(
     const std::string& presentation_url, bool available) {
   if (!controller_)
     return;
 
   // Reset the callback to get the next event.
   DoUpdateAvailableChangeWatched(presentation_url,
                                  controller_->isAvailableChangeWatched());
 
   controller_->didChangeAvailability(available);
@@ skipping 58 matching lines @@
   /*
   presentation_service_->ListenForDefaultSessionStart(base::Bind(
       &PresentationDispatcher::OnDefaultSessionStarted,
       base::Unretained(this)));
   presentation_service_->ListenForSessionStateChange(base::Bind(
       &PresentationDispatcher::OnSessionStateChange,
       base::Unretained(this)));
   */
 }
 
+PresentationDispatcher::MessageRequest::MessageRequest(
+    const std::string& presentation_url,
+    const std::string& presentation_id,
+    const std::string& message)
+    : presentation_url(presentation_url),
+      presentation_id(presentation_id),
+      message(message) {
+}
+
+PresentationDispatcher::MessageRequest::~MessageRequest() {
+}
+
 }  // namespace content