mxstreamcontroller.h

Go to the documentation of this file.

#ifndef MXSTREAMCONTROLLER_H
#define MXSTREAMCONTROLLER_H
 
#include "decomp.h"
#include "mxatom.h"
#include "mxcore.h"
#include "mxcriticalsection.h"
#include "mxdsobject.h"
#include "mxdssubscriber.h"
#include "mxnextactiondatastart.h"
#include "mxstl/stlcompat.h"
 
class MxDSAction;
class MxDSStreamingAction;
class MxStreamProvider;
 
class MxNextActionDataStartList : public MxUtilityList<MxNextActionDataStart*> {
public:
    MxNextActionDataStart* Find(MxU32 p_id, MxS16 p_value);
 
    MxNextActionDataStart* FindAndErase(MxU32 p_id, MxS16 p_value);
};
 
class MxStreamController : public MxCore {
public:
    MxStreamController();
 
    ~MxStreamController() override; // vtable+0x00
 
    const char* ClassName() const override // vtable+0x0c
    {
        // STRING: LEGO1 0x10102130
        return "MxStreamController";
    }
 
    MxBool IsA(const char* p_name) const override // vtable+0x10
    {
        return !strcmp(p_name, MxStreamController::ClassName()) || MxCore::IsA(p_name);
    }
 
    virtual MxResult Open(const char* p_filename); // vtable+0x14
 
    virtual MxResult VTable0x18(undefined4, undefined4) { return FAILURE; } // vtable+0x18
 
    virtual MxResult VTable0x1c(undefined4, undefined4) { return FAILURE; } // vtable+0x1c
 
    virtual MxResult VTable0x20(MxDSAction* p_action); // vtable+0x20
 
    virtual MxResult VTable0x24(MxDSAction* p_action); // vtable+0x24
 
    virtual MxDSStreamingAction* VTable0x28() { return NULL; } // vtable+0x28
 
    virtual MxResult VTable0x2c(MxDSAction* p_action, MxU32 p_bufferval); // vtable+0x2c
 
    virtual MxResult VTable0x30(MxDSAction* p_action); // vtable+0x30
 
    void AddSubscriber(MxDSSubscriber* p_subscriber);
 
    void RemoveSubscriber(MxDSSubscriber* p_subscriber);
 
    MxResult FUN_100c1800(MxDSAction* p_action, MxU32 p_val);
 
    MxResult FUN_100c1a00(MxDSAction* p_action, MxU32 p_offset);
 
    MxPresenter* FUN_100c1e70(MxDSAction& p_action);
 
    MxResult FUN_100c1f00(MxDSAction* p_action);
 
    MxBool IsStoped(MxDSObject* p_obj);
 
    MxResult InsertActionToList54(MxDSAction* p_action);
 
    MxNextActionDataStart* FindNextActionDataStartFromStreamingAction(MxDSStreamingAction* p_action);
 
    MxAtomId& GetAtom() { return m_atom; }
 
    MxStreamProvider* GetProvider() { return m_provider; }
 
    MxDSObjectList& GetUnk0x3c() { return m_unk0x3c; }
 
    MxDSObjectList& GetUnk0x54() { return m_unk0x54; }
 
    MxDSSubscriberList& GetSubscriberList() { return m_subscribers; }
 
protected:
    MxCriticalSection m_criticalSection;        
    MxAtomId m_atom;                            
    MxStreamProvider* m_provider;               
    undefined4* m_unk0x2c;                      
    MxDSSubscriberList m_subscribers;           
    MxDSObjectList m_unk0x3c;                   
    MxNextActionDataStartList m_nextActionList; 
    MxDSObjectList m_unk0x54;                   
    MxDSAction* m_action0x60;                   
};
 
#endif // MXSTREAMCONTROLLER_H