sid
/
NazaraEngine
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

UnitTests/Process: Flush files to avoid read issues

This commit is contained in:
SirLynix 2024-01-23 15:30:40 +01:00 committed by Jérôme Leclercq
parent a228325bd5
commit 0e5e3ab9dd
2 changed files with 28 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/UnitTests/subprocess1.cpp
View File

@ -9,14 +9,16 @@
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
{ {
Nz::File file(Nz::Utf8Path("step1_success.txt"), Nz::OpenMode::Write); Nz::File file(Nz::Utf8Path("step1_success.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
file.Write("1"); file.Write("1");
file.Flush();
} }
for (int i = 1; i < argc; ++i) for (int i = 1; i < argc; ++i)
{ {
Nz::File file(Nz::Utf8Path(Nz::Format("step2_param{}.txt", i)), Nz::OpenMode::Write); Nz::File file(Nz::Utf8Path(Nz::Format("step2_param{}.txt", i)), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
file.Write(argv[i]); file.Write(argv[i]);
file.Flush();
} }
std::vector<std::string> parameters; std::vector<std::string> parameters;
@ -25,13 +27,15 @@ int main(int argc, char* argv[])
Nz::Result result = Nz::Process::SpawnDetached("../UnitTests_sub2", parameters); Nz::Result result = Nz::Process::SpawnDetached("../UnitTests_sub2", parameters);
if (result) if (result)
{ {
Nz::File file(Nz::Utf8Path("step3_pid.txt"), Nz::OpenMode::Write); Nz::File file(Nz::Utf8Path("step3_pid.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
file.Write(std::to_string(result.GetValue())); file.Write(std::to_string(result.GetValue()));
file.Flush();
} }
else else
{ {
Nz::File file(Nz::Utf8Path("step3_failure.txt"), Nz::OpenMode::Write); Nz::File errFile(Nz::Utf8Path("step3_failure.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
file.Write(result.GetError()); errFile.Write(result.GetError());
errFile.Flush();
} }
// Wait for our child process to start and check for our existence // Wait for our child process to start and check for our existence

29
tests/UnitTests/subprocess2.cpp
View File

@ -12,8 +12,9 @@ int main(int argc, char* argv[])
{ {
if (argc != 2) if (argc != 2)
{ {
Nz::File errFile(Nz::Utf8Path("step4_failure.txt"), Nz::OpenMode::Write); Nz::File errFile(Nz::Utf8Path("step4_failure.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
errFile.Write(Nz::Format("unexpected argc: {}", argc)); errFile.Write(Nz::Format("unexpected argc: {}", argc));
errFile.Flush();
return EXIT_FAILURE; return EXIT_FAILURE;
} }
@ -21,34 +22,39 @@ int main(int argc, char* argv[])
Nz::Pid pid; Nz::Pid pid;
if (auto pidParse = std::from_chars(argv[1], argv[1] + std::strlen(argv[1]), pid); pidParse.ec != std::errc()) if (auto pidParse = std::from_chars(argv[1], argv[1] + std::strlen(argv[1]), pid); pidParse.ec != std::errc())
{ {
Nz::File errFile(Nz::Utf8Path("step4_failure.txt"), Nz::OpenMode::Write); Nz::File errFile(Nz::Utf8Path("step4_failure.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
errFile.Write(Nz::Format("invalid pid: {}", argv[1])); errFile.Write(Nz::Format("invalid pid: {}", argv[1]));
errFile.Flush();
return EXIT_FAILURE; return EXIT_FAILURE;
} }
Nz::File successFile4(Nz::Utf8Path("step4_success.txt"), Nz::OpenMode::Write); Nz::File successFile4(Nz::Utf8Path("step4_success.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
successFile4.Write("1"); successFile4.Write("1");
successFile4.Flush();
Nz::Result result = Nz::Process::Exists(pid); Nz::Result result = Nz::Process::Exists(pid);
if (!result) if (!result)
{ {
Nz::File errFile(Nz::Utf8Path("step5_failure.txt"), Nz::OpenMode::Write); Nz::File errFile(Nz::Utf8Path("step5_failure.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
errFile.Write(Nz::Format("failed to retrieve parent process status: {}", result.GetError())); errFile.Write(Nz::Format("failed to retrieve parent process status: {}", result.GetError()));
errFile.Flush();
return EXIT_FAILURE; return EXIT_FAILURE;
} }
if (!result.GetValue()) if (!result.GetValue())
{ {
Nz::File file(Nz::Utf8Path("step5_failure.txt"), Nz::OpenMode::Write); Nz::File errFile(Nz::Utf8Path("step5_failure.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
file.Write("parent process is already dead"); errFile.Write("parent process is already dead");
errFile.Flush();
return EXIT_FAILURE; return EXIT_FAILURE;
} }
Nz::File successFile5(Nz::Utf8Path("step5_success.txt"), Nz::OpenMode::Write); Nz::File successFile5(Nz::Utf8Path("step5_success.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
successFile5.Write("1"); successFile5.Write("1");
successFile5.Flush();
// Wait until parent dies // Wait until parent dies
std::this_thread::sleep_for(std::chrono::milliseconds(500)); std::this_thread::sleep_for(std::chrono::milliseconds(500));
@ -56,22 +62,25 @@ int main(int argc, char* argv[])
result = Nz::Process::Exists(pid); result = Nz::Process::Exists(pid);
if (!result) if (!result)
{ {
Nz::File errFile(Nz::Utf8Path("step6_failure.txt"), Nz::OpenMode::Write); Nz::File errFile(Nz::Utf8Path("step6_failure.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
errFile.Write(Nz::Format("failed to retrieve parent process status after waiting: {}", result.GetError())); errFile.Write(Nz::Format("failed to retrieve parent process status after waiting: {}", result.GetError()));
errFile.Flush();
return EXIT_FAILURE; return EXIT_FAILURE;
} }
if (result.GetValue()) if (result.GetValue())
{ {
Nz::File errFile(Nz::Utf8Path("step6_failure.txt"), Nz::OpenMode::Write); Nz::File errFile(Nz::Utf8Path("step6_failure.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
errFile.Write("parent process is still alive"); errFile.Write("parent process is still alive");
errFile.Flush();
return EXIT_FAILURE; return EXIT_FAILURE;
} }
Nz::File successFile6(Nz::Utf8Path("step6_success.txt"), Nz::OpenMode::Write); Nz::File successFile6(Nz::Utf8Path("step6_success.txt"), Nz::OpenMode::Write | Nz::OpenMode::Unbuffered);
successFile6.Write("1"); successFile6.Write("1");
successFile6.Flush();
// Wait for the unit tests process to check our existence // Wait for the unit tests process to check our existence
std::this_thread::sleep_for(std::chrono::milliseconds(3000)); std::this_thread::sleep_for(std::chrono::milliseconds(3000));