blob: 000995151e008a2e378963eff1d03032e59396aa [file] [log] [blame]
James Robinsone2ac7e82014-10-15 13:21:59 -07001// Copyright 2014 The Chromium Authors. All rights reserved.
2// Use of this source code is governed by a BSD-style license that can be
3// found in the LICENSE file.
4
5#ifndef MOJO_SERVICES_NETWORK_TCP_SERVER_SOCKET_H_
6#define MOJO_SERVICES_NETWORK_TCP_SERVER_SOCKET_H_
7
8#include "base/memory/scoped_ptr.h"
9#include "mojo/public/cpp/bindings/interface_impl.h"
Colin Blundellb470fa12014-12-10 16:28:40 +010010#include "mojo/services/network/public/interfaces/tcp_server_socket.mojom.h"
James Robinsone2ac7e82014-10-15 13:21:59 -070011#include "net/base/ip_endpoint.h"
12#include "net/socket/tcp_socket.h"
13
14namespace mojo {
15
16class TCPServerSocketImpl : public InterfaceImpl<TCPServerSocket> {
17 public:
18 typedef Callback<void(NetworkErrorPtr, NetAddressPtr)> AcceptCallback;
19
20 // Passed ownership of a socket already in listening mode.
21 explicit TCPServerSocketImpl(scoped_ptr<net::TCPSocket> socket);
James Robinsone1b30cf2014-10-21 12:25:40 -070022 ~TCPServerSocketImpl() override;
James Robinsone2ac7e82014-10-15 13:21:59 -070023
24 // TCPServerSocket.
James Robinsone1b30cf2014-10-21 12:25:40 -070025 void Accept(ScopedDataPipeConsumerHandle send_stream,
26 ScopedDataPipeProducerHandle receive_stream,
27 InterfaceRequest<TCPConnectedSocket> client_socket,
28 const AcceptCallback& callback) override;
James Robinsone2ac7e82014-10-15 13:21:59 -070029
30 private:
31 void OnAcceptCompleted(int result);
32
33 scoped_ptr<net::TCPSocket> socket_;
34
35 // Non-null when accept is pending.
36 AcceptCallback pending_callback_;
37
38 // The parameters associated with the pending Accept call.
39 ScopedDataPipeConsumerHandle pending_send_stream_;
40 ScopedDataPipeProducerHandle pending_receive_stream_;
41 InterfaceRequest<TCPConnectedSocket> pending_client_socket_;
42
43 // These are written to by net::TCPSocket when Accept is completed.
44 scoped_ptr<net::TCPSocket> accepted_socket_;
45 net::IPEndPoint accepted_address_;
46};
47
48} // namespace mojo
49
50#endif // MOJO_SERVICES_NETWORK_TCP_SERVER_SOCKET_H_