OilfieldToolsNet/opm-simulators
4
0
Fork 0
mirror of https://github.com/OPM/opm-simulators.git synced 2025-02-25 18:55:30 -06:00
Code Issues Packages Projects Releases Wiki Activity

changed: do not use boost.test in test_tasklets_failure

Browse Source 
the boost.test signal handlers do not play nicely with fork()
This commit is contained in:
Arne Morten Kvarving 2024-12-04 15:44:01 +01:00
parent dc19f2d47f
commit e3a48a3059
1 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
tests/models/test_tasklets_failure.cpp
View File

@ -26,10 +26,9 @@
* \brief This file serves as an example of how to use the tasklet mechanism for * \brief This file serves as an example of how to use the tasklet mechanism for
* asynchronous work, especially for tasklets that fail. * asynchronous work, especially for tasklets that fail.
*/ */
#define BOOST_TEST_MODULE TASKLETS_FAILURE
//#include <boost/test/unit_test.hpp> // Note: we do not use boost.test as it does not cleanly combine with fork() usage
#include <boost/test/included/unit_test.hpp>
#include <chrono> #include <chrono>
#include <iostream> #include <iostream>
#include <mutex> #include <mutex>
@ -91,8 +90,8 @@ void execute () {
runner = std::make_unique<Opm::TaskletRunner>(numWorkers); runner = std::make_unique<Opm::TaskletRunner>(numWorkers);
// the master thread is not a worker thread // the master thread is not a worker thread
BOOST_REQUIRE_LT(runner->workerThreadIndex(), 0); assert(runner->workerThreadIndex() < 0);
BOOST_REQUIRE_EQUAL(runner->numWorkerThreads(), numWorkers); assert(runner->numWorkerThreads() == numWorkers);
// Dispatch some successful tasklets // Dispatch some successful tasklets
for (int i = 0; i < 5; ++i) { for (int i = 0; i < 5; ++i) {
@ -127,11 +126,12 @@ void execute () {
std::cout << "before barrier" << std::endl; std::cout << "before barrier" << std::endl;
runner->barrier(); runner->barrier();
} }
BOOST_AUTO_TEST_SUITE(Tasklets)
BOOST_AUTO_TEST_CASE(TASKLETS_FAILURE) { int main()
{
pid_t pid = fork(); // Create a new process, such that this child process can call exit(EXIT_FAILURE) pid_t pid = fork(); // Create a new process, such that this child process can call exit(EXIT_FAILURE)
if (pid == -1) { if (pid == -1) {
BOOST_FAIL("Fork failed"); assert(0 && "Fork failed");
} else if (pid == 0) { } else if (pid == 0) {
// Child process // Child process
execute(); execute();
@ -141,8 +141,7 @@ BOOST_AUTO_TEST_CASE(TASKLETS_FAILURE) {
std::cout << "Checking failure of child process with parent process, process id " << pid << std::endl; std::cout << "Checking failure of child process with parent process, process id " << pid << std::endl;
int status; int status;
waitpid(pid, &status, 0); waitpid(pid, &status, 0);
BOOST_CHECK(WIFEXITED(status)); // Check if the child process exited assert(WIFEXITED(status)); // Check if the child process exited
BOOST_CHECK_EQUAL(WEXITSTATUS(status), EXIT_FAILURE); // Check if the exit status is EXIT_FAILURE assert(WEXITSTATUS(status) == EXIT_FAILURE); // Check if the exit status is EXIT_FAILURE
} }
} }
BOOST_AUTO_TEST_SUITE_END()