GcTcpHub.cxx

Go to the documentation of this file.

 
#include "utils/GcTcpHub.hxx"
 
#include <memory>
 
#include "nmranet_config.h"
#include "utils/GridConnectHub.hxx"
#include "utils/FdUtils.hxx"
 
void GcTcpHub::on_new_connection(int fd)
{
    const bool use_select =
        (config_gridconnect_tcp_use_select() == CONSTANT_TRUE);
    {
        AtomicHolder h(this);
        numClients_++;
    }
    // Applies kernel parameters like socket options.
    FdUtils::optimize_socket_fd(fd);
    create_gc_port_for_can_hub(canHub_, fd, this, use_select);
}
 
void GcTcpHub::notify()
{
    AtomicHolder h(this);
    if (numClients_)
    {
        numClients_--;
    }
}
 
GcTcpHub::GcTcpHub(CanHubFlow *can_hub, int port)
    : canHub_(can_hub)
    , tcpListener_(port,
          std::bind(&GcTcpHub::on_new_connection, this, std::placeholders::_1),
          "GcTcpHub")
{
}
 
GcTcpHub::~GcTcpHub()
{
    tcpListener_.shutdown();
}