GxDebugCommunication.h

Go to the documentation of this file.

//===========================================================================
//===========================================================================
#pragma once
 
GX_CORE_NAMESPACE_BEGIN()
 
#if GX_DEVELOP
 
//===========================================================================
//===========================================================================
class GxDebugCommunicationBase : public GxClassBase
{
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    // RTTI定義
    GX_RTTI_ABSTRACT_CLASS(GxDebugCommunicationBase, GxClassBase)
    // new, delete定義
    GX_OPERATOR_NEW_DELETE(GxAllocatorList::ALLOCATOR_TYPE::DEVELOP)
    // GxClassBase継承クラス用禁止宣言
    GX_PROHIBIT_CLASS_BASE(GxDebugCommunicationBase)
 
public:
#if defined(_PS4) || defined(_PS5) || defined(_XBOX_XS)
    static constexpr u32 PACKET_MAX_SIZE        = GxMath::VALUE_1K * 64;
    static constexpr u32 RECEIVE_MAX_SIZE       = PACKET_MAX_SIZE;
#elif defined(_WINDOWS)
    static constexpr u32 PACKET_MAX_SIZE        = GxMath::VALUE_1K;
    static constexpr u32 RECEIVE_MAX_SIZE       = PACKET_MAX_SIZE;
#elif defined(_NX64)
    static constexpr u32 PACKET_MAX_SIZE        = GxMath::VALUE_1K * 54;    // NX htcs 制限値
    static constexpr u32 RECEIVE_MAX_SIZE       = PACKET_MAX_SIZE;
#endif  // _NX64
 
    struct GxPacketHeader
    {
        u32                 _command;                           
        u16                 _bodySize;                          
        u8                  _isReply;                           
        u8                  _padding;                           
    };
 
    typedef void (*PACKET_ANALYSE_CALLBACK)(const GxPacketHeader& header, const void* pBody);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
 
public:
    GxDebugCommunicationBase(void);
    ~GxDebugCommunicationBase(void);
 
    virtual b32 initialize(u32 receiveBufferSize = GxDebugCommunicationBase::RECEIVE_MAX_SIZE);
    virtual void terminate(void);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    virtual void update(void){}
 
    virtual b32 send(const void* /*pData*/ = nullptr, u32 /*size*/ = 0, b32 /*isOutputTrace*/ = true){ return false; }
 
    static u16 getNetworkToPlatform(u16 value);                             
    static s16 getNetworkToPlatform(s16 value);
    static u32 getNetworkToPlatform(u32 value);
    static s32 getNetworkToPlatform(s32 value);
    static u64 getNetworkToPlatform(u64 value);
    static s64 getNetworkToPlatform(s64 value);
    static f32 getNetworkToPlatform(f32 value);
    static f64 getNetworkToPlatform(f64 value);                             
 
    static u16 getPlatformToNetwork(u16 value);
    static s16 getPlatformToNetwork(s16 value);
    static u32 getPlatformToNetwork(u32 value);
    static s32 getPlatformToNetwork(s32 value);
    static u64 getPlatformToNetwork(u64 value);
    static s64 getPlatformToNetwork(s64 value);
    static f32 getPlatformToNetwork(f32 value);
    static f64 getPlatformToNetwork(f64 value);                             
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    b32 isConnected(void)                               const   { return _isConnected; }
    constexpr void setAnalyseCallback(PACKET_ANALYSE_CALLBACK callback) { _pAnalyseCallback = callback; }
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
protected:
    static GxCriticalSection    _criticalSection;                           
    GX_STR                      _receiveBuffer;                             
    b32                         _isConnected;                               
    PACKET_ANALYSE_CALLBACK     _pAnalyseCallback;                          
    u32                         _receiveBufferSize;                         
 
};
 
#if defined(_WINDOWS) || defined(_XBOX_XS)
//===========================================================================
//===========================================================================
class GxDebugCommunicationPC : public GxDebugCommunicationBase
{
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    // RTTI定義
    GX_RTTI_CLASS(GxDebugCommunicationPC, GxDebugCommunicationBase)
    // GxClassBase継承クラス用禁止宣言
    GX_PROHIBIT_CLASS_BASE(GxDebugCommunicationPC);
 
private:
    static constexpr u16 COMMUNICATION_PORT  = 5631;
 
