db.c File Reference

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <string.h>
#include <sys/time.h>
#include <signal.h>
#include <errno.h>
#include <unistd.h>
#include <dirent.h>
#include <asterisk/channel.h>
#include <asterisk/file.h>
#include <asterisk/app.h>
#include <asterisk/dsp.h>
#include <asterisk/logger.h>
#include <asterisk/options.h>
#include <asterisk/astdb.h>
#include <asterisk/cli.h>
#include <asterisk/utils.h>
#include "db1-ast/include/db.h"
#include "asterisk.h"
#include "astconf.h"

Include dependency graph for db.c:

Go to the source code of this file.

Functions
	AST_MUTEX_DEFINE_STATIC (dblock)
int	ast_db_deltree (const char *family, const char *keytree)
int	ast_db_put (const char *family, const char *keys, char *value)
int	ast_db_get (const char *family, const char *keys, char *value, int valuelen)
int	ast_db_del (const char *family, const char *keys)
ast_db_entry *	ast_db_gettree (const char *family, const char *keytree)
void	ast_db_freetree (struct ast_db_entry *dbe)
int	astdb_init (void)
Variables
ast_cli_entry	cli_database_show
ast_cli_entry	cli_database_get
ast_cli_entry	cli_database_put
ast_cli_entry	cli_database_del
ast_cli_entry	cli_database_deltree

---

Function Documentation

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

Definition at line 179 of file db.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, key(), and LOG_DEBUG. Referenced by ast_privacy_set(). { char fullkey[256]; DBT key; int res, fullkeylen; ast_mutex_lock(&dblock); if (dbinit()) { ast_mutex_unlock(&dblock); return -1; } fullkeylen = snprintf(fullkey, sizeof(fullkey), "/%s/%s", family, keys); memset(&key, 0, sizeof(key)); key.data = fullkey; key.size = fullkeylen + 1; res = astdb->del(astdb, &key, 0); astdb->sync(astdb, 0); ast_mutex_unlock(&dblock); if (res) ast_log(LOG_DEBUG, "Unable to find key '%s' in family '%s'\n", keys, family); return res; }

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

Definition at line 71 of file db.c. References ast_mutex_lock, ast_mutex_unlock, and key(). Referenced by ast_privacy_reset(). { char prefix[256]; DBT key, data; char *keys; int res; int pass; if (family) { if (keytree) snprintf(prefix, sizeof(prefix), "/%s/%s", family, keytree); else snprintf(prefix, sizeof(prefix), "/%s", family); } else if (keytree) return -1; else strcpy(prefix, ""); ast_mutex_lock(&dblock); if (dbinit()) return -1; memset(&key, 0, sizeof(key)); memset(&data, 0, sizeof(data)); pass = 0; while(!(res = astdb->seq(astdb, &key, &data, pass++ ? R_NEXT : R_FIRST))) { if (key.size) { keys = key.data; keys[key.size - 1] = '\0'; } else keys = "<bad key>"; if (keymatch(keys, prefix)) { astdb->del(astdb, &key, 0); } } astdb->sync(astdb, 0); ast_mutex_unlock(&dblock); return 0; }

void ast_db_freetree (  struct ast_db_entry *  dbe  )

Definition at line 367 of file db.c. References free, and ast_db_entry::next. { struct ast_db_entry *last; while(dbe) { last = dbe; dbe = dbe->next; free(last); } }

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

