apps/app_shim/unix_domain_socket_acceptor.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 APPS_APP_SHIM_UNIX_DOMAIN_SOCKET_ACCEPTOR_H_
   6 #define APPS_APP_SHIM_UNIX_DOMAIN_SOCKET_ACCEPTOR_H_
   7
   8 #include "base/files/file_path.h"
   9 #include "base/message_loop/message_loop.h"
  10 #include "ipc/ipc_channel_handle.h"
  11
  12 namespace apps {
  13
  14 // A UnixDomainSocketAcceptor listens on a UNIX domain socket. When a
  15 // client connects to the socket, it accept()s the connection and
  16 // passes the new FD to the delegate. The delegate is then responsible
  17 // for creating a new IPC::Channel for the FD.
  18 class UnixDomainSocketAcceptor : public base::MessageLoopForIO::Watcher {
  19  public:
  20   class Delegate {
  21    public:
  22     // Called when a client connects to the factory. It is the delegate's
  23     // responsibility to create an IPC::Channel for the handle, or else close
  24     // the file descriptor contained therein.
  25     virtual void OnClientConnected(const IPC::ChannelHandle& handle) = 0;
  26
  27     // Called when an error occurs and the channel is closed.
  28     virtual void OnListenError() = 0;
  29   };
  30
  31   UnixDomainSocketAcceptor(const base::FilePath& path, Delegate* delegate);
  32
  33   virtual ~UnixDomainSocketAcceptor();
  34
  35   // Call this to start listening on the socket.
  36   bool Listen();
  37
  38   // Close and unlink the socket, and stop accepting connections.
  39   void Close();
  40
  41  private:
  42   bool CreateSocket();
  43   virtual void OnFileCanReadWithoutBlocking(int fd) OVERRIDE;
  44   virtual void OnFileCanWriteWithoutBlocking(int fd) OVERRIDE;
  45
  46   base::MessageLoopForIO::FileDescriptorWatcher
  47       server_listen_connection_watcher_;
  48   base::FilePath path_;
  49   Delegate* delegate_;
  50   int listen_fd_;
  51
  52   DISALLOW_COPY_AND_ASSIGN(UnixDomainSocketAcceptor);
  53 };
  54
  55 }  // namespace apps
  56
  57 #endif  // APPS_APP_SHIM_UNIX_DOMAIN_SOCKET_ACCEPTOR_H_