GxP2PDuplicateManager.h

Go to the documentation of this file.

//===========================================================================
//===========================================================================
#pragma once
 
GX_P2P_NAMESPACE_BEGIN()
 
//---- クラス宣言
class GxP2PSessionManager;
class GxP2PDuplicateObjectBase;
 
//===========================================================================
//===========================================================================
class GxP2PDuplicateManager
{
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    static constexpr u32 DUPLICATE_TABLE_MAX = MyNetLib::MyNetworkDuplicate::DUPLICATE_TABLE_MAX;
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    GxP2PDuplicateManager(void);
    virtual ~GxP2PDuplicateManager(void);
 
    b32 initialize(GxP2PSessionManager* pSessionManager);
    b32 terminate(void);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    b32 update(u32 elapsedTime);
 
    b32 registerObject(GxP2PDuplicateObjectBase* pObject);
    void unregisterObject(GxP2PDuplicateObjectBase* pObject);
    
private:
    static b32 duplicateCheckCallback(nu32 index);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
protected:
    GxP2PSessionManager*                _pSessionManager;                               
    MyNetLib::MyNetworkDuplicate        _duplicateInstance;                             
    
    static GxP2PDuplicateObjectBase*    _pDuplicateObjectArray[DUPLICATE_TABLE_MAX];    
 
};
 
//===========================================================================
//===========================================================================
class GxP2PDuplicateObjectBase : public GxClassBase
{
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    // RTTI定義
    GX_RTTI_CLASS(GxP2PDuplicateObjectBase, GxClassBase)
    // ClassBase継承クラス用禁止宣言
    GX_PROHIBIT_CLASS_BASE(GxP2PDuplicateObjectBase)
 
    // フレンド宣言
    friend class GxP2PDuplicateManager;
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    GxP2PDuplicateObjectBase(void);
    GxP2PDuplicateObjectBase(void* pOriginal, void* pDiffrence, u32 size, b32 isReliable = true);
    ~GxP2PDuplicateObjectBase(void) override;
 
    virtual void initialize(void* pOriginal, void* pDiffrence, u32 size, b32 isReliable = true);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    virtual void update(void* pData);
 
    virtual b32 registerDuplicateObject(u32 myStationId, u32 masterStationId);
    virtual void unregisterDuplicateObject(void);
 
private:
    GX_FORCE_INLINE virtual b32 checkDuplicate(void) { return true; }
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
 
public:
    GX_FORCE_INLINE b32 isRegistered(void) const { return _isRegistered; }
    GX_FORCE_INLINE b32 isMaster(void) const { return (_myStationId == _masterIndex); }
    constexpr u32 getStationId(void) const { return _myStationId; }
    constexpr u32 getMasterIndex(void) const { return _masterIndex; }
    constexpr u32 getDataSize(void) const { return _size; }
    constexpr u32 getUpdateSpan(void) const { return _updateSpan; }
    constexpr void setUpdateSpan(u32 span) { _updateSpan = span; }
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
private:
    u32                         _myStationId;               
    u32                         _masterIndex;               
    void*                       _pOriginal;                 
    void*                       _pDiffrence;                
    u32                         _size;                      
    u32                         _objectIndex;               
    b32                         _isReliable;                
    b32                         _isRegistered;              
    u32                         _updateSpan;                
    u32                         _updateCounter;             
 
};
 
GX_P2P_NAMESPACE_END()