From db270734d8b4208e00ce9de5af1af7ee11823f6d Mon Sep 17 00:00:00 2001 From: Rusty Russell Date: Wed, 24 Feb 2010 10:41:15 +1030 Subject: tdb: cleanup: tdb_release_extra_locks() helper Move locking intelligence back into lock.c, rather than open-coding the lock release in transaction.c. Signed-off-by: Rusty Russell --- lib/tdb/common/lock.c | 20 ++++++++++++++++++++ lib/tdb/common/tdb_private.h | 1 + lib/tdb/common/transaction.c | 18 +----------------- 3 files changed, 22 insertions(+), 17 deletions(-) (limited to 'lib/tdb/common') diff --git a/lib/tdb/common/lock.c b/lib/tdb/common/lock.c index 4f8970fd34..3013b06af6 100644 --- a/lib/tdb/common/lock.c +++ b/lib/tdb/common/lock.c @@ -702,3 +702,23 @@ bool tdb_have_extra_locks(struct tdb_context *tdb) } return false; } + +/* The transaction code uses this to remove all locks. */ +void tdb_release_extra_locks(struct tdb_context *tdb) +{ + unsigned int i; + + if (tdb->allrecord_lock.count != 0) { + tdb_brunlock(tdb, tdb->allrecord_lock.ltype, + FREELIST_TOP, 4*tdb->header.hash_size); + tdb->allrecord_lock.count = 0; + } + + for (i=0;inum_lockrecs;i++) { + tdb_brunlock(tdb, tdb->lockrecs[i].ltype, + tdb->lockrecs[i].off, 1); + } + tdb->num_locks = 0; + tdb->num_lockrecs = 0; + SAFE_FREE(tdb->lockrecs); +} diff --git a/lib/tdb/common/tdb_private.h b/lib/tdb/common/tdb_private.h index 1af975de6e..32c05210ba 100644 --- a/lib/tdb/common/tdb_private.h +++ b/lib/tdb/common/tdb_private.h @@ -235,6 +235,7 @@ int tdb_brlock(struct tdb_context *tdb, int tdb_brunlock(struct tdb_context *tdb, int rw_type, tdb_off_t offset, size_t len); bool tdb_have_extra_locks(struct tdb_context *tdb); +void tdb_release_extra_locks(struct tdb_context *tdb); int tdb_transaction_lock(struct tdb_context *tdb, int ltype); int tdb_transaction_unlock(struct tdb_context *tdb, int ltype); int tdb_brlock_upgrade(struct tdb_context *tdb, tdb_off_t offset, size_t len); diff --git a/lib/tdb/common/transaction.c b/lib/tdb/common/transaction.c index 36b5c035b7..02ef72a357 100644 --- a/lib/tdb/common/transaction.c +++ b/lib/tdb/common/transaction.c @@ -620,23 +620,7 @@ static int _tdb_transaction_cancel(struct tdb_context *tdb, int ltype) tdb->transaction->open_lock_taken = false; } - /* remove any global lock created during the transaction */ - if (tdb->allrecord_lock.count != 0) { - tdb_brunlock(tdb, tdb->allrecord_lock.ltype, - FREELIST_TOP, 4*tdb->header.hash_size); - tdb->allrecord_lock.count = 0; - } - - /* remove any locks created during the transaction */ - if (tdb->num_locks != 0) { - for (i=0;inum_lockrecs;i++) { - tdb_brunlock(tdb, tdb->lockrecs[i].ltype, - tdb->lockrecs[i].off, 1); - } - tdb->num_locks = 0; - tdb->num_lockrecs = 0; - SAFE_FREE(tdb->lockrecs); - } + tdb_release_extra_locks(tdb); /* restore the normal io methods */ tdb->methods = tdb->transaction->io_methods; -- cgit