Remove outdated and deprecated code.

1 files changed, 0 insertions, 392 deletions

diff --git a/src/kvstorage_bdb.c b/src/kvstorage_bdb.c
deleted file mode 100644
index df2a5ba19..000000000
--- a/src/kvstorage_bdb.c
+++ /dev/null
@@ -1,392 +0,0 @@
-/* Copyright (c) 2010, Vsevolod Stakhov
- * All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *       * Redistributions of source code must retain the above copyright
- *         notice, this list of conditions and the following disclaimer.
- *       * Redistributions in binary form must reproduce the above copyright
- *         notice, this list of conditions and the following disclaimer in the
- *         documentation and/or other materials provided with the distribution.
- *
- * THIS SOFTWARE IS PROVIDED ''AS IS'' AND ANY
- * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
- * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
- * DISCLAIMED. IN NO EVENT SHALL AUTHOR BE LIABLE FOR ANY
- * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
- * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
- * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
- * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
- * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- */
-
-
-#include "config.h"
-#include "kvstorage.h"
-#include "kvstorage_bdb.h"
-#include "util.h"
-#include "main.h"
-#include <db.h>
-
-struct bdb_op {
-	struct rspamd_kv_element *elt;
-	enum {
-		BDB_OP_INSERT,
-		BDB_OP_DELETE,
-		BDB_OP_REPLACE
-	} op;
-};
-
-/* Main bdb structure */
-struct rspamd_bdb_backend {
-	backend_init init_func;                     /*< this callback is called on kv storage initialization */
-	backend_insert insert_func;                 /*< this callback is called when element is inserted */
-	backend_replace replace_func;               /*< this callback is called when element is replaced */
-	backend_lookup lookup_func;                 /*< this callback is used for lookup of element */
-	backend_delete delete_func;                 /*< this callback is called when an element is deleted */
-	backend_sync sync_func;                     /*< this callback is called when backend need to be synced */
-	backend_destroy destroy_func;               /*< this callback is used for destroying all elements inside backend */
-	DB_ENV *envp;                               /*< db environment */
-	DB *dbp;                                    /*< db pointer */
-	gchar *filename;
-	gchar *dirname;
-	guint sync_ops;
-	GQueue *ops_queue;
-	GHashTable *ops_hash;
-	gboolean initialized;
-};
-
-/* Process single bdb operation */
-static gboolean
-bdb_process_single_op (struct rspamd_bdb_backend *db,
-	DB_TXN *txn,
-	struct bdb_op *op)
-{
-	DBT db_key, db_data;
-
-	memset (&db_key,  0, sizeof(DBT));
-	memset (&db_data, 0, sizeof(DBT));
-
-	db_key.size = op->elt->keylen;
-	db_key.data = ELT_KEY (op->elt);
-	db_data.size = op->elt->size + sizeof (struct rspamd_kv_element) +
-		op->elt->keylen + 1;
-	db_data.data = op->elt;
-
-	switch (op->op) {
-	case BDB_OP_INSERT:
-	case BDB_OP_REPLACE:
-		db_data.flags = DB_DBT_USERMEM;
-		if (db->dbp->put (db->dbp, NULL, &db_key, &db_data, 0) != 0) {
-			return FALSE;
-		}
-		break;
-	case BDB_OP_DELETE:
-		db_data.flags = DB_DBT_USERMEM;
-		/* Set cursor */
-		if (db->dbp->del (db->dbp, NULL, &db_key, 0) != 0) {
-			return FALSE;
-		}
-		break;
-	}
-
-	op->elt->flags &= ~KV_ELT_DIRTY;
-	return TRUE;
-}
-
-/* Process operations queue */
-static gboolean
-bdb_process_queue (struct rspamd_kv_backend *backend)
-{
-	struct rspamd_bdb_backend *db = (struct rspamd_bdb_backend *)backend;
-	struct bdb_op *op;
-	GList *cur;
-
-	cur = db->ops_queue->head;
-	while (cur) {
-		op = cur->data;
-		if (!bdb_process_single_op (db, NULL, op)) {
-			return FALSE;
-		}
-		cur = g_list_next (cur);
-	}
-
-	/* Clean the queue */
-	cur = db->ops_queue->head;
-	while (cur) {
-		op = cur->data;
-		if (op->op == BDB_OP_DELETE || (op->elt->flags & KV_ELT_NEED_FREE) !=
-			0) {
-			/* Also clean memory */
-			g_slice_free1 (ELT_SIZE (op->elt), op->elt);
-		}
-		g_slice_free1 (sizeof (struct bdb_op), op);
-		cur = g_list_next (cur);
-	}
-
-	g_hash_table_remove_all (db->ops_hash);
-	g_queue_clear (db->ops_queue);
-
-	return TRUE;
-
-}
-
-/* Backend callbacks */
-static void
-rspamd_bdb_init (struct rspamd_kv_backend *backend)
-{
-	struct rspamd_bdb_backend *db = (struct rspamd_bdb_backend *)backend;
-	guint32 flags;
-	gint ret;
-
-	if ((ret = db_env_create (&db->envp, 0)) != 0) {
-		/* Cannot create environment */
-		goto err;
-	}
-
-	flags = DB_INIT_MPOOL |
-		DB_CREATE |            /* Create the environment if it does not already exist. */
-		DB_INIT_LOCK |         /* Initialize locking. */
-		DB_THREAD;             /* Use threads */
-
-	if ((ret = db->envp->open (db->envp, db->dirname, flags, 0)) != 0) {
-		/* Cannot open environment */
-		goto err;
-	}
-	/*
-	 * Configure db to perform deadlock detection internally, and to
-	 * choose the transaction that has performed the least amount of
-	 * writing to break the deadlock in the event that one is detected.
-	 */
-	db->envp->set_lk_detect (db->envp, DB_LOCK_DEFAULT);
-
-	/*
-	 * Avoid explicit sync on committing
-	 */
-	db->envp->set_flags (db->envp, DB_TXN_NOSYNC, 1);
-
-	flags = DB_CREATE | DB_THREAD;
-	/* Create and open db pointer */
-	if ((ret = db_create (&db->dbp, db->envp, 0)) != 0) {
-		goto err;
-	}
-
-	if ((ret =
-		db->dbp->open (db->dbp, NULL, db->filename, NULL, DB_HASH, flags,
-		0)) != 0) {
-		goto err;
-	}
-
-	db->initialized = TRUE;
-
-	return;
-err:
-	if (db->dbp != NULL) {
-		msg_err ("error opening bdb database: %s", db_strerror (ret));
-		db->dbp->close (db->dbp, 0);
-	}
-	if (db->envp != NULL) {
-		msg_err ("error opening bdb environment: %s", db_strerror (ret));
-		db->envp->close (db->envp, 0);
-	}
-}
-
-static gboolean
-rspamd_bdb_insert (struct rspamd_kv_backend *backend,
-	gpointer key,
-	guint keylen,
-	struct rspamd_kv_element *elt)
-{
-	struct rspamd_bdb_backend *db = (struct rspamd_bdb_backend *)backend;
-	struct bdb_op *op;
-
-	if (!db->initialized) {
-		return FALSE;
-	}
-
-	op = g_slice_alloc (sizeof (struct bdb_op));
-	op->op = BDB_OP_INSERT;
-	op->elt = elt;
-	elt->flags |= KV_ELT_DIRTY;
-
-	g_queue_push_head (db->ops_queue, op);
-	g_hash_table_insert (db->ops_hash, elt, op);
-
-	if (db->sync_ops > 0 && g_queue_get_length (db->ops_queue) >=
-		db->sync_ops) {
-		return bdb_process_queue (backend);
-	}
-
-	return TRUE;
-}
-
-static gboolean
-rspamd_bdb_replace (struct rspamd_kv_backend *backend,
-	gpointer key,
-	guint keylen,
-	struct rspamd_kv_element *elt)
-{
-	struct rspamd_bdb_backend *db = (struct rspamd_bdb_backend *)backend;
-	struct bdb_op *op;
-
-	if (!db->initialized) {
-		return FALSE;
-	}
-
-	op = g_slice_alloc (sizeof (struct bdb_op));
-	op->op = BDB_OP_REPLACE;
-	op->elt = elt;
-	elt->flags |= KV_ELT_DIRTY;
-
-	g_queue_push_head (db->ops_queue, op);
-	g_hash_table_insert (db->ops_hash, elt, op);
-
-	if (db->sync_ops > 0 && g_queue_get_length (db->ops_queue) >=
-		db->sync_ops) {
-		return bdb_process_queue (backend);
-	}
-
-	return TRUE;
-}
-
-static struct rspamd_kv_element *
-rspamd_bdb_lookup (struct rspamd_kv_backend *backend, gpointer key,
-	guint keylen)
-{
-	struct rspamd_bdb_backend *db = (struct rspamd_bdb_backend *)backend;
-	struct bdb_op *op;
-	DBT db_key, db_data;
-	struct rspamd_kv_element *elt = NULL;
-	struct rspamd_kv_element search_elt;
-
-	search_elt.keylen = keylen;
-	search_elt.p = key;
-
-	if (!db->initialized) {
-		return NULL;
-	}
-	/* First search in ops queue */
-	if ((op = g_hash_table_lookup (db->ops_hash, &search_elt)) != NULL) {
-		if (op->op == BDB_OP_DELETE) {
-			/* To delete, so assume it as not found */
-			return NULL;
-		}
-		return op->elt;
-	}
-
-	memset (&db_key,  0, sizeof(DBT));
-	memset (&db_data, 0, sizeof(DBT));
-	db_key.size = keylen;
-	db_key.data = key;
-	db_data.flags = DB_DBT_MALLOC;
-
-	if (db->dbp->get (db->dbp, NULL, &db_key, &db_data, 0) == 0) {
-		elt = db_data.data;
-		elt->flags &= ~KV_ELT_DIRTY;
-	}
-
-	return elt;
-}
-
-static void
-rspamd_bdb_delete (struct rspamd_kv_backend *backend, gpointer key,
-	guint keylen)
-{
-	struct rspamd_bdb_backend *db = (struct rspamd_bdb_backend *)backend;
-	struct bdb_op *op;
-	struct rspamd_kv_element *elt;
-	struct rspamd_kv_element search_elt;
-
-	search_elt.keylen = keylen;
-	search_elt.p = key;
-
-	if (!db->initialized) {
-		return;
-	}
-
-	if ((op = g_hash_table_lookup (db->ops_hash, &search_elt)) != NULL) {
-		op->op = BDB_OP_DELETE;
-		return;
-	}
-
-	elt = rspamd_bdb_lookup (backend, key, keylen);
-	if (elt == NULL) {
-		return;
-	}
-	op = g_slice_alloc (sizeof (struct bdb_op));
-	op->op = BDB_OP_DELETE;
-	op->elt = elt;
-	elt->flags |= KV_ELT_DIRTY;
-
-	g_queue_push_head (db->ops_queue, op);
-	g_hash_table_insert (db->ops_hash, elt, op);
-
-	if (db->sync_ops > 0 && g_queue_get_length (db->ops_queue) >=
-		db->sync_ops) {
-		bdb_process_queue (backend);
-	}
-
-	return;
-}
-
-static void
-rspamd_bdb_destroy (struct rspamd_kv_backend *backend)
-{
-	struct rspamd_bdb_backend *db = (struct rspamd_bdb_backend *)backend;
-
-	if (db->initialized) {
-		bdb_process_queue (backend);
-		if (db->dbp != NULL) {
-			db->dbp->close (db->dbp, 0);
-		}
-		if (db->envp != NULL) {
-			db->envp->close (db->envp, 0);
-		}
-		g_free (db->filename);
-		g_free (db->dirname);
-		g_queue_free (db->ops_queue);
-		g_hash_table_unref (db->ops_hash);
-		g_slice_free1 (sizeof (struct rspamd_bdb_backend), db);
-	}
-}
-
-/* Create new bdb backend */
-struct rspamd_kv_backend *
-rspamd_kv_bdb_new (const gchar *filename, guint sync_ops)
-{
-	struct rspamd_bdb_backend *new;
-	struct stat st;
-	gchar *dirname;
-
-	if (filename == NULL) {
-		return NULL;
-	}
-	dirname = g_path_get_dirname (filename);
-	if (dirname == NULL || stat (dirname, &st) == -1 || !S_ISDIR (st.st_mode)) {
-		/* Inaccessible path */
-		if (dirname != NULL) {
-			g_free (dirname);
-		}
-		msg_err ("invalid file: %s", filename);
-		return NULL;
-	}
-
-	new = g_slice_alloc0 (sizeof (struct rspamd_bdb_backend));
-	new->dirname = dirname;
-	new->filename = g_strdup (filename);
-	new->sync_ops = sync_ops;
-	new->ops_queue = g_queue_new ();
-	new->ops_hash = g_hash_table_new (kv_elt_hash_func, kv_elt_compare_func);
-
-	/* Init callbacks */
-	new->init_func = rspamd_bdb_init;
-	new->insert_func = rspamd_bdb_insert;
-	new->lookup_func = rspamd_bdb_lookup;
-	new->delete_func = rspamd_bdb_delete;
-	new->replace_func = rspamd_bdb_replace;
-	new->sync_func = bdb_process_queue;
-	new->destroy_func = rspamd_bdb_destroy;
-
-	return (struct rspamd_kv_backend *)new;
-}