Commit d0227a5e authored by Yoni Fogel's avatar Yoni Fogel

refs #4964 Comments/cleanups due to review

git-svn-id: file:///svn/toku/tokudb@45005 c7de825b-a66e-492c-adef-691d508d4ae1
parent 2b1c108a
...@@ -463,7 +463,8 @@ int toku_db_pre_acquire_fileops_lock(DB *db, DB_TXN *txn) { ...@@ -463,7 +463,8 @@ int toku_db_pre_acquire_fileops_lock(DB *db, DB_TXN *txn) {
} }
// //
// This function is the only way to set a descriptor of a DB. // This function is used both to set an initial descriptor of a DB and to
// change a descriptor. (only way to set a descriptor of a DB)
// //
static int static int
toku_db_change_descriptor(DB *db, DB_TXN* txn, const DBT* descriptor, u_int32_t flags) { toku_db_change_descriptor(DB *db, DB_TXN* txn, const DBT* descriptor, u_int32_t flags) {
...@@ -484,8 +485,10 @@ toku_db_change_descriptor(DB *db, DB_TXN* txn, const DBT* descriptor, u_int32_t ...@@ -484,8 +485,10 @@ toku_db_change_descriptor(DB *db, DB_TXN* txn, const DBT* descriptor, u_int32_t
r = EINVAL; // cannot have a parent if you are a resetting op r = EINVAL; // cannot have a parent if you are a resetting op
goto cleanup; goto cleanup;
} }
// For a hot index, this is an initial descriptor.
// We do not support (yet) hcad with hot index concurrently on a single table, which
// would require changing a descriptor for a hot index.
if (!is_db_hot_index) { if (!is_db_hot_index) {
//TODO(zardosht): why doesn't hot_index need to do locking?
r = toku_db_pre_acquire_table_lock(db, txn); r = toku_db_pre_acquire_table_lock(db, txn);
if (r != 0) { goto cleanup; } if (r != 0) { goto cleanup; }
} }
...@@ -661,7 +664,6 @@ locked_db_close(DB * db, u_int32_t UU(flags)) { ...@@ -661,7 +664,6 @@ locked_db_close(DB * db, u_int32_t UU(flags)) {
int int
autotxn_db_get(DB* db, DB_TXN* txn, DBT* key, DBT* data, u_int32_t flags) { autotxn_db_get(DB* db, DB_TXN* txn, DBT* key, DBT* data, u_int32_t flags) {
BOOL changed; int r; BOOL changed; int r;
// ydb lock is NOT held here
r = toku_db_construct_autotxn(db, &txn, &changed, FALSE); r = toku_db_construct_autotxn(db, &txn, &changed, FALSE);
if (r!=0) return r; if (r!=0) return r;
r = toku_db_get(db, txn, key, data, flags); r = toku_db_get(db, txn, key, data, flags);
...@@ -671,7 +673,6 @@ autotxn_db_get(DB* db, DB_TXN* txn, DBT* key, DBT* data, u_int32_t flags) { ...@@ -671,7 +673,6 @@ autotxn_db_get(DB* db, DB_TXN* txn, DBT* key, DBT* data, u_int32_t flags) {
static inline int static inline int
autotxn_db_getf_set (DB *db, DB_TXN *txn, u_int32_t flags, DBT *key, YDB_CALLBACK_FUNCTION f, void *extra) { autotxn_db_getf_set (DB *db, DB_TXN *txn, u_int32_t flags, DBT *key, YDB_CALLBACK_FUNCTION f, void *extra) {
BOOL changed; int r; BOOL changed; int r;
// ydb lock is NOT held here
r = toku_db_construct_autotxn(db, &txn, &changed, FALSE); r = toku_db_construct_autotxn(db, &txn, &changed, FALSE);
if (r!=0) return r; if (r!=0) return r;
r = db_getf_set(db, txn, flags, key, f, extra); r = db_getf_set(db, txn, flags, key, f, extra);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment