diff --git a/src/loader.c b/src/loader.c index b0f1a206784..7337bcc7aa1 100644 --- a/src/loader.c +++ b/src/loader.c @@ -164,7 +164,10 @@ int toku_loader_create_loader(DB_ENV *env, // lock tables and check empty for(int i=0;ipre_acquire_table_lock(dbs[i], txn); + toku_ydb_lock(); //Must hold ydb lock for acquiring locks + BOOL using_puts = (loader->i->loader_flags & LOADER_USE_PUTS) != 0; + r = toku_db_pre_acquire_table_lock(dbs[i], txn, !using_puts); + toku_ydb_unlock(); if (r!=0) break; } r = verify_empty(dbs[i], txn);