exchange_to_client_processor.hpp

Go to the documentation of this file.

#ifndef ISIMUD_EXCHANGES_COMMON_EXCHANGE_TO_CLIENT_PROCESSOR_HPP
#define ISIMUD_EXCHANGES_COMMON_EXCHANGE_TO_CLIENT_PROCESSOR_HPP
 
/******************************************************************************
** Copyright © 2016 by J.M.McGuiness, isimud@hussar.me.uk
**
** This library is free software; you can redistribute it and/or
** modify it under the terms of the GNU Lesser General Public
** License as published by the Free Software Foundation; either
** version 2.1 of the License, or (at your option) any later version.
**
** This library is distributed in the hope that it will be useful,
** but WITHOUT ANY WARRANTY; without even the implied warranty of
** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
** Lesser General Public License for more details.
**
** You should have received a copy of the GNU Lesser General Public
** License along with this library; if not, write to the Free Software
** Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
 
#include "core/jthread.hpp"
#include "core/ttypes.hpp"
 
#include <boost/exception_ptr.hpp>
#include <boost/mpl/assert.hpp>
 
#include <atomic>
 
namespace isimud { namespace ISIMUD_VER_NAMESPACE { namespace exchanges { namespace common {
 
/**
* \todo
* -# We need to write to the dest_skt found using the xdest in the msg in the unordered_tuple of exchange_to_client_processor passed as a template parameter & fn arg.
* -# Pass this up to the client_to_exchange_transformations & link_t.
* -# The client_to_exchange_transformations should contain the unordered_tuple of exchange_to_client_transformations (which contain the connections to the various exchanges).
*/
template<class ClientCxnPtr, class EchgCxn>
class exchange_to_client_processor final {
public:
   using client_connection_t=ClientCxnPtr;
   using exchg_link_t=EchgCxn;
   using conn_pol_t=typename exchg_link_t::conn_pol_t;
   using exchange_msg_details_t=typename exchg_link_t::msg_details_t;
   using proc_rules_t=typename exchg_link_t::proc_rules_t;
   using socket_t=typename exchg_link_t::socket_t;
   using socket_priority=typename exchg_link_t::socket_priority;
   using ctor_args=typename exchg_link_t::ctor_args;
 
   template<class LatencyTimestamps>
   exchange_to_client_processor(std::atomic<bool> &e, ctor_args const &exchange_cxn_details, socket_priority to_exchg_priority, proc_rules_t const &proc_rules, LatencyTimestamps &timestamps);
 
   bool is_logged_on() const noexcept(true);
   void connect_client(client_connection_t client_connection) noexcept(true);
   socket_t &socket() noexcept(true);
   std::string to_string() const noexcept(false);
 
private:
   /**
    * This class manages sending messages received from the exchange, translating them and returning them to the connected client. Naturally this is done on a separate, single thread.
    */
   class flow;
 
   exchg_link_t exchg_link;
   flow exchange_to_client;
};
 
template<class ClientCxnPtr, class ServerCxn>
inline std::ostream &
operator<<(std::ostream &os, exchange_to_client_processor<ClientCxnPtr, ServerCxn> const &s) noexcept(false);
 
} } } }
 
#include "exchange_to_client_processor_impl.hpp"
 
#endif