Definition at line 138 of file db.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, key(), LOG_DEBUG, and LOG_NOTICE. Referenced by ast_privacy_check(). { char fullkey[256]=""; DBT key, data; int res, fullkeylen; ast_mutex_lock(&dblock); if (dbinit()) { ast_mutex_unlock(&dblock); return -1; } fullkeylen = snprintf(fullkey, sizeof(fullkey), "/%s/%s", family, keys); memset(&key, 0, sizeof(key)); memset(&data, 0, sizeof(data)); memset(value, 0, valuelen); key.data = fullkey; key.size = fullkeylen + 1; res = astdb->get(astdb, &key, &data, 0); ast_mutex_unlock(&dblock); /* Be sure to NULL terminate our data either way */ if (res) { ast_log(LOG_DEBUG, "Unable to find key '%s' in family '%s'\n", keys, family); } else { #if 0 printf("Got value of size %d\n", data.size); #endif if (data.size) { ((char *)data.data)[data.size - 1] = '\0'; /* Make sure that we don't write too much to the dst pointer or we don't read too much from the source pointer */ strncpy(value, data.data, (valuelen > data.size) ? data.size : valuelen); } else { ast_log(LOG_NOTICE, "Strange, empty value for /%s/%s\n", family, keys); } } return res; }

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

Definition at line 309 of file db.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, key(), LOG_WARNING, and malloc. { char prefix[256]; DBT key, data; char *keys, *values; int res; int pass; struct ast_db_entry *last = NULL; struct ast_db_entry *cur, *ret=NULL; if (family && !ast_strlen_zero(family)) { if (keytree && !ast_strlen_zero(keytree)) /* Family and key tree */ snprintf(prefix, sizeof(prefix), "/%s/%s", family, prefix); else /* Family only */ snprintf(prefix, sizeof(prefix), "/%s", family); } else strcpy(prefix, ""); ast_mutex_lock(&dblock); if (dbinit()) { ast_mutex_unlock(&dblock); ast_log(LOG_WARNING, "Database unavailable\n"); return NULL; } memset(&key, 0, sizeof(key)); memset(&data, 0, sizeof(data)); pass = 0; while(!(res = astdb->seq(astdb, &key, &data, pass++ ? R_NEXT : R_FIRST))) { if (key.size) { keys = key.data; keys[key.size - 1] = '\0'; } else keys = "<bad key>"; if (data.size) { values = data.data; values[data.size - 1]='\0'; } else values = "<bad value>"; if (keymatch(keys, prefix)) { cur = malloc(sizeof(struct ast_db_entry) + strlen(keys) + strlen(values) + 2); if (cur) { cur->next = NULL; cur->key = cur->data + strlen(values) + 1; strcpy(cur->data, values); strcpy(cur->key, keys); if (last) last->next = cur; else ret = cur; last = cur; } } } ast_mutex_unlock(&dblock); return ret; }

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

Definition at line 111 of file db.c. References ast_log(), ast_mutex_lock, ast_mutex_unlock, key(), and LOG_WARNING. Referenced by ast_privacy_set(). { char fullkey[256]; DBT key, data; int res, fullkeylen; ast_mutex_lock(&dblock); if (dbinit()) { ast_mutex_unlock(&dblock); return -1; } fullkeylen = snprintf(fullkey, sizeof(fullkey), "/%s/%s", family, keys); memset(&key, 0, sizeof(key)); memset(&data, 0, sizeof(data)); key.data = fullkey; key.size = fullkeylen + 1; data.data = value; data.size = strlen(value) + 1; res = astdb->put(astdb, &key, &data, 0); astdb->sync(astdb, 0); ast_mutex_unlock(&dblock); if (res) ast_log(LOG_WARNING, "Unable to put value '%s' for key '%s' in family '%s'\n", value, keys, family); return res; }

AST_MUTEX_DEFINE_STATIC (  dblock   )

int astdb_init (  void   )

Definition at line 417 of file db.c. References ast_cli_register(), cli_database_del, cli_database_deltree, cli_database_get, cli_database_put, and cli_database_show. Referenced by main(). { dbinit(); ast_cli_register(&cli_database_show); ast_cli_register(&cli_database_get); ast_cli_register(&cli_database_put); ast_cli_register(&cli_database_del); ast_cli_register(&cli_database_deltree); return 0; }

---

Variable Documentation

struct ast_cli_entry cli_database_del

Initial value: { { "database", "del", NULL }, database_del, "Removes database key/value", database_del_usage } Definition at line 411 of file db.c. Referenced by astdb_init().

struct ast_cli_entry cli_database_deltree

Initial value: { { "database", "deltree", NULL }, database_deltree, "Removes database keytree/values", database_deltree_usage } Definition at line 414 of file db.c. Referenced by astdb_init().

struct ast_cli_entry cli_database_get

Initial value: { { "database", "get", NULL }, database_get, "Gets database value", database_get_usage } Definition at line 405 of file db.c. Referenced by astdb_init().

struct ast_cli_entry cli_database_put

Initial value: { { "database", "put", NULL }, database_put, "Adds/updates database value", database_put_usage } Definition at line 408 of file db.c. Referenced by astdb_init().

struct ast_cli_entry cli_database_show

Initial value: { { "database", "show", NULL }, database_show, "Shows database contents", database_show_usage } Definition at line 402 of file db.c. Referenced by astdb_init().

---