dlg_state.c File Reference

---

Detailed Description

Serving-CSCF - Dialog State Operations.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Alberto Diez - Changes to handle release_call

Definition in file dlg_state.c.

#include <time.h>
#include "dlg_state.h"
#include "../tm/tm_load.h"
#include "../sl/sl_funcs.h"
#include "../../mem/shm_mem.h"
#include "../../parser/parse_rr.h"
#include "sip.h"
#include "release_call.h"
#include "ims_pm.h"

Go to the source code of this file.

Defines
#define	strtotime(src, dest)
#define	FParam_INT(val)
#define	FParam_STRING(val)
#define	h_inc   h+=v^(v>>3)
Functions
int	supports_extension (struct sip_msg *m, str *extension)
int	requires_extension (struct sip_msg *m, str *extension)
unsigned int	get_s_dialog_hash (str call_id)
	Computes the hash for a string.
int	s_dialogs_init (int hash_size)
	Initialize the S-CSCF dialogs registrar.
void	s_dialogs_destroy ()
	Destroy the registrar.
void	d_lock (unsigned int hash)
	Locks the required part of the hash table.
void	d_unlock (unsigned int hash)
	UnLocks the required part of the hash table.
int	d_act_time ()
	Refresh the current dialog time.
void	s_dialog_count_lock ()
	Locks the dialog counter variable.
void	s_dialog_count_unlock ()
	UnLocks the dialog counter variable.
int	s_dialog_count_increment ()
	Try to increment the dialog count.
void	s_dialog_count_decrement ()
	Decrement the dialog count.
s_dialog *	new_s_dialog (str call_id, str aor, enum s_dialog_direction dir)
	Creates a new s_dialog structure.
s_dialog *	add_s_dialog (str call_id, str aor, enum s_dialog_direction dir)
	Creates and adds a dialog to the hash table.
int	is_s_dialog (str call_id, str aor, enum s_dialog_direction dir)
	Finds out if a dialog is in the hash table.
int	is_s_dialog_dir (str call_id, enum s_dialog_direction dir)
	Finds out if a dialog is in the hash table.
s_dialog *	get_s_dialog (str call_id, str aor)
	Finds and returns a dialog from the hash table.
s_dialog *	get_s_dialog_dir (str call_id, enum s_dialog_direction dir)
	Finds and returns a dialog from the hash table.
s_dialog *	get_s_dialog_dir_nolock (str call_id, enum s_dialog_direction dir)
	Finds and returns a dialog from the hash table.
int	terminate_s_dialog (s_dialog *d)
	Terminates a dialog - called before del_s_dialog to send out terminatination messages.
void	del_s_dialog (s_dialog *d)
	Deletes a dialog from the hash table.
void	free_s_dialog (s_dialog *d)
	Frees a dialog.
void	print_s_dialogs (int log_level)
	Prints the list of dialogs.
enum s_dialog_direction	get_dialog_direction (char *direction)
	Returns the s_dialog_direction from the direction string.
static int	find_dialog_aor (struct sip_msg *msg, enum s_dialog_direction d, str *aor)
	Finds the AOR for a dialog.
static enum s_dialog_direction	find_dialog_route_dir (struct sip_msg *msg)
	Find the dialog direction from the first Route header.
int	S_is_in_dialog (struct sip_msg *msg, char *str1, char *str2)
	Find out if a message is within a saved dialog.
static enum s_dialog_method	get_dialog_method (str method)
	Return s_dialog_method for a method string.
int	S_422_session_expires (struct sip_msg *msg, char *str1, char *str2)
	Send a 422 Session Interval Too Small.
int	S_check_session_expires (struct sip_msg *msg, char *str1, char *str2)
	Checks if Session-Expires value is over Min_SE local policy.
int	S_save_dialog (struct sip_msg *msg, char *str1, char *str2)
	Saves a dialog.
int	update_dialog_on_reply (struct sip_msg *msg, s_dialog *d)
	Updates dialog on reply message.
int	S_update_dialog (struct sip_msg *msg, char *str1, char *str2)
	Updates a dialog.
