db.c File Reference

---

Detailed Description

Interrogating-CSCF - Database operations.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file db.c.

#include "db.h"
#include "../../db/db.h"
#include "../../mem/shm_mem.h"
#include "mod.h"

Go to the source code of this file.

Functions
int	icscf_db_bind (char *db_url)
	Bind to the database module.
int	icscf_db_init (char *db_url, char *db_table_nds, char *db_table_scscf, char *db_table_capabilities)
	Init the database connection.
void	icscf_db_close ()
	Close the database connection.
static int	icscf_db_check_init (db_con_t *db_hdl)
	Simply check if the database connection was initialized and connect if not.
int	icscf_db_get_nds (str *d[])
	Get the NDS list from the database.
int	icscf_db_get_scscf (scscf_capabilities *cap[])
	Get the S-CSCF names from the database and create the S-CSCF set.
int	icscf_db_get_capabilities (scscf_capabilities *cap[], int cap_cnt)
	Get the S-CSCF capabilities from the database and fill the S-CSCF set.
Variables
static db_func_t	dbf
	db function bindings
char *	icscf_db_url
	DB URL.
char *	icscf_db_nds_table
	NDS table in DB.
char *	icscf_db_scscf_table
	S-CSCF table in db.
char *	icscf_db_capabilities_table
	S-CSCF capabilities table in db.
static db_con_t *	hdl_nds = 0
	handle for the NDS table
static db_con_t *	hdl_scscf = 0
	handle for the S-CSCF table
static db_con_t *	hdl_capabilities = 0
	handle for the S-CSCF capabilities table

---

Function Documentation

int icscf_db_bind

(

char *

db_url

)

Bind to the database module.

Parameters:

db_url

- URL of the database

Returns:

0 on success, -1 on error

Definition at line 80 of file db.c.

References dbf, icscf_db_url, and M_NAME.

Referenced by icscf_mod_init().

{
    if (bind_dbmod(icscf_db_url, &dbf)) {
        LOG(L_CRIT, "CRIT:"M_NAME":icscf_db_bind: cannot bind to database module! "
        "Did you forget to load a database module ?\n");
        return -1;
    }
    return 0;
}

int icscf_db_init	(	char *	db_url,
		char *	db_table_nds,
		char *	db_table_scscf,
		char *	db_table_capabilities
	)

Init the database connection.

Parameters:

	db_url	- URL of the database
	db_table_nds	- name of the NDS table
	db_table_scscf	- name of the S-CSCF table
	db_table_capabilities	- name of the S-CSCF capabilities table

Returns:

0 on success, -1 on error

Definition at line 99 of file db.c.

References dbf, hdl_capabilities, hdl_nds, hdl_scscf, and M_NAME.

Referenced by icscf_db_check_init(), and icscf_mod_child_init().

{
    if (dbf.init==0){
        LOG(L_CRIT, "BUG:"M_NAME":icscf_db_init: unbound database module\n");
        return -1;
    }
    /* NDS */
    hdl_nds=dbf.init(db_url);
    if (hdl_nds==0){
        LOG(L_CRIT,"ERR:"M_NAME":icscf_db_init: cannot initialize database "
            "connection\n");
        goto error;
    }   
    if (dbf.use_table(hdl_nds, db_table_nds)<0) {
        LOG(L_CRIT,"ERR:"M_NAME":icscf_db_init: cannot select table \"%s\"\n",db_table_nds);
        goto error;
    }
    /* S_CSCF */
    hdl_scscf=dbf.init(db_url);
    if (hdl_scscf==0){
        LOG(L_CRIT,"ERR:"M_NAME":icscf_db_init: cannot initialize database "
            "connection\n");
        goto error;
    }   
    if (dbf.use_table(hdl_scscf, db_table_scscf)<0) {
        LOG(L_CRIT,"ERR:"M_NAME":icscf_db_init: cannot select table \"%s\"\n",db_table_scscf);
        goto error;
    }
    /* Capabilities */
    hdl_capabilities=dbf.init(db_url);
    if (hdl_capabilities==0){
        LOG(L_CRIT,"ERR:"M_NAME":icscf_db_init: cannot initialize database "
            "connection\n");
        goto error;
    }   
    if (dbf.use_table(hdl_capabilities, db_table_capabilities)<0) {
        LOG(L_CRIT,"ERR:"M_NAME":icscf_db_init: cannot select table \"%s\"\n",db_table_capabilities);
        goto error;
    }

    return 0;

error:
    if (hdl_nds){
        dbf.close(hdl_nds);
        hdl_nds=0;
    }
    if (hdl_scscf){
        dbf.close(hdl_scscf);
        hdl_nds=0;
    }
    if (hdl_capabilities){
        dbf.close(hdl_capabilities);
        hdl_nds=0;
    }
    return -1;
}

