dlg_state.h

Go to the documentation of this file.

#ifndef P_CSCF_DLG_STATE_H
#define P_CSCF_DLG_STATE_H

#include "../../sr_module.h"
#include "mod.h"
#include "../../locking.h"
#include "../tm/dlg.h"
#include "../tm/tm_load.h"

enum p_dialog_method {
    DLG_METHOD_OTHER=0,
    DLG_METHOD_INVITE=1,
    DLG_METHOD_SUBSCRIBE=2  
};

#define DLG_METHOD_MAX DLG_METHOD_SUBSCRIBE

enum p_dialog_state {
    DLG_STATE_UNKNOWN=0,
    DLG_STATE_INITIAL=1,
    DLG_STATE_EARLY=2,
    DLG_STATE_CONFIRMED=3,
    DLG_STATE_TERMINATED_ONE_SIDE=4,
    DLG_STATE_TERMINATED=5  
};

enum p_dialog_direction {
    DLG_MOBILE_ORIGINATING=0,
    DLG_MOBILE_TERMINATING=1,
    DLG_MOBILE_UNKNOWN=2
};

typedef struct _p_dialog {
    unsigned int hash;
    str call_id;
    enum p_dialog_direction direction; /*Needed to locate dialogs easier in release_call*/
    
    str host;                   
    unsigned short port;                    
    char transport;             
    str *routes;
    unsigned short routes_cnt;
    
    enum p_dialog_method method;
    str method_str;
    int first_cseq;
    int last_cseq;
    enum p_dialog_state state;
    time_t expires;
    time_t lr_session_expires;          
    str refresher;                      
    unsigned char uac_supp_timer;       
    unsigned char is_releasing;         
    dlg_t *dialog_s;  /* dialog as UAS*/
    dlg_t *dialog_c;  /* dialog as UAC*/
            
    struct _p_dialog *next,*prev;   
} p_dialog;

typedef struct {
    p_dialog *head,*tail;
    gen_lock_t *lock;               
} p_dialog_hash_slot;


inline unsigned int get_p_dialog_hash(str call_id);

int p_dialogs_init(int hash_size);

void p_dialogs_destroy();

inline void d_lock(unsigned int hash);
inline void d_unlock(unsigned int hash);


p_dialog* new_p_dialog(str call_id,str host,int port, int transport);
p_dialog* add_p_dialog(str call_id,str host,int port, int transport);
int is_p_dialog(str call_id,str host,int port, int transport,enum p_dialog_direction *dir);
int is_p_dialog_dir(str call_id,enum p_dialog_direction dir);
p_dialog* get_p_dialog(str call_id,str host,int port, int transport,enum p_dialog_direction *dir);
p_dialog* get_p_dialog_dir(str call_id,enum p_dialog_direction dir);
p_dialog* get_p_dialog_dir_nolock(str call_id,enum p_dialog_direction dir);
int terminate_p_dialog(p_dialog *d);
void del_p_dialog(p_dialog *d);
void free_p_dialog(p_dialog *d);
void print_p_dialogs(int log_level);
        


int P_is_in_dialog(struct sip_msg* msg, char* str1, char* str2);

int P_save_dialog(struct sip_msg* msg, char* str1, char* str2);

int P_update_dialog(struct sip_msg* msg, char* str1, char* str2);

int P_drop_dialog(struct sip_msg* msg, char* str1, char* str2);

int P_drop_all_dialogs(str host,int port, int transport);

int P_follows_dialog_routes(struct sip_msg *msg,char *str1,char *str2);

int P_enforce_dialog_routes(struct sip_msg *msg,char *str1,char*str2);

int P_record_route(struct sip_msg *msg,char *str1,char *str2);

int P_check_session_expires(struct sip_msg* msg, char* str1, char* str2);

int P_422_session_expires(struct sip_msg* msg, char* str1, char* str2);

void dialog_timer(unsigned int ticks, void* param);
        
#endif

---