ISAR/libmdbx
3
0
Fork 0
mirror of https://github.com/isar/libmdbx.git synced 2025-04-01 02:32:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

mdbx-tests: дополнение extra/txn (backport).

Browse Source
This commit is contained in:
Леонид Юрьев (Leonid Yuriev) 2025-03-20 01:47:24 +03:00
parent 5f37ea60d2
commit 9c177de034
1 changed files with 287 additions and 252 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

77
test/extra/txn.c++
View File

@ -1,4 +1,5 @@
#include "mdbx.h++"
#include MDBX_CONFIG_H
#include <iostream>
@ -25,22 +26,11 @@ static void logger_nofmt(MDBX_log_level_t loglevel, const char *function, int li
fprintf(stdout, "%s:%u %s", function, line, msg);
}
int main(int argc, const char *argv[]) {
(void)argc;
(void)argv;
bool ok = true;
int err;
mdbx_setup_debug_nofmt(MDBX_LOG_VERBOSE, MDBX_DBG_ASSERT, logger_nofmt, log_buffer, sizeof(log_buffer));
mdbx::path path = "test-txn";
mdbx::env::remove(path);
mdbx::env::operate_parameters operateParameters(100, 10);
{
bool case0(const mdbx::path &path) {
mdbx::env_managed::create_parameters createParameters;
createParameters.geometry.make_dynamic(21 * mdbx::env::geometry::MiB, 84 * mdbx::env::geometry::MiB);
mdbx::env::operate_parameters operateParameters(100, 10);
operateParameters.options.no_sticky_threads = false;
mdbx::env_managed env(path, createParameters, operateParameters);
auto txn = env.start_write(false);
@ -50,9 +40,9 @@ int main(int argc, const char *argv[]) {
//-------------------------------------
txn = env.start_write();
MDBX_txn *c_txn = txn;
err = mdbx_txn_reset(txn);
int err = mdbx_txn_reset(txn);
assert(err == MDBX_EINVAL);
ok = ok && err == MDBX_EINVAL;
bool ok = err == MDBX_EINVAL;
err = mdbx_txn_break(txn);
assert(err == MDBX_SUCCESS);
@ -145,19 +135,25 @@ int main(int argc, const char *argv[]) {
assert(err == MDBX_THREAD_MISMATCH);
ok = ok && err == MDBX_THREAD_MISMATCH;
#endif /* MDBX_TXN_CHECKOWNER */
err = mdbx_txn_begin(env, txn, MDBX_TXN_READWRITE, &c_txn);
#if MDBX_TXN_CHECKOWNER
assert(err == MDBX_THREAD_MISMATCH);
ok = ok && err == MDBX_THREAD_MISMATCH;
#else
assert(err == MDBX_BAD_TXN);
ok = ok && err == MDBX_BAD_TXN;
#endif /* MDBX_TXN_CHECKOWNER */
});
s.count_down();
t.join();
}
//=====================================
//=====================================
return ok;
}
{
bool case1(const mdbx::path &path) {
mdbx::env::operate_parameters operateParameters(100, 10);
operateParameters.options.no_sticky_threads = true;
operateParameters.options.nested_write_transactions = true;
mdbx::env_managed env(path, operateParameters);
@ -165,9 +161,9 @@ int main(int argc, const char *argv[]) {
//-------------------------------------
auto txn = env.start_write();
MDBX_txn *c_txn = txn;
err = mdbx_txn_reset(txn);
int err = mdbx_txn_reset(txn);
assert(err == MDBX_EINVAL);
ok = ok && err == MDBX_EINVAL;
bool ok = err == MDBX_EINVAL;
err = mdbx_txn_break(txn);
assert(err == MDBX_SUCCESS);
@ -285,7 +281,46 @@ int main(int argc, const char *argv[]) {
t.join();
txn.abort();
return ok;
}
bool case2(const mdbx::path &path, bool no_sticky_threads) {
mdbx::env::operate_parameters operateParameters(100, 10);
operateParameters.options.no_sticky_threads = no_sticky_threads;
mdbx::env_managed env(path, operateParameters);
std::latch s(1);
std::vector<std::thread> l;
for (size_t n = 0; n < 8; ++n)
l.push_back(std::thread([&]() {
s.wait();
for (size_t i = 0; i < 1000000; ++i) {
auto txn = env.start_read();
txn.abort();
}
}));
s.count_down();
for (auto &t : l)
t.join();
return true;
}
int main(int argc, const char *argv[]) {
(void)argc;
(void)argv;
mdbx_setup_debug_nofmt(MDBX_LOG_VERBOSE, MDBX_DBG_ASSERT, logger_nofmt, log_buffer, sizeof(log_buffer));
mdbx::path path = "test-txn";
mdbx::env::remove(path);
bool ok = case0(path);
ok = case1(path) && ok;
ok = case2(path, false) && ok;
ok = case2(path, true) && ok;
std::cout << (ok ? "OK\n" : "FAIL\n");
return ok ? EXIT_SUCCESS : EXIT_FAILURE;