GxP2PMessageManager.h

Go to the documentation of this file.

//===========================================================================
//===========================================================================
#pragma once
 
GX_P2P_NAMESPACE_BEGIN()
 
//---- クラス宣言
class GxP2PSessionManager;
 
//===========================================================================
//===========================================================================
class GxP2PMessageManager
{
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    static constexpr size_t INNER_BUFFER_SIZE = GxMath::VALUE_512;
 
    struct GxMessageHeader
    {
        nu32                _id;                            
        nu32                _kind;                          
        size_t              _size;                          
    };
    
    static const size_t     MESSAGE_HEADER_SIZE    = sizeof(GxMessageHeader);
    static const size_t     MESSAGE_BODY_MAX       = INNER_BUFFER_SIZE - MESSAGE_HEADER_SIZE;
 
    struct GxMessageAll
    {
        GxMessageHeader     _header;                        
        GX_CHAR             _body[MESSAGE_BODY_MAX];        
    };
    
    static const size_t     MESSAGE_QUEUE_BLOCK_NUM = GxMath::VALUE_128;
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    GxP2PMessageManager(void);
    ~GxP2PMessageManager(void);
 
    void initialize(GxP2PSessionManager* pSessionManager);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    b32 sendMessageUnicast(nu32 id, nu32 kind, const void* pData, size_t size);
    b32 sendMessageMulticast(nu32 kind, const void* pData, size_t size);
 
private:
    size_t createMessage(GX_STR dstBuffer, size_t bufferSize, nu32 kind, const void* pData, size_t size);
    b32 transportMessage(void);
    b32 transportMessage(nu8 id, const void* pBuffer, size_t size);
    b32 transportMessage(const void* pBuffer, size_t size);
 
public:
    void   update(void);
    b32 dequeueRecieveQueue(GxP2PMessageManager::GxMessageAll& output);
    GX_FORCE_INLINE nu32 getRecieveQueueNum(void)   const { return _recieveQueue.getQueueNum(); }
#if GX_DEVELOP
    GX_FORCE_INLINE nu32 getRecieveQueueMaxNum(void) const { return _recieveQueue.getMaxQueueNum(); }
#endif  // GX_DEVELOP
 
private:
    void analyzeRecvMessage(GX_STR buffer, size_t size);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
private:
    constexpr GX_CSTR getSendBuffer(void) const { return _sendBuffer; }
    GX_FORCE_INLINE GX_STR getFreePointer(void) { return &_sendBuffer[_sendUsedSize]; }
    constexpr size_t getFreeSize(void) const { return INNER_BUFFER_SIZE - _sendUsedSize; }
    constexpr size_t getUsedSize(void) const { return _sendUsedSize; }
    constexpr void addUsedSize(size_t size) { _sendUsedSize += size; }
    constexpr void clearUsedSize(void) { _sendUsedSize = 0; }
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
private:
    GxP2PSessionManager*                        _pSessionManager;                   
    GX_CHAR                                     _recieveBuffer[INNER_BUFFER_SIZE];  
    GX_CHAR                                     _sendBuffer[INNER_BUFFER_SIZE];     
    size_t                                      _sendUsedSize;                      
    GxP2PQueue<GxMessageAll, MESSAGE_QUEUE_BLOCK_NUM>   _recieveQueue;              
 
};
 
GX_P2P_NAMESPACE_END()