summaryrefslogtreecommitdiff
path: root/source4/lib/tdb/common
diff options
context:
space:
mode:
authorAndrew Tridgell <tridge@samba.org>2008-02-07 23:06:44 +1100
committerAndrew Tridgell <tridge@samba.org>2008-02-07 23:06:44 +1100
commit8c4e52547bbcf8b334c0a1ba65191c8258e00132 (patch)
tree4ce792d18b83d1a90c15e3fa94e26de1a0c84dac /source4/lib/tdb/common
parente939659e439c153df492f9e76968d723687da353 (diff)
downloadsamba-8c4e52547bbcf8b334c0a1ba65191c8258e00132.tar.gz
samba-8c4e52547bbcf8b334c0a1ba65191c8258e00132.tar.bz2
samba-8c4e52547bbcf8b334c0a1ba65191c8258e00132.zip
merge growing tdb for tdb_wipe_all() fix from ctdb
(This used to be commit df4efb902ec5053ae9d7c6e4fd1e21255ca66914)
Diffstat (limited to 'source4/lib/tdb/common')
-rw-r--r--source4/lib/tdb/common/tdb.c43
1 files changed, 43 insertions, 0 deletions
diff --git a/source4/lib/tdb/common/tdb.c b/source4/lib/tdb/common/tdb.c
index ea5d9ccc60..a25c3e7aca 100644
--- a/source4/lib/tdb/common/tdb.c
+++ b/source4/lib/tdb/common/tdb.c
@@ -696,11 +696,31 @@ int tdb_wipe_all(struct tdb_context *tdb)
int i;
tdb_off_t offset = 0;
ssize_t data_len;
+ tdb_off_t recovery_head;
+ tdb_len_t recovery_size = 0;
if (tdb_lockall(tdb) != 0) {
return -1;
}
+ /* see if the tdb has a recovery area, and remember its size
+ if so. We don't want to lose this as otherwise each
+ tdb_wipe_all() in a transaction will increase the size of
+ the tdb by the size of the recovery area */
+ if (tdb_ofs_read(tdb, TDB_RECOVERY_HEAD, &recovery_head) == -1) {
+ TDB_LOG((tdb, TDB_DEBUG_FATAL, "tdb_wipe_all: failed to read recovery head\n"));
+ goto failed;
+ }
+
+ if (recovery_head != 0) {
+ struct list_struct rec;
+ if (tdb->methods->tdb_read(tdb, recovery_head, &rec, sizeof(rec), DOCONV()) == -1) {
+ TDB_LOG((tdb, TDB_DEBUG_FATAL, "tdb_wipe_all: failed to read recovery record\n"));
+ return -1;
+ }
+ recovery_size = rec.rec_len + sizeof(rec);
+ }
+
/* wipe the hashes */
for (i=0;i<tdb->header.hash_size;i++) {
if (tdb_ofs_write(tdb, TDB_HASH_TOP(i), &offset) == -1) {
@@ -722,6 +742,11 @@ int tdb_wipe_all(struct tdb_context *tdb)
/* add all the rest of the file to the freelist */
data_len = (tdb->map_size - TDB_DATA_START(tdb->header.hash_size)) - sizeof(struct list_struct);
+ if (data_len < recovery_size+sizeof(tdb_off_t)) {
+ recovery_size = 0;
+ } else {
+ data_len -= recovery_size;
+ }
if (data_len > 0) {
struct list_struct rec;
memset(&rec,'\0',sizeof(rec));
@@ -732,6 +757,24 @@ int tdb_wipe_all(struct tdb_context *tdb)
}
}
+ /* possibly add the recovery record */
+ if (recovery_size != 0) {
+ struct list_struct rec;
+
+ recovery_head = tdb->map_size - recovery_size;
+
+ ZERO_STRUCT(rec);
+ rec.rec_len = recovery_size - sizeof(rec);
+ if (tdb_rec_write(tdb, recovery_head, &rec) != 0) {
+ TDB_LOG((tdb, TDB_DEBUG_FATAL,"tdb_wipe_all: failed to add recovery record\n"));
+ goto failed;
+ }
+ if (tdb_ofs_write(tdb, TDB_RECOVERY_HEAD, &recovery_head) == -1) {
+ TDB_LOG((tdb, TDB_DEBUG_FATAL,"tdb_wipe_all: failed to write recovery head\n"));
+ goto failed;
+ }
+ }
+
if (tdb_unlockall(tdb) != 0) {
TDB_LOG((tdb, TDB_DEBUG_FATAL,"tdb_wipe_all: failed to unlock\n"));
goto failed;