ISAR/libmdbx
3
0
Fork 0
mirror of https://github.com/isar/libmdbx.git synced 2025-01-06 19:34:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

mdbx-test: add seek-test for MDBX_GET_BOTH.

Browse Source 
Related to https://github.com/erthink/libmdbx/issues/243
This commit is contained in:
Leonid Yuriev 2021-11-25 19:19:15 +03:00
parent 76399bd643
commit 66c354baff
2 changed files with 38 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
test/test.cc
View File

@ -641,7 +641,8 @@ enum speculum_cursors : int {
prev = 1, prev = 1,
prev_prev = 2, prev_prev = 2,
next = 3, next = 3,
next_next = 4 next_next = 4,
seek_check = 5
}; };
bool testcase::is_same(const Item &a, const Item &b) const { bool testcase::is_same(const Item &a, const Item &b) const {
@ -852,11 +853,26 @@ int testcase::insert(const keygen::buffer &akey, const keygen::buffer &adata,
int err; int err;
bool rc = true; bool rc = true;
Item item; Item item;
#if SPECULUM_CURSORS
MDBX_cursor *check_seek_cursor = nullptr;
MDBX_val seek_check_key, seek_check_data;
int seek_check_err = 42;
#endif /* SPECULUM_CURSORS */
if (config.params.speculum) { if (config.params.speculum) {
item.first = iov2dataview(akey); item.first = iov2dataview(akey);
item.second = iov2dataview(adata); item.second = iov2dataview(adata);
#if SPECULUM_CURSORS #if SPECULUM_CURSORS
speculum_prepare_cursors(item); speculum_prepare_cursors(item);
check_seek_cursor = speculum_cursors[seek_check].get();
seek_check_key = akey->value;
seek_check_data = adata->value;
seek_check_err = mdbx_cursor_get(
check_seek_cursor, &seek_check_key, &seek_check_data,
(config.params.table_flags & MDBX_DUPSORT) ? MDBX_GET_BOTH
: MDBX_SET_KEY);
if (seek_check_err != MDBX_SUCCESS && seek_check_err != MDBX_NOTFOUND)
failure("speculum-%s: %s pre-insert %d %s", "insert", "seek",
seek_check_err, mdbx_strerror(seek_check_err));
#endif /* SPECULUM_CURSORS */ #endif /* SPECULUM_CURSORS */
} }
@ -881,6 +897,26 @@ int testcase::insert(const keygen::buffer &akey, const keygen::buffer &adata,
} }
#if SPECULUM_CURSORS #if SPECULUM_CURSORS
if (insertion_result.second) {
if (seek_check_err != MDBX_NOTFOUND) {
log_error(
"speculum.pre-insert-seek: unexpected %d {%s, %s}", seek_check_err,
mdbx_dump_val(&seek_check_key, dump_key, sizeof(dump_key)),
mdbx_dump_val(&seek_check_data, dump_value, sizeof(dump_value)));
rc = false;
}
} else {
if (seek_check_err != MDBX_SUCCESS) {
log_error(
"speculum.pre-insert-seek: unexpected %d {%s, %s}", seek_check_err,
mdbx_dump_val(&seek_check_key, dump_key, sizeof(dump_key)),
mdbx_dump_val(&seek_check_data, dump_value, sizeof(dump_value)));
speculum_check_iterator("insert", "pre-seek", insertion_result.first,
seek_check_key, seek_check_data);
rc = false;
}
}
if (insertion_result.first != speculum.begin()) { if (insertion_result.first != speculum.begin()) {
const auto cursor_prev = speculum_cursors[prev].get(); const auto cursor_prev = speculum_cursors[prev].get();
auto it_prev = insertion_result.first; auto it_prev = insertion_result.first;

2
test/test.h
View File

@ -202,7 +202,7 @@ protected:
#define SPECULUM_CURSORS 1 #define SPECULUM_CURSORS 1
#endif /* SPECULUM_CURSORS */ #endif /* SPECULUM_CURSORS */
#if SPECULUM_CURSORS #if SPECULUM_CURSORS
scoped_cursor_guard speculum_cursors[5]; scoped_cursor_guard speculum_cursors[5 + 1];
void speculum_prepare_cursors(const Item &item); void speculum_prepare_cursors(const Item &item);
void speculum_check_cursor(const char *where, const char *stage, void speculum_check_cursor(const char *where, const char *stage,
const testcase::SET::const_iterator &it, const testcase::SET::const_iterator &it,