forked from sipwise/mediator
-
Notifications
You must be signed in to change notification settings - Fork 0
/
mediator.h
154 lines (124 loc) · 4.45 KB
/
mediator.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
#ifndef _MEDIATOR_H
#define _MEDIATOR_H
#include <stdint.h>
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <errno.h>
#include <syslog.h>
#include <unistd.h>
#include <stdlib.h>
#include <glib.h>
#include <inttypes.h>
#define MEDIATOR_DEFAULT_INTERVAL 10
#define MEDIATOR_SYSLOG_NAME "mediator"
#define MEDIATOR_LOCK_FILE "/run/lock/mediator.lock"
#define MEDIATOR_DEFAULT_CONFIG_FILE "/etc/ngcp-mediator/ngcp-mediator.conf"
#define MEDIATOR_DEFAULT_DAEMONIZE 0
#define MEDIATOR_DEFAULT_DUMPCDR 0
#define MEDIATOR_DEFAULT_PIDPATH "/run/mediator.pid"
#define MEDIATOR_DEFAULT_ACCHOST "localhost"
#define MEDIATOR_DEFAULT_ACCUSER "mediator"
#define MEDIATOR_DEFAULT_ACCPASS "GimmeAllUr$$$"
#define MEDIATOR_DEFAULT_ACCDB "accounting"
#define MEDIATOR_DEFAULT_ACCPORT 0
#define MEDIATOR_DEFAULT_CDRHOST "localhost"
#define MEDIATOR_DEFAULT_CDRUSER "mediator"
#define MEDIATOR_DEFAULT_CDRPASS "GimmeAllUr$$$"
#define MEDIATOR_DEFAULT_CDRDB "accounting"
#define MEDIATOR_DEFAULT_CDRPORT 0
#define MEDIATOR_DEFAULT_PROVHOST "localhost"
#define MEDIATOR_DEFAULT_PROVUSER "mediator"
#define MEDIATOR_DEFAULT_PROVPASS "GimmeAllUr$$$"
#define MEDIATOR_DEFAULT_PROVDB "provisioning"
#define MEDIATOR_DEFAULT_PROVPORT 0
#define MEDIATOR_DEFAULT_STATSHOST "localhost"
#define MEDIATOR_DEFAULT_STATSUSER "mediator"
#define MEDIATOR_DEFAULT_STATSPASS "GimmeAllUr$$$"
#define MEDIATOR_DEFAULT_STATSDB "stats"
#define MEDIATOR_DEFAULT_STATSPORT 0
#define MEDIATOR_DEFAULT_STATSPERIOD MED_STATS_HOUR
#define MEDIATOR_DEFAULT_REDISHOST "localhost"
#define MEDIATOR_DEFAULT_REDISPORT 6379
#define MEDIATOR_DEFAULT_REDISDB 21
#define MEDIATOR_DEFAULT_LOGLEVEL MED_LOG_INFO
#define MED_GW_STRING "gw"
#define MED_AS_STRING "as"
#define MED_PEER_STRING "peer"
#define MED_MIN_BASELEN 6
#define MED_SEP '|'
#define PBXSUFFIX "_pbx-1"
#define XFERSUFFIX "_xfer-1"
extern int mediator_lockfd;
extern sig_atomic_t mediator_shutdown;
typedef enum {
MED_INVITE = 1,
MED_BYE = 2,
MED_UNRECOGNIZED = 3
} med_method_t;
typedef struct {
char src_leg[1024];
char dst_leg[1024];
char sip_code[4];
char sip_reason[32];
char callid[256];
char timestamp[24];
double unix_timestamp;
char branch_id[3];
uint8_t valid;
med_method_t method;
char sip_method[32];
uint8_t redis;
char acc_ref[256];
uint8_t timed_out;
} med_entry_t;
typedef struct {
med_entry_t *records;
uint64_t rec_count;
char callid[256];
} med_redis_entry_t;
typedef struct {
char value[256];
} med_callid_t;
extern GHashTable *med_peer_host_table;
extern GHashTable *med_peer_ip_table;
extern GHashTable *med_peer_id_table;
extern GHashTable *med_uuid_table;
extern GHashTable *med_call_stat_info_table;
extern GHashTable *med_cdr_tag_table;
void critical(const char *);
static inline int check_shutdown(void) {
if (mediator_shutdown) {
syslog(LOG_INFO, "Shutdown detected, aborting work in progress");
return 1;
}
return 0;
}
typedef enum {
MED_STATS_HOUR = 1,
MED_STATS_DAY = 2,
MED_STATS_MONTH = 3
} med_stats_period_t;
typedef enum {
MED_LOG_EMERGENCY = 0,
MED_LOG_ALERT = 1,
MED_LOG_CRITICAL = 2,
MED_LOG_ERROR = 3,
MED_LOG_WARNING = 4,
MED_LOG_NOTICE = 5,
MED_LOG_INFO = 6,
MED_LOG_DEBUG = 7
} med_loglevel_t;
#define _LOG(level, fmt, args...) \
do { \
syslog((level), "%s:%d [%s]: " fmt, __FILE__, __LINE__, __func__, ##args); \
} while(0)
#define L_DEBUG(fmt, args...) do { if (config_loglevel >= MED_LOG_DEBUG) { _LOG(LOG_DEBUG, fmt, ##args); } } while(0)
#define L_INFO(fmt, args...) do { if (config_loglevel >= MED_LOG_INFO) { _LOG(LOG_INFO, fmt, ##args); } } while(0)
#define L_NOTICE(fmt, args...) do { if (config_loglevel >= MED_LOG_NOTICE) { _LOG(LOG_NOTICE, fmt, ##args); } } while(0)
#define L_WARNING(fmt, args...) do { if (config_loglevel >= MED_LOG_WARNING) { _LOG(LOG_WARNING, fmt, ##args); } } while(0)
#define L_ERROR(fmt, args...) do { if (config_loglevel >= MED_LOG_ERROR) { _LOG(LOG_ERR, fmt, ##args); } } while(0)
#define L_CRITICAL(fmt, args...) do { if (config_loglevel >= MED_LOG_CRITICAL) { _LOG(LOG_CRIT, fmt, ##args); } } while(0)
#define L_ALERT(fmt, args...) do { if (config_loglevel >= MED_LOG_ALERT) { _LOG(LOG_ALERT, fmt, ##args); } } while(0)
#define L_EMERGENCY(fmt, args...) do { if (config_loglevel >= MED_LOG_EMERG) { _LOG(LOG_EMERG, fmt, ##args); } } while(0)
#endif /* _MEDIATOR_H */