mod.c File Reference

---

Detailed Description

Serving-CSCF - SER module interface.

Scope:

• Exports parameters and functions
• Initialization functions

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file mod.c.

#include "mod.h"
#include "../../db/db.h"
#include "../../sr_module.h"
#include "../../timer.h"
#include "../../locking.h"
#include "../tm/tm_load.h"
#include "../cdp/cdp_load.h"
#include "../dialog/dlg_mod.h"
#include "registration.h"
#include "registrar.h"
#include "registrar_storage.h"
#include "registrar_notify.h"
#include "sip.h"
#include "cx.h"
#include "scscf_load.h"
#include "dlg_state.h"
#include "s_persistency.h"
#include "ims_pm_scscf.h"
#include "privacy.h"

Go to the source code of this file.

Functions
static MODULE_VERSION int	mod_init (void)
	Initializes the module.
static int	mod_child_init (int rank)
	Initializes the module in child.
static void	mod_destroy (void)
	Destroys the modules.
static int	build_record_service_route ()
	Builds the Service-Route header from the scscf_name_str.
db_con_t *	create_scscf_db_connection ()
void	close_scscf_db_connection (db_con_t *db)
int	S_trans_in_processing (struct sip_msg *msg, char *str1, char *str2)
	Checks if this transaction is already in processing.
Variables
char *	scscf_name = "sip:scscf.open-ims.test:6060"
	name of the S-CSCF
char *	scscf_forced_hss_peer = ""
	FQDN of the Forced Diameter Peer (HSS).
char *	scscf_user_data_dtd = 0
char *	scscf_user_data_xsd = 0
int	auth_data_hash_size = 1024
	authentication vector hash table size
int	auth_vector_timeout = 60
	timeout for a sent auth vector to expire in sec
int	auth_data_timeout = 60
	timeout for a hash entry to expire when empty in sec
int	av_request_at_once = 1
	how many auth vectors to request in a MAR
int	av_request_at_sync = 1
	how many auth vectors to request in a sync MAR
int	server_assignment_store_data = 0
	whether to ask to keep the data in SAR
int	registrar_hash_size = 1024
	the size of the hash table
int	registration_default_expires = 3600
	the default value for expires if none found
int	registration_min_expires = 10
	minimum registration expiration time
int	registration_max_expires = 1000000
	maximum registration expiration time
char *	registration_qop = "auth,auth-int"
	the qop options to put in the authorization challenges
str	registration_qop_str = {0,0}
	the qop options to put in the authorization challenges
char *	registration_default_algorithm = "AKAv1-MD5"
	default algorithm for registration (if none present)
unsigned char	registration_default_algorithm_type = 1
	fixed default algorithm for registration (if none present)
int	registration_disable_early_ims = 1
	if to disable the Early-IMS checks
int	registration_disable_nass_bundled = 1
	if to disable the NASS-Bundled checks
int	subscription_default_expires = 3600
	the default value for expires if none found
int	subscription_min_expires = 10
	minimum subscription expiration time
int	subscription_max_expires = 1000000
	maximum subscription expiration time
int	append_branches = 1
	if to append branches
int	scscf_dialogs_hash_size = 256
	size of the dialog hash table
int	scscf_dialogs_expiration_time = 3600
	default expiration time for dialogs
int	scscf_dialogs_enable_release = 1
	if to enable dialog release
int	scscf_min_se = 90
	Minimum session-expires accepted value.
int *	scscf_dialog_count = 0
	Counter for saved dialogs.
int	scscf_max_dialog_count = 20000
	Maximum number of dialogs.
gen_lock_t *	scscf_dialog_count_lock = 0
	Lock for the dialog counter.
int	scscf_support_wildcardPSI = 0
persistency_mode_t	scscf_persistency_mode = NO_PERSISTENCY
	the type of persistency
char *	scscf_persistency_location = "/opt/OpenIMSCore/persistency"
	where to dump the persistency data
int	scscf_persistency_timer_authdata = 60
	interval to snapshot authorization data
int	scscf_persistency_timer_dialogs = 60
	interval to snapshot dialogs data
int	scscf_persistency_timer_registrar = 60
	interval to snapshot registrar data