int	S_drop_dialog (struct sip_msg *msg, char *str1, char *str2)
	Drops and deletes a dialog.
int	S_drop_all_dialogs (str aor)
	Drop all dialogs belonging to one AOR.
int	S_record_route (struct sip_msg *msg, char *str1, char *str2)
	Record routes, with given user as parameter.
int	S_is_record_routed (struct sip_msg *msg, char *str1, char *str2)
	Check if we already did record-route.
void	dialog_timer (unsigned int ticks, void *param)
	The dialog timer looks for expired dialogs and removes them.
Variables
tm_binds	tmb
	Structure with pointers to tm funcs.
int	s_dialogs_hash_size
	size of the dialog hash table
s_dialog_hash_slot *	s_dialogs = 0
	the hash table
int	scscf_dialogs_expiration_time
	default expiration time for dialogs
int	scscf_dialogs_enable_release
	if to enable dialog release
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
time_t	d_time_now
	dialogs current time
int	scscf_min_se
	Minimum session-expires accepted value.
int(*)	sl_reply (struct sip_msg *_msg, char *_str1, char *_str2)
	link to the stateless reply function in sl module
int *	scscf_dialog_count
	Counter for saved dialogs.
int	scscf_max_dialog_count
	Maximum number of dialogs.
gen_lock_t *	scscf_dialog_count_lock
	Lock for the dialog counter.
static str	Reason = {"Reason: SIP ;cause=503 ;text=\"Session Time-out on S-CSCF\"\r\n",59}
str	s_OTHER = {"<OTHER>",7}
str	s_INVITE = {"INVITE",6}
str	s_SUBSCRIBE = {"SUBSCRIBE",9}
static fparam_t	fp_422 = FParam_INT(422)
static fparam_t	fp_se_small = FParam_STRING("Session Interval Too Small")
static str	s_refresher = {"refresher=", 10}
static str	str_ext_timer = {"timer", 5}
static str	str_min_se = {"Min-SE:",7}
static str	str_se = {"Session-Expires:",16}
static str	str_require = {"Require:",8}
static str	s_record_route_s = {"Record-Route: <",15}
static str	s_record_route_e = {";lr>\r\n",6}

---

Define Documentation

#define strtotime	(	src,
		dest		)

Value:

{\
    int i;\
    (dest)=0;\
    for(i=0;i<(src).len;i++)\
        if ((src).s[i]>='0' && (src).s[i]<='9')\
            (dest) = (dest)*10 + (src).s[i] -'0';\
}

Definition at line 90 of file dlg_state.c.

#define FParam_INT

(

val

)

Value:

{ \
     .v = { \
        .i = val \
     },\
    .type = FPARAM_INT, \
    .orig = "int_value", \
};

Definition at line 99 of file dlg_state.c.

#define FParam_STRING

(

val

)

Value:

{ \
    .v = { \
        .str = STR_STATIC_INIT(val) \
    },\
    .type = FPARAM_STR, \
    .orig = val, \
};

Definition at line 107 of file dlg_state.c.

#define h_inc   h+=v^(v>>3)

---

Function Documentation

int supports_extension	(	struct sip_msg *	m,
		str *	extension
	)

int requires_extension	(	struct sip_msg *	m,
		str *	extension
	)

unsigned int get_s_dialog_hash

(

str

call_id

)

[inline]

Computes the hash for a string.

Parameters:

call_id

- the string to compute for

Returns:

the hash % scscf_dialogs_hash_size

Definition at line 121 of file dlg_state.c.

References h_inc, and s_dialogs_hash_size.

Referenced by bin_decode_s_dialog(), get_s_dialog(), get_s_dialog_dir(), get_s_dialog_dir_nolock(), is_s_dialog(), is_s_dialog_dir(), and new_s_dialog().

