socket_server_manager.hpp

Go to the documentation of this file.

#ifndef LIBJMMCG_CORE_SOCKET_SERVER_MANAGER_HPP
#define LIBJMMCG_CORE_SOCKET_SERVER_MANAGER_HPP
 
/******************************************************************************
** Copyright © 2015 by J.M.McGuiness, coder@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 "socket_server_manager_asio.hpp"
#include "socket_server_manager_glibc.hpp"
#include "thread_api_traits.hpp"
 
namespace jmmcg { namespace LIBJMMCG_VER_NAMESPACE { namespace socket { namespace server_manager {
 
/// A simple TCP/IP socket wrapper using a wrapped socket for servers.
template<class SktT>
class manager;
template<class LkT>
class manager<socket::asio::socket_wrapper<LkT>> : public asio::manager<LkT> {
public:
   using base_t=asio::manager<LkT>;
   using socket_t=typename base_t::socket_t;
   using base_t::manager;
};
template<class LkT>
class manager<socket::glibc::client::wrapper<LkT>> : public glibc::manager<LkT> {
public:
   using base_t=glibc::manager<LkT>;
   using socket_t=typename base_t::socket_t;
   using base_t::manager;
};
 
/// A simple TCP/IP socket wrapper using wrapped socket for loop-back servers.
template<class SvrHBs, class SktT>
class loopback;
template<class SvrHBs, class LkT>
class loopback<SvrHBs, socket::asio::socket_wrapper<LkT>> final : public asio::loopback<SvrHBs, LkT> {
public:
   using base_t=asio::loopback<SvrHBs, LkT>;
   using server_to_client_flow_t=typename base_t::server_to_client_flow_t;
   using socket_t=typename base_t::socket_t;
   using socket_priority=typename base_t::socket_priority;
 
   loopback(boost::asio::ip::address const &addr, unsigned short port_num, std::size_t min_message_size, std::size_t max_message_size, unsigned short timeout, socket_priority priority, std::size_t incoming_cpu, server_to_client_flow_t &&server_to_client_flow)
   : base_t(addr, port_num, min_message_size, max_message_size, timeout, priority, incoming_cpu, std::move(server_to_client_flow)) {}
};
template<class SvrHBs, class LkT>
class loopback<SvrHBs, socket::glibc::client::wrapper<LkT>> final : public glibc::loopback<SvrHBs, LkT> {
public:
   using base_t=glibc::loopback<SvrHBs, LkT>;
   using server_to_client_flow_t=typename base_t::server_to_client_flow_t;
   using socket_t=typename base_t::socket_t;
   using socket_priority=typename base_t::socket_priority;
 
   loopback(boost::asio::ip::address const &addr, unsigned short port_num, std::size_t min_message_size, std::size_t max_message_size, unsigned short timeout, socket_priority priority, std::size_t incoming_cpu, server_to_client_flow_t &&server_to_client_flow)
   : base_t(addr, port_num, min_message_size, max_message_size, timeout, priority, incoming_cpu, std::move(server_to_client_flow)) {}
};
 
/// A simple TCP/IP socket wrapper using a wrapped socket for forwarding servers.
template<class SktT>
class forwarding;
template<class LkT>
class forwarding<socket::asio::socket_wrapper<LkT>> final : public asio::forwarding<LkT> {
public:
   using base_t=asio::forwarding<LkT>;
   using server_to_client_flow_t=typename base_t::server_to_client_flow_t;
   using socket_t=typename base_t::socket_t;
   using base_t::forwarding;
};
template<class LkT>
class forwarding<socket::glibc::client::wrapper<LkT>> final : public glibc::forwarding<LkT> {
public:
   using base_t=glibc::forwarding<LkT>;
   using server_to_client_flow_t=typename base_t::server_to_client_flow_t;
   using socket_t=typename base_t::socket_t;
   using base_t::forwarding;
};
 
} } } }
 
#endif