char *	scscf_db_url = "postgres://mario:mario@localhost/scscfdb"
int *	auth_snapshot_version = 0
	the version of the next auth snapshot on the db
int *	auth_step_version = 0
	the step version within the current auth snapshot version
int *	dialogs_snapshot_version = 0
	the version of the next dialogs snapshot on the db
int *	dialogs_step_version = 0
	the step version within the current dialogs snapshot version
int *	registrar_snapshot_version = 0
	the version of the next registrar snapshot on the db
int *	registrar_step_version = 0
	the step version within the current registrar snapshot version
gen_lock_t *	db_lock
	lock for db access
str	scscf_name_str
	fixed name of the S-CSCF
str	scscf_record_route_mo
	the record route header for Mobile Originating
str	scscf_record_route_mt
	the record route header for Mobile Terminating
str	scscf_record_route_mo_uri
	just the record route uri for Mobile Originating
str	scscf_record_route_mt_uri
	just the record route uri for Mobile Terminating
str	scscf_service_route
	the service route header
str	scscf_service_route_uri
	just the service route uri
str	scscf_registration_min_expires
	fixed minimum registration expiration time
str	scscf_subscription_min_expires
	fixed minimum subscription expiration time
str	scscf_forced_hss_peer_str
	FQDN of the forced Diameter Peer (HSS).
int *	callback_singleton
	Cx callback singleton.
int *	shutdown_singleton
	Shutdown singleton.
static cmd_export_t	scscf_cmds []
	Exported functions.
static param_export_t	scscf_params []
	Exported parameters.
module_exports	exports
	module exports
int(*)	sl_reply (struct sip_msg *_msg, char *_str1, char *_str2)
	link to the stateless reply function in sl module
tm_binds	tmb
	Structure with pointers to tm funcs.
cdp_binds	cdpb
	Structure with pointers to cdp funcs.
dlg_func_t	dialogb
	Structure with pointers to dialog funcs.
auth_hash_slot_t *	auth_data
	authentication vectors hast table
r_hash_slot *	registrar
	the S-CSCF registrar
r_notification_list *	notification_list
	list of notifications for reg to be sent
s_dialog_hash_slot *	s_dialogs
	the dialogs hash table
db_con_t *	scscf_db = NULL
	Database connection handle.
db_func_t	scscf_dbf
	Structure with pointers to db functions.
static str	s_qop_s = {", qop=\"",7}
static str	s_qop_e = {"\"",1}
static str	s_service_route = {"Service-Route: <",16}
static str	s_orig = {"sip:orig@",9}
static str	s_sr_end = {";lr>\r\n",6}
static str	s_min_expires_s = {"Min-Expires: ",13}
static str	s_min_expires_e = {"\r\n",2}
static str	s_record_route_s = {"Record-Route: <",15}
static str	s_mo = {"sip:mo@",7}
static str	s_mt = {"sip:mt@",7}
static str	s_record_route_e = {";lr>\r\n",6}
gen_lock_t *	process_lock

---

Function Documentation

static int mod_init

(

void

)

[static]

Initializes the module.

Definition at line 544 of file mod.c.

References auth_data, auth_data_hash_size, auth_data_init(), auth_snapshot_version, auth_step_version, build_record_service_route(), callback_singleton, cdpb, create_scscf_db_connection(), db_lock, dialog_timer(), dialogs_snapshot_version, dialogs_step_version, get_algorithm_type(), load_cdp(), load_snapshot_authdata(), load_snapshot_dialogs(), load_snapshot_registrar(), M_NAME, NO_PERSISTENCY, NO_SCRIPT, notification_list, notification_timer(), persistency_timer_authdata(), persistency_timer_dialogs(), persistency_timer_registrar(), r_notify_init(), r_storage_init(), reg_await_timer(), registrar, registrar_hash_size, registrar_snapshot_version, registrar_step_version, registrar_timer(), registration_default_algorithm, registration_default_algorithm_type, s_dialogs, s_dialogs_init(), scscf_db_url, scscf_dialog_count, scscf_dialog_count_lock, scscf_dialogs_hash_size, scscf_forced_hss_peer, scscf_forced_hss_peer_str, scscf_name, scscf_name_str, scscf_persistency_mode, scscf_persistency_timer_authdata, scscf_persistency_timer_dialogs, scscf_persistency_timer_registrar, shutdown_singleton, sl_reply, WITH_DATABASE_BULK, and WITH_DATABASE_CACHE.

