ISAR/libmdbx
3
0
Fork 0
mirror of https://github.com/isar/libmdbx.git synced 2025-04-21 04:17: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-10 12:14:53 +03:00
parent 5bd99d4da2
commit 2ceda89b05
1 changed files with 27 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -172,9 +172,21 @@ mdbx::map_handle case1_cycle_dbi(std::deque<mdbx::map_handle> &dbi) {
void case1_read_cycle(mdbx::txn txn, std::deque<mdbx::map_handle> &dbi, std::vector<MDBX_cursor *> &pool, void case1_read_cycle(mdbx::txn txn, std::deque<mdbx::map_handle> &dbi, std::vector<MDBX_cursor *> &pool,
mdbx::cursor pre, bool nested = false) { mdbx::cursor pre, bool nested = false) {
if (nested) {
for (auto c : pool)
try {
mdbx::cursor(c).bind(txn, case1_cycle_dbi(dbi));
} catch (const std::invalid_argument &) {
}
try {
pre.bind(txn, case1_cycle_dbi(dbi));
} catch (const std::invalid_argument &) {
}
} else {
for (auto c : pool) for (auto c : pool)
mdbx::cursor(c).bind(txn, case1_cycle_dbi(dbi)); mdbx::cursor(c).bind(txn, case1_cycle_dbi(dbi));
pre.bind(txn, case1_cycle_dbi(dbi)); pre.bind(txn, case1_cycle_dbi(dbi));
}
for (auto n = prng(3 + dbi.size()); n > 0; --n) { for (auto n = prng(3 + dbi.size()); n > 0; --n) {
auto c = txn.open_cursor(dbi[prng(dbi.size())]); auto c = txn.open_cursor(dbi[prng(dbi.size())]);
@ -215,6 +227,16 @@ void case1_read_cycle(mdbx::txn txn, std::deque<mdbx::map_handle> &dbi, std::vec
switch (prng(nested ? 7 : 3)) { switch (prng(nested ? 7 : 3)) {
case 0: case 0:
if (pre.txn()) {
if (nested)
try {
pre.unbind();
} catch (const std::invalid_argument &) {
return;
}
else
pre.unbind();
}
for (auto i = pool.begin(); i != pool.end();) for (auto i = pool.begin(); i != pool.end();)
if (mdbx_cursor_txn(*i)) if (mdbx_cursor_txn(*i))
i = pool.erase(i); i = pool.erase(i);
@ -253,6 +275,8 @@ void case1_write_cycle(mdbx::txn_managed txn, std::deque<mdbx::map_handle> &dbi,
if (prng(16) > 8) if (prng(16) > 8)
case1_write_cycle(txn.start_nested(), dbi, pool, pre, true); case1_write_cycle(txn.start_nested(), dbi, pool, pre, true);
case1_read_cycle(txn, dbi, pool, pre, nested);
if (flipcoin()) if (flipcoin())
txn.commit(); txn.commit();
else else