[*] AuIO harden

This commit is contained in:
Reece Wilson 2024-07-01 11:52:12 +01:00
parent 8fc20bcc11
commit 3bae761e50
2 changed files with 9 additions and 2 deletions

View File

@ -164,6 +164,11 @@ namespace Aurora::IO
bool IOPipeWork::End() bool IOPipeWork::End()
{ {
if (!this->iStartTickMS_)
{
return true;
}
if (this->parent_->parent_->CheckThread()) if (this->parent_->parent_->CheckThread())
{ {
TerminateOnThread(); TerminateOnThread();

View File

@ -78,13 +78,15 @@ namespace Aurora::IO
return this->dwIoTimeoutMS; return this->dwIoTimeoutMS;
} }
AUKN_SYM AuSPtr<IIOWatachableIOLoopSource> NewWaitableLoopSource(const AuSPtr<Loop::ILoopSource>&pSource) AUKN_SYM AuSPtr<IIOWatachableIOLoopSource> NewWaitableLoopSource(const AuSPtr<Loop::ILoopSource> &pSource)
{ {
SysCheckArgNotNull(pSource, {});
SysCheckRetExpNotNullMemory(AuMakeShared<IOWatachableIOLoopSource>(pSource), {}); SysCheckRetExpNotNullMemory(AuMakeShared<IOWatachableIOLoopSource>(pSource), {});
} }
AUKN_SYM AuSPtr<IIOWatachableIOLoopSource> NewWaitableLoopSourceEx(const AuSPtr<Loop::ILoopSource>&pSource, AuUInt32 dwIoTimeoutMS) AUKN_SYM AuSPtr<IIOWatachableIOLoopSource> NewWaitableLoopSourceEx(const AuSPtr<Loop::ILoopSource> &pSource, AuUInt32 dwIoTimeoutMS)
{ {
SysCheckArgNotNull(pSource, {});
SysCheckRetExpNotNullMemory(AuMakeShared<IOWatachableIOLoopSource>(pSource, dwIoTimeoutMS), {}); SysCheckRetExpNotNullMemory(AuMakeShared<IOWatachableIOLoopSource>(pSource, dwIoTimeoutMS), {});
} }
} }