From 64922e213ac731279cf3341253e67509adb2dfc8 Mon Sep 17 00:00:00 2001 From: Felix Morgner Date: Fri, 16 Sep 2022 21:36:12 +0200 Subject: wanda: restructure source directory --- include/wanda/control_connection.hpp | 114 ----------------------------------- 1 file changed, 114 deletions(-) delete mode 100644 include/wanda/control_connection.hpp (limited to 'include/wanda/control_connection.hpp') diff --git a/include/wanda/control_connection.hpp b/include/wanda/control_connection.hpp deleted file mode 100644 index b692d37..0000000 --- a/include/wanda/control_connection.hpp +++ /dev/null @@ -1,114 +0,0 @@ -#ifndef WANDA_CONTROL_CONNECTION_HPP -#define WANDA_CONTROL_CONNECTION_HPP - -#include -#include - -#include - -#include -#include -#include -#include -#include -#include - -namespace wanda -{ - /** - * @brief A connection to a remote control endpoint - */ - struct control_connection : keyed, std::enable_shared_from_this - { - using protocol = asio::local::stream_protocol; - using pointer = std::shared_ptr; - - /** - * @brief The interface to be implemented by the control interface listener - */ - struct listener - { - virtual void on_close(pointer connection) {} - virtual void on_received(pointer connection, message message) {} - virtual void on_error(pointer connection, std::error_code) {} - }; - - /** - * @brief A enum to describe different connection states - */ - enum struct state : std::underlying_type_t - { - unknown, //< Connection is in an unknown state - fresh, //< Connection is freshly created but not established - established, //< Connection has been established - }; - - /** - * @internal - * @brief Construct a new control connection object - * - * @note This constructor is keyed on a private key type so it can only be constructed using the #wanda::make_connection factory - */ - control_connection(key, protocol::socket socket); - - /** - * @brief Add the given listener to this control connection's listener set - * - * @returns true iff. the listener was not already in the listener set - */ - bool add(listener * listener); - - /** - * @brief Remove the given listener from this control connection's listener set - * - * @return true iff. the listener was previously registered with this control connection - */ - bool remove(listener * listener); - - /** - * @brief Start I/O processing for this control connection - */ - void start(); - - /** - * @brief Close this control connection - */ - void close(); - - /** - * @brief Send the given message to the remote endpoint - */ - void send(message message); - - /** - * @brief Set the connection state to the provided state - */ - void update(state state); - - /** - * @brief Get the current connection state - */ - state current_state() const; - - private: - friend pointer make_control_connection(protocol::socket && socket); - - void perform_read(); - - protocol::socket m_socket; - asio::streambuf m_in{}; - asio::streambuf m_out{}; - std::istream m_input{&m_in}; - std::ostream m_output{&m_out}; - std::set m_listeners{}; - state m_state{}; - }; - - /** - * @brief Create a new control connection - */ - control_connection::pointer make_control_connection(control_connection::protocol::socket && socket); - -} // namespace wanda - -#endif \ No newline at end of file -- cgit v1.2.3