Index: content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc |
diff --git a/content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc b/content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc |
index af2234d5110b1390acea13de94d7c33c25e63ccf..e2912a79448c2e339fc6505a83ad0088cb35131a 100644 |
--- a/content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc |
+++ b/content/browser/renderer_host/pepper/pepper_tcp_server_socket_message_filter.cc |
@@ -15,8 +15,6 @@ |
#include "net/base/ip_endpoint.h" |
#include "net/base/net_errors.h" |
#include "net/base/net_util.h" |
-#include "net/socket/tcp_client_socket.h" |
-#include "net/socket/tcp_server_socket.h" |
#include "ppapi/c/pp_errors.h" |
#include "ppapi/c/private/ppb_net_address_private.h" |
#include "ppapi/host/dispatch_host_message.h" |
@@ -25,6 +23,7 @@ |
#include "ppapi/host/resource_host.h" |
#include "ppapi/proxy/ppapi_messages.h" |
#include "ppapi/shared_impl/api_id.h" |
+#include "ppapi/shared_impl/ppb_tcp_socket_shared.h" |
#include "ppapi/shared_impl/private/net_address_private_impl.h" |
using ppapi::NetAddressPrivateImpl; |
@@ -134,7 +133,8 @@ int32_t PepperTCPServerSocketMessageFilter::OnMsgAccept( |
ppapi::host::ReplyMessageContext reply_context( |
context->MakeReplyMessageContext()); |
int net_result = socket_->Accept( |
- &socket_buffer_, |
+ &accepted_socket_, |
+ &accepted_address_, |
base::Bind(&PepperTCPServerSocketMessageFilter::OnAcceptCompleted, |
base::Unretained(this), reply_context)); |
if (net_result != net::ERR_IO_PENDING) |
@@ -169,8 +169,22 @@ void PepperTCPServerSocketMessageFilter::DoListen( |
state_ = STATE_LISTEN_IN_PROGRESS; |
- socket_.reset(new net::TCPServerSocket(NULL, net::NetLog::Source())); |
- int net_result = socket_->Listen(net::IPEndPoint(address, port), backlog); |
+ socket_.reset(new net::TCPSocket(NULL, net::NetLog::Source())); |
+ int net_result = net::OK; |
+ do { |
+ net::IPEndPoint ip_end_point(address, port); |
+ net_result = socket_->Open(ip_end_point.GetFamily()); |
+ if (net_result != net::OK) |
+ break; |
+ net_result = socket_->SetDefaultOptionsForServer(); |
+ if (net_result != net::OK) |
+ break; |
+ net_result = socket_->Bind(ip_end_point); |
+ if (net_result != net::OK) |
+ break; |
+ net_result = socket_->Listen(backlog); |
+ } while (false); |
+ |
if (net_result != net::ERR_IO_PENDING) |
OnListenCompleted(context, net_result); |
} |
@@ -229,16 +243,15 @@ void PepperTCPServerSocketMessageFilter::OnAcceptCompleted( |
return; |
} |
- DCHECK(socket_buffer_.get()); |
+ DCHECK(accepted_socket_.get()); |
- scoped_ptr<net::StreamSocket> socket(socket_buffer_.release()); |
net::IPEndPoint ip_end_point_local; |
- net::IPEndPoint ip_end_point_remote; |
PP_NetAddress_Private local_addr = NetAddressPrivateImpl::kInvalidNetAddress; |
PP_NetAddress_Private remote_addr = NetAddressPrivateImpl::kInvalidNetAddress; |
int32_t pp_result = |
- NetErrorToPepperError(socket->GetLocalAddress(&ip_end_point_local)); |
+ NetErrorToPepperError(accepted_socket_->GetLocalAddress( |
+ &ip_end_point_local)); |
if (pp_result != PP_OK) { |
SendAcceptError(context, pp_result); |
return; |
@@ -246,19 +259,10 @@ void PepperTCPServerSocketMessageFilter::OnAcceptCompleted( |
if (!NetAddressPrivateImpl::IPEndPointToNetAddress( |
ip_end_point_local.address(), |
ip_end_point_local.port(), |
- &local_addr)) { |
- SendAcceptError(context, PP_ERROR_FAILED); |
- return; |
- } |
- pp_result = |
- NetErrorToPepperError(socket->GetPeerAddress(&ip_end_point_remote)); |
- if (pp_result != PP_OK) { |
- SendAcceptError(context, pp_result); |
- return; |
- } |
- if (!NetAddressPrivateImpl::IPEndPointToNetAddress( |
- ip_end_point_remote.address(), |
- ip_end_point_remote.port(), |
+ &local_addr) || |
+ !NetAddressPrivateImpl::IPEndPointToNetAddress( |
+ accepted_address_.address(), |
+ accepted_address_.port(), |
&remote_addr)) { |
SendAcceptError(context, PP_ERROR_FAILED); |
return; |
@@ -266,7 +270,8 @@ void PepperTCPServerSocketMessageFilter::OnAcceptCompleted( |
scoped_ptr<ppapi::host::ResourceHost> host = |
factory_->CreateAcceptedTCPSocket( |
- instance_, true /* private_api */, socket.release()); |
+ instance_, ppapi::TCP_SOCKET_VERSION_PRIVATE, |
+ accepted_socket_.Pass()); |
if (!host) { |
SendAcceptError(context, PP_ERROR_NOSPACE); |
return; |