ISAR/libmdbx
3
0
Fork 0
mirror of https://github.com/isar/libmdbx.git synced 2025-05-12 16:27:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

mdbx-tests: привязка кол-ва потоков/проверок к кол-ву процессоров в extra/cursor-closing.

Browse Source
This commit is contained in:
Леонид Юрьев (Leonid Yuriev) 2025-04-19 20:02:09 +03:00
parent 89de43293d
commit dc747483dd
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
test/extra/cursor_closing.c++
View File

@ -318,11 +318,11 @@ bool case1(mdbx::env env) {
std::deque<mdbx::map_handle> dbi; std::deque<mdbx::map_handle> dbi;
std::vector<mdbx::cursor_managed> cursors; std::vector<mdbx::cursor_managed> cursors;
#if defined(__cpp_lib_latch) && __cpp_lib_latch >= 201907L #if defined(__cpp_lib_latch) && __cpp_lib_latch >= 201907L
static const auto N = 10; static const auto N = std::thread::hardware_concurrency();
#else #else
static const auto N = 3; static const auto N = 3u;
#endif #endif
for (auto t = 0; t < N; ++t) { for (auto t = 0u; t < N; ++t) {
auto txn = env.start_write(); auto txn = env.start_write();
auto table = txn.create_map(std::to_string(t), mdbx::key_mode::ordinal, mdbx::value_mode::multi_samelength); auto table = txn.create_map(std::to_string(t), mdbx::key_mode::ordinal, mdbx::value_mode::multi_samelength);
auto cursor = txn.open_cursor(table); auto cursor = txn.open_cursor(table);
@ -337,7 +337,7 @@ bool case1(mdbx::env env) {
#if defined(__cpp_lib_latch) && __cpp_lib_latch >= 201907L #if defined(__cpp_lib_latch) && __cpp_lib_latch >= 201907L
std::latch s(1); std::latch s(1);
std::vector<std::thread> threads; std::vector<std::thread> threads;
for (auto t = 1; t < N; ++t) { for (auto t = 1u; t < cursors.size(); ++t) {
case1_cycle_dbi(dbi); case1_cycle_dbi(dbi);
threads.push_back(std::thread([&, t]() { threads.push_back(std::thread([&, t]() {
s.wait(); s.wait();