diff --git a/Source/IO/AuIOPipeProcessor.cpp b/Source/IO/AuIOPipeProcessor.cpp index d79a33b9..df61fd5b 100644 --- a/Source/IO/AuIOPipeProcessor.cpp +++ b/Source/IO/AuIOPipeProcessor.cpp @@ -164,6 +164,11 @@ namespace Aurora::IO bool IOPipeWork::End() { + if (!this->iStartTickMS_) + { + return true; + } + if (this->parent_->parent_->CheckThread()) { TerminateOnThread(); diff --git a/Source/IO/AuIOWaitableIOLoopSource.cpp b/Source/IO/AuIOWaitableIOLoopSource.cpp index 0c808e71..dadd6b33 100644 --- a/Source/IO/AuIOWaitableIOLoopSource.cpp +++ b/Source/IO/AuIOWaitableIOLoopSource.cpp @@ -78,13 +78,15 @@ namespace Aurora::IO return this->dwIoTimeoutMS; } - AUKN_SYM AuSPtr NewWaitableLoopSource(const AuSPtr&pSource) + AUKN_SYM AuSPtr NewWaitableLoopSource(const AuSPtr &pSource) { + SysCheckArgNotNull(pSource, {}); SysCheckRetExpNotNullMemory(AuMakeShared(pSource), {}); } - AUKN_SYM AuSPtr NewWaitableLoopSourceEx(const AuSPtr&pSource, AuUInt32 dwIoTimeoutMS) + AUKN_SYM AuSPtr NewWaitableLoopSourceEx(const AuSPtr &pSource, AuUInt32 dwIoTimeoutMS) { + SysCheckArgNotNull(pSource, {}); SysCheckRetExpNotNullMemory(AuMakeShared(pSource, dwIoTimeoutMS), {}); } } \ No newline at end of file