/* * 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_RPC_CONNECTION_CREATOR_H_ #define ANBOX_RPC_CONNECTION_CREATOR_H_ #include #include #include "anbox/do_not_copy_or_move.h" #include "anbox/network/connection_creator.h" #include "anbox/network/connections.h" #include "anbox/network/socket_connection.h" #include "anbox/network/socket_messenger.h" #include "anbox/runtime.h" namespace anbox { namespace rpc { class ConnectionCreator : public network::ConnectionCreator { public: typedef std::function( const std::shared_ptr &)> MessageProcessorFactory; ConnectionCreator(const std::shared_ptr &rt, const MessageProcessorFactory &factory); ~ConnectionCreator() noexcept; void create_connection_for( std::shared_ptr> const &socket) override; private: int next_id(); std::shared_ptr runtime_; std::atomic next_connection_id_; std::shared_ptr> const connections_; MessageProcessorFactory message_processor_factory_; }; } // namespace rpc } // namespace anbox #endif