modules_k/dispatcher/dispatch.h

Go to the documentation of this file.

#ifndef _DISPATCH_H_
#define _DISPATCH_H_

#include <stdio.h>
#include "../../pvar.h"
#include "../../parser/msg_parser.h"
#include "../../modules/tm/tm_load.h"


#define DS_HASH_USER_ONLY       1  
#define DS_FAILOVER_ON          2  
#define DS_INACTIVE_DST         1  
#define DS_TRYING_DST           2  
#define DS_DISABLED_DST         4  
#define DS_PROBING_DST          8  
#define DS_STATES_ALL           15  
#define ds_skip_dst(flags)      ((flags) & (DS_INACTIVE_DST|DS_DISABLED_DST))

#define DS_PROBE_NONE           0
#define DS_PROBE_ALL            1
#define DS_PROBE_INACTIVE       2

extern str ds_db_url;
extern str ds_table_name;
extern str ds_set_id_col;
extern str ds_dest_uri_col;
extern str ds_dest_flags_col;
extern str ds_dest_priority_col;
extern str ds_dest_attrs_col;

extern int ds_flags; 
extern int ds_use_default;

extern int_str dst_avp_name;
extern unsigned short dst_avp_type;
extern int_str grp_avp_name;
extern unsigned short grp_avp_type;
extern int_str cnt_avp_name;
extern unsigned short cnt_avp_type;
extern int_str dstid_avp_name;
extern unsigned short dstid_avp_type;
extern int_str attrs_avp_name;
extern unsigned short attrs_avp_type;

extern pv_elem_t * hash_param_model;

extern str ds_setid_pvname;
extern pv_spec_t ds_setid_pv;

/* Structure containing pointers to TM-functions */
extern struct tm_binds tmb;
extern str ds_ping_method;
extern str ds_ping_from;
extern int probing_threshhold; 
extern int ds_probing_mode;
extern str ds_outbound_proxy;

int init_data(void);
int init_ds_db(void);
int ds_load_list(char *lfile);
int ds_connect_db(void);
void ds_disconnect_db(void);
int ds_load_db(void);
int ds_destroy_list(void);
int ds_select_dst(struct sip_msg *msg, int set, int alg, int mode);
int ds_next_dst(struct sip_msg *msg, int mode);
int ds_update_state(sip_msg_t *msg, int group, str *address, int state);
int ds_reinit_state(int group, str *address, int state);
int ds_mark_dst(struct sip_msg *msg, int mode);
int ds_print_list(FILE *fout);
int ds_print_mi_list(struct mi_node* rpl);
int ds_print_sets(void);

int ds_load_unset(struct sip_msg *msg);
int ds_load_update(struct sip_msg *msg);

int ds_hash_load_init(unsigned int htsize, int expire, int initexpire);
int ds_hash_load_destroy(void);

int ds_is_from_list(struct sip_msg *_m, int group);
void ds_check_timer(unsigned int ticks, void* param);


void ds_ht_timer(unsigned int ticks, void *param);

int ds_ping_check_rplcode(int);

typedef struct _ds_attrs
{
        str body;
        str duid;
        int maxload;
        int weight;
} ds_attrs_t;

typedef struct _ds_dest
{
        str uri;
        int flags;
        int priority;
        int dload;
        ds_attrs_t attrs;
        struct ip_addr ip_address;      
        unsigned short int port;        
        int failure_count;
        struct _ds_dest *next;
} ds_dest_t;

typedef struct _ds_set
{
        int id;                         
        int nr;                         
        int last;                       
        int wlast;                      
        ds_dest_t *dlist;
        unsigned int wlist[100];
        struct _ds_set *next;
} ds_set_t;

ds_set_t *ds_get_list(void);
int ds_get_list_nr(void);
#endif