diff --git a/Source/IO/IPC/AuIPCPipe.NT.cpp b/Source/IO/IPC/AuIPCPipe.NT.cpp index ee6c35b5..bb2e23c9 100644 --- a/Source/IO/IPC/AuIPCPipe.NT.cpp +++ b/Source/IO/IPC/AuIPCPipe.NT.cpp @@ -14,6 +14,8 @@ #include #include +#include + #include "AuIPCPipe.NT.hpp" namespace Aurora::IO::IPC @@ -84,7 +86,6 @@ namespace Aurora::IO::IPC IPCPipeImpl::IPCPipeImpl(HANDLE clientHandle, HANDLE serverHandle, const IPCHandle &handle) : serverHandle_(serverHandle), clientHandle_(clientHandle), ipcHandle_(handle) { - if (serverHandle != INVALID_HANDLE_VALUE) { this->hasClient_ = Loop::NewLSEvent(false, false, true); @@ -97,6 +98,8 @@ namespace Aurora::IO::IPC this->fsStream_ = AuMakeSharedPanic(); this->fsHandle_->InitFromMove((AuUInt)this->GetPipeHandle()); + AuStaticCast(this->fsHandle_)->bIsAsync = true; + this->fsStream_->Init(this->fsHandle_); TryConnect(); diff --git a/Source/Processes/AuProcess.NT.cpp b/Source/Processes/AuProcess.NT.cpp index f4d9f9d3..7e8fcd5e 100644 --- a/Source/Processes/AuProcess.NT.cpp +++ b/Source/Processes/AuProcess.NT.cpp @@ -19,6 +19,7 @@ #include #include #include +#include #include "AuCreatePipeEx.NT.hpp" @@ -384,6 +385,7 @@ namespace Aurora::Processes } this->fsHandle_->InitFromPairMove((AuUInt64)this->pipeStdOutRead_, (AuUInt64)this->pipeStdInWrite_); + AuStaticCast(this->fsHandle_)->bIsAsync = true; this->fsStream_->Init(this->fsHandle_); } @@ -402,6 +404,7 @@ namespace Aurora::Processes } this->fsErrorHandle_->InitFromPairMove((AuUInt64)this->pipeStdErrRead_, {}); + AuStaticCast(this->fsErrorHandle_)->bIsAsync = true; this->fsErrorStream_->Init(this->fsErrorHandle_); }