{
    if (call_id.len==0) return 0;
#define h_inc h+=v^(v>>3)
    char* p;
    register unsigned v;
    register unsigned h;
    
    h=0;
    for (p=call_id.s; p<=(call_id.s+call_id.len-4); p+=4){
        v=(*p<<24)+(p[1]<<16)+(p[2]<<8)+p[3];
        h_inc;
    }
    v=0;
    for (;p<(call_id.s+call_id.len); p++) {
        v<<=8;
        v+=*p;
    }
    h_inc;
    
    h=((h)+(h>>11))+((h>>13)+(h>>23));
    return (h)%s_dialogs_hash_size;
#undef h_inc 
}

int s_dialogs_init

(

int

hash_size

)

Initialize the S-CSCF dialogs registrar.

Parameters:

hash_size

- size of the dialog hash table

Returns:

1 if OK, 0 on error

Definition at line 151 of file dlg_state.c.

References s_dialog_hash_slot::lock, M_NAME, s_dialogs, and s_dialogs_hash_size.

Referenced by mod_init().

{
    int i;
    
    s_dialogs_hash_size = hash_size;
    s_dialogs = shm_malloc(sizeof(s_dialog_hash_slot)*s_dialogs_hash_size);

    if (!s_dialogs) return 0;

    memset(s_dialogs,0,sizeof(s_dialog_hash_slot)*s_dialogs_hash_size);
    
    for(i=0;i<s_dialogs_hash_size;i++){
        s_dialogs[i].lock = lock_alloc();
        if (!s_dialogs[i].lock){
            LOG(L_ERR,"ERR:"M_NAME":d_hash_table_init(): Error creating lock\n");
            return 0;
        }
        s_dialogs[i].lock = lock_init(s_dialogs[i].lock);
    }
            
    return 1;
}

void s_dialogs_destroy

(

)

Destroy the registrar.

Definition at line 177 of file dlg_state.c.

References d_lock(), d_unlock(), free_s_dialog(), s_dialog_hash_slot::head, _s_dialog::next, s_dialogs, and s_dialogs_hash_size.

Referenced by mod_destroy().

{
    int i;
    s_dialog *d,*nd;
    for(i=0;i<s_dialogs_hash_size;i++){
        d_lock(i);
            d = s_dialogs[i].head;
            while(d){
                nd = d->next;
                free_s_dialog(d);
                d = nd;
            }
        d_unlock(i);
        lock_dealloc(s_dialogs[i].lock);
    }
    shm_free(s_dialogs);
}

void d_lock

(

unsigned int

hash

)

[inline]

Locks the required part of the hash table.

Parameters:

hash

- index of the slot to lock

Definition at line 199 of file dlg_state.c.

References p_dialogs, and s_dialogs.

{
//  LOG(L_CRIT,"GET %d\n",hash);
    lock_get(s_dialogs[(hash)].lock);
//  LOG(L_CRIT,"GOT %d\n",hash);    
}

void d_unlock

(

unsigned int

hash

)

[inline]

UnLocks the required part of the hash table.

Parameters:

hash

- index of the slot to unlock

Definition at line 210 of file dlg_state.c.

References p_dialogs, and s_dialogs.

{
    lock_release(s_dialogs[(hash)].lock);
//  LOG(L_CRIT,"RELEASED %d\n",hash);   
}

int d_act_time

(

)

[inline]

Refresh the current dialog time.

Returns:

the current time

Definition at line 220 of file dlg_state.c.

References d_time_now.

{
    d_time_now=time(0);
    return d_time_now;
}

void s_dialog_count_lock

(

)

[inline]

Locks the dialog counter variable.

Definition at line 233 of file dlg_state.c.

References scscf_dialog_count_lock.

Referenced by s_dialog_count_decrement(), and s_dialog_count_increment().

{
    lock_get(scscf_dialog_count_lock);
}

void s_dialog_count_unlock

(

)

[inline]

UnLocks the dialog counter variable.

Definition at line 241 of file dlg_state.c.

References scscf_dialog_count_lock.

Referenced by s_dialog_count_decrement(), and s_dialog_count_increment().

{
        lock_release(scscf_dialog_count_lock);
}

int s_dialog_count_increment

(

)

[inline]

Try to increment the dialog count.

Returns:

1 on success or 0 if the total number of dialogs is already reached

Definition at line 251 of file dlg_state.c.

