| // 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 CHROME_BROWSER_APPS_APP_SHIM_UNIX_DOMAIN_SOCKET_ACCEPTOR_H_ |
| #define CHROME_BROWSER_APPS_APP_SHIM_UNIX_DOMAIN_SOCKET_ACCEPTOR_H_ |
| |
| #include "base/files/file_path.h" |
| #include "base/macros.h" |
| #include "base/message_loop/message_pump_for_io.h" |
| #include "mojo/public/cpp/platform/named_platform_channel.h" |
| #include "mojo/public/cpp/platform/platform_channel_endpoint.h" |
| #include "mojo/public/cpp/platform/platform_channel_server_endpoint.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::MessagePumpForIO::FdWatcher { |
| 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(mojo::PlatformChannelEndpoint endpoint) = 0; |
| |
| // Called when an error occurs and the channel is closed. |
| virtual void OnListenError() = 0; |
| }; |
| |
| UnixDomainSocketAcceptor(const base::FilePath& path, Delegate* delegate); |
| |
| ~UnixDomainSocketAcceptor() override; |
| |
| // Call this to start listening on the socket. |
| bool Listen(); |
| |
| // Close and unlink the socket, and stop accepting connections. |
| void Close(); |
| |
| private: |
| void OnFileCanReadWithoutBlocking(int fd) override; |
| void OnFileCanWriteWithoutBlocking(int fd) override; |
| |
| base::MessagePumpForIO::FdWatchController server_listen_connection_watcher_; |
| mojo::NamedPlatformChannel::ServerName named_pipe_; |
| Delegate* delegate_; |
| mojo::PlatformChannelServerEndpoint listen_handle_; |
| |
| DISALLOW_COPY_AND_ASSIGN(UnixDomainSocketAcceptor); |
| }; |
| |
| } // namespace apps |
| |
| #endif // CHROME_BROWSER_APPS_APP_SHIM_UNIX_DOMAIN_SOCKET_ACCEPTOR_H_ |