GxP2PSyncManager.h

Go to the documentation of this file.

//===========================================================================
//===========================================================================
#pragma once
 
GX_P2P_NAMESPACE_BEGIN()
 
//---- クラス宣言
class GxP2PSessionManager;
 
//===========================================================================
//===========================================================================
class GxP2PSyncManager
{
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    static constexpr nu32   NETWORK_GAMER_MAX = GxMath::VALUE_8;
    static constexpr nu32   PACKET_SIZE_MAX = GxMath::VALUE_32;
    static constexpr nu32   BATCH_COUNT_MIN = GxMath::VALUE_1;
    static constexpr nu32   BATCH_COUNT_MAX = GxMath::VALUE_4;
 
    enum class SYNC_STATUS
    {
        STOP = 0,   
        SYNC,       
        WAIT        
    };
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    GxP2PSyncManager(void);
    virtual ~GxP2PSyncManager(void);
 
    void initialize(GxP2PSessionManager* pSessionManager);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    void update(nu32 elapsedTime);
 
    b32 start(void);
    b32 end(void);
 
    SYNC_STATUS sendData(const void* pData);
    SYNC_STATUS receiveData(void);
 
    void getReceiveData(nu32 gamerIndex, void* pData);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    void setSyncDataSize(nu32 syncDataSize, nu32 batchPacketCount = BATCH_COUNT_MIN);
    GX_FORCE_INLINE u32 getFrameSend(void) const { return _syncInstance.getFrameSend(); }
    GX_FORCE_INLINE u32 getFrameRecieve(void) const { return _syncInstance.getFrameRecv(); }
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
private:
    GxP2PSessionManager*        _pSessionManager;                                                       
    MyNetLib::MyNetworkSync     _syncInstance;                                                          
    nu8                         _sendBuffer[BATCH_COUNT_MAX * PACKET_SIZE_MAX];                         
    nu8                         _recieveBuffer[NETWORK_GAMER_MAX][BATCH_COUNT_MAX * PACKET_SIZE_MAX];   
    nu32                        _packetSize;                                                            
    nu32                        _batchPacketCount;                                                      
    nu32                        _sendPacketCount;                                                       
    nu32                        _recievePacketCount;                                                    
 
};
 
GX_P2P_NAMESPACE_END()