GcTcpHub.hxx

Go to the documentation of this file.

 
#ifndef _UTILS_GCTCPHUB_HXX_
#define _UTILS_GCTCPHUB_HXX_
 
#include "utils/socket_listener.hxx"
#include "utils/Hub.hxx"
 
class ExecutorBase;
 
class GcTcpHub : private Notifiable, private Atomic
{
public:
    GcTcpHub(CanHubFlow *can_hub, int port);
    ~GcTcpHub();
 
    bool is_started()
    {
        return tcpListener_.is_started();
    }
 
    unsigned get_num_clients()
    {
        return numClients_;
    }
 
private:
    void on_new_connection(int fd);
 
    void notify() override;
 
    CanHubFlow *canHub_;
    unsigned numClients_ {0};
    SocketListener tcpListener_;
};
 
#endif // _UTILS_GCTCPHUB_HXX_