warsocketengine.h

ftpserver very good sample

/** 

  There must be one WarSocketEngine object in
  each therad using WarSocket* object.

  The engine handles global data for sockets and
  calls system-dependent initializion routines.

  The applications main-thread must cerate it's 
  engine before any worker-therads, as the first 
  created object will be used as a shared object.

*/

#ifndef WAR_SOCKET_ENGINE_H
#define WAR_SOCKET_ENGINE_H

/* SYSTEM INCLUDES */


/* PROJECT INCLUDES */

#ifndef WAR_CRITICAL_SECTION_H
#   include "WarCriticalSection.h"
#endif

#ifndef WAR_EXCEPTION_H
#   include "WarException.h"
#endif

/* LOCAL INCLUDES */


/* FORWARD REFERENCES */

class WarSocketIo;

#ifdef __cplusplus
extern "C" 
{
#endif
/****************** BEGIN OLD STYLE C spesific ********/


/****************** END OLD STYLE C spesific **********/
#ifdef __cplusplus 
}
#endif

/****************** BEGIN C++ spesific ****************/

#ifdef __cplusplus

class WarSocketEngine 
{
public:
    // LIFECYCLE
    
    /**
    * Default constructor.
    */
    WarSocketEngine(void);
    
    
    /**
    * Destructor.
    */
    ~WarSocketEngine(void);
    
    // OPERATORS
    // OPERATIONS                       

    static war_int64_t GetNewSeqNumber() 
        throw(WarException);

    static size_t GetNumberOfCurrentSockets()
        throw(WarException);

    static void RegisterSocket(WarSocketIo *pSocket)
        throw(WarException);

    static void UnregisterSocket(WarSocketIo *pSocket)
        throw(WarException);

    // ACCESS

    static WarSocketEngine& GetSharedEngine()
        throw(WarException)
    {
        if (mpShared == NULL)
            WarThrow(WarError(WAR_ERR_INTERNAL_DATA_NOT_INITIALIZED), NULL);
        return *mpShared;
    }

    // INQUIRY

    bool IsShared() const
    {
        return mpShared == this;
    }
    
protected:
private:
    WarCriticalSection mLock;
    war_int64_t mCurrSeqNumber;
    size_t mNumSocketsInUse;

    static WarSocketEngine *mpShared; // Shared for all therads
};

/* INLINE METHODS */

/* EXTERNAL REFERENCES */

#endif /* __cplusplus */

/****************** END C++ spesific ******************/

#endif  /* WarSocketEngine_h_ */