NetworkSingleton.h

Go to the documentation of this file.

 
// NetworkSingleton.h
 
// Declares the cNetworkSingleton class representing the storage for global data pertaining to network API
// such as a list of all connections, all listening sockets and the LibEvent dispatch thread.
 
// This is an internal header, no-one outside OSSupport should need to include it; use Network.h instead;
// the only exception being the main app entrypoint that needs to call Terminate before quitting.
 
 
 
 
 
#pragma once
 
#include <event2/event.h>
#include "NetworkLookup.h"
#include "CriticalSection.h"
#include "Event.h"
 
 
 
 
 
// fwd:
struct event_base;
class cTCPLink;
typedef std::shared_ptr<cTCPLink> cTCPLinkPtr;
typedef std::vector<cTCPLinkPtr> cTCPLinkPtrs;
class cServerHandle;
typedef std::shared_ptr<cServerHandle> cServerHandlePtr;
typedef std::vector<cServerHandlePtr> cServerHandlePtrs;
 
 
 
 
 
class cNetworkSingleton
{
public:
    cNetworkSingleton();
    ~cNetworkSingleton() noexcept(false);
 
    static cNetworkSingleton & Get(void);
 
    void Initialise(void);
 
    void Terminate(void);
 
    event_base * GetEventBase(void) { return m_EventBase; }
 
    cNetworkLookup & GetLookupThread() { return m_LookupThread; }
 
    void AddLink(const cTCPLinkPtr & a_Link);
 
    void RemoveLink(const cTCPLink * a_Link);
 
    void AddServer(const cServerHandlePtr & a_Server);
 
    void RemoveServer(const cServerHandle * a_Server);
 
protected:
 
    event_base * m_EventBase;
 
    cTCPLinkPtrs m_Connections;
 
    cServerHandlePtrs m_Servers;
 
    cCriticalSection m_CS;
 
    std::atomic<bool> m_HasTerminated;
 
    std::thread m_EventLoopThread;
 
    cEvent m_StartupEvent;
 
    cNetworkLookup m_LookupThread;
 
 
    static void LogCallback(int a_Severity, const char * a_Msg);
 
    static void RunEventLoop(cNetworkSingleton * a_Self);
 
    static void SignalizeStartup(evutil_socket_t a_Socket, short a_Events, void * a_Self);
};