diff options
Diffstat (limited to 'storage/tokudb/ft-index/src/tests/blocking-first.cc')
-rw-r--r-- | storage/tokudb/ft-index/src/tests/blocking-first.cc | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/storage/tokudb/ft-index/src/tests/blocking-first.cc b/storage/tokudb/ft-index/src/tests/blocking-first.cc index 1bd414a90aa..6d255023274 100644 --- a/storage/tokudb/ft-index/src/tests/blocking-first.cc +++ b/storage/tokudb/ft-index/src/tests/blocking-first.cc @@ -116,7 +116,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; @@ -125,7 +124,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; @@ -140,11 +138,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 ... 0 -#if TOKUDB r = cursor->c_getf_first(cursor, DB_RMW, blocking_first_callback, &context); assert(r == 0); -#else - r = cursor->c_get(cursor, &context.key, &context.val, DB_FIRST + DB_RMW); assert(r == 0); -#endif usleep(sleeptime); r = cursor->c_close(cursor); assert(r == 0); @@ -236,9 +230,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; |