AsyncTcpPrioClient.h

Go to the documentation of this file.

 
#ifndef ASYNC_TCP_PRIO_CLIENT_INCLUDED
#define ASYNC_TCP_PRIO_CLIENT_INCLUDED
 
 
/****************************************************************************
 *
 * System Includes
 *
 ****************************************************************************/
 
#include <cassert>
 
 
/****************************************************************************
 *
 * Project Includes
 *
 ****************************************************************************/
 
#include <AsyncTcpClient.h>
#include <AsyncTcpPrioClientBase.h>
#include <AsyncDnsLookup.h>
#include <AsyncTimer.h>
#include <AsyncApplication.h>
 
 
/****************************************************************************
 *
 * Local Includes
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Forward declarations
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Namespace
 *
 ****************************************************************************/
 
namespace Async
{
 
 
/****************************************************************************
 *
 * Forward declarations of classes inside of the declared namespace
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Defines & typedefs
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Exported Global Variables
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Class definitions
 *
 ****************************************************************************/
 
template <typename ConT=TcpConnection>
class TcpPrioClient : public ConT, public TcpPrioClientBase
{
  public:
    explicit TcpPrioClient(size_t recv_buf_len = ConT::DEFAULT_RECV_BUF_LEN)
      : ConT(recv_buf_len), TcpPrioClientBase(this) {}
 
    TcpPrioClient(const TcpPrioClient&) = delete;
 
    TcpPrioClient& operator=(const TcpPrioClient&) = delete;
 
    virtual ~TcpPrioClient(void) {}
 
    virtual void disconnect(void)
    {
      //std::cout << "### TcpPrioClient::disconnect" << std::endl;
      TcpPrioClientBase::disconnect();
    }
 
  protected:
    using ConT::operator=;
    using TcpPrioClientBase::operator=;
 
    virtual void closeConnection(void)
    {
      ConT::closeConnection();
      TcpPrioClientBase::closeConnection();
    }
 
    virtual void onDisconnected(TcpConnection::DisconnectReason reason)
    {
      //std::cout << "### TcpPrioClient::onDisconnected:"
      //          << std::endl;
      ConT::onDisconnected(reason);
      TcpPrioClientBase::onDisconnected(reason);
    }
 
    virtual TcpClientBase* newTcpClient(void) override
    {
      return new TcpClient<ConT>;
    }
 
    virtual void emitDisconnected(TcpConnection::DisconnectReason reason)
    {
      ConT::emitDisconnected(reason);
    }
 
  private:
    TcpPrioClient<ConT>& operator=(TcpClient<ConT>&& other)
    {
      //std::cout << "### TcpPrioClient::operator=(TcpClient<ConT>&&)"
      //          << std::endl;
      *static_cast<TcpClientBase*>(this) =
        std::move(*static_cast<TcpClientBase*>(&other));
      return *this;
    }
};  /* class TcpPrioClient */
 
 
} /* namespace Async */
 
#endif /* ASYNC_TCP_PRIO_CLIENT_INCLUDED */
 
/*
 * This file has not been truncated
 */