void icscf_db_close

(

)

Close the database connection.

Definition at line 163 of file db.c.

References dbf, and hdl_nds.

{
    if (hdl_nds && dbf.close){
        dbf.close(hdl_nds);
        hdl_nds=0;
    }
}

static int icscf_db_check_init

(

db_con_t *

db_hdl

)

[inline, static]

Simply check if the database connection was initialized and connect if not.

Parameters:

db_hdl

- database handle to test

Returns:

1 if connected, 0 if not

Definition at line 176 of file db.c.

References icscf_db_capabilities_table, icscf_db_init(), icscf_db_nds_table, icscf_db_scscf_table, and icscf_db_url.

Referenced by icscf_db_get_capabilities(), icscf_db_get_nds(), and icscf_db_get_scscf().

{
    if (db_hdl) return 1;
    return (icscf_db_init( icscf_db_url,
        icscf_db_nds_table,
        icscf_db_scscf_table,
        icscf_db_capabilities_table)==0);       
}

int icscf_db_get_nds

(

str *

d[]

)

Get the NDS list from the database.

Parameters:

d

- array of string to fill with the db contents

Returns:

1 on success, 0 on error

Definition at line 190 of file db.c.

References dbf, hdl_nds, icscf_db_check_init(), if, M_NAME, and NULL.

Referenced by I_NDS_get_trusted_domains().

{
    db_key_t   keys_ret[] = {"trusted_domain"};
    db_res_t   * res = 0 ;  
    str s;
    int i;

    if (!icscf_db_check_init(hdl_nds))
        goto error;

    DBG("DBG:"M_NAME":icscf_db_get_nds: fetching list of NDS for I-CSCF \n");

    if (dbf.query(hdl_nds, 0, 0, 0, keys_ret, 0, 1, NULL, & res) < 0) {
        LOG(L_ERR, "ERR:"M_NAME":icscf_db_get_nds: db_query failed\n");
        goto error;
    }

    if (res->n == 0) {
        DBG("DBG:"M_NAME":icscf_db_get_nds: I-CSCF has no NDS trusted domains in db\n");
        *d=shm_malloc(sizeof(str));
        if (*d==NULL){
            LOG(L_ERR, "ERR:"M_NAME":icscf_db_get_nds: failed shm_malloc for 0 domains\n");
            goto error;
        }   
        (*d)[0].s=0;
        (*d)[0].len=0;
    }
    else {
        *d=shm_malloc(sizeof(str)*(res->n+1));
        if (*d==NULL){
            LOG(L_ERR, "ERR:"M_NAME":icscf_db_get_nds: failed shm_malloc for %d domains\n",
                res->n);
            goto error;
        }   
        for(i=0;i<res->n;i++){
            s.s = (char*) res->rows[i].values[0].val.string_val;
            s.len = strlen(s.s);
            (*d)[i].s = shm_malloc(s.len);
            if ((*d)[i].s==NULL) {
                LOG(L_ERR, "ERR:"M_NAME":icscf_db_get_nds: failed shm_malloc for %d bytes\n",
                    s.len);
                (*d)[i].len = 0;
            }else{
                (*d)[i].len = s.len;
                memcpy((*d)[i].s,s.s,s.len);
            }
        }
        (*d)[res->n].s=0;
        (*d)[res->n].len=0;
    }

    LOG(L_INFO, "INF:"M_NAME":icscf_db_get_nds: Loaded %d trusted domains\n",
        res->n);

    dbf.free_result( hdl_nds, res);
    return 1;
error:
    if (res)
        dbf.free_result( hdl_nds, res);
    *d=shm_malloc(sizeof(str));
    if (*d==NULL)
        LOG(L_ERR, "ERR:"M_NAME":icscf_db_get_nds: failed shm_malloc for 0 domains\n");
    else {
        (*d)[0].s=0;
        (*d)[0].len=0;
    }
    return 0;
}

