diff options
author | MarcoFalke <falke.marco@gmail.com> | 2018-12-17 10:33:53 -0500 |
---|---|---|
committer | MarcoFalke <falke.marco@gmail.com> | 2018-12-17 10:37:09 -0500 |
commit | fa0d3c44073ab67d3f2e682dba7d3668daa55e25 (patch) | |
tree | 9c14591c9558f08d7e70e6a306fb6a93312003cd /src/test/validation_block_tests.cpp | |
parent | b545a6e68965ceda1c1405cadb13d7245e077618 (diff) |
test: Undo thread_local g_insecure_rand_ctx
Diffstat (limited to 'src/test/validation_block_tests.cpp')
-rw-r--r-- | src/test/validation_block_tests.cpp | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/test/validation_block_tests.cpp b/src/test/validation_block_tests.cpp index 7dd176b25d..62dfed6c41 100644 --- a/src/test/validation_block_tests.cpp +++ b/src/test/validation_block_tests.cpp @@ -152,12 +152,13 @@ BOOST_AUTO_TEST_CASE(processnewblock_signals_ordering) // create a bunch of threads that repeatedly process a block generated above at random // this will create parallelism and randomness inside validation - the ValidationInterface // will subscribe to events generated during block validation and assert on ordering invariance - boost::thread_group threads; + std::vector<std::thread> threads; for (int i = 0; i < 10; i++) { - threads.create_thread([&blocks]() { + threads.emplace_back([&blocks]() { bool ignored; + FastRandomContext insecure; for (int i = 0; i < 1000; i++) { - auto block = blocks[InsecureRandRange(blocks.size() - 1)]; + auto block = blocks[insecure.randrange(blocks.size() - 1)]; ProcessNewBlock(Params(), block, true, &ignored); } @@ -171,7 +172,9 @@ BOOST_AUTO_TEST_CASE(processnewblock_signals_ordering) }); } - threads.join_all(); + for (auto& t : threads) { + t.join(); + } while (GetMainSignals().CallbacksPending() > 0) { MilliSleep(100); } |