/* * 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_CONTAINER_CLIENT_H_ #define ANBOX_CONTAINER_CLIENT_H_ #include "anbox/container/configuration.h" #include "anbox/runtime.h" namespace anbox { namespace rpc { class PendingCallCache; class Channel; class MessageProcessor; } // namespace rpc namespace network { class LocalSocketMessenger; } // namespace network namespace container { class ManagementApiStub; class Client { public: typedef std::function TerminateCallback; Client(const std::shared_ptr &rt); ~Client(); void start(const Configuration &configuration); void stop(); void register_terminate_handler(const TerminateCallback &callback); private: void read_next_message(); void on_read_size(const boost::system::error_code &ec, std::size_t bytes_read); std::shared_ptr messenger_; std::shared_ptr pending_calls_; std::shared_ptr rpc_channel_; std::shared_ptr management_api_; std::shared_ptr processor_; std::array buffer_; TerminateCallback terminate_callback_; }; } // namespace container } // namespace anbox #endif