diff options
Diffstat (limited to 'storage/tokudb/ft-index/src/tests/blocking-first-empty.cc')
-rw-r--r-- | storage/tokudb/ft-index/src/tests/blocking-first-empty.cc | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/storage/tokudb/ft-index/src/tests/blocking-first-empty.cc b/storage/tokudb/ft-index/src/tests/blocking-first-empty.cc index 72267437a4a..6ccf879005d 100644 --- a/storage/tokudb/ft-index/src/tests/blocking-first-empty.cc +++ b/storage/tokudb/ft-index/src/tests/blocking-first-empty.cc @@ -98,7 +98,6 @@ struct my_callback_context { DBT val; }; -#if TOKUDB static int blocking_first_callback(DBT const *a UU(), DBT const *b UU(), void *e UU()) { DBT const *found_key = a; DBT const *found_val = b; @@ -107,7 +106,6 @@ static int blocking_first_callback(DBT const *a UU(), DBT const *b UU(), void *e copy_dbt(&context->val, found_val); return 0; } -#endif static void blocking_first(DB_ENV *db_env, DB *db, uint64_t nrows, long sleeptime) { int r; @@ -122,11 +120,7 @@ static void blocking_first(DB_ENV *db_env, DB *db, uint64_t nrows, long sleeptim DBC *cursor = NULL; r = db->cursor(db, txn, &cursor, 0); assert(r == 0); // get a write lock on -inf +inf -#if TOKUDB r = cursor->c_getf_first(cursor, DB_RMW, blocking_first_callback, &context); assert(r == DB_NOTFOUND); -#else - r = cursor->c_get(cursor, &context.key, &context.val, DB_FIRST + DB_RMW); assert(r == DB_NOTFOUND); -#endif usleep(sleeptime); @@ -219,9 +213,7 @@ int test_main(int argc, char * const argv[]) { r = db_env->set_cachesize(db_env, cachesize / gig, cachesize % gig, 1); assert(r == 0); } r = db_env->open(db_env, db_env_dir, db_env_open_flags, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0); -#if TOKUDB r = db_env->set_lock_timeout(db_env, 30 * 1000, nullptr); assert(r == 0); -#endif // create the db DB *db = NULL; |