References M_NAME, s_dialog_count_lock(), s_dialog_count_unlock(), scscf_dialog_count, and scscf_max_dialog_count.

Referenced by new_s_dialog().

{
    if (scscf_max_dialog_count<0) return 1;
    s_dialog_count_lock();  
    if (*scscf_dialog_count<scscf_max_dialog_count){
        (*scscf_dialog_count)++;
        s_dialog_count_unlock();
        return 1;
    } else {
        s_dialog_count_unlock();
        return 0;
    }
    LOG(L_DBG,"DBG:"M_NAME":s_dialog_count_increment(): P-CSCF Dialog counter value is %d\n", *scscf_dialog_count);
}

void s_dialog_count_decrement

(

)

[inline]

Decrement the dialog count.

Definition at line 269 of file dlg_state.c.

References M_NAME, s_dialog_count_lock(), s_dialog_count_unlock(), scscf_dialog_count, and scscf_max_dialog_count.

Referenced by free_s_dialog(), and new_s_dialog().

{
    if (scscf_max_dialog_count<0) return ;
    s_dialog_count_lock();
    (*scscf_dialog_count)--;
    s_dialog_count_unlock();
    LOG(L_DBG,"DBG:"M_NAME":s_dialog_count_decrement(): P-CSCF Dialog counter value is %d\n", *scscf_dialog_count);    
}

s_dialog* new_s_dialog	(	str	call_id,
		str	aor,
		enum s_dialog_direction	dir
	)

Creates a new s_dialog structure.

Does not add the structure to the list

Parameters:

	call_id	- call_id of the dialog
	aor	- aor of the user
	dir	- the direction

Returns:

the new s_dialog* or NULL s_dialog

Definition at line 287 of file dlg_state.c.

References _s_dialog::aor, _s_dialog::call_id, _s_dialog::direction, get_s_dialog_hash(), _s_dialog::hash, _s_dialog::is_releasing, M_NAME, s_dialog_count_decrement(), s_dialog_count_increment(), and STR_SHM_DUP.

Referenced by add_s_dialog().

{
    s_dialog *d;
    
    if (!s_dialog_count_increment()) return 0;
    d = shm_malloc(sizeof(s_dialog));
    if (!d) {
        LOG(L_ERR,"ERR:"M_NAME":new_s_dialog(): Unable to alloc %d bytes\n",
            sizeof(s_dialog));
        goto error;
    }
    memset(d,0,sizeof(s_dialog));
    
    d->hash = get_s_dialog_hash(call_id);       
    STR_SHM_DUP(d->call_id,call_id,"shm");
    STR_SHM_DUP(d->aor,aor,"shm");  
    d->direction = dir;
    d->is_releasing = 0;
    return d;
error:
out_of_memory:
    if (d){
        shm_free(d);        
    }
    s_dialog_count_decrement();
    return 0;
}

s_dialog* add_s_dialog	(	str	call_id,
		str	aor,
		enum s_dialog_direction	dir
	)

Creates and adds a dialog to the hash table.

Note:

Locks the hash slot if OK! Call d_unlock(s_dialog->hash) when you are finished)

make sure that is_s_dialog(call_id) returns 0 or there will be unreachable duplicates!

Parameters:

	call_id	- call_id of the dialog
	aor	- aor of the user
	dir	- the direction

Returns:

the new s_dialog* or NULL s_dialog

Definition at line 324 of file dlg_state.c.

References d_lock(), _s_dialog::hash, s_dialog_hash_slot::head, new_s_dialog(), _s_dialog::next, _s_dialog::prev, s_dialogs, and s_dialog_hash_slot::tail.

Referenced by S_save_dialog().

{
    s_dialog *d;
    
    d = new_s_dialog(call_id,aor,dir);
    if (!d) return 0;       
    
    d_lock(d->hash);
        d->next = 0;
        d->prev = s_dialogs[d->hash].tail;
        if (d->prev) d->prev->next = d;
        s_dialogs[d->hash].tail = d;
        if (!s_dialogs[d->hash].head) s_dialogs[d->hash].head = d;

        return d;
}

