76 static DBPool *pool = NULL;
84 static void dlr_cass_shutdown()
90 static void dlr_cass_add(
struct dlr_entry *entry)
97 debug(
"dlr.cass", 0,
"adding DLR entry into database");
106 sql =
octstr_format(
"INSERT INTO %S (%S, %S, %S, %S, %S, %S, %S, %S, %S) VALUES " 107 "(?, ?, ?, ?, ?, ?, ?, ?, 0) ",
131 #if defined(DLR_TRACE) 148 List *result = NULL, *row;
156 sql =
octstr_format(
"SELECT %S, %S, %S, %S, %S, %S FROM %S WHERE %S=? AND %S=? LIMIT 1;",
166 #if defined(DLR_TRACE) 180 #define LO2CSTR(r, i) octstr_get_cstr(gwlist_get(r, i)) 186 res->
mask = atoi(LO2CSTR(row,0));
209 debug(
"dlr.cass", 0,
"removing DLR from database");
223 #if defined(DLR_TRACE) 242 debug(
"dlr.cass", 0,
"updating DLR status in database");
249 sql =
octstr_format(
"UPDATE %S SET %S=? WHERE %S=? AND %S=? LIMIT 1;",
258 #if defined(DLR_TRACE) 270 static long dlr_cass_messages(
void)
282 #if defined(DLR_TRACE) 304 static void dlr_cass_flush(
void)
316 #if defined(DLR_TRACE) 321 error(0,
"DLR: Cassandra: Error while flushing dlr entries from database");
328 .dlr_add = dlr_cass_add,
329 .dlr_get = dlr_cass_get,
330 .dlr_update = dlr_cass_update,
331 .dlr_remove = dlr_cass_remove,
332 .dlr_shutdown = dlr_cass_shutdown,
333 .dlr_messages = dlr_cass_messages,
334 .dlr_flush = dlr_cass_flush
352 panic(0,
"DLR: Cassandra: group 'dlr-db' is not specified!");
355 panic(0,
"DLR: Cassandra: directive 'id' is not specified!");
376 panic(0,
"DLR: Cassandra: connection settings for id '%s' are not specified!",
387 panic(0,
"DLR: Cassandra: directive 'host' is not specified!");
397 db_conf = gw_malloc(
sizeof(
DBConf));
416 panic(0,
"DLR: Cassandra: database pool has no connections!");
void error(int err, const char *fmt,...)
long dbpool_conn_count(DBPool *p)
DBPool * dbpool_create(enum db_type db_type, DBConf *conf, unsigned int connections)
gw_assert(wtls_machine->packet_to_send !=NULL)
void gwlist_append(List *list, void *item)
void dlr_db_fields_destroy(struct dlr_db_fields *fields)
struct dlr_entry * dlr_entry_create(void)
long gwlist_len(List *list)
void * gwlist_get(List *list, long pos)
void octstr_append_char(Octstr *ostr, int ch)
#define cfg_get(grp, varname)
#define octstr_get_cstr(ostr)
static struct pid_list * found
void dbpool_conn_produce(DBPoolConn *conn)
static struct dlr_storage * handles
Octstr * octstr_imm(const char *cstr)
void * gwlist_extract_first(List *list)
#define octstr_duplicate(ostr)
List * cfg_get_multi_group(Cfg *cfg, Octstr *name)
Octstr * octstr_format(const char *fmt,...)
void octstr_destroy(Octstr *ostr)
#define octstr_create(cstr)
void octstr_destroy_item(void *os)
void dbpool_destroy(DBPool *p)
int dbpool_conn_update(DBPoolConn *conn, const Octstr *sql, List *binds)
struct dlr_storage * dlr_init_cass(Cfg *cfg)
void dlr_entry_destroy(struct dlr_entry *dlr)
void debug(const char *place, int err, const char *fmt,...)
int cfg_get_integer(long *n, CfgGroup *grp, Octstr *varname)
void octstr_format_append(Octstr *os, const char *fmt,...)
int dbpool_conn_select(DBPoolConn *conn, const Octstr *sql, List *binds, List **result)
DBPoolConn * dbpool_conn_consume(DBPool *p)
CfgGroup * cfg_get_single_group(Cfg *cfg, Octstr *name)
struct dlr_db_fields * dlr_db_fields_create(CfgGroup *grp)
int octstr_compare(const Octstr *ostr1, const Octstr *ostr2)
void gwlist_destroy(List *list, gwlist_item_destructor_t *destructor)