mxstreamer.h

Go to the documentation of this file.

#ifndef MXSTREAMER_H
#define MXSTREAMER_H
 
#include "decomp.h"
#include "mxcore.h"
#include "mxmemorypool.h"
#include "mxnotificationparam.h"
#include "mxstl/stlcompat.h"
#include "mxstreamcontroller.h"
#include "mxtypes.h"
 
#include <assert.h>
 
class MxDSObject;
 
typedef MxMemoryPool<64, 22> MxMemoryPool64; // [AI]
typedef MxMemoryPool<128, 2> MxMemoryPool128; // [AI]
 
class MxStreamerNotification : public MxNotificationParam {
public:
    MxStreamerNotification(NotificationId p_type, MxCore* p_sender, MxStreamController* p_ctrlr)
        : MxNotificationParam(p_type, p_sender)
    {
        m_controller = p_ctrlr;
    }
 
    MxNotificationParam* Clone() const override;
 
    MxStreamController* GetController() { return m_controller; }
 
private:
    MxStreamController* m_controller; 
};
 
class MxStreamer : public MxCore {
public:
    enum OpenMode {
        e_diskStream = 0, 
        e_RAMStream        
    };
 
    MxStreamer();
    ~MxStreamer() override;
 
    MxStreamController* Open(const char* p_name, MxU16 p_openMode);
 
    MxLong Close(const char* p_name);
 
    MxLong Notify(MxParam& p_param) override;
 
    const char* ClassName() const override
    {
        return "MxStreamer";
    }
 
    MxBool IsA(const char* p_name) const override
    {
        return !strcmp(p_name, MxStreamer::ClassName()) || MxCore::IsA(p_name);
    }
 
    virtual MxResult Create();
 
    MxBool FUN_100b9b30(MxDSObject& p_dsObject);
 
    MxStreamController* GetOpenStream(const char* p_name);
 
    void FUN_100b98f0(MxDSAction* p_action);
 
    MxResult AddStreamControllerToOpenList(MxStreamController* p_stream);
 
    MxResult FUN_100b99b0(MxDSAction* p_action);
 
    MxResult DeleteObject(MxDSAction* p_dsAction);
 
    MxU8* GetMemoryBlock(MxU32 p_blockSize)
    {
        switch (p_blockSize) {
        case 0x40:
            return m_pool64.Get();
 
        case 0x80:
            return m_pool128.Get();
 
        default:
            assert("Invalid block size for memory pool" == NULL);
            break;
        }
 
        return NULL;
    }
 
    void ReleaseMemoryBlock(MxU8* p_block, MxU32 p_blockSize)
    {
        switch (p_blockSize) {
        case 0x40:
            m_pool64.Release(p_block);
            break;
 
        case 0x80:
            m_pool128.Release(p_block);
            break;
 
        default:
            assert("Invalid block size for memory pool" == NULL);
            break;
        }
    }
 
private:
    list<MxStreamController*> m_controllers; 
    MxMemoryPool64 m_pool64;                 
    MxMemoryPool128 m_pool128;               
};
 
#endif // MXSTREAMER_H