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

Fix indentation

Browse Source
This commit is contained in:
Lisa Julia Nebel 2024-07-15 14:52:47 +02:00
parent 0a70296eb9
commit c78a629528
1 changed files with 33 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
tests/models/test_tasklets_failure.cpp
View File

@ -87,46 +87,46 @@ private:
}; };
void execute () { void execute () {
int numWorkers = 2; int numWorkers = 2;
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
assert(runner->workerThreadIndex() < 0); assert(runner->workerThreadIndex() < 0);
assert(runner->numWorkerThreads() == numWorkers); assert(runner->numWorkerThreads() == numWorkers);
// Dispatch some successful tasklets
for (int i = 0; i < 5; ++i) {
runner->barrier();
if (runner->failure()) {
exit(EXIT_FAILURE);
}
auto st = std::make_shared<SleepTasklet>(10,i);
runner->dispatch(st);
}
// Dispatch some successful tasklets
for (int i = 0; i < 5; ++i) {
runner->barrier(); runner->barrier();
if (runner->failure()) { if (runner->failure()) {
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
// Dispatch a failing tasklet auto st = std::make_shared<SleepTasklet>(10,i);
auto failingSleepTasklet = std::make_shared<FailingSleepTasklet>(100); runner->dispatch(st);
runner->dispatch(failingSleepTasklet);
// Dispatch more successful tasklets
for (int i = 5; i < 10; ++i) {
runner->barrier();
if (runner->failure()) {
exit(EXIT_FAILURE);
}
auto st = std::make_shared<SleepTasklet>(10,i);
runner->dispatch(st);
}
std::cout << "before barrier" << std::endl;
runner->barrier();
} }
runner->barrier();
if (runner->failure()) {
exit(EXIT_FAILURE);
}
// Dispatch a failing tasklet
auto failingSleepTasklet = std::make_shared<FailingSleepTasklet>(100);
runner->dispatch(failingSleepTasklet);
// Dispatch more successful tasklets
for (int i = 5; i < 10; ++i) {
runner->barrier();
if (runner->failure()) {
exit(EXIT_FAILURE);
}
auto st = std::make_shared<SleepTasklet>(10,i);
runner->dispatch(st);
}
std::cout << "before barrier" << std::endl;
runner->barrier();
}
BOOST_AUTO_TEST_SUITE(Tasklets) BOOST_AUTO_TEST_SUITE(Tasklets)
BOOST_AUTO_TEST_CASE(TASKLETS_FAILURE) { BOOST_AUTO_TEST_CASE(TASKLETS_FAILURE) {
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)