int is_s_dialog	(	str	call_id,
		str	aor,
		enum s_dialog_direction	dir
	)

Finds out if a dialog is in the hash table.

Parameters:

	call_id	- call_id of the dialog
	aor	- aor of the user

Returns:

1 if found, 0 if not found

Definition at line 347 of file dlg_state.c.

References _s_dialog::aor, _s_dialog::call_id, d_lock(), d_unlock(), _s_dialog::direction, get_s_dialog_hash(), s_dialog_hash_slot::head, _s_dialog::next, and s_dialogs.

Referenced by S_save_dialog().

{
    s_dialog *d=0;
    unsigned int hash = get_s_dialog_hash(call_id);

    d_lock(hash);
        d = s_dialogs[hash].head;
        while(d){
                if (d->direction == dir &&
                    d->aor.len == aor.len &&
                    d->call_id.len == call_id.len &&
                    strncasecmp(d->aor.s,aor.s,aor.len)==0 &&
                    strncasecmp(d->call_id.s,call_id.s,call_id.len)==0) {
                    d_unlock(hash);
                    return 1;
                }
            d = d->next;
        }
    d_unlock(hash);
    return 0;
}

int is_s_dialog_dir	(	str	call_id,
		enum s_dialog_direction	dir
	)

Finds out if a dialog is in the hash table.

Parameters:

	call_id	- call_id of the dialog
	dir	- the direction

Returns:

1 if found, 0 if not found

Definition at line 375 of file dlg_state.c.

References _s_dialog::call_id, d_lock(), d_unlock(), _s_dialog::direction, get_s_dialog_hash(), s_dialog_hash_slot::head, _s_dialog::next, and s_dialogs.

Referenced by S_is_in_dialog().

{
    s_dialog *d=0;
    unsigned int hash = get_s_dialog_hash(call_id);

    d_lock(hash);
        d = s_dialogs[hash].head;
        while(d){
                if (d->direction == dir &&
                d->call_id.len == call_id.len &&
                strncasecmp(d->call_id.s,call_id.s,call_id.len)==0) {
                    d_unlock(hash);
                    return 1;
                }
            d = d->next;
        }
    d_unlock(hash);
    return 0;
}

s_dialog* get_s_dialog	(	str	call_id,
		str	aor
	)

Finds and returns a dialog from the hash table.

Note:

Locks the hash slot if ok! Call d_unlock(s_dialog->hash) when you are finished)

Parameters:

	call_id	- call_id of the dialog
	aor	- aor of the user

Returns:

the s_dialog* or NULL if not found

Definition at line 402 of file dlg_state.c.

References _s_dialog::aor, _s_dialog::call_id, d_lock(), d_unlock(), get_s_dialog_hash(), s_dialog_hash_slot::head, _s_dialog::next, and s_dialogs.

{
    s_dialog *d=0;
    unsigned int hash = get_s_dialog_hash(call_id);

    d_lock(hash);
        d = s_dialogs[hash].head;
        while(d){
            if (d->aor.len == aor.len &&
                d->call_id.len == call_id.len &&
                strncasecmp(d->aor.s,aor.s,aor.len)==0 &&
                strncasecmp(d->call_id.s,call_id.s,call_id.len)==0) {
                    return d;
                }
            d = d->next;
        }
    d_unlock(hash);
    return 0;
}

s_dialog* get_s_dialog_dir	(	str	call_id,
		enum s_dialog_direction	dir
	)

Finds and returns a dialog from the hash table.

Note:

Locks the hash slot if ok! Call d_unlock(s_dialog->hash) when you are finished)

Parameters:

	call_id	- call_id of the dialog
	dir	- the direction

Returns:

the s_dialog* or NULL if not found

Definition at line 429 of file dlg_state.c.

References _s_dialog::call_id, d_lock(), d_unlock(), _s_dialog::direction, get_s_dialog_hash(), s_dialog_hash_slot::head, _s_dialog::next, and s_dialogs.

Referenced by confirmed_response(), release_call(), S_drop_dialog(), and S_update_dialog().