{
    load_tm_f load_tm;
    load_cdp_f load_cdp;
    bind_dlg_mod_f load_dlg;
    str algo;
    
    callback_singleton=shm_malloc(sizeof(int));
    *callback_singleton=0;
    shutdown_singleton=shm_malloc(sizeof(int));
    *shutdown_singleton=0;
    
        
    LOG(L_INFO,"INFO:"M_NAME":mod_init: Initialization of module\n");
    /* fix the parameters */
    scscf_name_str.s = scscf_name;
    scscf_name_str.len = strlen(scscf_name);
    if (!build_record_service_route()) goto error;
    scscf_forced_hss_peer_str.s = scscf_forced_hss_peer;
    scscf_forced_hss_peer_str.len = strlen(scscf_forced_hss_peer);
    
    algo.s = registration_default_algorithm;
    algo.len = strlen(registration_default_algorithm);
    registration_default_algorithm_type = get_algorithm_type(algo); 
    

    #ifdef WITH_IMS_PM
        ims_pm_init(scscf_name_str,ims_pm_node_type, ims_pm_logfile);
        ims_pm_init_scscf();
    #endif /* WITH_IMS_PM */
            
    /* load the send_reply function from sl module */
    sl_reply = find_export("sl_send_reply", 2, 0);
    if (!sl_reply) {
        LOG(L_ERR, "ERR"M_NAME":mod_init: This module requires sl module\n");
        goto error;
    }
    
//  /* bind to the db module */
//  if ( cscf_db_bind( scscf_db_url ) < 0 ) goto error;

    if(scscf_persistency_mode==WITH_DATABASE_BULK || scscf_persistency_mode==WITH_DATABASE_CACHE){
        if (!scscf_db_url) {
            LOG(L_ERR, "ERR:"M_NAME":mod_init: no db_url specified but DB has to be used "
                "(scscf_persistency_mode=%d\n", scscf_persistency_mode);
            return -1;
        }
        if (bind_dbmod(scscf_db_url, &scscf_dbf) < 0) { /* Find database module */
            LOG(L_ERR, "ERR"M_NAME":mod_init: Can't bind database module via url %s\n", scscf_db_url);
            return -1;
        }

        if (!DB_CAPABILITY(scscf_dbf, DB_CAP_ALL)) {
            LOG(L_ERR, "ERR:"M_NAME":mod_init: Database module does not implement all functions needed by the module\n");
            return -1;
        }
        
        scscf_db = create_scscf_db_connection();
        if (!scscf_db) {
            LOG(L_ERR, "ERR:"M_NAME": mod_init: Error while connecting database\n");
            return -1;
        }
        
        /* db lock */
        db_lock = (gen_lock_t*)lock_alloc();
        if(!db_lock){
            LOG(L_ERR, "ERR:"M_NAME": mod_init: No memory left\n");
            return -1;
        }
        lock_init(db_lock);
    
        /* snapshot and step versions */
    
        auth_snapshot_version=(int*)shm_malloc(sizeof(int));
        if(!auth_snapshot_version){
            LOG(L_ERR, "ERR:"M_NAME":mod_init: auth_snapshot_version, no memory left\n");
            return -1;
        }
        *auth_snapshot_version=0;
    
        auth_step_version=(int*)shm_malloc(sizeof(int));
        if(!auth_step_version){
            LOG(L_ERR, "ERR:"M_NAME":mod_init: auth_step_version, no memory left\n");
            return -1;
        }
        *auth_step_version=0;
    
        dialogs_snapshot_version=(int*)shm_malloc(sizeof(int));
        if(!dialogs_snapshot_version){
            LOG(L_ERR, "ERR:"M_NAME":mod_init: dialogs_snapshot_version, no memory left\n");
            return -1;
        }
        *dialogs_snapshot_version=0;
    
        dialogs_step_version=(int*)shm_malloc(sizeof(int));
        if(!dialogs_step_version){
            LOG(L_ERR, "ERR:"M_NAME":mod_init: dialogs_step_version, no memory left\n");
            return -1;
        }
        *dialogs_step_version=0;
    
        registrar_snapshot_version=(int*)shm_malloc(sizeof(int));
        if(!registrar_snapshot_version){
            LOG(L_ERR, "ERR:"M_NAME":mod_init: registrar_snapshot_version, no memory left\n");
            return -1;
        }
        *registrar_snapshot_version=0;
    
        registrar_step_version=(int*)shm_malloc(sizeof(int));
        if(!registrar_step_version){
            LOG(L_ERR, "ERR:"M_NAME":mod_init: registrar_step_version, no memory left\n");
            return -1;
        }
        *registrar_step_version=0;
        
    }
    
    /* bind to the tm module */
    if (!(load_tm = (load_tm_f)find_export("load_tm",NO_SCRIPT,0))) {
        LOG(L_ERR, "ERR"M_NAME":mod_init: Can not import load_tm. This module requires tm module\n");
        goto error;
    }
    if (load_tm(&tmb) == -1)
        goto error;
    /* bind to the cdp module */
    if (!(load_cdp = (load_cdp_f)find_export("load_cdp",NO_SCRIPT,0))) {
        LOG(L_ERR, "ERR"M_NAME":mod_init: Can not import load_cdp. This module requires cdp module\n");
        goto error;
    }
    if (load_cdp(&cdpb) == -1)
        goto error;

    /* bind to the dialog module */
    load_dlg = (bind_dlg_mod_f)find_export("bind_dlg_mod", -1, 0);
    if (!load_dlg) {
        LOG(L_ERR, "ERR"M_NAME":mod_init:  Can not import bind_dlg_mod. This module requires dialog module\n");
        return -1;
    }
    if (load_dlg(&dialogb) != 0) {
        return -1;
    }
    
    
    /* Init the authorization data storage */
    if (!auth_data_init(auth_data_hash_size)) goto error;   
    if (scscf_persistency_mode!=NO_PERSISTENCY){
        load_snapshot_authdata();
        if (register_timer(persistency_timer_authdata,0,scscf_persistency_timer_authdata)<0) goto error;
    }
    

    /* register the authentication vectors timer */
    if (register_timer(reg_await_timer,auth_data,10)<0) goto error;
    
    /* init the registrar storage */
    if (!r_storage_init(registrar_hash_size)) goto error;
    if (scscf_persistency_mode!=NO_PERSISTENCY){
        load_snapshot_registrar();
        if (register_timer(persistency_timer_registrar,0,scscf_persistency_timer_registrar)<0) goto error;
    }

    /* register the registrar timer */
    if (register_timer(registrar_timer,registrar,10)<0) goto error;

    /* init the registrar notifications */
    if (!r_notify_init()) goto error;

    /* register the registrar notifications timer */
    if (register_timer(notification_timer,notification_list,5)<0) goto error;

    /* init the dialog storage */
    if (!s_dialogs_init(scscf_dialogs_hash_size)){
        LOG(L_ERR, "ERR"M_NAME":mod_init: Error initializing the Hash Table for stored dialogs\n");
        goto error;
    }       
    scscf_dialog_count = shm_malloc(sizeof(int));
    *scscf_dialog_count = 0;
    scscf_dialog_count_lock = lock_alloc();
    scscf_dialog_count_lock = lock_init(scscf_dialog_count_lock);

    if (scscf_persistency_mode!=NO_PERSISTENCY){
        load_snapshot_dialogs();
        if (register_timer(persistency_timer_dialogs,0,scscf_persistency_timer_dialogs)<0) goto error;
    }

    /* register the dialog timer */
    if (register_timer(dialog_timer,s_dialogs,60)<0) goto error;


    /* don't register response callback as we always set callback per transactions 
     *  and we're not interested in other responses */
    /*AAAAddResponseHandler(&CxAnswerHandler,0);*/

    
    return 0;
error:
    return -1;
}

