main/db.c File Reference

ASTdb Management. More...

#include "asterisk.h"
#include "asterisk/_private.h"
#include "asterisk/paths.h"
#include <sys/time.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <signal.h>
#include <dirent.h>
#include <sqlite3.h>
#include "asterisk/channel.h"
#include "asterisk/file.h"
#include "asterisk/app.h"
#include "asterisk/dsp.h"
#include "asterisk/astdb.h"
#include "asterisk/cli.h"
#include "asterisk/utils.h"
#include "asterisk/manager.h"

Include dependency graph for main/db.c:

Go to the source code of this file.

Macros
#define	DEFINE_SQL_STATEMENT(stmt, sql)
#define	MAX_DB_FIELD   256

Functions
static int	ast_db_begin_transaction (void)
static int	ast_db_commit_transaction (void)
int	ast_db_del (const char *family, const char *key)
	Delete entry in astdb. More...
int	ast_db_del2 (const char *family, const char *key)
	Same as ast_db_del, but with more stringent error checking. More...
int	ast_db_deltree (const char *family, const char *keytree)
	Delete one or more entries in astdb. More...
int	ast_db_exists (const char *family, const char *key)
	Check if family/key exitsts. More...
void	ast_db_freetree (struct ast_db_entry *dbe)
	Free structure created by ast_db_gettree() More...
int	ast_db_get (const char *family, const char *key, char *value, int valuelen)
	Get key value specified by family/key. More...
int	ast_db_get_allocated (const char *family, const char *key, char **out)
	Get key value specified by family/key as a heap allocated string. More...
struct ast_db_entry *	ast_db_gettree (const char *family, const char *keytree)
	Get a list of values within the astdb tree. More...
struct ast_db_entry *	ast_db_gettree_by_prefix (const char *family, const char *key_prefix)
	Get a list of values with the given key prefix. More...
int	ast_db_put (const char *family, const char *key, const char *value)
	Store value addressed by family/key. More...
static int	ast_db_rollback_transaction (void)
static void	astdb_atexit (void)
int	astdb_init (void)
static void	clean_statements (void)
static int	clean_stmt (sqlite3_stmt **stmt, const char *sql)
static int	convert_bdb_to_sqlite3 (void)
static int	db_create_astdb (void)
static int	db_execute_sql (const char *sql, int(*callback)(void *, int, char **, char **), void *arg)
static int	db_get_common (const char *family, const char *key, char **buffer, int bufferlen)
static struct ast_db_entry *	db_gettree_common (sqlite3_stmt *stmt)
static int	db_init (void)
static int	db_open (void)
static void	db_sync (void)
static void *	db_sync_thread (void *data)
	DEFINE_SQL_STATEMENT (put_stmt, "INSERT OR REPLACE INTO astdb (key, value) VALUES (?, ?)")
