ServerHandleImpl.h

Go to the documentation of this file.

// ServerHandleImpl.h

// Declares the cServerHandleImpl class implementing the TCP server functionality

// This is an internal header, no-one outside OSSupport should need to include it; use Network.h instead





#pragma once

#include "Network.h"
#include <event2/listener.h>
#include "CriticalSection.h"





// fwd:
class cTCPLinkImpl;
typedef std::shared_ptr<cTCPLinkImpl> cTCPLinkImplPtr;
typedef std::vector<cTCPLinkImplPtr> cTCPLinkImplPtrs;
class cServerHandleImpl;
typedef std::shared_ptr<cServerHandleImpl> cServerHandleImplPtr;
typedef std::vector<cServerHandleImplPtr> cServerHandleImplPtrs;





class cServerHandleImpl:
    public cServerHandle
{
    typedef cServerHandle super;
    friend class cTCPLinkImpl;

public:
    virtual ~cServerHandleImpl() override;

    static cServerHandleImplPtr Listen(
        UInt16 a_Port,
        cNetwork::cListenCallbacksPtr a_ListenCallbacks
    );

    // cServerHandle overrides:
    virtual void Close(void) override;
    virtual bool IsListening(void) const override { return m_IsListening; }

protected:
    cNetwork::cListenCallbacksPtr m_ListenCallbacks;

    evconnlistener * m_ConnListener;

    evconnlistener * m_SecondaryConnListener;

    bool m_IsListening;

    cTCPLinkImplPtrs m_Connections;

    cCriticalSection m_CS;

    int m_ErrorCode;

    AString m_ErrorMsg;

    cServerHandleImplPtr m_SelfPtr;



    cServerHandleImpl(cNetwork::cListenCallbacksPtr a_ListenCallbacks);

    bool Listen(UInt16 a_Port);

    static void Callback(evconnlistener * a_Listener, evutil_socket_t a_Socket, sockaddr * a_Addr, int a_Len, void * a_Self);

    void RemoveLink(const cTCPLinkImpl * a_Link);
};