experimental QDBM TXN patch

[Matthias Andree]

OK, here's the second try of transactions for QDBM. Turns out QDBM
allows transactions only for writer database handles.

This passes "make check" for me.

--- src/datastore_qdbm.c	1 Nov 2004 01:04:25 -0000	1.33
+++ src/datastore_qdbm.c	8 Nov 2004 22:13:21 -0000
@@ -7,7 +7,7 @@
 
 AUTHORS:
 Gyepi Sam <gyepi at praxis-sw.com>          2003
-Matthias Andree <matthias.andree at gmx.de> 2003
+Matthias Andree <matthias.andree at gmx.de> 2003-2004
 Stefan Bellon <sbellon at sbellon.de>       2003-2004
 
 ******************************************************************************/
@@ -18,6 +18,7 @@
 #include <cabin.h>
 #include <villa.h>
 #include <stdlib.h>
+#include <assert.h>
 
 #include "datastore.h"
 #include "datastore_db.h"
@@ -34,6 +35,7 @@
     char *name;
     bool locked;
     bool created;
+    bool writer;
     VILLA *dbp;
 } dbh_t;
 
@@ -41,6 +43,7 @@
  * or transactional initialization/shutdown */
 
 static bool init = false;
+static bool txn = false;
 
 /* Function definitions */
 
@@ -123,6 +126,7 @@
 
     dbp = handle->dbp = vlopen(handle->name, open_flags, cmpkey);
 
+    /* retry if a writer */
     if ((dbp == NULL) && (open_mode & DS_WRITE)) {
 	dbp = handle->dbp = vlopen(handle->name, open_flags|VL_OCREAT, cmpkey);
 	if (dbp != NULL)
@@ -203,14 +207,10 @@
 */
 static inline void db_optimize(VILLA *dbp, char *name)
 {
-    UNUSED(dbp);
     UNUSED(name);
 
-    /* The Villa API doesn't need optimizing like the formerly used
-       Depot API because Villa uses B+ trees and Depot uses hash tables.
-       Database size may grow larger and could get compacted with
-       vloptimize() however as the database size with Villa is smaller
-       anyway, I don't think it is worth it. */
+    assert(!txn);
+    vloptimize(dbp);
 }
 
 
@@ -230,7 +230,16 @@
 	exit(EX_ERROR);
     }
 
+#if 0
+    /* The Villa API doesn't need optimizing like the formerly used
+       Depot API because Villa uses B+ trees and Depot uses hash tables.
+       Database size may grow larger and could get compacted with
+       vloptimize() however as the database size with Villa is smaller
+       anyway, I don't think it is worth it. -- Stefan Bellon */
+
+    /* NOTE: db_optimize must not be called with a transaction open! */
     db_optimize(dbp, handle->name);
+#endif
 
     return 0;
 }
@@ -271,6 +280,7 @@
     dbh_t *handle = vhandle;
     VILLA * dbp = handle->dbp;
 
+    assert(!txn);
     if (!vlsync(dbp))
 	print_error(__FILE__, __LINE__, "(qdbm) vlsync failed: %s",
 		    dperrmsg(dpecode));
@@ -342,25 +352,51 @@
 }
 
 /** begin transaction. Returns 0 for success. */
-int db_txn_begin(void *d)
+int db_txn_begin(void *vhandle)
 {
-    UNUSED(d);
+    dbh_t *handle = vhandle;
+    VILLA *dbp = handle->dbp;
 
-    return 0;
+    assert(!txn);
+    if (!handle->writer) return DST_OK;
+
+    if (vltranbegin(dbp)) {
+	txn = true;
+	return DST_OK;
+    }
+    print_error(__FILE__, __LINE__, "(qdbm) vltranbegin(%s) failed: %s",
+		handle->name, dperrmsg(dpecode));
+    return DST_FAILURE;
 }
 
-int db_txn_abort(void *d)
+int db_txn_abort(void *vhandle)
 {
-    UNUSED(d);
+    dbh_t *handle = vhandle;
+    VILLA *dbp = handle->dbp;
 
-    return 0;
+    if (!handle->writer) return DST_OK;
+    assert(txn);
+
+    txn = false;
+    if (vltranabort(dbp)) return DST_OK;
+    print_error(__FILE__, __LINE__, "(qdbm) vltranabort(%s) failed: %s",
+		handle->name, dperrmsg(dpecode));
+    return DST_FAILURE;
 }
 
-int db_txn_commit(void *d)
+int db_txn_commit(void *vhandle)
 {
-    UNUSED(d);
+    dbh_t *handle = vhandle;
+    VILLA *dbp = handle->dbp;
 
-    return 0;
+    if (!handle->writer) return DST_OK;
+    assert(txn);
+
+    txn = false;
+    if (vltrancommit(dbp)) return DST_OK;
+    print_error(__FILE__, __LINE__, "(qdbm) vltrancommit(%s) failed: %s",
+		handle->name, dperrmsg(dpecode));
+    return DST_FAILURE;
 }
 
 int db_recover(int a, int b)


-- 
Matthias Andree