GxCurl.h

Go to the documentation of this file.

//===========================================================================
//===========================================================================
#pragma once
 
#if GX_EDITOR
GX_NETWORK_NAMESPACE_BEGIN()
 
//===========================================================================
//===========================================================================
class GxCurl : public GxClassBase
{
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    class GxDownloadThread : public GxThread
    {
        //-------------------------------------------------------------
        //-------------------------------------------------------------
    public:
        GX_RTTI_CLASS(GxDownloadThread, GxThread)
        // GxClassBase継承クラス用禁止宣言
        GX_PROHIBIT_CLASS_BASE(GxDownloadThread)
 
        
        //-----------------------------------------------------------
        //-----------------------------------------------------------
 
        GxDownloadThread(void){}
 
        //-----------------------------------------------------------
        //-----------------------------------------------------------
    public:
        void threadMain(void* pArgument) override;
        GX_FORCE_INLINE void stopRequest(void) { _stopRequest = true; }
    private:
        static size_t bufferWriter(GX_STR pSrc, size_t size, size_t count, void* pFilePointer);
 
        //-----------------------------------------------------------
        //-----------------------------------------------------------
    private:
        b32 _stopRequest;   
 
    };
 
private:
    struct GxDownloadRequest
    {
        GxString                    _url;           
        GxString                    _outputPath;    
        b32                         _unzip;         
        GxCallback::GxHandlerBase   _callback;      
    };
 
public:
    // RTTI定義
    GX_RTTI_CLASS( GxCurl, GxClassBase )
 
    
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    GxCurl(void);
    ~GxCurl(void) override;
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    void downloadAsync(GX_CSTR url, GX_CSTR outputPath, b32 unzip = false, GxCallback::GxHandlerBase* pCallback = nullptr);
    GX_FORCE_INLINE u32 getDownloadRequestCount(void) const { return (_requests.isEmpty() && _downloadProgress >= 100) ? 0 : _requests.getCount() + 1; }
private:
    s32 progressCallback(s64 downloadTotal, s64 downloadNow, s64 uploadTotal, s64 uploadNow);
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
public:
    constexpr f64 getDownloadProgress(void) const { return _downloadProgress; }
    constexpr f64 getUploadProgress(void) const { return _uploadProgress; }
public:
    constexpr void setProgress(f64 downloadProgress, f64 uploadProgress) { _downloadProgress = downloadProgress; _uploadProgress = uploadProgress; }
 
    //-----------------------------------------------------------
    //-----------------------------------------------------------
private:
    CURL*               _pCurl;             
    GxDownloadThread    _downloadThread;    
    GxLockFreeQueue<GxDownloadRequest*, GxAllocatorList::ALLOCATOR_TYPE::DEVELOP>   _requests;  
    f64                 _downloadProgress;  
    f64                 _uploadProgress;    
 
};
 
GX_NETWORK_NAMESPACE_END()
#endif //GX_EDITOR