[PresentationAPI] on-session-message handler for binary messages (Blink side).

Source/modules/presentation/PresentationSession.cpp

 // Copyright 2014 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 "config.h"
 #include "modules/presentation/PresentationSession.h"
 
 #include "core/dom/DOMArrayBuffer.h"
 #include "core/dom/DOMArrayBufferView.h"
 #include "core/dom/Document.h"
@@ skipping 203 matching lines @@
         case MessageTypeBlob:
             ASSERT(!m_blobLoader);
             m_blobLoader = new BlobLoader(message->blobDataHandle, this);
             break;
         }
     }
 }
 
 void PresentationSession::didReceiveTextMessage(const String& message)
 {
+    if (m_state == WebPresentationSessionState::Disconnected)
+        return;
+
     dispatchEvent(MessageEvent::create(message));
 }
 
+void PresentationSession::didReceiveArrayBufferMessage(const uint8_t* data, size_t length)
+{
+    if (m_state == WebPresentationSessionState::Disconnected)
+        return;
+
+    RefPtr<DOMArrayBuffer> buffer = DOMArrayBuffer::create(data, length);
+    dispatchEvent(MessageEvent::create(buffer.release()));
+}
+
+void PresentationSession::didReceiveBlobMessage(const uint8_t* data, size_t length)
+{
+    if (m_state == WebPresentationSessionState::Disconnected)
+        return;
+
+    RefPtr<RawData> rawData = RawData::create();
+    rawData->mutableData()->resize(length);
+    memcpy(rawData->mutableData()->data(), data, length);

[mark a. foltz, 2015/07/06 21:19:44]

Can you just call BlobData::appendBytes(data, length)?

[USE s.singapati at gmail.com, 2015/07/07 15:00:32]

Done. Manual tested.

+    OwnPtr<BlobData> blobData = BlobData::create();
+    blobData->appendData(rawData.release(), 0, BlobDataItem::toEndOfFile);
+    Blob* blob = Blob::create(BlobDataHandle::create(blobData.release(), length));
+    dispatchEvent(MessageEvent::create(blob));
+}
+
 void PresentationSession::close()
 {
     if (m_state != WebPresentationSessionState::Connected)
         return;
     PresentationController* controller = presentationController();
     if (controller)
         controller->closeSession(m_url, m_id);
 
     // Cancel current Blob loading if any.
     if (m_blobLoader) {
@@ skipping 45 matching lines @@
 {
     ASSERT(!m_messages.isEmpty() && m_messages.first()->type == MessageTypeBlob);
     // FIXME: generate error message?
     // Ignore the current failed blob item and continue with next items.
     m_messages.removeFirst();
     m_blobLoader.clear();
     handleMessageQueue();
 }
 
 } // namespace blink