static int mod_child_init

(

int

rank

)

[static]

Initializes the module in child.

Definition at line 754 of file mod.c.

References cdp_binds::AAAAddRequestHandler, callback_singleton, cdpb, CxRequestHandler(), M_NAME, NULL, parser_init(), scscf_user_data_dtd, and scscf_user_data_xsd.

{
    LOG(L_INFO,"INFO:"M_NAME":mod_child_init: Initialization of module in child [%d] \n",
        rank);
    /* don't do anything for main process and TCP manager process */
    if ( rank == PROC_MAIN || rank == PROC_TCP_MAIN )
        return 0;
    
//  /* db child init */
//  cscf_db_init( scscf_db_url, 
//      scscf_db_nds_table,
//      scscf_db_scscf_table,
//      scscf_db_capabilities_table);
    
    /*if (scscf_persistency_mode==WITH_DATABASE_BULK || scscf_persistency_mode==WITH_DATABASE_CACHE) { 
        scscf_db = create_scscf_db_connection();
        if (!scscf_db) {
            LOG(L_ERR, "ERR:"M_NAME":mod_child_init(%d): "
                    "Error while connecting database\n", rank);
            return -1;
        }
    }*/
    
    /* init the diameter callback - must be done just once */
    lock_get(process_lock);
        if((*callback_singleton)==0){
            *callback_singleton=1;
            cdpb.AAAAddRequestHandler(CxRequestHandler,NULL);
        }
    lock_release(process_lock);
    /* Init the user data parser */
    if (!parser_init(scscf_user_data_dtd,scscf_user_data_xsd)) return -1;
        
    return 0;
}

