exchange_connection_impl.hpp

Go to the documentation of this file.

/******************************************************************************
** 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
*/
 
namespace isimud { namespace ISIMUD_VER_NAMESPACE { namespace exchanges { namespace common {
 
template<class ClientCxn, class EchgCxn>
template<class LatencyTimestamps>
inline
exchange_connection<ClientCxn, EchgCxn>::exchange_connection(typename client_link_t::ctor_args const &client_cxn_details, typename exchg_link_t::ctor_args const &exchange_cxn_details, socket_priority to_exchg_priority, socket_priority to_client_priority, exchg_to_client_proc_rules_t const &proc_rules, LatencyTimestamps &timestamps, char const *svr_name)
:  exchg_link_(exit_, exchange_cxn_details, to_exchg_priority, proc_rules, timestamps),
   client_link(
      client_cxn_details,
      exchg_link_.socket(),
      (exchg_link_t::conn_pol_t::max_attempts*exchg_link_t::conn_pol_t::min_timeout).count(),
      to_client_priority,
      typename thread_traits::api_params_type::processor_mask_type(common::thread_traits::client_to_exchange_thread.core),
      common::thread_traits::client_to_exchange_thread.priority,
      timestamps,
      svr_name,
      [this](typename client_link_t::svr_mgr_t::session::ptr_type client_connection) {
         exchg_link_.connect_client(client_connection);
      }
   ) {
}
 
template<class ClientCxn, class EchgCxn> inline
exchange_connection<ClientCxn, EchgCxn>::~exchange_connection() noexcept(false) {
   exit_=true;
}
 
template<class ClientCxn, class EchgCxn> inline bool
exchange_connection<ClientCxn, EchgCxn>::is_logged_on() const noexcept(true) {
   return exchg_link_.is_logged_on();
}
 
template<class ClientCxn, class EchgCxn> inline std::sig_atomic_t
exchange_connection<ClientCxn, EchgCxn>::signal_status() const noexcept(true) {
   return client_link.signal_status();
}
 
template<class ClientCxn, class EchgCxn> inline std::string
exchange_connection<ClientCxn, EchgCxn>::to_string() const noexcept(false) {
   std::ostringstream ss;
   ss
      <<thread_traits::demangle_name(typeid(*this))
      <<",\nexit="<<static_cast<bool>(exit_)
      <<". "<<mic_codes::to_string()
      <<" "<<ccy_codes::to_string()
      <<" "<<ctry_codes::to_string()
      <<" Client link: "<<client_link
      <<", client-to-exchange core: "<<common::thread_traits::client_to_exchange_thread
      <<", exchange links: "<<exchg_link_;
   return ss.str();
}
 
template<class ClientCxn, class EchgCxn> inline std::ostream &
operator<<(std::ostream &os, exchange_connection<ClientCxn, EchgCxn> const &ec) noexcept(false) {
   os<<ec.to_string();
   return os;
}
 
} } } }