| Index: content/browser/renderer_host/pepper_tcp_server_socket.cc
|
| diff --git a/content/browser/renderer_host/pepper_tcp_server_socket.cc b/content/browser/renderer_host/pepper_tcp_server_socket.cc
|
| index b108d0f61da79d36e26689680e45274212857a11..15a39c4e160237128345295e3afba9e74b6759c9 100644
|
| --- a/content/browser/renderer_host/pepper_tcp_server_socket.cc
|
| +++ b/content/browser/renderer_host/pepper_tcp_server_socket.cc
|
| @@ -24,13 +24,13 @@ PepperTCPServerSocket::PepperTCPServerSocket(
|
| PepperMessageFilter* manager,
|
| int32 routing_id,
|
| uint32 plugin_dispatcher_id,
|
| - uint32 real_socket_id,
|
| - uint32 temp_socket_id)
|
| + PP_Resource socket_resource,
|
| + uint32 socket_id)
|
| : manager_(manager),
|
| routing_id_(routing_id),
|
| plugin_dispatcher_id_(plugin_dispatcher_id),
|
| - real_socket_id_(real_socket_id),
|
| - temp_socket_id_(temp_socket_id),
|
| + socket_resource_(socket_resource),
|
| + socket_id_(socket_id),
|
| state_(BEFORE_LISTENING) {
|
| DCHECK(manager);
|
| }
|
| @@ -57,7 +57,7 @@ void PepperTCPServerSocket::Listen(const PP_NetAddress_Private& addr,
|
| OnListenCompleted(result);
|
| }
|
|
|
| -void PepperTCPServerSocket::Accept() {
|
| +void PepperTCPServerSocket::Accept(int32 tcp_client_socket_routing_id) {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
|
|
| if (state_ != LISTENING) {
|
| @@ -70,30 +70,31 @@ void PepperTCPServerSocket::Accept() {
|
| int result = socket_->Accept(
|
| &socket_buffer_,
|
| base::Bind(&PepperTCPServerSocket::OnAcceptCompleted,
|
| - base::Unretained(this)));
|
| + base::Unretained(this),
|
| + tcp_client_socket_routing_id));
|
| if (result != net::ERR_IO_PENDING)
|
| - OnAcceptCompleted(result);
|
| + OnAcceptCompleted(tcp_client_socket_routing_id, result);
|
| }
|
|
|
| void PepperTCPServerSocket::CancelListenRequest() {
|
| manager_->Send(new PpapiMsg_PPBTCPServerSocket_ListenACK(
|
| routing_id_,
|
| plugin_dispatcher_id_,
|
| + socket_resource_,
|
| 0,
|
| - temp_socket_id_,
|
| PP_ERROR_FAILED));
|
| BrowserThread::PostTask(
|
| BrowserThread::IO,
|
| FROM_HERE,
|
| base::Bind(&PepperMessageFilter::RemoveTCPServerSocket, manager_,
|
| - real_socket_id_));
|
| + socket_id_));
|
| }
|
|
|
| void PepperTCPServerSocket::SendAcceptACKError() {
|
| manager_->Send(new PpapiMsg_PPBTCPServerSocket_AcceptACK(
|
| routing_id_,
|
| plugin_dispatcher_id_,
|
| - real_socket_id_,
|
| + socket_id_,
|
| 0,
|
| NetAddressPrivateImpl::kInvalidNetAddress,
|
| NetAddressPrivateImpl::kInvalidNetAddress));
|
| @@ -108,14 +109,16 @@ void PepperTCPServerSocket::OnListenCompleted(int result) {
|
| manager_->Send(new PpapiMsg_PPBTCPServerSocket_ListenACK(
|
| routing_id_,
|
| plugin_dispatcher_id_,
|
| - real_socket_id_,
|
| - temp_socket_id_,
|
| + socket_resource_,
|
| + socket_id_,
|
| PP_OK));
|
| state_ = LISTENING;
|
| }
|
| }
|
|
|
| -void PepperTCPServerSocket::OnAcceptCompleted(int result) {
|
| +void PepperTCPServerSocket::OnAcceptCompleted(
|
| + int32 tcp_client_socket_routing_id,
|
| + int result) {
|
| DCHECK(state_ == ACCEPT_IN_PROGRESS && socket_buffer_.get());
|
|
|
| if (result != net::OK) {
|
| @@ -139,14 +142,14 @@ void PepperTCPServerSocket::OnAcceptCompleted(int result) {
|
| SendAcceptACKError();
|
| } else {
|
| uint32 accepted_socket_id =
|
| - manager_->AddAcceptedTCPSocket(routing_id_,
|
| + manager_->AddAcceptedTCPSocket(tcp_client_socket_routing_id,
|
| plugin_dispatcher_id_,
|
| socket.release());
|
| if (accepted_socket_id != 0) {
|
| manager_->Send(new PpapiMsg_PPBTCPServerSocket_AcceptACK(
|
| routing_id_,
|
| plugin_dispatcher_id_,
|
| - real_socket_id_,
|
| + socket_id_,
|
| accepted_socket_id,
|
| local_addr,
|
| remote_addr));
|
|
|