static void mod_destroy

(

void

)

[static]

Destroys the modules.

Definition at line 793 of file mod.c.

References auth_data_destroy(), close_scscf_db_connection(), M_NAME, make_snapshot_authdata(), make_snapshot_dialogs(), make_snapshot_registrar(), NO_PERSISTENCY, NULL, parser_destroy(), r_notify_destroy(), r_storage_destroy(), s_dialogs_destroy(), scscf_dialog_count, scscf_dialog_count_lock, scscf_persistency_mode, scscf_service_route, shutdown_singleton, WITH_DATABASE_BULK, and WITH_DATABASE_CACHE.

{
    int do_destroy=0;
    LOG(L_INFO,"INFO:"M_NAME":mod_destroy: child exit\n");
    lock_get(process_lock);
        if((*shutdown_singleton)==0){
            *shutdown_singleton=1;
            do_destroy=1;
        }
    lock_release(process_lock);
    if (do_destroy){
        if (scscf_persistency_mode!=NO_PERSISTENCY){
            /* First let's snapshot everything */
            make_snapshot_authdata();
            make_snapshot_dialogs();
            make_snapshot_registrar();
        }
        /* Then nuke it all */
        auth_data_destroy();
        parser_destroy();
        r_notify_destroy(); 
        r_storage_destroy();
        s_dialogs_destroy();    
        lock_get(scscf_dialog_count_lock);
        shm_free(scscf_dialog_count);
        lock_destroy(scscf_dialog_count_lock);      
        pkg_free(scscf_service_route.s);
    }
    
    if ( (scscf_persistency_mode==WITH_DATABASE_BULK || scscf_persistency_mode==WITH_DATABASE_CACHE) && scscf_db) {
        DBG("INFO:"M_NAME": ... closing db connection\n");
        close_scscf_db_connection(scscf_db);
    }
    scscf_db = NULL;
    #ifdef WITH_IMS_PM
        ims_pm_destroy();   
    #endif /* WITH_IMS_PM */    
}

static int build_record_service_route

(

)

[inline, static]

Builds the Service-Route header from the scscf_name_str.

Definition at line 421 of file mod.c.

References M_NAME, registration_min_expires, registration_qop, registration_qop_str, scscf_name_str, scscf_record_route_mo, scscf_record_route_mo_uri, scscf_record_route_mt, scscf_record_route_mt_uri, scscf_registration_min_expires, scscf_service_route, scscf_service_route_uri, scscf_subscription_min_expires, STR_APPEND, and subscription_min_expires.

Referenced by mod_init().

