[+] Add async process API test; add nanosecond-res timer

[*] Update Aurora Runtime
This commit is contained in:
Reece Wilson 2022-05-05 12:52:37 +01:00
parent 13389ae938
commit e7394e2858
3 changed files with 100 additions and 1 deletions

@ -1 +1 @@
Subproject commit 45975e475571bf76dace0aab9bd30b263eec0192 Subproject commit 61f20b6c697f498db6f2b46e89830ce6ea09322d

View File

@ -38,6 +38,82 @@ TEST(Process, RunSystem)
AuLogDbg("Exit Code: 0x{:x}", (AuUInt)process->GetExitCode()); AuLogDbg("Exit Code: 0x{:x}", (AuUInt)process->GetExitCode());
} }
TEST(Process, RunSystemLoopSourceStdOut)
{
auto proc = "^/HelloSystem"
#if defined(AURORA_PLATFORM_WIN32)
".exe"
#endif
;
AuProcesses::StartupParmaters params;
params.type = AuProcesses::ESpawnType::eSpawnChildProcessWorker;
params.process = proc;
params.fwdOut = true;
params.fwdIn = true;
params.noShowConsole = true;
auto process = AuProcesses::SpawnUnique(params);
ASSERT_TRUE(static_cast<bool>(process));
ASSERT_TRUE(process->Start());
bool bIsRunning {true};
AuByteBuffer stdoutPipe(4096 * 16);
AuMemoryViewWrite readView(stdoutPipe.begin(), stdoutPipe.end());
auto transaction = process->NewAsyncTransaction();
auto transactionSource = transaction->NewLoopSource();
auto processDeadLoopSource = process->AsLoopSource();
auto processDeadCallback = AuMakeShared<Aurora::Loop::ILoopSourceSubscriberFunctional>([&](const AuSPtr<AuLoop::ILoopSource> &source) -> bool
{
AuLogDbg("Exit Code [2]: 0x{:x} -> exiting", (AuUInt)process->GetExitCode());
bIsRunning = false;
return false; // dont evict
});
transaction->SetCallback(AuMakeShared<AuIOFS::IAsyncFinishedSubscriberFunctional>([&](AuUInt64 offset, AuUInt32 length)
{
transaction->Reset();
if (length)
{
AuLogDbg("STDOUT {}", AuString(stdoutPipe.begin(), stdoutPipe.begin() + length));
transaction->StartRead(0, AuUnsafeRaiiToShared(&readView)); // NOTE: removed assert bc the final read +1 may result in an instant nonblocking error under NT
}
}));
ASSERT_TRUE(transaction->StartRead(0, AuUnsafeRaiiToShared(&readView)));
auto loop = Aurora::Loop::NewLoopQueue();
ASSERT_TRUE(loop->SourceAdd(transactionSource));
ASSERT_TRUE(loop->SourceAdd(processDeadLoopSource));
ASSERT_TRUE(loop->AddCallback(processDeadLoopSource, processDeadCallback));
ASSERT_TRUE(loop->Commit());
while (bIsRunning)
{
loop->WaitAny();
}
// Read until EOF
while (transactionSource->IsSignaled())
{
}
// Report any remaining bytes
{
AuByteBuffer stdoutPipe(4096 * 16);
AuUInt written {};
while (process->Read(AuProcesses::EStandardHandle::eStdOut, AuMemoryViewStreamWrite {stdoutPipe.begin(), stdoutPipe.end(), written}, false))
{
AuLogDbg("FAIL {}", AuString(stdoutPipe.begin(), stdoutPipe.begin() + written));
}
}
}
void RunTests() void RunTests()
{ {
Aurora::RuntimeStartInfo info; Aurora::RuntimeStartInfo info;

View File

@ -155,6 +155,29 @@ TEST(Loop, Timer3)
ASSERT_FALSE(loop->WaitAny(100)); ASSERT_FALSE(loop->WaitAny(100));
} }
TEST(Loop, Timer4)
{
auto timer = AuLoop::NewLSTimer(AuTime::CurrentClockMS() + 100, 100, 2);
timer->UpdateTimeNs(AuTime::CurrentClockNS() + AuMSToNS<AuUInt64>(100));
timer->UpdateTickRateIfAnyNs(AuMSToNS<AuUInt64>(100), 2);
// Create loop to sync against the two outstanding IO requests
auto loop = AuLoop::NewLoopQueue();
// Add initial loop sources
ASSERT_TRUE(loop->SourceAdd(timer));
ASSERT_TRUE(loop->Commit());
// Test for incremental ticks
ASSERT_FALSE(loop->WaitAll(5));
ASSERT_TRUE(loop->WaitAll(100));
ASSERT_FALSE(loop->WaitAll(5));
ASSERT_TRUE(loop->WaitAll(100));
ASSERT_FALSE(loop->WaitAll(5));
ASSERT_FALSE(loop->WaitAll(100));
}
// //
// Note: kernel loop queues also support async file and pipe transactions. // Note: kernel loop queues also support async file and pipe transactions.
// See the specialized tests for loop queue related interfaces // See the specialized tests for loop queue related interfaces