IDataLoader.h

#pragma once
#include "NPLMessageQueue.h"
#include <boost/noncopyable.hpp>

namespace ParaEngine
{
    class IDataLoader
    {
    public:
        virtual ~IDataLoader(){};

        virtual const char* GetFileName() {return 0;};

        virtual const char* GetKeyName() {return 0;};
        
        virtual HRESULT Decompress( void** ppData, int* pcBytes ) = 0;
        virtual HRESULT Destroy() = 0;
        virtual HRESULT Load() = 0;

        virtual void SetEstimatedSizeInBytes(int nSize) {};

        virtual int GetEstimatedSizeInBytes() {return 0;};

        virtual bool IsDeviceObject() { return true; };
    };


    class IProcessorWorkerData
    {
    public:
        virtual int GetProcessorQueueID(){return 0;};

        virtual void* GetCurlInterface(int nID = 0) {return NULL;};

        virtual void AddBytesProcessed(int nBytesProcessed) {};

        virtual int GetBytesProcessed() {return 0;};
    };

    class IDataProcessor
    {
    public:
        virtual ~IDataProcessor(){};

        virtual HRESULT LockDeviceObject() = 0;
        virtual HRESULT UnLockDeviceObject() = 0;
        virtual HRESULT Destroy() = 0;
        virtual HRESULT Process( void* pData, int cBytes ) = 0;
        virtual HRESULT CopyToResource() = 0;
        virtual void SetResourceError() = 0;

        virtual void SetProcessorWorkerData(IProcessorWorkerData * pThreadLocalData ) {};
        virtual IProcessorWorkerData * GetProcessorWorkerData() {return NULL;};

        virtual bool IsDeviceObject() { return true; };
    };


    enum ResourceRequestType
    {
        ResourceRequestType_Local,
        ResourceRequestType_Asset,
        ResourceRequestType_Web,
        ResourceRequestType_Quit,
    };

    enum ResourceRequestID
    {
        ResourceRequestID_Local = 0,
        ResourceRequestID_Asset,
        ResourceRequestID_Web,
        ResourceRequestID_Asset_BigFile,
        ResourceRequestID_AudioFile,
    };

    struct ResourceRequest : 
        public ParaEngine::PoolBase<ResourceRequest>,
        public ParaEngine::intrusive_ptr_thread_safe_base,
        private boost::noncopyable
    {
        ResourceRequest(ResourceRequestType nType = ResourceRequestType_Local):m_nType(nType),m_pDataLoader(NULL), m_pDataProcessor(NULL), m_ppDeviceObject(NULL), m_pHR(NULL), m_nProcessorQueueID(0), m_last_error_code(S_OK) {}
        virtual ~ResourceRequest();

        ResourceRequestType m_nType;

        IDataLoader* m_pDataLoader;
        IDataProcessor* m_pDataProcessor;
        HRESULT* m_pHR;
        HRESULT m_last_error_code;
        void** m_ppDeviceObject;
        int m_nProcessorQueueID;

        bool m_bLock;
        bool m_bCopy;
        bool m_bError;
    };
    typedef ParaIntrusivePtr<ResourceRequest> ResourceRequest_ptr;

    class CResourceRequestQueue : public NPL::concurrent_ptr_queue<ResourceRequest_ptr>
    {
    public:
        CResourceRequestQueue();
        CResourceRequestQueue(int capacity);
        ~CResourceRequestQueue();

        BufferStatus try_push(ResourceRequest_ptr& item);
    };
}