{
    scscf_service_route.s = pkg_malloc(s_service_route.len+s_orig.len+scscf_name_str.len+s_sr_end.len);
    if (!scscf_service_route.s){
        LOG(L_ERR, "ERR"M_NAME":mod_init: Error allocating %d bytes\n",
            s_service_route.len+s_orig.len+scscf_name_str.len+s_sr_end.len);
        return 0;
    }
    scscf_registration_min_expires.s = pkg_malloc(s_min_expires_s.len+10+s_min_expires_e.len);
    if (!scscf_registration_min_expires.s){
        LOG(L_ERR, "ERR"M_NAME":mod_init: Error allocating %d bytes\n",
            s_min_expires_s.len+10+s_min_expires_e.len);
        return 0;
    }
    scscf_subscription_min_expires.s = pkg_malloc(s_min_expires_s.len+10+s_min_expires_e.len);
    if (!scscf_subscription_min_expires.s){
        LOG(L_ERR, "ERR"M_NAME":mod_init: Error allocating %d bytes\n",
            s_min_expires_s.len+10+s_min_expires_e.len);
        return 0;
    }
    
    if (registration_qop && strlen(registration_qop)>0) {
        registration_qop_str.len = s_qop_s.len+strlen(registration_qop)+s_qop_e.len;
        registration_qop_str.s = pkg_malloc(registration_qop_str.len);
        if (!registration_qop_str.s){
            LOG(L_ERR, "ERR"M_NAME":mod_init: Error allocating %d bytes\n",registration_qop_str.len);
            registration_qop_str.len = 0;
            return 0;
        }
        registration_qop_str.len = 0;
        STR_APPEND(registration_qop_str,s_qop_s);
        memcpy(registration_qop_str.s+registration_qop_str.len,registration_qop,strlen(registration_qop));
        registration_qop_str.len += strlen(registration_qop);
        STR_APPEND(registration_qop_str,s_qop_e);       
    }else{
        registration_qop_str.len=0;
        registration_qop_str.s=0;
    }
    
    scscf_record_route_mo.s = pkg_malloc(s_record_route_s.len+s_mo.len+scscf_name_str.len+s_record_route_e.len);
    if (!scscf_record_route_mo.s){
        LOG(L_ERR, "ERR"M_NAME":mod_init: Error allocating %d bytes\n",
            s_record_route_s.len+s_mo.len+scscf_name_str.len+s_record_route_e.len);
        return 0;
    }
    scscf_record_route_mt.s = pkg_malloc(s_record_route_s.len+s_mt.len+scscf_name_str.len+s_record_route_e.len);
    if (!scscf_record_route_mt.s){
        LOG(L_ERR, "ERR"M_NAME":mod_init: Error allocating %d bytes\n",
            s_record_route_s.len+s_mt.len+scscf_name_str.len+s_record_route_e.len);
        return 0;
    }
    
    STR_APPEND(scscf_service_route,s_service_route);
    if (scscf_name_str.len>4 && strncasecmp(scscf_name_str.s,"sip:",4)==0){
        STR_APPEND(scscf_service_route,s_orig);
        memcpy(scscf_service_route.s+scscf_service_route.len,scscf_name_str.s+4,
            scscf_name_str.len-4);
        scscf_service_route.len += scscf_name_str.len-4;
    } else {
        STR_APPEND(scscf_service_route,s_orig);
        STR_APPEND(scscf_service_route,scscf_name_str);
    }
    STR_APPEND(scscf_service_route,s_sr_end);
    scscf_service_route_uri.s = scscf_service_route.s + s_service_route.len;
    scscf_service_route_uri.len = scscf_service_route.len - s_service_route.len - s_sr_end.len;

    sprintf(scscf_registration_min_expires.s,"%.*s%d%.*s",
        s_min_expires_s.len,s_min_expires_s.s,
        registration_min_expires,
        s_min_expires_e.len,s_min_expires_e.s);
    scscf_registration_min_expires.len = strlen(scscf_registration_min_expires.s);

    sprintf(scscf_subscription_min_expires.s,"%.*s%d%.*s",
        s_min_expires_s.len,s_min_expires_s.s,
        subscription_min_expires,
        s_min_expires_e.len,s_min_expires_e.s);
    scscf_subscription_min_expires.len = strlen(scscf_subscription_min_expires.s);

    scscf_record_route_mo.len=0;
    STR_APPEND(scscf_record_route_mo,s_record_route_s);
    if (scscf_name_str.len>4 && strncasecmp(scscf_name_str.s,"sip:",4)==0){
        STR_APPEND(scscf_record_route_mo,s_mo);
        memcpy(scscf_record_route_mo.s+scscf_record_route_mo.len,scscf_name_str.s+4,
            scscf_name_str.len-4);
        scscf_record_route_mo.len += scscf_name_str.len-4;
    } else {
        STR_APPEND(scscf_record_route_mo,s_mo);
        STR_APPEND(scscf_record_route_mo,scscf_name_str);
    }
    STR_APPEND(scscf_record_route_mo,s_record_route_e);
    scscf_record_route_mo_uri.s = scscf_record_route_mo.s + s_record_route_s.len;
    scscf_record_route_mo_uri.len = scscf_record_route_mo.len - s_record_route_s.len - s_record_route_e.len;

    scscf_record_route_mt.len=0;
    STR_APPEND(scscf_record_route_mt,s_record_route_s);
    if (scscf_name_str.len>4 && strncasecmp(scscf_name_str.s,"sip:",4)==0){
        STR_APPEND(scscf_record_route_mt,s_mt);
        memcpy(scscf_record_route_mt.s+scscf_record_route_mt.len,scscf_name_str.s+4,
            scscf_name_str.len-4);
        scscf_record_route_mt.len += scscf_name_str.len-4;
    } else {
        STR_APPEND(scscf_record_route_mt,s_mt);
        STR_APPEND(scscf_record_route_mt,scscf_name_str);
    }
    STR_APPEND(scscf_record_route_mt,s_record_route_e);
    scscf_record_route_mt_uri.s = scscf_record_route_mt.s + s_record_route_s.len;
    scscf_record_route_mt_uri.len = scscf_record_route_mt.len - s_record_route_s.len - s_record_route_e.len;


    return 1;
}

