mxdiskstreamprovider.h

Go to the documentation of this file.

#ifndef MXDISKSTREAMPROVIDER_H
#define MXDISKSTREAMPROVIDER_H
 
#include "compat.h"
#include "decomp.h"
#include "mxcriticalsection.h"
#include "mxdsaction.h"
#include "mxstreamprovider.h"
#include "mxthread.h"
 
class MxDiskStreamProvider;
class MxDSStreamingAction;
 
class MxDiskStreamProviderThread : public MxThread {
public:
    MxDiskStreamProviderThread() : MxThread() { m_target = NULL; }
 
    MxResult Run() override;
 
    MxResult StartWithTarget(MxDiskStreamProvider* p_target);
 
protected:
    MxDiskStreamProvider* m_target;
};
 
class MxDiskStreamProvider : public MxStreamProvider {
public:
    MxDiskStreamProvider();
    ~MxDiskStreamProvider() override;
 
    const char* ClassName() const override;
 
    MxBool IsA(const char* p_name) const override;
 
    MxResult WaitForWorkToComplete();
 
    MxResult FUN_100d1780(MxDSStreamingAction* p_action);
 
    void PerformWork();
 
    static MxBool FUN_100d1af0(MxDSStreamingAction* p_action);
 
    MxResult FUN_100d1b20(MxDSStreamingAction* p_action);
 
    MxResult SetResourceToGet(MxStreamController* p_resource) override;
 
    MxU32 GetFileSize() override;
 
    MxS32 GetStreamBuffersNum() override;
 
    void VTable0x20(MxDSAction* p_action) override;
 
    MxU32 GetLengthInDWords() override;
 
    MxU32* GetBufferForDWords() override;
 
protected:
    MxDiskStreamProviderThread m_thread; // 0x10
 
    MxSemaphore m_busySemaphore;         // 0x2c
 
    MxBool m_remainingWork;              // 0x34
 
    MxBool m_unk0x35;                    // 0x35
 
    MxCriticalSection m_criticalSection; // 0x38
 
    MxDSObjectList m_list;               // 0x54
};
 
#endif // MXDISKSTREAMPROVIDER_H