AuroraSupport/HelloAurora
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

[+] Added early async file io test

Browse Source
This commit is contained in:
Reece Wilson 2022-04-13 12:14:34 +01:00
parent 74cfa7380c
commit 47162ec671
1 changed files with 53 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
Tests/Public/4. Hello FS/Main.cpp
View File

@ -185,9 +185,58 @@ TEST(FS, Watcher)
{ {
AuLogDbg(" {}: {} {}", AuIOFS::EWatchEventToString(update.event), update.file, update.watch.path); AuLogDbg(" {}: {} {}", AuIOFS::EWatchEventToString(update.event), update.file, update.watch.path);
} }
} }
TEST(FS, Async)
{
auto stream = AuIOFS::OpenAsyncUnique("./AsyncFile", AuIOFS::EFileOpenMode::eReadWrite, true);
ASSERT_TRUE(bool(stream));
AuByteBuffer rngbuffer(32);
AuRng::RngFillRange(rngbuffer);
auto transaction = stream->NewTransaction();
ASSERT_TRUE(bool(transaction));
transaction->SetCallback(AuMakeShared<AuIOFS::IAsyncFinishedSubscriberFunctional>([](AuUInt64 offset, AuUInt32 length)
{
AuLogDbg("AIO 1 callback: {} {}", offset, length);
}));
AuMemoryViewRead readView(rngbuffer);
ASSERT_TRUE(transaction->StartWrite(0, AuUnsafeRaiiToShared(&readView)));
AuLogDbg("AIO 1: waiting....");
ASSERT_TRUE(transaction->Wait(0));
AuLogDbg("AIO 1: wait complete....");
ASSERT_TRUE(transaction->NewLoopSource()->IsSignaled());
ASSERT_TRUE(transaction->Complete());
}
TEST(FS, AsyncAltWait)
{
auto stream = AuIOFS::OpenAsyncUnique("./AsyncFile", AuIOFS::EFileOpenMode::eReadWrite, true);
ASSERT_TRUE(bool(stream));
AuByteBuffer rngbuffer(32);
AuRng::RngFillRange(rngbuffer);
auto transaction = stream->NewTransaction();
ASSERT_TRUE(bool(transaction));
transaction->SetCallback(AuMakeShared<AuIOFS::IAsyncFinishedSubscriberFunctional>([](AuUInt64 offset, AuUInt32 length)
{
AuLogDbg("AIO 2 callback: {} {}", offset, length);
}));
AuMemoryViewRead readView(rngbuffer);
ASSERT_TRUE(transaction->StartWrite(0, AuUnsafeRaiiToShared(&readView)));
AuLogDbg("AIO 2: waiting....");
ASSERT_TRUE(transaction->NewLoopSource()->WaitOn());
AuLogDbg("AIO 2: wait complete....");
ASSERT_TRUE(transaction->Complete());
}
static void PrintSystemRoot() static void PrintSystemRoot()
{ {
@ -266,14 +315,16 @@ static void PrintSystemRoot()
} }
// TODO: sample and test code for: // TODO: sample and test code for:
// * async
// * file stream objects // * file stream objects
// * stat
// * iterate
void RunTests() void RunTests()
{ {
Aurora::RuntimeStartInfo info; Aurora::RuntimeStartInfo info;
info.console.fio.enableLogging = false; info.console.fio.enableLogging = false;
info.fio.defaultBrand = "AuSdkBrand"; info.fio.defaultBrand = "AuSdkBrand";
info.bFIODisableBatching = false;
Aurora::RuntimeStart(info); Aurora::RuntimeStart(info);
PrintSystemRoot(); PrintSystemRoot();