db_con_t* create_scscf_db_connection

(

)

Definition at line 533 of file mod.c.

References NULL, scscf_db_url, scscf_persistency_mode, WITH_DATABASE_BULK, and WITH_DATABASE_CACHE.

Referenced by mod_init().

{
    if (scscf_persistency_mode!=WITH_DATABASE_BULK && scscf_persistency_mode!=WITH_DATABASE_CACHE) return NULL;
    if (!scscf_dbf.init) return NULL;

    return scscf_dbf.init(scscf_db_url);
}

void close_scscf_db_connection

(

db_con_t *

db

)

Definition at line 746 of file mod.c.

Referenced by mod_destroy().

{
    if (db && scscf_dbf.close) scscf_dbf.close(db);
}

int S_trans_in_processing	(	struct sip_msg *	msg,
		char *	str1,
		char *	str2
	)

Checks if this transaction is already in processing.

Parameters:

	msg	- the SIP message
	str1	- not used
	str2	- not used

Returns:

CSCF_RETURN_TRUE if in processing or CSCF_RETURN_FALSE if not

Definition at line 842 of file mod.c.

References CSCF_RETURN_FALSE, and CSCF_RETURN_TRUE.

{
    unsigned int hash, label;
    if (tmb.t_get_trans_ident(msg,&hash,&label)<0)
        return CSCF_RETURN_FALSE;
    return CSCF_RETURN_TRUE;    
}

---

Variable Documentation

char* scscf_name = "sip:scscf.open-ims.test:6060"

name of the S-CSCF

Definition at line 89 of file mod.c.

Referenced by bin_cache_dump_auth_to_table(), bin_cache_load_auth_from_table(), I_get_capabilities(), I_scscf_select(), icscf_db_get_scscf(), and mod_init().

char* scscf_forced_hss_peer = ""

FQDN of the Forced Diameter Peer (HSS).

Definition at line 91 of file mod.c.

Referenced by mod_init().

char* scscf_user_data_dtd = 0

Definition at line 93 of file mod.c.

Referenced by mod_child_init(), and parse_user_data().

char* scscf_user_data_xsd = 0

Definition at line 94 of file mod.c.

Referenced by mod_child_init(), and parse_user_data().

int auth_data_hash_size = 1024

authentication vector hash table size

Definition at line 96 of file mod.c.

Referenced by bin_cache_dump_auth_to_table(), make_snapshot_authdata(), and mod_init().

int auth_vector_timeout = 60

timeout for a sent auth vector to expire in sec

Definition at line 97 of file mod.c.

Referenced by start_reg_await_timer().