Index: content/renderer/presentation/presentation_dispatcher.cc |
diff --git a/content/renderer/presentation/presentation_dispatcher.cc b/content/renderer/presentation/presentation_dispatcher.cc |
index 1d4062a0dd7ea2b93fbe27eba3d11d8951dc2d01..a34f0c3e7f0f8b55d3aebe11dd24bcca94650153 100644 |
--- a/content/renderer/presentation/presentation_dispatcher.cc |
+++ b/content/renderer/presentation/presentation_dispatcher.cc |
@@ -4,6 +4,7 @@ |
#include "content/renderer/presentation/presentation_dispatcher.h" |
+#include <string> |
#include <utility> |
#include <vector> |
@@ -142,7 +143,7 @@ void PresentationDispatcher::joinSession( |
void PresentationDispatcher::sendString(const blink::WebURL& presentationUrl, |
const blink::WebString& presentationId, |
const blink::WebString& message) { |
- if (message.utf8().size() > kMaxPresentationSessionMessageSize) { |
+ if (message.utf8().size() > kMaxPresentationConnectionMessageSize) { |
// TODO(crbug.com/459008): Limit the size of individual messages to 64k |
// for now. Consider throwing DOMException or splitting bigger messages |
// into smaller chunks later. |
@@ -163,7 +164,7 @@ void PresentationDispatcher::sendArrayBuffer( |
const uint8_t* data, |
size_t length) { |
DCHECK(data); |
- if (length > kMaxPresentationSessionMessageSize) { |
+ if (length > kMaxPresentationConnectionMessageSize) { |
// TODO(crbug.com/459008): Same as in sendString(). |
LOG(WARNING) << "data size exceeded limit!"; |
return; |
@@ -171,7 +172,7 @@ void PresentationDispatcher::sendArrayBuffer( |
message_request_queue_.push(base::WrapUnique(CreateSendBinaryMessageRequest( |
presentationUrl, presentationId, |
- blink::mojom::PresentationMessageType::ARRAY_BUFFER, data, length))); |
+ blink::mojom::PresentationMessageType::BINARY, data, length))); |
// Start processing request if only one in the queue. |
if (message_request_queue_.size() == 1) |
DoSendMessage(message_request_queue_.front().get()); |
@@ -183,7 +184,7 @@ void PresentationDispatcher::sendBlobData( |
const uint8_t* data, |
size_t length) { |
DCHECK(data); |
- if (length > kMaxPresentationSessionMessageSize) { |
+ if (length > kMaxPresentationConnectionMessageSize) { |
// TODO(crbug.com/459008): Same as in sendString(). |
LOG(WARNING) << "data size exceeded limit!"; |
return; |
@@ -191,7 +192,7 @@ void PresentationDispatcher::sendBlobData( |
message_request_queue_.push(base::WrapUnique(CreateSendBinaryMessageRequest( |
presentationUrl, presentationId, |
- blink::mojom::PresentationMessageType::BLOB, data, length))); |
+ blink::mojom::PresentationMessageType::BINARY, data, length))); |
// Start processing request if only one in the queue. |
if (message_request_queue_.size() == 1) |
DoSendMessage(message_request_queue_.front().get()); |
@@ -200,7 +201,7 @@ void PresentationDispatcher::sendBlobData( |
void PresentationDispatcher::DoSendMessage(SendMessageRequest* request) { |
ConnectToPresentationServiceIfNeeded(); |
- presentation_service_->SendSessionMessage( |
+ presentation_service_->SendConnectionMessage( |
std::move(request->session_info), std::move(request->message), |
base::Bind(&PresentationDispatcher::HandleSendMessageRequests, |
base::Unretained(this))); |
@@ -376,7 +377,7 @@ void PresentationDispatcher::OnDefaultSessionStarted( |
return; |
if (!session_info.is_null()) { |
- presentation_service_->ListenForSessionMessages(session_info.Clone()); |
+ presentation_service_->ListenForConnectionMessages(session_info.Clone()); |
controller_->didStartDefaultSession( |
new PresentationConnectionClient(std::move(session_info))); |
} |
@@ -396,7 +397,7 @@ void PresentationDispatcher::OnSessionCreated( |
} |
DCHECK(!session_info.is_null()); |
- presentation_service_->ListenForSessionMessages(session_info.Clone()); |
+ presentation_service_->ListenForConnectionMessages(session_info.Clone()); |
callback->onSuccess( |
base::MakeUnique<PresentationConnectionClient>(std::move(session_info))); |
} |
@@ -435,9 +436,9 @@ void PresentationDispatcher::OnConnectionClosed( |
blink::WebString::fromUTF8(message)); |
} |
-void PresentationDispatcher::OnSessionMessagesReceived( |
+void PresentationDispatcher::OnConnectionMessagesReceived( |
blink::mojom::PresentationSessionInfoPtr session_info, |
- std::vector<blink::mojom::SessionMessagePtr> messages) { |
+ std::vector<blink::mojom::ConnectionMessagePtr> messages) { |
if (!controller_) |
return; |
@@ -454,8 +455,7 @@ void PresentationDispatcher::OnSessionMessagesReceived( |
blink::WebString::fromUTF8(messages[i]->message.value())); |
break; |
} |
- case blink::mojom::PresentationMessageType::ARRAY_BUFFER: |
- case blink::mojom::PresentationMessageType::BLOB: { |
+ case blink::mojom::PresentationMessageType::BINARY: { |
// TODO(mfoltz): Do we need to DCHECK(messages[i]->data)? |
controller_->didReceiveSessionBinaryMessage( |
session_client.release(), &(messages[i]->data->front()), |
@@ -498,7 +498,7 @@ void PresentationDispatcher::UpdateListeningState(AvailabilityStatus* status) { |
PresentationDispatcher::SendMessageRequest::SendMessageRequest( |
blink::mojom::PresentationSessionInfoPtr session_info, |
- blink::mojom::SessionMessagePtr message) |
+ blink::mojom::ConnectionMessagePtr message) |
: session_info(std::move(session_info)), message(std::move(message)) {} |
PresentationDispatcher::SendMessageRequest::~SendMessageRequest() {} |
@@ -514,8 +514,8 @@ PresentationDispatcher::CreateSendTextMessageRequest( |
session_info->url = presentationUrl; |
session_info->id = presentationId.utf8(); |
- blink::mojom::SessionMessagePtr session_message = |
- blink::mojom::SessionMessage::New(); |
+ blink::mojom::ConnectionMessagePtr session_message = |
+ blink::mojom::ConnectionMessage::New(); |
session_message->type = blink::mojom::PresentationMessageType::TEXT; |
session_message->message = message.utf8(); |
return new SendMessageRequest(std::move(session_info), |
@@ -535,8 +535,8 @@ PresentationDispatcher::CreateSendBinaryMessageRequest( |
session_info->url = presentationUrl; |
session_info->id = presentationId.utf8(); |
- blink::mojom::SessionMessagePtr session_message = |
- blink::mojom::SessionMessage::New(); |
+ blink::mojom::ConnectionMessagePtr session_message = |
+ blink::mojom::ConnectionMessage::New(); |
session_message->type = type; |
session_message->data = std::vector<uint8_t>(data, data + length); |
return new SendMessageRequest(std::move(session_info), |