AsyncTcpPrioClientBase.h

Go to the documentation of this file.

 
#ifndef ASYNC_TCP_PRIO_CLIENT_BASE_INCLUDED
#define ASYNC_TCP_PRIO_CLIENT_BASE_INCLUDED
 
 
/****************************************************************************
 *
 * System Includes
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Project Includes
 *
 ****************************************************************************/
 
#include <AsyncTcpClientBase.h>
#include <AsyncDnsLookup.h>
#include <AsyncTimer.h>
 
 
/****************************************************************************
 *
 * Local Includes
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Forward declarations
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Namespace
 *
 ****************************************************************************/
 
namespace Async
{
 
/****************************************************************************
 *
 * Forward declarations of classes inside of the declared namespace
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Defines & typedefs
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Exported Global Variables
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Class definitions
 *
 ****************************************************************************/
 
class TcpPrioClientBase : public TcpClientBase
{
  public:
    explicit TcpPrioClientBase(TcpConnection *con);
 
    TcpPrioClientBase(TcpConnection *con, const std::string& remote_host,
                      uint16_t remote_port) = delete;
 
    TcpPrioClientBase(TcpConnection *con, const IpAddress& remote_ip,
                      uint16_t remote_port) = delete;
 
    virtual ~TcpPrioClientBase(void);
 
    void setReconnectMinTime(unsigned t);
 
    void setReconnectMaxTime(unsigned t);
 
    void setReconnectBackoffPercent(unsigned p);
 
    void setReconnectRandomizePercent(unsigned p);
 
    void setService(const std::string& srv_name, const std::string& srv_proto,
                    const std::string& srv_domain);
 
    void addStaticSRVRecord(DnsResourceRecordSRV::Ttl     ttl,
                            DnsResourceRecordSRV::Prio    prio,
                            DnsResourceRecordSRV::Weight  weight,
                            DnsResourceRecordSRV::Port    port,
                            DnsResourceRecordSRV::Target  target);
 
    const std::string& service(void) const;
 
    void connect(void);
 
    void connect(const std::string &remote_host,
                 uint16_t remote_port) = delete;
 
    void connect(const Async::IpAddress& remote_ip,
                 uint16_t remote_port) = delete;
 
    virtual void disconnect(void);
 
    void markAsEstablished(void);
 
    bool markedAsEstablished(void) const;
 
    bool isIdle(void) const;
 
    bool isPrimary(void) const;
 
    using TcpClientBase::operator=;
 
  protected:
    virtual void connectionEstablished(void) override;
 
    virtual void onDisconnected(TcpConnection::DisconnectReason reason);
 
    virtual TcpClientBase *newTcpClient(void) = 0;
 
    virtual void emitDisconnected(TcpConnection::DisconnectReason reason) = 0;
 
  private:
    class Machine;
 
    Machine* machine(void) const;
 
    mutable Machine*  m_machine = nullptr;
 
};  /* class TcpPrioClientBase */
 
 
} /* namespace */
 
#endif /* ASYNC_TCP_PRIO_CLIENT_BASE_INCLUDED */
 
 
 
/*
 * This file has not been truncated
 */