X-Git-Url: https://gerrit.akraino.org/r/gitweb?a=blobdiff_plain;f=src%2Ftype3_AndroidCloud%2Fanbox-master%2Fsrc%2Fanbox%2Fnetwork%2Ftcp_socket_connector.h;fp=src%2Ftype3_AndroidCloud%2Fanbox-master%2Fsrc%2Fanbox%2Fnetwork%2Ftcp_socket_connector.h;h=94fa0a3fb62039b7023d88687857a686bbb37472;hb=e26c1ec581be598521517829adba8c8dd23a768f;hp=0000000000000000000000000000000000000000;hpb=6699c1aea74eeb0eb400e6299079f0c7576f716f;p=iec.git diff --git a/src/type3_AndroidCloud/anbox-master/src/anbox/network/tcp_socket_connector.h b/src/type3_AndroidCloud/anbox-master/src/anbox/network/tcp_socket_connector.h new file mode 100644 index 0000000..94fa0a3 --- /dev/null +++ b/src/type3_AndroidCloud/anbox-master/src/anbox/network/tcp_socket_connector.h @@ -0,0 +1,57 @@ +/* + * Copyright (C) 2016 Simon Fels + * + * This program is free software: you can redistribute it and/or modify it + * under the terms of the GNU General Public License version 3, as published + * by the Free Software Foundation. + * + * This program is distributed in the hope that it will be useful, but + * WITHOUT ANY WARRANTY; without even the implied warranties of + * MERCHANTABILITY, SATISFACTORY QUALITY, or FITNESS FOR A PARTICULAR + * PURPOSE. See the GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program. If not, see . + * + */ + +#ifndef ANBOX_TCPSOCKETCONNECTOR_H +#define ANBOX_TCPSOCKETCONNECTOR_H + +#include + +#include "anbox/do_not_copy_or_move.h" +#include "anbox/runtime.h" + +#include "anbox/network/connection_creator.h" +#include "anbox/network/connector.h" + +namespace anbox { +namespace network { +class TcpSocketConnector : public DoNotCopyOrMove, public Connector { + public: + explicit TcpSocketConnector( + const boost::asio::ip::address_v4 &address, unsigned short port, + const std::shared_ptr &rt, + const std::shared_ptr> + &connection_creator); + ~TcpSocketConnector() noexcept; + + unsigned short port() const { return port_; } + + private: + void start_accept(); + void on_new_connection( + std::shared_ptr const &socket, + boost::system::error_code const &err); + + boost::asio::ip::address_v4 address_; + unsigned short port_; + std::shared_ptr runtime_; + std::shared_ptr> connection_creator_; + boost::asio::ip::tcp::acceptor acceptor_; +}; +} // namespace network +} // namespace anbox + +#endif