| // 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. |
| |
| #ifndef APPS_APP_SHIM_UNIX_DOMAIN_SOCKET_ACCEPTOR_H_ |
| #define APPS_APP_SHIM_UNIX_DOMAIN_SOCKET_ACCEPTOR_H_ |
| |
| #include "base/files/file_path.h" |
| #include "base/message_loop/message_loop.h" |
| #include "ipc/ipc_channel_handle.h" |
| |
| namespace apps { |
| |
| // A UnixDomainSocketAcceptor listens on a UNIX domain socket. When a |
| // client connects to the socket, it accept()s the connection and |
| // passes the new FD to the delegate. The delegate is then responsible |
| // for creating a new IPC::Channel for the FD. |
| class UnixDomainSocketAcceptor : public base::MessageLoopForIO::Watcher { |
| public: |
| class Delegate { |
| public: |
| // Called when a client connects to the factory. It is the delegate's |
| // responsibility to create an IPC::Channel for the handle, or else close |
| // the file descriptor contained therein. |
| virtual void OnClientConnected(const IPC::ChannelHandle& handle) = 0; |
| |
| // Called when an error occurs and the channel is closed. |
| virtual void OnListenError() = 0; |
| }; |
| |
| UnixDomainSocketAcceptor(const base::FilePath& path, Delegate* delegate); |
| |
| virtual ~UnixDomainSocketAcceptor(); |
| |
| // Call this to start listening on the socket. |
| bool Listen(); |
| |
| // Close and unlink the socket, and stop accepting connections. |
| void Close(); |
| |
| private: |
| bool CreateSocket(); |
| virtual void OnFileCanReadWithoutBlocking(int fd) OVERRIDE; |
| virtual void OnFileCanWriteWithoutBlocking(int fd) OVERRIDE; |
| |
| base::MessageLoopForIO::FileDescriptorWatcher |
| server_listen_connection_watcher_; |
| base::FilePath path_; |
| Delegate* delegate_; |
| int listen_fd_; |
| |
| DISALLOW_COPY_AND_ASSIGN(UnixDomainSocketAcceptor); |
| }; |
| |
| } // namespace apps |
| |
| #endif // APPS_APP_SHIM_UNIX_DOMAIN_SOCKET_ACCEPTOR_H_ |