int icscf_db_get_scscf

(

scscf_capabilities *

cap[]

)

Get the S-CSCF names from the database and create the S-CSCF set.

Parameters:

cap

- array of scscf_capabilities to fill with the db contents for the S-CSCF names

Returns:

1 on success, 0 on error

Definition at line 265 of file db.c.

References dbf, hdl_scscf, icscf_db_check_init(), id_s_cscf, if, M_NAME, and scscf_name.

Referenced by I_get_capabilities().

{
    db_key_t   keys_ret[] = {"id","s_cscf_uri"};
    db_key_t   key_ord = "id";
    db_res_t   * res = 0 ;  
    int i;

    *cap = 0;
        
    if (!icscf_db_check_init(hdl_scscf))
        goto error;

    DBG("DBG:"M_NAME":icscf_db_get_scscf: fetching S-CSCFs \n");

    if (dbf.query(hdl_scscf, 0, 0, 0, keys_ret, 0, 2, key_ord, & res) < 0) {
        LOG(L_ERR, "ERR:"M_NAME":icscf_db_get_scscf: db_query failed\n");
        goto error;
    }

    if (res->n == 0) {
        LOG(L_ERR,"ERR:"M_NAME":icscf_db_get_scscf:  no S-CSCFs found\n");
        goto error;
    }
    else {
        *cap = shm_malloc(sizeof(scscf_capabilities)*res->n);
        if (!(*cap)) {
            LOG(L_ERR,"ERR:"M_NAME":icscf_db_get_scscf: Error allocating %d bytes\n",
                sizeof(scscf_capabilities)*res->n);
            goto error;
        }
        memset((*cap),0,sizeof(scscf_capabilities)*res->n);
        for(i=0;i<res->n;i++){
            (*cap)[i].id_s_cscf = res->rows[i].values[0].val.int_val;
            (*cap)[i].scscf_name.len = strlen(res->rows[i].values[1].val.string_val);
            (*cap)[i].scscf_name.s = shm_malloc((*cap)[i].scscf_name.len);
            if (!(*cap)[i].scscf_name.s){
                LOG(L_ERR,"ERR:"M_NAME":icscf_db_get_scscf: Error allocating %d bytes\n",
                    (*cap)[i].scscf_name.len);
                (*cap)[i].scscf_name.len=0;
                goto error;
            }
            memcpy((*cap)[i].scscf_name.s,res->rows[i].values[1].val.string_val,
                (*cap)[i].scscf_name.len);
        }
    }

    dbf.free_result( hdl_scscf, res);
    
    // return the size of scscf set  
    return i;
    
error:
    if (res)
        dbf.free_result( hdl_scscf, res);
    return 0;
}

int icscf_db_get_capabilities	(	scscf_capabilities *	cap[],
		int	cap_cnt
	)

Get the S-CSCF capabilities from the database and fill the S-CSCF set.

Parameters:

cap

- array of scscf_capabilities to fill with capabilities

Returns:

1 on success, 0 on error

Definition at line 327 of file db.c.

References dbf, hdl_capabilities, icscf_db_check_init(), and M_NAME.

Referenced by I_get_capabilities().

