socket_listener.hxx

Go to the documentation of this file.

 
#ifndef _UTILS_SOCKET_LISTENER_HXX_
#define _UTILS_SOCKET_LISTENER_HXX_
 
#include <functional>
 
#include "os/OS.hxx"
 
class SocketListener
{
public:
    typedef std::function<void(int)> connection_callback_t;
 
    SocketListener(int port, connection_callback_t callback,
                   const char *thread_name = "accept_thread");
    ~SocketListener();
 
    void AcceptThreadBody();
 
    void shutdown();
 
    bool is_started()
    {
        return startupComplete_;
    }
 
private:
    volatile unsigned startupComplete_ : 1;
    volatile unsigned shutdownRequested_ : 1;
    volatile unsigned shutdownComplete_ : 1;
    int port_;
    connection_callback_t callback_;
    OSThread accept_thread_;
};
 
int ConnectSocket(const char *host, int port);
 
int ConnectSocket(const char *host, const char* port_str);
 
#endif //_UTILS_SOCKET_LISTENER_HXX_