{
    s_dialog *d=0;
    unsigned int hash = get_s_dialog_hash(call_id);

    d_lock(hash);
        d = s_dialogs[hash].head;
        while(d){
            if (d->direction == dir &&
                d->call_id.len == call_id.len &&
                strncasecmp(d->call_id.s,call_id.s,call_id.len)==0) {
                    return d;
                }
            d = d->next;
        }
    d_unlock(hash);
    return 0;
}

s_dialog* get_s_dialog_dir_nolock	(	str	call_id,
		enum s_dialog_direction	dir
	)

Finds and returns a dialog from the hash table.

Note:

the table should be locked already for the call_id in the parameter

Parameters:

	call_id	- call_id of the dialog
	dir	- the direction

Returns:

the s_dialog* or NULL if not found

Definition at line 455 of file dlg_state.c.

References _s_dialog::call_id, _s_dialog::direction, get_s_dialog_hash(), s_dialog_hash_slot::head, _s_dialog::next, and s_dialogs.

Referenced by release_call_s().

{
    s_dialog *d=0;
    unsigned int hash = get_s_dialog_hash(call_id);

    d = s_dialogs[hash].head;
    while(d){
        if (d->direction == dir &&
            d->call_id.len == call_id.len &&
            strncasecmp(d->call_id.s,call_id.s,call_id.len)==0) {
                return d;
            }
        d = d->next;
    }
    return 0;
}

int terminate_s_dialog

(

s_dialog *

d

)

Terminates a dialog - called before del_s_dialog to send out terminatination messages.

Parameters:

d

- the dialog to terminate

Returns:

- 1 if the requests were sent and the dialog will be deleted, 0 on error (you will have to delete the dialog yourself!)

Definition at line 479 of file dlg_state.c.

References del_s_dialog(), DLG_METHOD_INVITE, DLG_METHOD_SUBSCRIBE, M_NAME, _s_dialog::method, Reason, release_call_s(), release_subscription(), and scscf_dialogs_enable_release.

Referenced by dialog_timer(), and S_drop_all_dialogs().

{
    if (!scscf_dialogs_enable_release) return 0;    
    switch (d->method){
        case DLG_METHOD_INVITE:
            if (release_call_s(d,Reason)<=0){
                //dialog has expired and not confirmed
                // or error releasing dialog
                del_s_dialog(d);
            }
            return 1;
            break;
        case DLG_METHOD_SUBSCRIBE:
            if (!release_subscription(d)){
                //error releasing the subscription - just drop silently
                del_s_dialog(d);
            }
            return 1;
            break;
        default:
            LOG(L_ERR,"ERR:"M_NAME":terminate_s_dialog(): Not implemented yet for method[%d]!\n",d->method);
            return 0;
    }
}

void del_s_dialog

(

s_dialog *

d

)

Deletes a dialog from the hash table.

Note:

Must be called with a lock on the dialogs slot

Parameters:

d

- the dialog to delete

Definition at line 509 of file dlg_state.c.

References _s_dialog::call_id, _s_dialog::direction, free_s_dialog(), _s_dialog::hash, s_dialog_hash_slot::head, M_NAME, _s_dialog::next, _s_dialog::prev, s_dialogs, and s_dialog_hash_slot::tail.

Referenced by confirmed_response(), dialog_timer(), release_subscription(), S_drop_all_dialogs(), S_drop_dialog(), S_save_dialog(), and terminate_s_dialog().

{
    LOG(L_INFO,"DBG:"M_NAME":del_s_dialog(): Deleting dialog <%.*s> DIR[%d]\n",d->call_id.len,d->call_id.s,d->direction);
    if (d->prev) d->prev->next = d->next;
    else s_dialogs[d->hash].head = d->next;
    if (d->next) d->next->prev = d->prev;
    else s_dialogs[d->hash].tail = d->prev;
    free_s_dialog(d);
}

void free_s_dialog

(

s_dialog *

d

)

Frees a dialog.

Parameters:

d

- the dialog to delete

Definition at line 524 of file dlg_state.c.

