thunderbrewhq/thunderbrew
1
0
Fork 0
mirror of https://github.com/thunderbrewhq/thunderbrew synced 2025-12-12 19:22:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat(model): properly handle IsDrawable and WaitForLoad calls

Browse source
This commit is contained in:
fallenoak 2023-02-20 11:15:06 -06:00
parent 5e3d08bf32
commit 961c722825
No known key found for this signature in database
GPG key ID: 7628F8E61AEA070D
3 changed files with 92 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

50
src/async/AsyncFileRead.cpp
View file

@ -2,6 +2,7 @@
#include "util/SFile.hpp"
#include <common/Prop.hpp>
#include <common/Time.hpp>
#include <storm/Error.hpp>
uint32_t AsyncFileRead::s_threadSleep;
uint32_t AsyncFileRead::s_handlerTimeout = 100;
@ -25,6 +26,7 @@ TSList<CAsyncQueue, TSGetLink<CAsyncQueue>> AsyncFileRead::s_asyncQueueList;
TSList<CAsyncThread, TSGetLink<CAsyncThread>> AsyncFileRead::s_asyncThreadList;
STORM_EXPLICIT_LIST(CAsyncObject, link) AsyncFileRead::s_asyncFileReadPostList;
STORM_EXPLICIT_LIST(CAsyncObject, link) AsyncFileRead::s_asyncFileReadFreeList;
int32_t AsyncFileRead::s_waiting;
CAsyncQueue* AsyncFileReadCreateQueue() {
CAsyncQueue* queue = AsyncFileRead::s_asyncQueueList.NewNode(0, 2, 0x8);
@ -194,3 +196,51 @@ uint32_t AsyncFileReadThread(void* param) {
return 0;
}
void AsyncFileReadWait(CAsyncObject* object) {
STORM_ASSERT(object);
AsyncFileRead::s_waiting++;
AsyncFileRead::s_queueLock.Enter();
if (object->isProcessed) {
AsyncFileRead::s_queueLock.Leave();
return;
}
AsyncFileRead::s_asyncWaitObject = object;
if (!object->isCurrent && !object->isRead) {
object->link.Unlink();
object->queue->readList.LinkToHead(object);
}
AsyncFileRead::s_queueLock.Leave();
if (SFile::IsStreamingMode()) {
// TODO
}
// TODO
if (AsyncFileRead::s_ingameStartCallback) {
// TODO AsyncFileRead::s_ingameStartCallback();
}
while (true) {
if (AsyncFileRead::s_ingameProgressCallback) {
// TODO AsyncFileRead::s_ingameProgressCallback(0.0, 0);
}
AsyncFileReadPollHandler(nullptr, nullptr);
if (!AsyncFileRead::s_asyncWaitObject) {
break;
}
OsSleep(1);
}
AsyncFileRead::s_waiting--;
}

3
src/async/AsyncFileRead.hpp
View file

@ -31,6 +31,7 @@ class AsyncFileRead {
static TSList<CAsyncThread, TSGetLink<CAsyncThread>> s_asyncThreadList;
static STORM_EXPLICIT_LIST(CAsyncObject, link) s_asyncFileReadPostList;
static STORM_EXPLICIT_LIST(CAsyncObject, link) s_asyncFileReadFreeList;
static int32_t s_waiting;
};
CAsyncQueue* AsyncFileReadCreateQueue();
@ -43,4 +44,6 @@ int32_t AsyncFileReadPollHandler(const void* a1, void* a2);
uint32_t AsyncFileReadThread(void* thread);
void AsyncFileReadWait(CAsyncObject* object);
#endif