mojo/services/network/tcp_bound_socket_impl.h

   1 // 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_BOUND_SOCKET_H_
   6 #define MOJO_SERVICES_NETWORK_TCP_BOUND_SOCKET_H_
   7
   8 #include "base/memory/scoped_ptr.h"
   9 #include "mojo/application/public/cpp/app_lifetime_helper.h"
  10 #include "mojo/services/network/public/interfaces/tcp_bound_socket.mojom.h"
  11 #include "net/socket/tcp_socket.h"
  12 #include "third_party/mojo/src/mojo/public/cpp/bindings/strong_binding.h"
  13
  14 namespace mojo {
  15
  16 class TCPBoundSocketImpl : public TCPBoundSocket {
  17  public:
  18   TCPBoundSocketImpl(scoped_ptr<mojo::AppRefCount> app_refcount,
  19                      InterfaceRequest<TCPBoundSocket> request);
  20   ~TCPBoundSocketImpl() override;
  21
  22   // Does the actual binding. Returns a net error code. On net::OK, the bound
  23   // socket will be ready to use and send back to the client. On failure, this
  24   // object should be destroyed and no longer used.
  25   int Bind(NetAddressPtr local_address);
  26
  27   // Returns the local address associated with this socket. This should only
  28   // be called after Bind has succeeded.
  29   NetAddressPtr GetLocalAddress() const;
  30
  31   // TCPBoundSocket.
  32   void StartListening(InterfaceRequest<TCPServerSocket> server,
  33                       const Callback<void(NetworkErrorPtr)>& callback) override;
  34   void Connect(NetAddressPtr remote_address,
  35                ScopedDataPipeConsumerHandle send_stream,
  36                ScopedDataPipeProducerHandle receive_stream,
  37                InterfaceRequest<TCPConnectedSocket> client_socket,
  38                const Callback<void(NetworkErrorPtr)>& callback) override;
  39
  40  private:
  41   void OnConnected(int result);
  42
  43   scoped_ptr<net::TCPSocket> socket_;
  44
  45   // Valid when waiting for a connect callback.
  46   ScopedDataPipeConsumerHandle pending_connect_send_stream_;
  47   ScopedDataPipeProducerHandle pending_connect_receive_stream_;
  48   InterfaceRequest<TCPConnectedSocket> pending_connect_socket_;
  49   Callback<void(NetworkErrorPtr)> pending_connect_callback_;
  50   scoped_ptr<mojo::AppRefCount> app_refcount_;
  51   StrongBinding<TCPBoundSocket> binding_;
  52 };
  53
  54 }  // namespace mojo
  55
  56 #endif  // MOJO_SERVICES_NETWORK_TCP_BOUND_SOCKET_H_