isledecomp/isle
1
0
Fork 0
mirror of https://github.com/isledecomp/isle.git synced 2026-01-20 23:01:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Match MxDiskStreamController::FUN_100c7db0

Browse Source
This commit is contained in:
Christian Semmler 2024-12-23 10:15:39 -07:00
parent 1b99d75543
commit 6bd395a0f8
3 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
LEGO1/omni/include/mxdiskstreamcontroller.h
View File

@ -92,6 +92,9 @@ class MxDiskStreamController : public MxStreamController {
// List<MxDSBuffer *>::~List<MxDSBuffer *>
// TEMPLATE: LEGO1 0x100c7ef0
// list<MxNextActionDataStart *>::insert
// list<MxNextActionDataStart *,allocator<MxNextActionDataStart *> >::insert
// TEMPLATE: BETA10 0x10150e60
// MxUtilityList<MxNextActionDataStart *>::PushBack
#endif // MXDISKSTREAMCONTROLLER_H

3
LEGO1/omni/include/mxutilitylist.h
View File

@ -18,6 +18,9 @@ class MxUtilityList : public list<T> {
this->pop_front();
return TRUE;
}
// Note: does not take a reference
void PushBack(T p_obj) { push_back(p_obj); }
};
#endif // MXUTILITYLIST_H

6
LEGO1/omni/src/stream/mxdiskstreamcontroller.cpp
View File

@ -248,27 +248,31 @@ MxResult MxDiskStreamController::FUN_100c7d10()
}
// FUNCTION: LEGO1 0x100c7db0
// FUNCTION: BETA10 0x101551d0
MxDSStreamingAction* MxDiskStreamController::FUN_100c7db0()
{
AUTOLOCK(m_criticalSection);
for (MxNextActionDataStartList::iterator it = m_nextActionList.begin(); it != m_nextActionList.end(); it++) {
MxNextActionDataStart* data = *it;
for (MxDSObjectList::iterator it2 = m_list0x64.begin(); it2 != m_list0x64.end(); it2++) {
MxDSStreamingAction* streamingAction = (MxDSStreamingAction*) *it2;
if (streamingAction->GetObjectId() == data->GetObjectId() &&
streamingAction->GetUnknown24() == data->GetUnknown24() &&
streamingAction->GetBufferOffset() == data->GetData()) {
m_nextActionList.erase(it);
data->SetData(m_provider->GetFileSize() + data->GetData());
m_nextActionList.push_back(data);
m_nextActionList.PushBack(data);
m_list0x64.erase(it2);
return streamingAction;
}
}
}
return NULL;
}