{
//  db_key_t   keys_cmp[] = {"icscf"};
    db_key_t   keys_ret[] = {"id_s_cscf","capability"};
    db_key_t   key_ord = "id_s_cscf";
    db_res_t   * res = 0 ;  
    int i,j;
    int ccnt=0;
    int cnt;


    if (!icscf_db_check_init(hdl_capabilities))
        goto error;

    DBG("DBG:"M_NAME":icscf_db_get_capabilities: fetching list of Capabilities for I-CSCF\n");


    if (dbf.query(hdl_capabilities, 0, 0, 0, keys_ret, 0, 2, key_ord, & res) < 0) {
        LOG(L_ERR, "ERR:"M_NAME":icscf_db_get_capabilities: db_query failed\n");
        goto error;
    }

    if (res->n == 0) {
        DBG("DBG:"M_NAME":icscf_db_get_capabilities: No Capabilites found... not critical...\n");
        return 1;
    }
    else {
        for(i=0;i<cap_cnt;i++){
            cnt = 0;
            for(j=0;j<res->n;j++)
                if (res->rows[j].values[0].val.int_val == (*cap)[i].id_s_cscf)
                    cnt++;
            (*cap)[i].capabilities = shm_malloc(sizeof(int)*cnt);
            if (!(*cap)[i].capabilities) {
                LOG(L_ERR,"ERR:"M_NAME":icscf_db_get_capabilities: Error allocating %d bytes\n",
                    sizeof(int)*cnt);
                (*cap)[i].cnt=0;
                    goto error;
            }           
            cnt=0;
            for(j=0;j<res->n;j++)
                if (res->rows[j].values[0].val.int_val == (*cap)[i].id_s_cscf) {
                    (*cap)[i].capabilities[cnt++]=res->rows[j].values[1].val.int_val;
                    ccnt++;
                }
            (*cap)[i].cnt=cnt;                  
        }
            
    } 
    LOG(L_INFO, "INF:"M_NAME":icscf_db_get_capabilities: Loaded %d capabilities for %d S-CSCFs (%d invalid entries in db)\n",
        ccnt,cap_cnt,res->n-ccnt);
    dbf.free_result( hdl_capabilities, res);
    return 1;
    
error:
    if (res)
        dbf.free_result( hdl_capabilities, res);
    return 0;
}

---

Variable Documentation

db_func_t dbf [static]

db function bindings

Definition at line 63 of file db.c.

Referenced by icscf_db_bind(), icscf_db_close(), icscf_db_get_capabilities(), icscf_db_get_nds(), icscf_db_get_scscf(), and icscf_db_init().

char* icscf_db_url

DB URL.

Definition at line 95 of file mod.c.

Referenced by icscf_db_bind(), icscf_db_check_init(), icscf_mod_child_init(), and icscf_mod_init().

char* icscf_db_nds_table

NDS table in DB.

Definition at line 96 of file mod.c.

Referenced by icscf_db_check_init(), and icscf_mod_child_init().

char* icscf_db_scscf_table

S-CSCF table in db.

Definition at line 97 of file mod.c.

Referenced by icscf_db_check_init(), and icscf_mod_child_init().

char* icscf_db_capabilities_table

S-CSCF capabilities table in db.

Definition at line 98 of file mod.c.

Referenced by icscf_db_check_init(), and icscf_mod_child_init().

db_con_t* hdl_nds = 0 [static]

handle for the NDS table

Definition at line 69 of file db.c.

Referenced by icscf_db_close(), icscf_db_get_nds(), and icscf_db_init().

db_con_t* hdl_scscf = 0 [static]

handle for the S-CSCF table

Definition at line 70 of file db.c.

Referenced by icscf_db_get_scscf(), and icscf_db_init().

db_con_t* hdl_capabilities = 0 [static]

handle for the S-CSCF capabilities table

Definition at line 71 of file db.c.

Referenced by icscf_db_get_capabilities(), and icscf_db_init().

---