    class GxReceiveThread : public GxThread
    {
        //-----------------------------------------------------------
        //-----------------------------------------------------------
    public:
        void threadMain(void* pArgument) override;
    private:
        static s32 receive(SOCKET& socket, void* pData, s32 size);
 
    };
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    GxDebugCommunicationPC(void);
 
    b32 initialize(u32 receiveBufferSize = GxDebugCommunicationBase::RECEIVE_MAX_SIZE) override;
    void terminate(void) override;
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    b32 send(const void* pData, u32 size, b32 isOutputTrace = true) override;
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
private:
    GxReceiveThread*        _pReceiveThread;                
    b32                     _isStopRequestThread;           
    SOCKET                  _server;                        
    SOCKET                  _socket;                        
 
};
 
#elif defined(_PS4) || defined(_PS5)
//===========================================================================
//===========================================================================
class GxDebugCommunicationPS : public GxDebugCommunicationBase
{
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    // RTTI定義
    GX_RTTI_CLASS(GxDebugCommunicationPS, GxDebugCommunicationBase)
    // GxClassBase継承クラス用禁止宣言
    GX_PROHIBIT_CLASS_BASE(GxDebugCommunicationPS);
 
private:
    static constexpr u16            COMMUNICATION_PORT  = 5631;
 
    class GxReceiveThread : public GxThread
    {
        //-----------------------------------------------------------
        //-----------------------------------------------------------
    public:
        void threadMain(void* pArgument) override;
    private:
        static s32 receive(GxNativeNetworkId& socket, void* pData, s32 size);
 
    };
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    GxDebugCommunicationPS(void);
 
    b32 initialize(u32 receiveBufferSize = GxDebugCommunicationBase::RECEIVE_MAX_SIZE) override;
    void terminate(void) override;
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    b32 send(const void* pData, u32 size, b32 isOutputTrace = true) override;
private:
    static void closeConnection(GxNativeNetworkId sid );
 
    static s32 controlAddSocket(GxNativeNetworkId eid, GxNativeNetworkId sid, GxNativeNetworkEvent* pEvent );
 
    static s32 controlDeleteSocket(GxNativeNetworkId eid, GxNativeNetworkId sid );
 
    static s32 doAccept(GxNativeNetworkId eid, GxNativeNetworkEvent* pEvent );
 
    static s32 doReceive(GxNativeNetworkId eid, GxNativeNetworkEvent* pEvent, void* pData, s32 dataSize, s32 receiveFlags = 0 );
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
private:
    GxReceiveThread*        _pReceiveThread;                
    b32                     _isStopRequestThread;           
    GxNativeNetworkId       _server;                        
    GxNativeNetworkId       _socket;                        
    GxNativeNetworkId       _epollId;                       
 
};
 
#elif defined(_NX64)
//===========================================================================
//===========================================================================
class GxDebugCommunicationNX : public GxDebugCommunicationBase
{
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    // RTTI定義
    GX_RTTI_CLASS(GxDebugCommunicationNX, GxDebugCommunicationBase)
    // GxClassBase継承クラス用禁止宣言
    GX_PROHIBIT_CLASS_BASE(GxDebugCommunicationNX);
 
private:
    static GX_CSTR                      COMMUNICATION_NAME;  
    static constexpr s32                    INVALID_ID = (-1);
 
    class GxReceiveThread : public GxThread
    {
        //-----------------------------------------------------------
        //-----------------------------------------------------------
    public:
        void threadMain(void* pArgument) override;
 
    };
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
 
public:
    GxDebugCommunicationNX(void);
 
    b32 initialize(u32 receiveBufferSize = GxDebugCommunicationBase::RECEIVE_MAX_SIZE) override;
    void terminate(void) override;
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    b32 send(const void* pData, u32 size, b32 isOutputTrace = true) override;
private:
    void HtcsSocketErrorOutput(s32 id);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
 
private:
    GxReceiveThread* _pReceiveThread;   
    b32 _isStopRequestThread;           
    s32 _server;                        
    s32 _socket;                        
 
};
 
#endif  // _NX64
 
#endif  // GX_DEVELOP
 
GX_CORE_NAMESPACE_END()