static int	display_results (void *arg, int columns, char **values, char **colnames)
static char *	handle_cli_database_del (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_database_deltree (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_database_get (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_database_put (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_database_query (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_database_show (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_database_showkey (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static int	init_statements (void)
static int	manager_db_tree_get (struct mansession *s, const struct message *m)
static int	manager_dbdel (struct mansession *s, const struct message *m)
static int	manager_dbdeltree (struct mansession *s, const struct message *m)
static int	manager_dbget (struct mansession *s, const struct message *m)
static int	manager_dbput (struct mansession *s, const struct message *m)

Variables
static sqlite3 *	astdb
static struct ast_cli_entry	cli_database []
static ast_cond_t	dbcond
static ast_mutex_t	dblock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static int	doexit
static int	dosync
static pthread_t	syncthread

Detailed Description

ASTdb Management.

Author

Mark Spencer marks.nosp@m.ter@.nosp@m.digiu.nosp@m.m.co.nosp@m.m

Note

DB3 is licensed under Sleepycat Public License and is thus incompatible with GPL. To avoid having to make another exception (and complicate licensing even further) we elect to use DB1 which is BSD licensed

Definition in file main/db.c.

Macro Definition Documentation

DEFINE_SQL_STATEMENT

#define DEFINE_SQL_STATEMENT	(		stmt,
			sql
	)

Value:

    static sqlite3_stmt *stmt; \
    const char stmt##_sql[] = sql;

Definition at line 129 of file main/db.c.

MAX_DB_FIELD

#define MAX_DB_FIELD   256

Definition at line 119 of file main/db.c.

Function Documentation

ast_db_begin_transaction()

static int ast_db_begin_transaction ( void  )

static

Definition at line 327 of file main/db.c.

{
    return db_execute_sql("BEGIN TRANSACTION", NULL, NULL);
}

References db_execute_sql(), and NULL.

Referenced by db_sync_thread().

ast_db_commit_transaction()

static int ast_db_commit_transaction ( void  )

static

Definition at line 332 of file main/db.c.

{
    return db_execute_sql("COMMIT", NULL, NULL);
}

References db_execute_sql(), and NULL.

Referenced by db_sync_thread().

ast_db_del()

int ast_db_del	(	const char *	family,
		const char *	key
	)

Delete entry in astdb.

Definition at line 476 of file main/db.c.

{
    char fullkey[MAX_DB_FIELD];
    size_t fullkey_len;
    int res = 0;
 
    if (strlen(family) + strlen(key) + 2 > sizeof(fullkey) - 1) {
        ast_log(LOG_WARNING, "Family and key length must be less than %zu bytes\n", sizeof(fullkey) - 3);
        return -1;
    }
 
    fullkey_len = snprintf(fullkey, sizeof(fullkey), "/%s/%s", family, key);
 
    ast_mutex_lock(&dblock);
    if (sqlite3_bind_text(del_stmt, 1, fullkey, fullkey_len, SQLITE_STATIC) != SQLITE_OK) {
        ast_log(LOG_WARNING, "Couldn't bind key to stmt: %s\n", sqlite3_errmsg(astdb));
        res = -1;
    } else if (sqlite3_step(del_stmt) != SQLITE_DONE) {
        ast_debug(1, "Unable to find key '%s' in family '%s'\n", key, family);
        res = -1;
    }
    sqlite3_reset(del_stmt);
    db_sync();
    ast_mutex_unlock(&dblock);
 
    return res;
}

References ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, astdb, db_sync(), dblock, LOG_WARNING, and MAX_DB_FIELD.

Referenced by __expire_registry(), add_cert_key_to_astdb(), ast_privacy_set(), AST_TEST_DEFINE(), auth_exec(), cache_lookup_internal(), cleanup_cert_from_astdb_and_fs(), destroy_all_channels(), dialgroup_refreshdb(), do_register_expire(), dump_queue_members(), function_db_delete(), handle_dbdel(), media_cache_item_del_from_astdb(), media_cache_remove_from_astdb(), mkintf(), process_clearcache(), reload_queue_members(), sorcery_astdb_delete(), stasis_app_device_state_delete(), and update_registry().

ast_db_del2()

int ast_db_del2	(	const char *	family,
		const char *	key
	)

Same as ast_db_del, but with more stringent error checking.

Unlike ast_db_del, if the key does not exist in the first place, an error is emitted and -1 is returned.

Return values

-1	An error occured (including key not found to begin with)
0	Successfully deleted

Definition at line 504 of file main/db.c.

{
    char fullkey[MAX_DB_FIELD];
    char tmp[1];
    size_t fullkey_len;
    int mres, res = 0;
 
    if (strlen(family) + strlen(key) + 2 > sizeof(fullkey) - 1) {
        ast_log(LOG_WARNING, "Family and key length must be less than %zu bytes\n", sizeof(fullkey) - 3);
        return -1;
    }
 
    fullkey_len = snprintf(fullkey, sizeof(fullkey), "/%s/%s", family, key);
 
    ast_mutex_lock(&dblock);
    if (ast_db_get(family, key, tmp, sizeof(tmp))) {
        ast_log(LOG_WARNING, "AstDB key %s does not exist\n", fullkey);
        res = -1;
    } else if (sqlite3_bind_text(del_stmt, 1, fullkey, fullkey_len, SQLITE_STATIC) != SQLITE_OK) {
        ast_log(LOG_WARNING, "Couldn't bind key to stmt: %s\n", sqlite3_errmsg(astdb));
        res = -1;
    } else if ((mres = sqlite3_step(del_stmt) != SQLITE_DONE)) {
        ast_log(LOG_WARNING, "AstDB error (%s): %s\n", fullkey, sqlite3_errstr(mres));
        res = -1;
    }
    sqlite3_reset(del_stmt);
    db_sync();
    ast_mutex_unlock(&dblock);
 
    return res;
}

References ast_db_get(), ast_log, ast_mutex_lock, ast_mutex_unlock, astdb, db_sync(), dblock, LOG_WARNING, MAX_DB_FIELD, and tmp().

Referenced by handle_cli_database_del(), and manager_dbdel().

ast_db_deltree()

int ast_db_deltree	(	const char *	family,
		const char *	keytree
	)

Delete one or more entries in astdb.

If both parameters are NULL, the entire database will be purged. If only keytree is NULL, all entries within the family will be purged. It is an error for keytree to have a value when family is NULL.

Return values

-1	An error occurred
>=	0 Number of records deleted

Definition at line 536 of file main/db.c.

{
    sqlite3_stmt *stmt = deltree_stmt;
    char prefix[MAX_DB_FIELD];
    int res = 0;
 
    if (!ast_strlen_zero(family)) {
        if (!ast_strlen_zero(keytree)) {
            /* Family and key tree */
            snprintf(prefix, sizeof(prefix), "/%s/%s", family, keytree);
        } else {
            /* Family only */
            snprintf(prefix, sizeof(prefix), "/%s", family);
        }
    } else {
        prefix[0] = '\0';
        stmt = deltree_all_stmt;
    }
 
    ast_mutex_lock(&dblock);
    if (!ast_strlen_zero(prefix) && (sqlite3_bind_text(stmt, 1, prefix, -1, SQLITE_STATIC) != SQLITE_OK)) {
        ast_log(LOG_WARNING, "Couldn't bind %s to stmt: %s\n", prefix, sqlite3_errmsg(astdb));
        res = -1;
    } else if (sqlite3_step(stmt) != SQLITE_DONE) {
        ast_log(LOG_WARNING, "Couldn't execute stmt: %s\n", sqlite3_errmsg(astdb));
        res = -1;
    }
    res = sqlite3_changes(astdb);
    sqlite3_reset(stmt);
    db_sync();
    ast_mutex_unlock(&dblock);
 
    return res;
}

References ast_log, ast_mutex_lock, ast_mutex_unlock, ast_strlen_zero(), astdb, db_sync(), dblock, LOG_WARNING, MAX_DB_FIELD, and prefix.

Referenced by ast_privacy_reset(), AST_TEST_DEFINE(), cleanup_cert_from_astdb_and_fs(), deinitialize_sorcery(), deltree_exec(), dundi_flush(), handle_cli_database_deltree(), handle_dbdeltree(), iax_provision_reload(), manager_dbdeltree(), media_cache_item_del_from_astdb(), and media_cache_remove_from_astdb().

ast_db_exists()

int ast_db_exists	(	const char *	family,
		const char *	key
	)

Check if family/key exitsts.

Parameters

family
key

Return values

1	if family/key exists
0	if family/key does not exist or an error occurred

Definition at line 444 of file main/db.c.

{
    int result;
    char fullkey[MAX_DB_FIELD];
    size_t fullkey_len;
    int res = 0;
 
    fullkey_len = snprintf(fullkey, sizeof(fullkey), "/%s/%s", family, key);
    if (fullkey_len >= sizeof(fullkey)) {
        ast_log(LOG_WARNING, "Family and key length must be less than %zu bytes\n", sizeof(fullkey) - 3);
        return -1;
    }
 
    ast_mutex_lock(&dblock);
    res = sqlite3_bind_text(exists_stmt, 1, fullkey, fullkey_len, SQLITE_STATIC);
    if (res != SQLITE_OK) {
        ast_log(LOG_WARNING, "Couldn't bind key to stmt: %d:%s\n", res, sqlite3_errmsg(astdb));
        res = 0;
    } else if (sqlite3_step(exists_stmt) != SQLITE_ROW) {
        res = 0;
    } else if (!(result = sqlite3_column_int(exists_stmt, 0))) {
        res = 0;
    } else {
        res = result;
    }
    sqlite3_reset(exists_stmt);
    ast_mutex_unlock(&dblock);
 
    return res;
}

References ast_log, ast_mutex_lock, ast_mutex_unlock, astdb, dblock, LOG_WARNING, MAX_DB_FIELD, and result.

Referenced by cleanup_cert_from_astdb_and_fs(), and retrieve_cert_from_cache().

ast_db_freetree()

void ast_db_freetree

(

struct ast_db_entry *

dbe

)

Free structure created by ast_db_gettree()

Definition at line 677 of file main/db.c.

{
    struct ast_db_entry *last;
    while (dbe) {
        last = dbe;
        dbe = dbe->next;
        ast_free(last);
    }
}

References ast_free, last, and ast_db_entry::next.

Referenced by AST_TEST_DEFINE(), dundi_show_cache(), dundi_show_hints(), function_db_keycount(), function_db_keys(), handle_cli_devstate_list(), handle_cli_presencestate_list(), load_module(), media_cache_item_populate_from_astdb(), media_cache_populate_from_astdb(), populate_cache(), process_clearcache(), reload_queue_members(), sorcery_astdb_retrieve_fields_common(), sorcery_astdb_retrieve_prefix(), sorcery_astdb_retrieve_regex(), and stasis_app_device_states_to_json().

ast_db_get()

int ast_db_get	(	const char *	family,
		const char *	key,
		char *	value,
		int	valuelen
	)

Get key value specified by family/key.

Definition at line 427 of file main/db.c.

{
    ast_assert(value != NULL);
 
    /* Make sure we initialize */
    value[0] = 0;
 
    return db_get_common(family, key, &value, valuelen);
}

References ast_assert, db_get_common(), NULL, and value.

Referenced by ast_db_del2(), ast_pbx_uuid_get(), ast_privacy_check(), AST_TEST_DEFINE(), auth_exec(), blacklist_read(), cache_lookup_internal(), check_access(), create_addr(), custom_devstate_callback(), custom_presence_callback(), database_increment(), destroy_all_channels(), function_db_delete(), function_db_exists(), function_db_read(), handle_cli_database_get(), handle_dbget(), iax_provision_version(), load_password(), manager_dbget(), mkintf(), populate_addr(), refresh_all_favorite(), reg_source_db(), retrieve_cert_from_cache(), sorcery_astdb_delete(), sorcery_astdb_update(), and stasis_device_state_cb().

ast_db_get_allocated()

int ast_db_get_allocated	(	const char *	family,
		const char *	key,
		char **	out
	)

Get key value specified by family/key as a heap allocated string.

Given a family and key, sets out to a pointer to a heap allocated string. In the event of an error, out will be set to NULL. The string must be freed by calling ast_free().

Return values

-1	An error occurred
0	Success

Definition at line 437 of file main/db.c.

{
    *out = NULL;
 
    return db_get_common(family, key, out, -1);
}

References db_get_common(), NULL, and out.

Referenced by AST_TEST_DEFINE(), media_cache_item_del_from_astdb(), reload_queue_members(), and sorcery_astdb_retrieve_id().

ast_db_gettree()

struct ast_db_entry * ast_db_gettree	(	const char *	family,
		const char *	keytree
	)

Get a list of values within the astdb tree.

If family is specified, only those keys will be returned. If keytree is specified, subkeys are expected to exist (separated from the key with a slash). If subkeys do not exist and keytree is specified, the tree will consist of either a single entry or NULL will be returned.

Resulting tree should be freed by passing the return value to ast_db_freetree() when usage is concluded.

Definition at line 610 of file main/db.c.

{
    char prefix[MAX_DB_FIELD];
    sqlite3_stmt *stmt = gettree_stmt;
    size_t res = 0;
    struct ast_db_entry *ret;
 
    if (!ast_strlen_zero(family)) {
        if (!ast_strlen_zero(keytree)) {
            /* Family and key tree */
            res = snprintf(prefix, sizeof(prefix), "/%s/%s", family, keytree);
        } else {
            /* Family only */
            res = snprintf(prefix, sizeof(prefix), "/%s", family);
        }
 
        if (res >= sizeof(prefix)) {
            ast_log(LOG_WARNING, "Requested prefix is too long: %s\n", keytree);
            return NULL;
        }
    } else {
        prefix[0] = '\0';
        stmt = gettree_all_stmt;
    }
 
    ast_mutex_lock(&dblock);
    if (res && (sqlite3_bind_text(stmt, 1, prefix, res, SQLITE_STATIC) != SQLITE_OK)) {
        ast_log(LOG_WARNING, "Could not bind %s to stmt: %s\n", prefix, sqlite3_errmsg(astdb));
        sqlite3_reset(stmt);
        ast_mutex_unlock(&dblock);
        return NULL;
    }
 
    ret = db_gettree_common(stmt);
    sqlite3_reset(stmt);
    ast_mutex_unlock(&dblock);
 
    return ret;
}

References ast_log, ast_mutex_lock, ast_mutex_unlock, ast_strlen_zero(), astdb, db_gettree_common(), dblock, LOG_WARNING, MAX_DB_FIELD, NULL, and prefix.

Referenced by AST_TEST_DEFINE(), dundi_show_cache(), dundi_show_hints(), function_db_keycount(), function_db_keys(), handle_cli_devstate_list(), handle_cli_presencestate_list(), load_module(), media_cache_item_populate_from_astdb(), media_cache_populate_from_astdb(), populate_cache(), process_clearcache(), reload_queue_members(), sorcery_astdb_retrieve_fields_common(), sorcery_astdb_retrieve_regex(), and stasis_app_device_states_to_json().

ast_db_gettree_by_prefix()

struct ast_db_entry * ast_db_gettree_by_prefix	(	const char *	family,
		const char *	key_prefix
	)

Get a list of values with the given key prefix.

Parameters

family	The family to search under
key_prefix	The key prefix to search under

Return values

NULL	An error occurred

Definition at line 650 of file main/db.c.

{
    char prefix[MAX_DB_FIELD];
    size_t res;
    struct ast_db_entry *ret;
 
    res = snprintf(prefix, sizeof(prefix), "/%s/%s", family, key_prefix);
    if (res >= sizeof(prefix)) {
        ast_log(LOG_WARNING, "Requested key prefix is too long: %s\n", key_prefix);
        return NULL;
    }
 
    ast_mutex_lock(&dblock);
    if (sqlite3_bind_text(gettree_prefix_stmt, 1, prefix, res, SQLITE_STATIC) != SQLITE_OK) {
        ast_log(LOG_WARNING, "Could not bind %s to stmt: %s\n", prefix, sqlite3_errmsg(astdb));
        sqlite3_reset(gettree_prefix_stmt);
        ast_mutex_unlock(&dblock);
        return NULL;
    }
 
    ret = db_gettree_common(gettree_prefix_stmt);
    sqlite3_reset(gettree_prefix_stmt);
    ast_mutex_unlock(&dblock);
 
    return ret;
}

References ast_log, ast_mutex_lock, ast_mutex_unlock, astdb, db_gettree_common(), dblock, LOG_WARNING, MAX_DB_FIELD, NULL, and prefix.

Referenced by sorcery_astdb_retrieve_prefix().

ast_db_put()

int ast_db_put	(	const char *	family,
		const char *	key,
		const char *	value
	)

Store value addressed by family/key.

Definition at line 342 of file main/db.c.

{
    char fullkey[MAX_DB_FIELD];
    size_t fullkey_len;
    int res = 0;
 
    if (strlen(family) + strlen(key) + 2 > sizeof(fullkey) - 1) {
        ast_log(LOG_WARNING, "Family and key length must be less than %zu bytes\n", sizeof(fullkey) - 3);
        return -1;
    }
 
    fullkey_len = snprintf(fullkey, sizeof(fullkey), "/%s/%s", family, key);
 
    ast_mutex_lock(&dblock);
    if (sqlite3_bind_text(put_stmt, 1, fullkey, fullkey_len, SQLITE_STATIC) != SQLITE_OK) {
        ast_log(LOG_WARNING, "Couldn't bind key to stmt: %s\n", sqlite3_errmsg(astdb));
        res = -1;
    } else if (sqlite3_bind_text(put_stmt, 2, value, -1, SQLITE_STATIC) != SQLITE_OK) {
        ast_log(LOG_WARNING, "Couldn't bind value to stmt: %s\n", sqlite3_errmsg(astdb));
        res = -1;
    } else if (sqlite3_step(put_stmt) != SQLITE_DONE) {
        ast_log(LOG_WARNING, "Couldn't execute statement: %s\n", sqlite3_errmsg(astdb));
        res = -1;
    }
 
    sqlite3_reset(put_stmt);
    db_sync();
    ast_mutex_unlock(&dblock);
 
    return res;
}

References ast_log, ast_mutex_lock, ast_mutex_unlock, astdb, db_sync(), dblock, LOG_WARNING, MAX_DB_FIELD, and value.

Referenced by __analog_ss_thread(), add_cert_expiration_to_astdb(), add_cert_key_to_astdb(), ast_privacy_set(), AST_TEST_DEFINE(), asterisk_daemon(), cache_save(), cache_save_hint(), database_increment(), devstate_write(), dialgroup_refreshdb(), dump_queue_members(), function_db_write(), handle_cli_database_put(), handle_cli_devstate_change(), handle_cli_presencestate_change(), handle_command_response(), handle_dbput(), iax_provision_build(), manager_dbput(), media_cache_item_sync_to_astdb(), metadata_sync_to_astdb(), presence_write(), save_secret(), sorcery_astdb_create(), stasis_app_device_state_update(), and update_registry().

ast_db_rollback_transaction()

static int ast_db_rollback_transaction ( void  )

static

Definition at line 337 of file main/db.c.

{
    return db_execute_sql("ROLLBACK", NULL, NULL);
}

References db_execute_sql(), and NULL.

Referenced by db_sync_thread().

astdb_atexit()

static void astdb_atexit ( void  )

static

Definition at line 1203 of file main/db.c.

{
    ast_cli_unregister_multiple(cli_database, ARRAY_LEN(cli_database));
    ast_manager_unregister("DBGet");
    ast_manager_unregister("DBGetTree");
    ast_manager_unregister("DBPut");
    ast_manager_unregister("DBDel");
    ast_manager_unregister("DBDelTree");
 
    /* Set doexit to 1 to kill thread. db_sync must be called with
     * mutex held. */
    ast_mutex_lock(&dblock);
    doexit = 1;
    db_sync();
    ast_mutex_unlock(&dblock);
 
    pthread_join(syncthread, NULL);
    ast_mutex_lock(&dblock);
    clean_statements();
    if (sqlite3_close(astdb) == SQLITE_OK) {
        astdb = NULL;
    }
    ast_mutex_unlock(&dblock);
}

References ARRAY_LEN, ast_cli_unregister_multiple(), ast_manager_unregister(), ast_mutex_lock, ast_mutex_unlock, astdb, clean_statements(), cli_database, db_sync(), dblock, doexit, NULL, and syncthread.

Referenced by astdb_init().

astdb_init()

int astdb_init

(

void

)

Provided by db.c

Definition at line 1228 of file main/db.c.

{
    ast_cond_init(&dbcond, NULL);
 
    if (db_init()) {
        return -1;
    }
 
    if (ast_pthread_create_background(&syncthread, NULL, db_sync_thread, NULL)) {
        return -1;
    }
 
    ast_register_atexit(astdb_atexit);
    ast_cli_register_multiple(cli_database, ARRAY_LEN(cli_database));
    ast_manager_register_xml_core("DBGet", EVENT_FLAG_SYSTEM | EVENT_FLAG_REPORTING, manager_dbget);
    ast_manager_register_xml_core("DBGetTree", EVENT_FLAG_SYSTEM | EVENT_FLAG_REPORTING, manager_db_tree_get);
    ast_manager_register_xml_core("DBPut", EVENT_FLAG_SYSTEM, manager_dbput);
    ast_manager_register_xml_core("DBDel", EVENT_FLAG_SYSTEM, manager_dbdel);
    ast_manager_register_xml_core("DBDelTree", EVENT_FLAG_SYSTEM, manager_dbdeltree);
    return 0;
}

References ARRAY_LEN, ast_cli_register_multiple, ast_cond_init, ast_manager_register_xml_core, ast_pthread_create_background, ast_register_atexit(), astdb_atexit(), cli_database, db_init(), db_sync_thread(), dbcond, EVENT_FLAG_REPORTING, EVENT_FLAG_SYSTEM, manager_db_tree_get(), manager_dbdel(), manager_dbdeltree(), manager_dbget(), manager_dbput(), NULL, and syncthread.

Referenced by asterisk_daemon().

clean_statements()

static void clean_statements ( void  )

static

Definition at line 189 of file main/db.c.

{
    clean_stmt(&get_stmt, get_stmt_sql);
    clean_stmt(&exists_stmt, exists_stmt_sql);
    clean_stmt(&del_stmt, del_stmt_sql);
    clean_stmt(&deltree_stmt, deltree_stmt_sql);
    clean_stmt(&deltree_all_stmt, deltree_all_stmt_sql);
    clean_stmt(&gettree_stmt, gettree_stmt_sql);
    clean_stmt(&gettree_all_stmt, gettree_all_stmt_sql);
    clean_stmt(&gettree_prefix_stmt, gettree_prefix_stmt_sql);
    clean_stmt(&showkey_stmt, showkey_stmt_sql);
    clean_stmt(&put_stmt, put_stmt_sql);
    clean_stmt(&create_astdb_stmt, create_astdb_stmt_sql);
}

References clean_stmt().

Referenced by astdb_atexit().

clean_stmt()

static int clean_stmt ( sqlite3_stmt **  stmt, const char *  sql  )

static

Definition at line 174 of file main/db.c.

{
    if (sqlite3_finalize(*stmt) != SQLITE_OK) {
        ast_log(LOG_WARNING, "Couldn't finalize statement '%s': %s\n", sql, sqlite3_errmsg(astdb));
        *stmt = NULL;
        return -1;
    }
    *stmt = NULL;
    return 0;
}

References ast_log, astdb, LOG_WARNING, and NULL.

Referenced by clean_statements().

convert_bdb_to_sqlite3()

static int convert_bdb_to_sqlite3 ( void  )

static

Definition at line 220 of file main/db.c.

{
    char *cmd;
    int res;
 
    res = ast_asprintf(&cmd, "%s/astdb2sqlite3 '%s'\n", ast_config_AST_SBIN_DIR, ast_config_AST_DB);
    if (0 <= res) {
        res = ast_safe_system(cmd);
        ast_free(cmd);
    }
 
    return res;
}

References ast_asprintf, ast_config_AST_DB, ast_config_AST_SBIN_DIR, ast_free, and ast_safe_system().

Referenced by db_open().

db_create_astdb()

static int db_create_astdb ( void  )

static

Definition at line 234 of file main/db.c.

{
    int res = 0;
 
    if (!create_astdb_stmt) {
        init_stmt(&create_astdb_stmt, create_astdb_stmt_sql, sizeof(create_astdb_stmt_sql));
    }
 
    ast_mutex_lock(&dblock);
    if (sqlite3_step(create_astdb_stmt) != SQLITE_DONE) {
        ast_log(LOG_WARNING, "Couldn't create astdb table: %s\n", sqlite3_errmsg(astdb));
        res = -1;
    }
    sqlite3_reset(create_astdb_stmt);
    db_sync();
    ast_mutex_unlock(&dblock);
 
    return res;
}

References ast_log, ast_mutex_lock, ast_mutex_unlock, astdb, db_sync(), dblock, init_stmt(), and LOG_WARNING.

Referenced by db_init().

db_execute_sql()

static int db_execute_sql ( const char *  sql, int(*)(void *, int, char **, char **)  callback, void *  arg  )

static

Definition at line 313 of file main/db.c.

{
    char *errmsg = NULL;
    int res =0;
 
    if (sqlite3_exec(astdb, sql, callback, arg, &errmsg) != SQLITE_OK) {
        ast_log(LOG_WARNING, "Error executing SQL (%s): %s\n", sql, errmsg);
        sqlite3_free(errmsg);
        res = -1;
    }
 
    return res;
}

References ast_log, astdb, LOG_WARNING, and NULL.

Referenced by ast_db_begin_transaction(), ast_db_commit_transaction(), ast_db_rollback_transaction(), and handle_cli_database_query().

db_get_common()

static int db_get_common ( const char *  family, const char *  key, char **  buffer, int  bufferlen  )

static

Definition at line 388 of file main/db.c.

{
    const unsigned char *result;
    char fullkey[MAX_DB_FIELD];
    size_t fullkey_len;
    int res = 0;
 
    if (strlen(family) + strlen(key) + 2 > sizeof(fullkey) - 1) {
        ast_log(LOG_WARNING, "Family and key length must be less than %zu bytes\n", sizeof(fullkey) - 3);
        return -1;
    }
 
    fullkey_len = snprintf(fullkey, sizeof(fullkey), "/%s/%s", family, key);
 
    ast_mutex_lock(&dblock);
    if (sqlite3_bind_text(get_stmt, 1, fullkey, fullkey_len, SQLITE_STATIC) != SQLITE_OK) {
        ast_log(LOG_WARNING, "Couldn't bind key to stmt: %s\n", sqlite3_errmsg(astdb));
        res = -1;
    } else if (sqlite3_step(get_stmt) != SQLITE_ROW) {
        ast_debug(1, "Unable to find key '%s' in family '%s'\n", key, family);
        res = -1;
    } else if (!(result = sqlite3_column_text(get_stmt, 0))) {
        ast_log(LOG_WARNING, "Couldn't get value\n");
        res = -1;
    } else {
        const char *value = (const char *) result;
 
        if (bufferlen == -1) {
            *buffer = ast_strdup(value);
        } else {
            ast_copy_string(*buffer, value, bufferlen);
        }
    }
    sqlite3_reset(get_stmt);
    ast_mutex_unlock(&dblock);
 
    return res;
}

References ast_copy_string(), ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_strdup, astdb, dblock, LOG_WARNING, MAX_DB_FIELD, result, and value.

Referenced by ast_db_get(), and ast_db_get_allocated().

db_gettree_common()

static struct ast_db_entry * db_gettree_common ( sqlite3_stmt *  stmt )

static

Definition at line 571 of file main/db.c.

{
    struct ast_db_entry *head = NULL, *prev = NULL, *cur;
 
    while (sqlite3_step(stmt) == SQLITE_ROW) {
        const char *key, *value;
        size_t key_len, value_len;
 
        key   = (const char *) sqlite3_column_text(stmt, 0);
        value = (const char *) sqlite3_column_text(stmt, 1);
 
        if (!key || !value) {
            break;
        }
 
        key_len = strlen(key);
        value_len = strlen(value);
 
        cur = ast_malloc(sizeof(*cur) + key_len + value_len + 2);
        if (!cur) {
            break;
        }
 
        cur->next = NULL;
        cur->key = cur->data + value_len + 1;
        memcpy(cur->data, value, value_len + 1);
        memcpy(cur->key, key, key_len + 1);
 
        if (prev) {
            prev->next = cur;
        } else {
            head = cur;
        }
        prev = cur;
    }
 
    return head;
}

References ast_malloc, ast_db_entry::key, NULL, and value.

Referenced by ast_db_gettree(), and ast_db_gettree_by_prefix().

db_init()

static int db_init ( void  )

static

Definition at line 297 of file main/db.c.

{
    if (astdb) {
        return 0;
    }
 
    if (db_open() || db_create_astdb() || init_statements()) {
        return -1;
    }
 
    return 0;
}

References astdb, db_create_astdb(), db_open(), and init_statements().

Referenced by astdb_init().

db_open()

static int db_open ( void  )

static

Definition at line 254 of file main/db.c.

{
    char *dbname;
    struct stat dont_care;
 
    if (!(dbname = ast_alloca(strlen(ast_config_AST_DB) + sizeof(".sqlite3")))) {
        return -1;
    }
    strcpy(dbname, ast_config_AST_DB);
    strcat(dbname, ".sqlite3");
 
    if (stat(dbname, &dont_care) && !stat(ast_config_AST_DB, &dont_care)) {
        if (convert_bdb_to_sqlite3()) {
            ast_log(LOG_ERROR, "*** Database conversion failed!\n");
            ast_log(LOG_ERROR, "*** Asterisk now uses SQLite3 for its internal\n");
            ast_log(LOG_ERROR, "*** database. Conversion from the old astdb\n");
            ast_log(LOG_ERROR, "*** failed. Most likely the astdb2sqlite3 utility\n");
            ast_log(LOG_ERROR, "*** was not selected for build. To convert the\n");
            ast_log(LOG_ERROR, "*** old astdb, please delete '%s'\n", dbname);
            ast_log(LOG_ERROR, "*** and re-run 'make menuselect' and select astdb2sqlite3\n");
            ast_log(LOG_ERROR, "*** in the Utilities section, then 'make && make install'.\n");
            ast_log(LOG_ERROR, "*** It is also imperative that the user under which\n");
            ast_log(LOG_ERROR, "*** Asterisk runs have write permission to the directory\n");
            ast_log(LOG_ERROR, "*** where the database resides.\n");
            sleep(5);
        } else {
            ast_log(LOG_NOTICE, "Database conversion succeeded!\n");
        }
    }
 
    ast_mutex_lock(&dblock);
    if (sqlite3_open(dbname, &astdb) != SQLITE_OK) {
        ast_log(LOG_WARNING, "Unable to open Asterisk database '%s': %s\n", dbname, sqlite3_errmsg(astdb));
        sqlite3_close(astdb);
        ast_mutex_unlock(&dblock);
        return -1;
    }
 
    ast_mutex_unlock(&dblock);
 
    return 0;
}

References ast_alloca, ast_config_AST_DB, ast_log, ast_mutex_lock, ast_mutex_unlock, astdb, convert_bdb_to_sqlite3(), dblock, dbname, LOG_ERROR, LOG_NOTICE, and LOG_WARNING.

Referenced by db_init().

db_sync()

static void db_sync ( void  )

static

Definition at line 1154 of file main/db.c.

{
    dosync = 1;
    ast_cond_signal(&dbcond);
}

References ast_cond_signal, dbcond, and dosync.

Referenced by ast_db_del(), ast_db_del2(), ast_db_deltree(), ast_db_put(), astdb_atexit(), db_create_astdb(), and handle_cli_database_query().

db_sync_thread()

static void * db_sync_thread ( void *  data )

static

Definition at line 1170 of file main/db.c.

{
    ast_mutex_lock(&dblock);
    ast_db_begin_transaction();
    for (;;) {
        /* If dosync is set, db_sync() was called during sleep(1),
         * and the pending transaction should be committed.
         * Otherwise, block until db_sync() is called.
         */
        while (!dosync) {
            ast_cond_wait(&dbcond, &dblock);
        }
        dosync = 0;
        if (ast_db_commit_transaction()) {
            ast_db_rollback_transaction();
        }
        if (doexit) {
            ast_mutex_unlock(&dblock);
            break;
        }
        ast_db_begin_transaction();
        ast_mutex_unlock(&dblock);
        sleep(1);
        ast_mutex_lock(&dblock);
    }
 
    return NULL;
}

References ast_cond_wait, ast_db_begin_transaction(), ast_db_commit_transaction(), ast_db_rollback_transaction(), ast_mutex_lock, ast_mutex_unlock, dbcond, dblock, doexit, dosync, and NULL.

Referenced by astdb_init().

DEFINE_SQL_STATEMENT()

DEFINE_SQL_STATEMENT	(	put_stmt	,
		"INSERT OR REPLACE INTO astdb (key, value) VALUES (?, ?)"
	)

Definition at line 132 of file main/db.c.

{
    ast_mutex_lock(&dblock);
    if (sqlite3_prepare(astdb, sql, len, stmt, NULL) != SQLITE_OK) {
        ast_log(LOG_WARNING, "Couldn't prepare statement '%s': %s\n", sql, sqlite3_errmsg(astdb));
        ast_mutex_unlock(&dblock);
        return -1;
    }
    ast_mutex_unlock(&dblock);
 
    return 0;
}

References ast_log, ast_mutex_lock, ast_mutex_unlock, astdb, dblock, len(), LOG_WARNING, and NULL.

display_results()

static int display_results ( void *  arg, int  columns, char **  values, char **  colnames  )

static

Definition at line 913 of file main/db.c.

{
    struct ast_cli_args *a = arg;
    size_t x;
 
    for (x = 0; x < columns; x++) {
        ast_cli(a->fd, "%-5s: %-50s\n", colnames[x], values[x]);
    }
    ast_cli(a->fd, "\n");
 
    return 0;
}

References a, ast_cli(), and columns.

Referenced by handle_cli_database_query().

handle_cli_database_del()

static char * handle_cli_database_del ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 742 of file main/db.c.

{
    int res;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "database del";
        e->usage =
            "Usage: database del <family> <key>\n"
            "       Deletes an entry in the Asterisk database for a given\n"
            "       family and key.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != 4)
        return CLI_SHOWUSAGE;
    res = ast_db_del2(a->argv[2], a->argv[3]);
    if (res) {
        ast_cli(a->fd, "Database entry could not be removed.\n");
    } else {
        ast_cli(a->fd, "Database entry removed.\n");
    }
    return CLI_SUCCESS;
}

References a, ast_cli(), ast_db_del2(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, NULL, and ast_cli_entry::usage.

handle_cli_database_deltree()

static char * handle_cli_database_deltree ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 769 of file main/db.c.

{
    int num_deleted;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "database deltree";
        e->usage =
            "Usage: database deltree <family> [keytree]\n"
            "   OR: database deltree <family>[/keytree]\n"
            "       Deletes a family or specific keytree within a family\n"
            "       in the Asterisk database.  The two arguments may be\n"
            "       separated by either a space or a slash.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if ((a->argc < 3) || (a->argc > 4))
        return CLI_SHOWUSAGE;
    if (a->argc == 4) {
        num_deleted = ast_db_deltree(a->argv[2], a->argv[3]);
    } else {
        num_deleted = ast_db_deltree(a->argv[2], NULL);
    }
    if (num_deleted < 0) {
        ast_cli(a->fd, "Database unavailable.\n");
    } else if (num_deleted == 0) {
        ast_cli(a->fd, "Database entries do not exist.\n");
    } else {
        ast_cli(a->fd, "%d database entries removed.\n",num_deleted);
    }
    return CLI_SUCCESS;
}

References a, ast_cli(), ast_db_deltree(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, NULL, and ast_cli_entry::usage.

handle_cli_database_get()

static char * handle_cli_database_get ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 714 of file main/db.c.

{
    int res;
    char tmp[MAX_DB_FIELD];
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "database get";
        e->usage =
            "Usage: database get <family> <key>\n"
            "       Retrieves an entry in the Asterisk database for a given\n"
            "       family and key.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != 4)
        return CLI_SHOWUSAGE;
    res = ast_db_get(a->argv[2], a->argv[3], tmp, sizeof(tmp));
    if (res) {
        ast_cli(a->fd, "Database entry not found.\n");
    } else {
        ast_cli(a->fd, "Value: %s\n", tmp);
    }
    return CLI_SUCCESS;
}

References a, ast_cli(), ast_db_get(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, MAX_DB_FIELD, NULL, tmp(), and ast_cli_entry::usage.

handle_cli_database_put()

static char * handle_cli_database_put ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 687 of file main/db.c.

{
    int res;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "database put";
        e->usage =
            "Usage: database put <family> <key> <value>\n"
            "       Adds or updates an entry in the Asterisk database for\n"
            "       a given family, key, and value.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != 5)
        return CLI_SHOWUSAGE;
    res = ast_db_put(a->argv[2], a->argv[3], a->argv[4]);
    if (res)  {
        ast_cli(a->fd, "Failed to update entry\n");
    } else {
        ast_cli(a->fd, "Updated database successfully\n");
    }
    return CLI_SUCCESS;
}

References a, ast_cli(), ast_db_put(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, NULL, and ast_cli_entry::usage.

handle_cli_database_query()

static char * handle_cli_database_query ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 926 of file main/db.c.

{
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "database query";
        e->usage =
            "Usage: database query \"<SQL Statement>\"\n"
            "       Run a user-specified SQL query on the database. Be careful.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != 3) {
        return CLI_SHOWUSAGE;
    }
 
    ast_mutex_lock(&dblock);
    db_execute_sql(a->argv[2], display_results, a);
    db_sync(); /* Go ahead and sync the db in case they write */
    ast_mutex_unlock(&dblock);
 
    return CLI_SUCCESS;
}

References a, ast_mutex_lock, ast_mutex_unlock, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, db_execute_sql(), db_sync(), dblock, display_results(), NULL, and ast_cli_entry::usage.

handle_cli_database_show()

static char * handle_cli_database_show ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 804 of file main/db.c.

{
    char prefix[MAX_DB_FIELD];
    int counter = 0;
    sqlite3_stmt *stmt = gettree_stmt;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "database show";
        e->usage =
            "Usage: database show [family [keytree]]\n"
            "   OR: database show [family[/keytree]]\n"
            "       Shows Asterisk database contents, optionally restricted\n"
            "       to a given family, or family and keytree. The two arguments\n"
            "       may be separated either by a space or by a slash.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc == 4) {
        /* Family and key tree */
        snprintf(prefix, sizeof(prefix), "/%s/%s", a->argv[2], a->argv[3]);
    } else if (a->argc == 3) {
        /* Family only */
        snprintf(prefix, sizeof(prefix), "/%s", a->argv[2]);
    } else if (a->argc == 2) {
        /* Neither */
        prefix[0] = '\0';
        stmt = gettree_all_stmt;
 
    } else {
        return CLI_SHOWUSAGE;
    }
 
    ast_mutex_lock(&dblock);
    if (!ast_strlen_zero(prefix) && (sqlite3_bind_text(stmt, 1, prefix, -1, SQLITE_STATIC) != SQLITE_OK)) {
        ast_log(LOG_WARNING, "Couldn't bind %s to stmt: %s\n", prefix, sqlite3_errmsg(astdb));
        sqlite3_reset(stmt);
        ast_mutex_unlock(&dblock);
        return NULL;
    }
 
    while (sqlite3_step(stmt) == SQLITE_ROW) {
        const char *key_s, *value_s;
        if (!(key_s = (const char *) sqlite3_column_text(stmt, 0))) {
            ast_log(LOG_WARNING, "Skipping invalid key!\n");
            continue;
        }
        if (!(value_s = (const char *) sqlite3_column_text(stmt, 1))) {
            ast_log(LOG_WARNING, "Skipping invalid value!\n");
            continue;
        }
        ++counter;
        ast_cli(a->fd, "%-50s: %-25s\n", key_s, value_s);
    }
 
    sqlite3_reset(stmt);
    ast_mutex_unlock(&dblock);
 
    ast_cli(a->fd, "%d results found.\n", counter);
    return CLI_SUCCESS;
}

References a, ast_cli(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_strlen_zero(), astdb, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, dblock, LOG_WARNING, MAX_DB_FIELD, NULL, prefix, and ast_cli_entry::usage.

handle_cli_database_showkey()

static char * handle_cli_database_showkey ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 868 of file main/db.c.

{
    int counter = 0;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "database showkey";
        e->usage =
            "Usage: database showkey <keytree>\n"
            "       Shows Asterisk database contents, restricted to a given key.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != 3) {
        return CLI_SHOWUSAGE;
    }
 
    ast_mutex_lock(&dblock);
    if (!ast_strlen_zero(a->argv[2]) && (sqlite3_bind_text(showkey_stmt, 1, a->argv[2], -1, SQLITE_STATIC) != SQLITE_OK)) {
        ast_log(LOG_WARNING, "Couldn't bind %s to stmt: %s\n", a->argv[2], sqlite3_errmsg(astdb));
        sqlite3_reset(showkey_stmt);
        ast_mutex_unlock(&dblock);
        return NULL;
    }
 
    while (sqlite3_step(showkey_stmt) == SQLITE_ROW) {
        const char *key_s, *value_s;
        if (!(key_s = (const char *) sqlite3_column_text(showkey_stmt, 0))) {
            break;
        }
        if (!(value_s = (const char *) sqlite3_column_text(showkey_stmt, 1))) {
            break;
        }
        ++counter;
        ast_cli(a->fd, "%-50s: %-25s\n", key_s, value_s);
    }
    sqlite3_reset(showkey_stmt);
    ast_mutex_unlock(&dblock);
 
    ast_cli(a->fd, "%d results found.\n", counter);
    return CLI_SUCCESS;
}

References a, ast_cli(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_strlen_zero(), astdb, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, dblock, LOG_WARNING, NULL, and ast_cli_entry::usage.

init_statements()

static int init_statements ( void  )

static

Definition at line 204 of file main/db.c.

{
    /* Don't initialize create_astdb_statement here as the astdb table needs to exist
     * brefore these statements can be initialized */
    return init_stmt(&get_stmt, get_stmt_sql, sizeof(get_stmt_sql))
    || init_stmt(&exists_stmt, exists_stmt_sql, sizeof(exists_stmt_sql))
    || init_stmt(&del_stmt, del_stmt_sql, sizeof(del_stmt_sql))
    || init_stmt(&deltree_stmt, deltree_stmt_sql, sizeof(deltree_stmt_sql))
    || init_stmt(&deltree_all_stmt, deltree_all_stmt_sql, sizeof(deltree_all_stmt_sql))
    || init_stmt(&gettree_stmt, gettree_stmt_sql, sizeof(gettree_stmt_sql))
    || init_stmt(&gettree_all_stmt, gettree_all_stmt_sql, sizeof(gettree_all_stmt_sql))
    || init_stmt(&gettree_prefix_stmt, gettree_prefix_stmt_sql, sizeof(gettree_prefix_stmt_sql))
    || init_stmt(&showkey_stmt, showkey_stmt_sql, sizeof(showkey_stmt_sql))
    || init_stmt(&put_stmt, put_stmt_sql, sizeof(put_stmt_sql));
}

References init_stmt().

Referenced by db_init().

manager_db_tree_get()

static int manager_db_tree_get ( struct mansession *  s, const struct message *  m  )

static

Definition at line 1029 of file main/db.c.

{
    char prefix[MAX_DB_FIELD];
    char idText[256];
    const char *id = astman_get_header(m,"ActionID");
    const char *family = astman_get_header(m, "Family");
    const char *key = astman_get_header(m, "Key");
    sqlite3_stmt *stmt = gettree_stmt;
    int count = 0;
 
    if (!ast_strlen_zero(family) && !ast_strlen_zero(key)) {
        /* Family and key tree */
        snprintf(prefix, sizeof(prefix), "/%s/%s", family, key);
    } else if (!ast_strlen_zero(family)) {
        /* Family only */
        snprintf(prefix, sizeof(prefix), "/%s", family);
    } else {
        /* Neither */
        prefix[0] = '\0';
        stmt = gettree_all_stmt;
    }
 
    idText[0] = '\0';
    if (!ast_strlen_zero(id)) {
        snprintf(idText, sizeof(idText) ,"ActionID: %s\r\n", id);
    }
 
    ast_mutex_lock(&dblock);
    if (!ast_strlen_zero(prefix) && (sqlite3_bind_text(stmt, 1, prefix, -1, SQLITE_STATIC) != SQLITE_OK)) {
        ast_log(LOG_WARNING, "Couldn't bind %s to stmt: %s\n", prefix, sqlite3_errmsg(astdb));
        sqlite3_reset(stmt);
        ast_mutex_unlock(&dblock);
        astman_send_error(s, m, "Unable to search database");
        return 0;
    }
 
    astman_send_listack(s, m, "Result will follow", "start");
 
    while (sqlite3_step(stmt) == SQLITE_ROW) {
        const char *key_s, *value_s;
        if (!(key_s = (const char *) sqlite3_column_text(stmt, 0))) {
            ast_log(LOG_WARNING, "Skipping invalid key!\n");
            continue;
        }
        if (!(value_s = (const char *) sqlite3_column_text(stmt, 1))) {
            ast_log(LOG_WARNING, "Skipping invalid value!\n");
            continue;
        }
        astman_append(s, "Event: DBGetTreeResponse\r\n"
            "Key: %s\r\n"
            "Val: %s\r\n"
            "%s"
            "\r\n",
            key_s, value_s, idText);
        count++;
    }
 
    sqlite3_reset(stmt);
    ast_mutex_unlock(&dblock);
 
    astman_send_list_complete_start(s, m, "DBGetTreeComplete", count);
    astman_send_list_complete_end(s);
 
    return 0;
}

References ast_log, ast_mutex_lock, ast_mutex_unlock, ast_strlen_zero(), astdb, astman_append(), astman_get_header(), astman_send_error(), astman_send_list_complete_end(), astman_send_list_complete_start(), astman_send_listack(), dblock, LOG_WARNING, MAX_DB_FIELD, and prefix.

Referenced by astdb_init().

manager_dbdel()

static int manager_dbdel ( struct mansession *  s, const struct message *  m  )

static

Definition at line 1095 of file main/db.c.

{
    const char *family = astman_get_header(m, "Family");
    const char *key = astman_get_header(m, "Key");
    int res;
 
    if (ast_strlen_zero(family)) {
        astman_send_error(s, m, "No family specified.");
        return 0;
    }
 
    if (ast_strlen_zero(key)) {
        astman_send_error(s, m, "No key specified.");
        return 0;
    }
 
    res = ast_db_del2(family, key);
    if (res)
        astman_send_error(s, m, "Database entry could not be deleted");
    else
        astman_send_ack(s, m, "Key deleted successfully");
 
    return 0;
}

References ast_db_del2(), ast_strlen_zero(), astman_get_header(), astman_send_ack(), and astman_send_error().

Referenced by astdb_init().

manager_dbdeltree()

static int manager_dbdeltree ( struct mansession *  s, const struct message *  m  )

static

Definition at line 1120 of file main/db.c.

{
    const char *family = astman_get_header(m, "Family");
    const char *key = astman_get_header(m, "Key");
    int num_deleted;
 
    if (ast_strlen_zero(family)) {
        astman_send_error(s, m, "No family specified.");
        return 0;
    }
 
    if (!ast_strlen_zero(key)) {
        num_deleted = ast_db_deltree(family, key);
    } else {
        num_deleted = ast_db_deltree(family, NULL);
    }
 
    if (num_deleted < 0) {
        astman_send_error(s, m, "Database unavailable");
    } else if (num_deleted == 0) {
        astman_send_error(s, m, "Database entry not found");
    } else {
        astman_send_ack(s, m, "Key tree deleted successfully");
    }
 
    return 0;
}

References ast_db_deltree(), ast_strlen_zero(), astman_get_header(), astman_send_ack(), astman_send_error(), and NULL.

Referenced by astdb_init().

manager_dbget()

static int manager_dbget ( struct mansession *  s, const struct message *  m  )

static

Definition at line 987 of file main/db.c.

{
    const char *id = astman_get_header(m,"ActionID");
    char idText[256];
    const char *family = astman_get_header(m, "Family");
    const char *key = astman_get_header(m, "Key");
    char tmp[MAX_DB_FIELD];
    int res;
 
    if (ast_strlen_zero(family)) {
        astman_send_error(s, m, "No family specified.");
        return 0;
    }
    if (ast_strlen_zero(key)) {
        astman_send_error(s, m, "No key specified.");
        return 0;
    }
 
    idText[0] = '\0';
    if (!ast_strlen_zero(id))
        snprintf(idText, sizeof(idText) ,"ActionID: %s\r\n", id);
 
    res = ast_db_get(family, key, tmp, sizeof(tmp));
    if (res) {
        astman_send_error(s, m, "Database entry not found");
    } else {
        astman_send_listack(s, m, "Result will follow", "start");
 
        astman_append(s, "Event: DBGetResponse\r\n"
                "Family: %s\r\n"
                "Key: %s\r\n"
                "Val: %s\r\n"
                "%s"
                "\r\n",
                family, key, tmp, idText);
 
        astman_send_list_complete_start(s, m, "DBGetComplete", 1);
        astman_send_list_complete_end(s);
    }
    return 0;
}

References ast_db_get(), ast_strlen_zero(), astman_append(), astman_get_header(), astman_send_error(), astman_send_list_complete_end(), astman_send_list_complete_start(), astman_send_listack(), MAX_DB_FIELD, and tmp().

Referenced by astdb_init().

manager_dbput()

static int manager_dbput ( struct mansession *  s, const struct message *  m  )

static

Definition at line 962 of file main/db.c.

{
    const char *family = astman_get_header(m, "Family");
    const char *key = astman_get_header(m, "Key");
    const char *val = astman_get_header(m, "Val");
    int res;
 
    if (ast_strlen_zero(family)) {
        astman_send_error(s, m, "No family specified");
        return 0;
    }
    if (ast_strlen_zero(key)) {
        astman_send_error(s, m, "No key specified");
        return 0;
    }
 
    res = ast_db_put(family, key, S_OR(val, ""));
    if (res) {
        astman_send_error(s, m, "Failed to update entry");
    } else {
        astman_send_ack(s, m, "Updated database successfully");
    }
    return 0;
}

References ast_db_put(), ast_strlen_zero(), astman_get_header(), astman_send_ack(), astman_send_error(), and S_OR.

Referenced by astdb_init().

Variable Documentation

astdb

sqlite3* astdb

static

Definition at line 122 of file main/db.c.

Referenced by ast_db_del(), ast_db_del2(), ast_db_deltree(), ast_db_exists(), ast_db_gettree(), ast_db_gettree_by_prefix(), ast_db_put(), astdb_atexit(), clean_stmt(), db_create_astdb(), db_execute_sql(), db_get_common(), db_init(), db_open(), DEFINE_SQL_STATEMENT(), handle_cli_database_show(), handle_cli_database_showkey(), and manager_db_tree_get().

cli_database

struct ast_cli_entry cli_database[]

static

Definition at line 952 of file main/db.c.

Referenced by astdb_atexit(), and astdb_init().

dbcond

ast_cond_t dbcond

static

Definition at line 121 of file main/db.c.

Referenced by astdb_init(), db_sync(), and db_sync_thread().

dblock

ast_mutex_t dblock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static

Definition at line 120 of file main/db.c.

Referenced by ast_db_del(), ast_db_del2(), ast_db_deltree(), ast_db_exists(), ast_db_gettree(), ast_db_gettree_by_prefix(), ast_db_put(), astdb_atexit(), db_create_astdb(), db_get_common(), db_open(), db_sync_thread(), DEFINE_SQL_STATEMENT(), handle_cli_database_query(), handle_cli_database_show(), handle_cli_database_showkey(), and manager_db_tree_get().

doexit

int doexit

static

Definition at line 124 of file main/db.c.

Referenced by astdb_atexit(), and db_sync_thread().

dosync

int dosync

static

Definition at line 125 of file main/db.c.

Referenced by db_sync(), and db_sync_thread().

syncthread

pthread_t syncthread

static

Definition at line 123 of file main/db.c.

Referenced by astdb_atexit(), and astdb_init().