AsyncTcpServer.h

Go to the documentation of this file.

 
#ifndef ASYNC_TCP_SERVER_INCLUDED
#define ASYNC_TCP_SERVER_INCLUDED
 
 
/****************************************************************************
 *
 * System Includes
 *
 ****************************************************************************/
 
#include <string>
#include <vector>
#include <sigc++/sigc++.h>
 
 
/****************************************************************************
 *
 * Project Includes
 *
 ****************************************************************************/
 
#include <AsyncTcpServerBase.h>
 
 
/****************************************************************************
 *
 * Local Includes
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Forward declarations
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Namespace
 *
 ****************************************************************************/
 
namespace Async
{
 
/****************************************************************************
 *
 * Forward declarations of classes inside of the declared namespace
 *
 ****************************************************************************/
 
class FdWatch;
  
 
/****************************************************************************
 *
 * Defines & typedefs
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Exported Global Variables
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Class definitions
 *
 ****************************************************************************/
 
template <typename ConT=TcpConnection>
class TcpServer : public TcpServerBase
{
  public:
    TcpServer(const std::string& port_str,
              const Async::IpAddress &bind_ip=IpAddress())
      : TcpServerBase(port_str, bind_ip)
    {
    }
  
    virtual ~TcpServer(void) {}
  
    ConT *getClient(unsigned int index)
    {
      TcpConnection *con = TcpServerBase::getClient(index);
      return dynamic_cast<ConT*>(con);
    }
 
    sigc::signal<void, ConT*>  clientConnected;
  
    sigc::signal<void, ConT*, typename ConT::DisconnectReason>
            clientDisconnected;
  
  protected:
    virtual void createConnection(int sock, const IpAddress& remote_addr,
                                  uint16_t remote_port) override
    {
      ConT *con = new TcpServerConnection(sock, remote_addr, remote_port);
      con->disconnected.connect(
          mem_fun(*this, &TcpServer<ConT>::onDisconnected));
      addConnection(con);
    }
 
    virtual void emitClientConnected(TcpConnection *con_base) override
    {
      auto con = dynamic_cast<TcpServerConnection*>(con_base);
      con->m_is_connected = true;
      clientConnected(reinterpret_cast<ConT*>(con));
    }
 
  private:
    struct TcpServerConnection : public ConT
    {
      TcpServerConnection(int sock, const IpAddress& remote_addr,
                          uint16_t remote_port)
        : ConT(sock, remote_addr, remote_port)
      {
      }
      virtual TcpConnection& operator=(TcpConnection&& other_base) override
      {
        this->TcpConnection::operator=(std::move(other_base));
        auto& other = dynamic_cast<TcpServerConnection&>(other_base);
        m_is_connected = other.m_is_connected;
        m_is_connected = false;
        return *this;
      }
 
      bool m_is_connected = false;
    };
 
    void onDisconnected(ConT *con_base, typename ConT::DisconnectReason reason)
    {
      auto con = dynamic_cast<TcpServerConnection*>(con_base);
      if (con->m_is_connected)
      {
        con->m_is_connected = false;
        clientDisconnected(con_base, reason);
      }
      removeConnection(con_base);
    }
    
};  /* class TcpServer */
 
 
} /* namespace */
 
#endif /* ASYNC_TCP_SERVER_INCLUDED */
 
 
 
/*
 * This file has not been truncated
 */