| // 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 "mojo/services/network/tcp_server_socket_impl.h" |
| |
| #include "mojo/services/network/net_adapters.h" |
| #include "mojo/services/network/net_address_type_converters.h" |
| #include "mojo/services/network/tcp_connected_socket_impl.h" |
| #include "net/base/net_errors.h" |
| |
| namespace mojo { |
| |
| TCPServerSocketImpl::TCPServerSocketImpl(scoped_ptr<net::TCPSocket> socket) |
| : socket_(socket.Pass()) { |
| } |
| |
| TCPServerSocketImpl::~TCPServerSocketImpl() { |
| } |
| |
| void TCPServerSocketImpl::Accept( |
| ScopedDataPipeConsumerHandle send_stream, |
| ScopedDataPipeProducerHandle receive_stream, |
| InterfaceRequest<TCPConnectedSocket> client_socket, |
| const AcceptCallback& callback) { |
| // One possible future enhancement would be to enqueue multiple Accept calls |
| // on this object. This would allow the client to accept some number of |
| // incoming connections rapidly without doing an IPC round-trip. |
| if (!pending_callback_.is_null()) { |
| // Already have a pending accept on this socket. |
| callback.Run(MakeNetworkError(net::ERR_UNEXPECTED), NetAddressPtr()); |
| return; |
| } |
| |
| int result = socket_->Accept( |
| &accepted_socket_, &accepted_address_, |
| base::Bind(&TCPServerSocketImpl::OnAcceptCompleted, |
| base::Unretained(this))); |
| if (result == net::OK || result == net::ERR_IO_PENDING) { |
| pending_callback_ = callback; |
| pending_send_stream_ = send_stream.Pass(); |
| pending_receive_stream_ = receive_stream.Pass(); |
| pending_client_socket_ = client_socket.Pass(); |
| if (result == net::OK) |
| OnAcceptCompleted(net::OK); |
| } else { |
| callback.Run(MakeNetworkError(result), NetAddressPtr()); |
| } |
| } |
| |
| void TCPServerSocketImpl::OnAcceptCompleted(int result) { |
| if (result != net::OK) { |
| pending_callback_.Run(MakeNetworkError(result), NetAddressPtr()); |
| pending_send_stream_.reset(); |
| pending_receive_stream_.reset(); |
| pending_client_socket_ = InterfaceRequest<TCPConnectedSocket>(); |
| } else { |
| BindToRequest(new TCPConnectedSocketImpl( |
| accepted_socket_.Pass(), |
| pending_send_stream_.Pass(), |
| pending_receive_stream_.Pass()), &pending_client_socket_); |
| pending_callback_.Run(MakeNetworkError(net::OK), |
| NetAddress::From(accepted_address_)); |
| } |
| |
| pending_callback_ = AcceptCallback(); |
| } |
| |
| } // namespace mojo |