AuroraSupport/AuroraRuntime
2
1
Fork 0
Code Issues 27 Pull Requests Releases Wiki Activity

[*] Potential Win32 loop queue bug fixes/improvements

Browse Source
This commit is contained in:
Reece Wilson 2023-10-22 22:11:24 +01:00
parent 6d49de430a
commit a7af61e9bf
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
Source/IO/Loop/LoopQueue.NT.cpp
View File

@ -666,7 +666,6 @@ namespace Aurora::IO::Loop
if (endTime <= startTime) if (endTime <= startTime)
{ {
StartUserAndTakeOwn(); StartUserAndTakeOwn();
ConsiderEvicitingTimeoutsAll();
Iterator queueIterator(this); Iterator queueIterator(this);
for (queueIterator.Start(); queueIterator.End() != queueIterator.itr; ) for (queueIterator.Start(); queueIterator.End() != queueIterator.itr; )
@ -683,6 +682,7 @@ namespace Aurora::IO::Loop
queueIterator.Next(); queueIterator.Next();
} }
ConsiderEvicitingTimeoutsAll();
StartUserAndTakeOwn_Release(); StartUserAndTakeOwn_Release();
bFinished = true; bFinished = true;
return false; return false;
@ -1456,7 +1456,6 @@ namespace Aurora::IO::Loop
auto now = AuTime::SteadyClockMS(); auto now = AuTime::SteadyClockMS();
for (queueIterator.Start(); queueIterator.End() != queueIterator.itr; ) for (queueIterator.Start(); queueIterator.End() != queueIterator.itr; )
{ {
auto &source = *queueIterator.itr; auto &source = *queueIterator.itr;
if (!source.ConsiderTimeout(now)) if (!source.ConsiderTimeout(now))
{ {
@ -1464,6 +1463,8 @@ namespace Aurora::IO::Loop
continue; continue;
} }
source.source->OnFinishSleep();
if (source.source->GetType() == ELoopSource::eSourceWin32) if (source.source->GetType() == ELoopSource::eSourceWin32)
{ {
// Null message loop hack // Null message loop hack
@ -1487,7 +1488,7 @@ namespace Aurora::IO::Loop
} }
queueIterator.Delete(this->loopSourceExs_.erase(queueIterator.itr)); queueIterator.Delete(this->loopSourceExs_.erase(queueIterator.itr));
break; continue;
} }
queueIterator.Next(); queueIterator.Next();