AsyncTcpClientBase.h

Go to the documentation of this file.

 
#ifndef ASYNC_TCP_CLIENT_BASE_INCLUDED
#define ASYNC_TCP_CLIENT_BASE_INCLUDED
 
 
/****************************************************************************
 *
 * System Includes
 *
 ****************************************************************************/
 
#include <sigc++/sigc++.h>
#include <stdint.h>
 
#include <string>
 
 
/****************************************************************************
 *
 * Project Includes
 *
 ****************************************************************************/
 
#include <AsyncTcpConnection.h>
#include <AsyncFdWatch.h>
#include <AsyncDnsLookup.h>
 
 
/****************************************************************************
 *
 * Local Includes
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Forward declarations
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Namespace
 *
 ****************************************************************************/
 
namespace Async
{
 
/****************************************************************************
 *
 * Forward declarations of classes inside of the declared namespace
 *
 ****************************************************************************/
 
class IpAddress;
 
 
/****************************************************************************
 *
 * Defines & typedefs
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Exported Global Variables
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Class definitions
 *
 ****************************************************************************/
 
class TcpClientBase : virtual public sigc::trackable
{
  public:
    explicit TcpClientBase(TcpConnection *con);
 
    TcpClientBase(TcpConnection *con, const std::string& remote_host,
                  uint16_t remote_port);
 
    TcpClientBase(TcpConnection *con, const IpAddress& remote_ip,
                  uint16_t remote_port);
 
    virtual ~TcpClientBase(void);
 
    virtual TcpClientBase& operator=(TcpClientBase&& other);
 
    std::string remoteHostName(void) const
    {
      if (!dns.label().empty())
      {
        return dns.label();
      }
      return con->remoteHost().toString();
    }
 
    void setBindIp(const IpAddress& bind_ip);
 
    const IpAddress& bindIp(void) const { return bind_ip; }
 
    void connect(const std::string &remote_host, uint16_t remote_port);
 
    void connect(const Async::IpAddress& remote_ip, uint16_t remote_port);
 
    void connect(void);
 
    virtual void disconnect(void) = 0;
 
    bool isIdle(void) const { return !dns.isPending() && (sock == -1); }
 
    TcpConnection* conObj(void) { return con; }
 
    sigc::signal<void>                    connected;
 
  protected:
    //virtual bool successfulConnect(void)
    //{
    //  return m_successful_connect;
    //}
 
    virtual void closeConnection(void);
 
    virtual void connectionEstablished(void)
    {
      //m_successful_connect = true;
      emitConnected();
    }
 
    virtual void emitConnected(void)
    {
      connected();
    }
 
  private:
    TcpConnection *   con;
    DnsLookup         dns;
    int               sock;
    FdWatch           wr_watch;
    Async::IpAddress  bind_ip;
    //bool              m_successful_connect  = false;
 
    void dnsResultsReady(DnsLookup& dns_lookup);
    void connectToRemote(void);
    void connectHandler(FdWatch *watch);
 
};  /* class TcpClientBase */
 
 
} /* namespace */
 
#endif /* ASYNC_TCP_CLIENT_BASE_INCLUDED */
 
 
 
/*
 * This file has not been truncated
 */