References _s_dialog::aor, _s_dialog::call_id, _s_dialog::dialog_c, _s_dialog::dialog_s, _s_dialog::event, _s_dialog::method_str, _s_dialog::refresher, s_dialog_count_decrement(), and tmb.

Referenced by del_s_dialog(), and s_dialogs_destroy().

{
    if (!d) return;
    if (d->call_id.s) shm_free(d->call_id.s);
    if (d->aor.s) shm_free(d->aor.s);   
    if (d->method_str.s) shm_free(d->method_str.s);
    if (d->dialog_s) tmb.free_dlg(d->dialog_s);
    if (d->dialog_c) tmb.free_dlg(d->dialog_c);
    if (d->refresher.s) shm_free(d->refresher.s);       
    if (d->event.s) shm_free(d->event.s);       
    shm_free(d);
    s_dialog_count_decrement();     
}

void print_s_dialogs

(

int

log_level

)

Prints the list of dialogs.

Parameters:

log_level

- level to log at

Definition at line 542 of file dlg_state.c.

References ANSI_BLUE, ANSI_GREEN, ANSI_MAGENTA, ANSI_RED, _s_dialog::aor, _s_dialog::call_id, d_act_time(), d_lock(), d_time_now, d_unlock(), _s_dialog::direction, _s_dialog::event, _s_dialog::expires, s_dialog_hash_slot::head, M_NAME, _s_dialog::method, _s_dialog::next, _s_dialog::refresher, s_dialogs, s_dialogs_hash_size, and _s_dialog::state.

Referenced by S_drop_dialog(), S_save_dialog(), and S_update_dialog().

{
    s_dialog *d;
    int i;
    if (debug<log_level) return; /* to avoid useless calls when nothing will be printed */
    d_act_time();
    LOG(log_level,"INF:"M_NAME":----------  S-CSCF Dialog List begin --------------\n");
    for(i=0;i<s_dialogs_hash_size;i++){
        d_lock(i);
            d = s_dialogs[i].head;
            while(d){
                LOG(log_level,"INF:"M_NAME":[%4d] Dir["ANSI_MAGENTA"%d"ANSI_GREEN
                    "] Call-ID:<"ANSI_BLUE"%.*s"ANSI_GREEN
                    "> AOR:<"ANSI_RED"%.*s"ANSI_GREEN
                    ">\n",i,                
                    d->direction,
                    d->call_id.len,d->call_id.s,
                    d->aor.len,d->aor.s);
                LOG(log_level,"INF:"M_NAME":\t\tMethod:["ANSI_MAGENTA"%d"ANSI_GREEN
                    "] State:["ANSI_MAGENTA"%d"ANSI_GREEN
                    "] Exp:["ANSI_MAGENTA"%4d"ANSI_GREEN"] Ref:["ANSI_MAGENTA"%.*s"ANSI_GREEN"] Event:["ANSI_MAGENTA"%.*s"ANSI_GREEN"]\n",              
                    d->method,
                    d->state,
                    (int)(d->expires - d_time_now),
                    d->refresher.len,d->refresher.s,
                    d->event.len,d->event.s);
                    
                d = d->next;
            }       
        d_unlock(i);
    }
    LOG(log_level,"INF:"M_NAME":----------  S-CSCF Dialog List end   --------------\n");    
}

enum s_dialog_direction get_dialog_direction

(

char *

direction

)

Returns the s_dialog_direction from the direction string.

Parameters:

direction

- "orig" or "term"

Returns:

the s_dialog_direction if ok or DLG_MOBILE_UNKNOWN if not found

Definition at line 583 of file dlg_state.c.

References DLG_MOBILE_ORIGINATING, DLG_MOBILE_TERMINATING, DLG_MOBILE_UNKNOWN, and M_NAME.

{
    switch(direction[0]){
        case 'o':
        case 'O':
        case '0':
            return DLG_MOBILE_ORIGINATING;
        case 't':
        case 'T':
        case '1':
            return DLG_MOBILE_TERMINATING;
        default:
            LOG(L_CRIT,"ERR:"M_NAME":get_dialog_direction(): Unknown direction %s",direction);