| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #include "content/renderer/pepper/pepper_websocket_host.h" | 5 #include "content/renderer/pepper/pepper_websocket_host.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 | 8 |
| 9 #include "content/public/renderer/renderer_ppapi_host.h" | 9 #include "content/public/renderer/renderer_ppapi_host.h" |
| 10 #include "net/base/net_util.h" | 10 #include "net/base/net_util.h" |
| 11 #include "ppapi/c/pp_errors.h" | 11 #include "ppapi/c/pp_errors.h" |
| 12 #include "ppapi/c/ppb_websocket.h" | 12 #include "ppapi/c/ppb_websocket.h" |
| 13 #include "ppapi/host/dispatch_host_message.h" | 13 #include "ppapi/host/dispatch_host_message.h" |
| 14 #include "ppapi/host/host_message_context.h" | 14 #include "ppapi/host/host_message_context.h" |
| 15 #include "ppapi/host/ppapi_host.h" | 15 #include "ppapi/host/ppapi_host.h" |
| 16 #include "ppapi/proxy/ppapi_messages.h" | 16 #include "ppapi/proxy/ppapi_messages.h" |
| 17 #include "third_party/WebKit/public/platform/WebArrayBuffer.h" | 17 #include "third_party/WebKit/public/platform/WebArrayBuffer.h" |
| 18 #include "third_party/WebKit/public/platform/WebString.h" | 18 #include "third_party/WebKit/public/platform/WebString.h" |
| 19 #include "third_party/WebKit/public/platform/WebURL.h" | 19 #include "third_party/WebKit/public/platform/WebURL.h" |
| 20 #include "third_party/WebKit/public/web/WebDocument.h" | 20 #include "third_party/WebKit/public/web/WebDocument.h" |
| 21 #include "third_party/WebKit/public/web/WebElement.h" | 21 #include "third_party/WebKit/public/web/WebElement.h" |
| 22 #include "third_party/WebKit/public/web/WebPluginContainer.h" | 22 #include "third_party/WebKit/public/web/WebPluginContainer.h" |
| 23 #include "third_party/WebKit/public/web/WebSocket.h" | 23 #include "third_party/WebKit/public/web/WebSocket.h" |
| 24 | 24 |
| 25 using WebKit::WebArrayBuffer; | 25 using blink::WebArrayBuffer; |
| 26 using WebKit::WebDocument; | 26 using blink::WebDocument; |
| 27 using WebKit::WebString; | 27 using blink::WebString; |
| 28 using WebKit::WebSocket; | 28 using blink::WebSocket; |
| 29 using WebKit::WebURL; | 29 using blink::WebURL; |
| 30 | 30 |
| 31 namespace content { | 31 namespace content { |
| 32 | 32 |
| 33 PepperWebSocketHost::PepperWebSocketHost( | 33 PepperWebSocketHost::PepperWebSocketHost( |
| 34 RendererPpapiHost* host, | 34 RendererPpapiHost* host, |
| 35 PP_Instance instance, | 35 PP_Instance instance, |
| 36 PP_Resource resource) | 36 PP_Resource resource) |
| 37 : ResourceHost(host->GetPpapiHost(), instance, resource), | 37 : ResourceHost(host->GetPpapiHost(), instance, resource), |
| 38 renderer_ppapi_host_(host), | 38 renderer_ppapi_host_(host), |
| 39 connecting_(false), | 39 connecting_(false), |
| (...skipping 30 matching lines...) Expand all Loading... |
| 70 if (websocket_) | 70 if (websocket_) |
| 71 protocol = websocket_->subprotocol().utf8(); | 71 protocol = websocket_->subprotocol().utf8(); |
| 72 connecting_ = false; | 72 connecting_ = false; |
| 73 connect_reply_.params.set_result(PP_OK); | 73 connect_reply_.params.set_result(PP_OK); |
| 74 host()->SendReply(connect_reply_, | 74 host()->SendReply(connect_reply_, |
| 75 PpapiPluginMsg_WebSocket_ConnectReply( | 75 PpapiPluginMsg_WebSocket_ConnectReply( |
| 76 url_, | 76 url_, |
| 77 protocol)); | 77 protocol)); |
| 78 } | 78 } |
| 79 | 79 |
| 80 void PepperWebSocketHost::didReceiveMessage(const WebKit::WebString& message) { | 80 void PepperWebSocketHost::didReceiveMessage(const blink::WebString& message) { |
| 81 // Dispose packets after receiving an error. | 81 // Dispose packets after receiving an error. |
| 82 if (error_was_received_) | 82 if (error_was_received_) |
| 83 return; | 83 return; |
| 84 | 84 |
| 85 // Send an IPC to transport received data. | 85 // Send an IPC to transport received data. |
| 86 std::string string_message = message.utf8(); | 86 std::string string_message = message.utf8(); |
| 87 host()->SendUnsolicitedReply(pp_resource(), | 87 host()->SendUnsolicitedReply(pp_resource(), |
| 88 PpapiPluginMsg_WebSocket_ReceiveTextReply( | 88 PpapiPluginMsg_WebSocket_ReceiveTextReply( |
| 89 string_message)); | 89 string_message)); |
| 90 } | 90 } |
| 91 | 91 |
| 92 void PepperWebSocketHost::didReceiveArrayBuffer( | 92 void PepperWebSocketHost::didReceiveArrayBuffer( |
| 93 const WebKit::WebArrayBuffer& binaryData) { | 93 const blink::WebArrayBuffer& binaryData) { |
| 94 // Dispose packets after receiving an error. | 94 // Dispose packets after receiving an error. |
| 95 if (error_was_received_) | 95 if (error_was_received_) |
| 96 return; | 96 return; |
| 97 | 97 |
| 98 // Send an IPC to transport received data. | 98 // Send an IPC to transport received data. |
| 99 uint8_t* data = static_cast<uint8_t*>(binaryData.data()); | 99 uint8_t* data = static_cast<uint8_t*>(binaryData.data()); |
| 100 std::vector<uint8_t> array_message(data, data + binaryData.byteLength()); | 100 std::vector<uint8_t> array_message(data, data + binaryData.byteLength()); |
| 101 host()->SendUnsolicitedReply(pp_resource(), | 101 host()->SendUnsolicitedReply(pp_resource(), |
| 102 PpapiPluginMsg_WebSocket_ReceiveBinaryReply( | 102 PpapiPluginMsg_WebSocket_ReceiveBinaryReply( |
| 103 array_message)); | 103 array_message)); |
| (...skipping 24 matching lines...) Expand all Loading... |
| 128 | 128 |
| 129 // Send an IPC to notice that server starts closing handshake. | 129 // Send an IPC to notice that server starts closing handshake. |
| 130 host()->SendUnsolicitedReply(pp_resource(), | 130 host()->SendUnsolicitedReply(pp_resource(), |
| 131 PpapiPluginMsg_WebSocket_StateReply( | 131 PpapiPluginMsg_WebSocket_StateReply( |
| 132 PP_WEBSOCKETREADYSTATE_CLOSING)); | 132 PP_WEBSOCKETREADYSTATE_CLOSING)); |
| 133 } | 133 } |
| 134 | 134 |
| 135 void PepperWebSocketHost::didClose(unsigned long unhandled_buffered_amount, | 135 void PepperWebSocketHost::didClose(unsigned long unhandled_buffered_amount, |
| 136 ClosingHandshakeCompletionStatus status, | 136 ClosingHandshakeCompletionStatus status, |
| 137 unsigned short code, | 137 unsigned short code, |
| 138 const WebKit::WebString& reason) { | 138 const blink::WebString& reason) { |
| 139 if (connecting_) { | 139 if (connecting_) { |
| 140 connecting_ = false; | 140 connecting_ = false; |
| 141 connect_reply_.params.set_result(PP_ERROR_FAILED); | 141 connect_reply_.params.set_result(PP_ERROR_FAILED); |
| 142 host()->SendReply( | 142 host()->SendReply( |
| 143 connect_reply_, | 143 connect_reply_, |
| 144 PpapiPluginMsg_WebSocket_ConnectReply(url_, std::string())); | 144 PpapiPluginMsg_WebSocket_ConnectReply(url_, std::string())); |
| 145 } | 145 } |
| 146 | 146 |
| 147 // Set close_was_clean_. | 147 // Set close_was_clean_. |
| 148 bool was_clean = | 148 bool was_clean = |
| (...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 217 } | 217 } |
| 218 // Join protocols with the comma separator. | 218 // Join protocols with the comma separator. |
| 219 if (vector_it != protocols.begin()) | 219 if (vector_it != protocols.begin()) |
| 220 protocol_string.append(","); | 220 protocol_string.append(","); |
| 221 protocol_string.append(*vector_it); | 221 protocol_string.append(*vector_it); |
| 222 } | 222 } |
| 223 | 223 |
| 224 // Convert protocols to WebString. | 224 // Convert protocols to WebString. |
| 225 WebString web_protocols = WebString::fromUTF8(protocol_string); | 225 WebString web_protocols = WebString::fromUTF8(protocol_string); |
| 226 | 226 |
| 227 // Create WebKit::WebSocket object and connect. | 227 // Create blink::WebSocket object and connect. |
| 228 WebKit::WebPluginContainer* container = | 228 blink::WebPluginContainer* container = |
| 229 renderer_ppapi_host_->GetContainerForInstance(pp_instance()); | 229 renderer_ppapi_host_->GetContainerForInstance(pp_instance()); |
| 230 if (!container) | 230 if (!container) |
| 231 return PP_ERROR_BADARGUMENT; | 231 return PP_ERROR_BADARGUMENT; |
| 232 // TODO(toyoshim) Remove following WebDocument object copy. | 232 // TODO(toyoshim) Remove following WebDocument object copy. |
| 233 WebDocument document = container->element().document(); | 233 WebDocument document = container->element().document(); |
| 234 websocket_.reset(WebSocket::create(document, this)); | 234 websocket_.reset(WebSocket::create(document, this)); |
| 235 DCHECK(websocket_.get()); | 235 DCHECK(websocket_.get()); |
| 236 if (!websocket_) | 236 if (!websocket_) |
| 237 return PP_ERROR_NOTSUPPORTED; | 237 return PP_ERROR_NOTSUPPORTED; |
| 238 | 238 |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 281 | 281 |
| 282 int32_t PepperWebSocketHost::OnHostMsgFail( | 282 int32_t PepperWebSocketHost::OnHostMsgFail( |
| 283 ppapi::host::HostMessageContext* context, | 283 ppapi::host::HostMessageContext* context, |
| 284 const std::string& message) { | 284 const std::string& message) { |
| 285 if (websocket_) | 285 if (websocket_) |
| 286 websocket_->fail(WebString::fromUTF8(message)); | 286 websocket_->fail(WebString::fromUTF8(message)); |
| 287 return PP_OK; | 287 return PP_OK; |
| 288 } | 288 } |
| 289 | 289 |
| 290 } // namespace content | 290 } // namespace content |
| OLD | NEW |