Asterisk - The Open Source Telephony Project GIT-master-a358458
Macros | Functions | Variables
cel_beanstalkd.c File Reference

Asterisk Channel Event Beanstalkd backend. More...

#include "asterisk.h"
#include "asterisk/channel.h"
#include "asterisk/cel.h"
#include "asterisk/module.h"
#include "asterisk/logger.h"
#include "asterisk/utils.h"
#include "asterisk/manager.h"
#include "asterisk/config.h"
#include "asterisk/json.h"
#include "beanstalk.h"
Include dependency graph for cel_beanstalkd.c:

Go to the source code of this file.

Macros

#define BEANSTALK_JOB_DELAY   0
 
#define BEANSTALK_JOB_PRIORITY   99
 
#define BEANSTALK_JOB_SIZE   4096
 
#define BEANSTALK_JOB_TTR   60
 
#define CEL_BACKEND_NAME   "Beanstalk Event Logging"
 
#define CEL_BEANSTALK_ENABLED_DEFAULT   0
 Beanstalk CEL is off by default. More...
 
#define CEL_SHOW_USERDEF_DEFAULT   0
 show_user_def is off by default More...
 
#define DEFAULT_BEANSTALK_HOST   "127.0.0.1"
 
#define DEFAULT_BEANSTALK_PORT   11300
 
#define DEFAULT_BEANSTALK_TUBE   "asterisk-cel"
 

Functions

static void __reg_module (void)
 
static void __unreg_module (void)
 
struct ast_module * AST_MODULE_SELF_SYM (void)
 
static void cel_bs_put (struct ast_event *event)
 
static int load_config (int reload)
 
static int load_module (void)
 
static int reload (void)
 
static int unload_module (void)
 

Variables

static struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Beanstalkd CEL Backend" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CDR_DRIVER, .requires = "cel", }
 
static const struct ast_module_info * ast_module_info = &__mod_info
 
static char * bs_host
 
static int bs_port
 
static char * bs_tube
 
static const char CONF_FILE [] = "cel_beanstalkd.conf"
 
static ast_rwlock_t config_lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} }
 
static const char DATE_FORMAT [] = "%Y-%m-%d %T"
 
static int enablecel
 
static int priority
 

Detailed Description

Asterisk Channel Event Beanstalkd backend.

This module requires the beanstalk-client library, avaialble from https://github.com/deepfryed/beanstalk-client

Definition in file cel_beanstalkd.c.

Macro Definition Documentation

◆ BEANSTALK_JOB_DELAY

#define BEANSTALK_JOB_DELAY   0

Definition at line 74 of file cel_beanstalkd.c.

◆ BEANSTALK_JOB_PRIORITY

#define BEANSTALK_JOB_PRIORITY   99

Definition at line 72 of file cel_beanstalkd.c.

◆ BEANSTALK_JOB_SIZE

#define BEANSTALK_JOB_SIZE   4096

Definition at line 71 of file cel_beanstalkd.c.

◆ BEANSTALK_JOB_TTR

#define BEANSTALK_JOB_TTR   60

Definition at line 73 of file cel_beanstalkd.c.

◆ CEL_BACKEND_NAME

#define CEL_BACKEND_NAME   "Beanstalk Event Logging"

Definition at line 69 of file cel_beanstalkd.c.

◆ CEL_BEANSTALK_ENABLED_DEFAULT

#define CEL_BEANSTALK_ENABLED_DEFAULT   0

Beanstalk CEL is off by default.

Definition at line 62 of file cel_beanstalkd.c.

◆ CEL_SHOW_USERDEF_DEFAULT

#define CEL_SHOW_USERDEF_DEFAULT   0

show_user_def is off by default

Definition at line 67 of file cel_beanstalkd.c.

◆ DEFAULT_BEANSTALK_HOST

#define DEFAULT_BEANSTALK_HOST   "127.0.0.1"

Definition at line 75 of file cel_beanstalkd.c.

◆ DEFAULT_BEANSTALK_PORT

#define DEFAULT_BEANSTALK_PORT   11300

Definition at line 76 of file cel_beanstalkd.c.

◆ DEFAULT_BEANSTALK_TUBE

#define DEFAULT_BEANSTALK_TUBE   "asterisk-cel"

Definition at line 77 of file cel_beanstalkd.c.

Function Documentation

◆ __reg_module()

static void __reg_module ( void  )
static

Definition at line 273 of file cel_beanstalkd.c.

◆ __unreg_module()

static void __unreg_module ( void  )
static

Definition at line 273 of file cel_beanstalkd.c.

◆ AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM ( void  )

Definition at line 273 of file cel_beanstalkd.c.

◆ cel_bs_put()

static void cel_bs_put ( struct ast_event *  event)
static

Definition at line 86 of file cel_beanstalkd.c.

87{
88 struct ast_tm timeresult;
89 char start_time[80];
90 char *cel_buffer;
91 int bs_id;
92 int bs_socket;
93 struct ast_json *t_cel_json;
94
95 struct ast_cel_event_record record = {
96 .version = AST_CEL_EVENT_RECORD_VERSION,
97 };
98
99 if (!enablecel) {
100 return;
101 }
102
103 if (ast_cel_fill_record(event, &record)) {
104 return;
105 }
106
107 ast_rwlock_rdlock(&config_lock);
108 bs_socket = bs_connect(bs_host, bs_port);
109
110 if (bs_use(bs_socket, bs_tube) != BS_STATUS_OK) {
111 ast_log(LOG_ERROR, "Connection to Beanstalk tube %s @ %s:%d had failed", bs_tube, bs_host, bs_port);
112 ast_rwlock_unlock(&config_lock);
113 return;
114 }
115
116 ast_localtime(&record.event_time, &timeresult, NULL);
117 ast_strftime(start_time, sizeof(start_time), DATE_FORMAT, &timeresult);
118
119 ast_rwlock_unlock(&config_lock);
120
121 t_cel_json = ast_json_pack("{s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s, s:s}",
122 "EventName", S_OR(record.event_name, ""),
123 "AccountCode", S_OR(record.account_code, ""),
124 "CallerIDnum", S_OR(record.caller_id_num, ""),
125 "CallerIDname", S_OR(record.caller_id_name, ""),
126 "CallerIDani", S_OR(record.caller_id_ani, ""),
127 "CallerIDrdnis", S_OR(record.caller_id_rdnis, ""),
128 "CallerIDdnid", S_OR(record.caller_id_dnid, ""),
129 "Exten", S_OR(record.extension, ""),
130 "Context", S_OR(record.context, ""),
131 "Channel", S_OR(record.channel_name, ""),
132 "Application", S_OR(record.application_name, ""),
133 "AppData", S_OR(record.application_data, ""),
134 "EventTime", S_OR(start_time, ""),
135 "AMAFlags", S_OR(ast_channel_amaflags2string(record.amaflag), ""),
136 "UniqueID", S_OR(record.unique_id, ""),
137 "LinkedID", S_OR(record.linked_id, ""),
138 "Userfield", S_OR(record.user_field, ""),
139 "Peer", S_OR(record.peer_account, ""),
140 "PeerAccount", S_OR(record.peer_account, ""),
141 "Extra", S_OR(record.extra, "")
142
143 );
144
145 cel_buffer = ast_json_dump_string(t_cel_json);
146
147 ast_json_unref(t_cel_json);
148
149 bs_id = bs_put(bs_socket, priority, BEANSTALK_JOB_DELAY, BEANSTALK_JOB_TTR, cel_buffer, strlen(cel_buffer));
150
151 if (bs_id > 0) {
152 ast_log(LOG_DEBUG, "Successfully created job %d with %s\n", bs_id, cel_buffer);
153 } else {
154 ast_log(LOG_ERROR, "CDR job creation failed for %s\n", cel_buffer);
155 }
156
157 bs_disconnect(bs_socket);
158 ast_json_free(cel_buffer);
159}
ast_log
#define ast_log
Definition: astobj2.c:42
ast_cel_fill_record
int ast_cel_fill_record(const struct ast_event *event, struct ast_cel_event_record *r)
Fill in an ast_cel_event_record from a CEL event.
Definition: cel.c:821
AST_CEL_EVENT_RECORD_VERSION
#define AST_CEL_EVENT_RECORD_VERSION
struct ABI version
Definition: cel.h:143
bs_tube
static char * bs_tube
Definition: cel_beanstalkd.c:81
bs_port
static int bs_port
Definition: cel_beanstalkd.c:80
config_lock
static ast_rwlock_t config_lock
Definition: cel_beanstalkd.c:84
BEANSTALK_JOB_DELAY
#define BEANSTALK_JOB_DELAY
Definition: cel_beanstalkd.c:74
DATE_FORMAT
static const char DATE_FORMAT[]
Definition: cel_beanstalkd.c:57
enablecel
static int enablecel
Definition: cel_beanstalkd.c:64
priority
static int priority
Definition: cel_beanstalkd.c:82
bs_host
static char * bs_host
Definition: cel_beanstalkd.c:79
BEANSTALK_JOB_TTR
#define BEANSTALK_JOB_TTR
Definition: cel_beanstalkd.c:73
ast_channel_amaflags2string
const char * ast_channel_amaflags2string(enum ama_flags flags)
Convert the enum representation of an AMA flag to a string representation.
Definition: channel.c:4373
LOG_DEBUG
#define LOG_DEBUG
Definition: include/asterisk/logger.h:242
LOG_ERROR
#define LOG_ERROR
Definition: include/asterisk/logger.h:286
ast_json_unref
void ast_json_unref(struct ast_json *value)
Decrease refcount on value. If refcount reaches zero, value is freed.
Definition: json.c:73
ast_json_free
void ast_json_free(void *p)
Asterisk's custom JSON allocator. Exposed for use by unit tests.
Definition: json.c:52
ast_json_dump_string
#define ast_json_dump_string(root)
Encode a JSON value to a compact string.
Definition: json.h:810
ast_json_pack
struct ast_json * ast_json_pack(char const *format,...)
Helper for creating complex JSON values.
Definition: json.c:612
ast_localtime
struct ast_tm * ast_localtime(const struct timeval *timep, struct ast_tm *p_tm, const char *zone)
Timezone-independent version of localtime_r(3).
Definition: localtime.c:1739
ast_strftime
int ast_strftime(char *buf, size_t len, const char *format, const struct ast_tm *tm)
Special version of strftime(3) that handles fractions of a second. Takes the same arguments as strfti...
Definition: localtime.c:2524
ast_rwlock_rdlock
#define ast_rwlock_rdlock(a)
Definition: lock.h:235
ast_rwlock_unlock
#define ast_rwlock_unlock(a)
Definition: lock.h:234
NULL
#define NULL
Definition: resample.c:96
S_OR
#define S_OR(a, b)
returns the equivalent of logic or for strings: first one if not empty, otherwise second one.
Definition: strings.h:80
ast_cel_event_record
Helper struct for getting the fields out of a CEL event.
Definition: cel.h:138
ast_cel_event_record::caller_id_dnid
const char * caller_id_dnid
Definition: cel.h:157
ast_cel_event_record::application_data
const char * application_data
Definition: cel.h:162
ast_cel_event_record::account_code
const char * account_code
Definition: cel.h:163
ast_cel_event_record::caller_id_rdnis
const char * caller_id_rdnis
Definition: cel.h:156
ast_cel_event_record::extra
const char * extra
Definition: cel.h:170
ast_cel_event_record::extension
const char * extension
Definition: cel.h:158
ast_cel_event_record::caller_id_num
const char * caller_id_num
Definition: cel.h:154
ast_cel_event_record::channel_name
const char * channel_name
Definition: cel.h:160
ast_cel_event_record::linked_id
const char * linked_id
Definition: cel.h:166
ast_cel_event_record::peer_account
const char * peer_account
Definition: cel.h:164
ast_cel_event_record::unique_id
const char * unique_id
Definition: cel.h:165
ast_cel_event_record::context
const char * context
Definition: cel.h:159
ast_cel_event_record::application_name
const char * application_name
Definition: cel.h:161
ast_cel_event_record::event_time
struct timeval event_time
Definition: cel.h:150
ast_cel_event_record::amaflag
uint amaflag
Definition: cel.h:167
ast_cel_event_record::version
uint32_t version
struct ABI version
Definition: cel.h:148
ast_cel_event_record::user_field
const char * user_field
Definition: cel.h:168
ast_cel_event_record::caller_id_ani
const char * caller_id_ani
Definition: cel.h:155
ast_cel_event_record::caller_id_name
const char * caller_id_name
Definition: cel.h:153
ast_cel_event_record::event_name
const char * event_name
Definition: cel.h:151
ast_json
Abstract JSON element (object, array, string, int, ...).
ast_tm
Definition: localtime.h:35
event
Definition: astman.c:222

References ast_cel_event_record::account_code, ast_cel_event_record::amaflag, ast_cel_event_record::application_data, ast_cel_event_record::application_name, AST_CEL_EVENT_RECORD_VERSION, ast_cel_fill_record(), ast_channel_amaflags2string(), ast_json_dump_string, ast_json_free(), ast_json_pack(), ast_json_unref(), ast_localtime(), ast_log, ast_rwlock_rdlock, ast_rwlock_unlock, ast_strftime(), BEANSTALK_JOB_DELAY, BEANSTALK_JOB_TTR, bs_host, bs_port, bs_tube, ast_cel_event_record::caller_id_ani, ast_cel_event_record::caller_id_dnid, ast_cel_event_record::caller_id_name, ast_cel_event_record::caller_id_num, ast_cel_event_record::caller_id_rdnis, ast_cel_event_record::channel_name, config_lock, ast_cel_event_record::context, DATE_FORMAT, enablecel, ast_cel_event_record::event_name, ast_cel_event_record::event_time, ast_cel_event_record::extension, ast_cel_event_record::extra, ast_cel_event_record::linked_id, LOG_DEBUG, LOG_ERROR, NULL, ast_cel_event_record::peer_account, priority, S_OR, ast_cel_event_record::unique_id, ast_cel_event_record::user_field, and ast_cel_event_record::version.

Referenced by load_config().

◆ load_config()

static int load_config ( int  reload)
static

Definition at line 161 of file cel_beanstalkd.c.

162{
163 const char *cat = NULL;
164 struct ast_config *cfg;
165 struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 };
166 struct ast_variable *v;
167 int newenablecel = CEL_BEANSTALK_ENABLED_DEFAULT;
168
169 cfg = ast_config_load(CONF_FILE, config_flags);
170 if (cfg == CONFIG_STATUS_FILEUNCHANGED) {
171 return 0;
172 }
173
174 if (cfg == CONFIG_STATUS_FILEINVALID) {
175 ast_log(LOG_WARNING, "Configuration file '%s' is invalid. CEL Beanstalkd Module not activated.\n",
176 CONF_FILE);
177 return -1;
178 } else if (!cfg) {
179 ast_log(LOG_WARNING, "Failed to load configuration file. CEL Beanstalkd Module not activated.\n");
180 if (enablecel) {
181 ast_cel_backend_unregister(CEL_BACKEND_NAME);
182 }
183 enablecel = 0;
184 return -1;
185 }
186
187 if (reload) {
188 ast_rwlock_wrlock(&config_lock);
189 ast_free(bs_host);
190 ast_free(bs_tube);
191 }
192
193 /* Bootstrap the default configuration */
194 bs_host = ast_strdup(DEFAULT_BEANSTALK_HOST);
195 bs_port = DEFAULT_BEANSTALK_PORT;
196 bs_tube = ast_strdup(DEFAULT_BEANSTALK_TUBE);
197 priority = BEANSTALK_JOB_PRIORITY;
198
199 while ((cat = ast_category_browse(cfg, cat))) {
200
201 if (strcasecmp(cat, "general")) {
202 continue;
203 }
204
205 for (v = ast_variable_browse(cfg, cat); v; v = v->next) {
206 if (!strcasecmp(v->name, "enabled")) {
207 newenablecel = ast_true(v->value) ? 1 : 0;
208 } else if (!strcasecmp(v->name, "host")) {
209 ast_free(bs_host);
210 bs_host = ast_strdup(v->value);
211 } else if (!strcasecmp(v->name, "port")) {
212 bs_port = atoi(v->value);
213 } else if (!strcasecmp(v->name, "tube")) {
214 ast_free(bs_tube);
215 bs_tube = ast_strdup(v->value);
216 } else if (!strcasecmp(v->name, "priority")) {
217 priority = atoi(v->value);
218 } else {
219 ast_log(LOG_NOTICE, "Unknown option '%s' specified "
220 "for CEL beanstalk backend.\n", v->name);
221 }
222 }
223 }
224
225 if (reload) {
226 ast_rwlock_unlock(&config_lock);
227 }
228
229 ast_config_destroy(cfg);
230
231 if (enablecel && !newenablecel) {
232 ast_cel_backend_unregister(CEL_BACKEND_NAME);
233 } else if (!enablecel && newenablecel) {
234 if (ast_cel_backend_register(CEL_BACKEND_NAME, cel_bs_put)) {
235 ast_log(LOG_ERROR, "Unable to register Beanstalkd CEL handling\n");
236 }
237 }
238
239 enablecel = newenablecel;
240
241 return 0;
242}
ast_free
#define ast_free(a)
Definition: astmm.h:180
ast_strdup
#define ast_strdup(str)
A wrapper for strdup()
Definition: astmm.h:241
ast_cel_backend_unregister
int ast_cel_backend_unregister(const char *name)
Unregister a CEL backend.
Definition: cel.c:1769
ast_cel_backend_register
int ast_cel_backend_register(const char *name, ast_cel_backend_cb backend_callback)
Register a CEL backend.
Definition: cel.c:1781
cel_bs_put
static void cel_bs_put(struct ast_event *event)
Definition: cel_beanstalkd.c:86
DEFAULT_BEANSTALK_HOST
#define DEFAULT_BEANSTALK_HOST
Definition: cel_beanstalkd.c:75
CEL_BEANSTALK_ENABLED_DEFAULT
#define CEL_BEANSTALK_ENABLED_DEFAULT
Beanstalk CEL is off by default.
Definition: cel_beanstalkd.c:62
DEFAULT_BEANSTALK_TUBE
#define DEFAULT_BEANSTALK_TUBE
Definition: cel_beanstalkd.c:77
CEL_BACKEND_NAME
#define CEL_BACKEND_NAME
Definition: cel_beanstalkd.c:69
reload
static int reload(void)
Definition: cel_beanstalkd.c:261
BEANSTALK_JOB_PRIORITY
#define BEANSTALK_JOB_PRIORITY
Definition: cel_beanstalkd.c:72
DEFAULT_BEANSTALK_PORT
#define DEFAULT_BEANSTALK_PORT
Definition: cel_beanstalkd.c:76
CONF_FILE
static const char CONF_FILE[]
Definition: cel_beanstalkd.c:59
ast_config_load
#define ast_config_load(filename, flags)
Load a config file.
Definition: include/asterisk/config.h:179
ast_category_browse
char * ast_category_browse(struct ast_config *config, const char *prev_name)
Browse categories.
Definition: extconf.c:3326
CONFIG_STATUS_FILEUNCHANGED
#define CONFIG_STATUS_FILEUNCHANGED
Definition: include/asterisk/config.h:59
CONFIG_STATUS_FILEINVALID
#define CONFIG_STATUS_FILEINVALID
Definition: include/asterisk/config.h:60
ast_config_destroy
void ast_config_destroy(struct ast_config *cfg)
Destroys a config.
Definition: extconf.c:1289
ast_variable_browse
struct ast_variable * ast_variable_browse(const struct ast_config *config, const char *category_name)
Definition: extconf.c:1215
CONFIG_FLAG_FILEUNCHANGED
@ CONFIG_FLAG_FILEUNCHANGED
Definition: include/asterisk/config.h:43
LOG_NOTICE
#define LOG_NOTICE
Definition: include/asterisk/logger.h:264
LOG_WARNING
#define LOG_WARNING
Definition: include/asterisk/logger.h:275
ast_rwlock_wrlock
#define ast_rwlock_wrlock(a)
Definition: lock.h:236
ast_true
int attribute_pure ast_true(const char *val)
Make sure something is true. Determine if a string containing a boolean value is "true"....
Definition: utils.c:2199
ast_config
Definition: main/config.c:249
ast_flags
Structure used to handle boolean flags.
Definition: utils.h:199
ast_variable
Structure for variables, used for configurations and for channel variables.
Definition: include/asterisk/config.h:83
ast_variable::value
const char * value
Definition: include/asterisk/config.h:87
ast_variable::name
const char * name
Definition: include/asterisk/config.h:85
ast_variable::next
struct ast_variable * next
Definition: include/asterisk/config.h:90

References ast_category_browse(), ast_cel_backend_register(), ast_cel_backend_unregister(), ast_config_destroy(), ast_config_load, ast_free, ast_log, ast_rwlock_unlock, ast_rwlock_wrlock, ast_strdup, ast_true(), ast_variable_browse(), BEANSTALK_JOB_PRIORITY, bs_host, bs_port, bs_tube, CEL_BACKEND_NAME, CEL_BEANSTALK_ENABLED_DEFAULT, cel_bs_put(), CONF_FILE, CONFIG_FLAG_FILEUNCHANGED, config_lock, CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEUNCHANGED, DEFAULT_BEANSTALK_HOST, DEFAULT_BEANSTALK_PORT, DEFAULT_BEANSTALK_TUBE, enablecel, LOG_ERROR, LOG_NOTICE, LOG_WARNING, ast_variable::name, ast_variable::next, NULL, priority, reload(), and ast_variable::value.

Referenced by load_module(), and reload().

◆ load_module()

static int load_module ( void  )
static

Definition at line 252 of file cel_beanstalkd.c.

253{
254 if (load_config(0)) {
255 return AST_MODULE_LOAD_DECLINE;
256 }
257
258 return AST_MODULE_LOAD_SUCCESS;
259}
load_config
static int load_config(int reload)
Definition: cel_beanstalkd.c:161
AST_MODULE_LOAD_SUCCESS
@ AST_MODULE_LOAD_SUCCESS
Definition: module.h:70
AST_MODULE_LOAD_DECLINE
@ AST_MODULE_LOAD_DECLINE
Module has failed to load, may be in an inconsistent state.
Definition: module.h:78

References AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, and load_config().

◆ reload()

static int reload ( void  )
static

Definition at line 261 of file cel_beanstalkd.c.

262{
263 return load_config(1);
264}

References load_config().

Referenced by load_config().

◆ unload_module()

static int unload_module ( void  )
static

Definition at line 244 of file cel_beanstalkd.c.

245{
246 ast_cel_backend_unregister(CEL_BACKEND_NAME);
247 ast_free(bs_host);
248 ast_free(bs_tube);
249 return 0;
250}

References ast_cel_backend_unregister(), ast_free, bs_host, bs_tube, and CEL_BACKEND_NAME.

Variable Documentation

◆ __mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Beanstalkd CEL Backend" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CDR_DRIVER, .requires = "cel", }
static

Definition at line 273 of file cel_beanstalkd.c.

◆ ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info
static

Definition at line 273 of file cel_beanstalkd.c.

◆ bs_host

char* bs_host
static

Definition at line 79 of file cel_beanstalkd.c.

Referenced by cel_bs_put(), load_config(), and unload_module().

◆ bs_port

int bs_port
static

Definition at line 80 of file cel_beanstalkd.c.

Referenced by cel_bs_put(), and load_config().

◆ bs_tube

char* bs_tube
static

Definition at line 81 of file cel_beanstalkd.c.

Referenced by cel_bs_put(), load_config(), and unload_module().

◆ CONF_FILE

const char CONF_FILE[] = "cel_beanstalkd.conf"
static

Definition at line 59 of file cel_beanstalkd.c.

Referenced by load_config().

◆ config_lock

ast_rwlock_t config_lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} }
static

Definition at line 84 of file cel_beanstalkd.c.

Referenced by cel_bs_put(), and load_config().

◆ DATE_FORMAT

const char DATE_FORMAT[] = "%Y-%m-%d %T"
static

Definition at line 57 of file cel_beanstalkd.c.

Referenced by cel_bs_put().

◆ enablecel

int enablecel
static

Definition at line 64 of file cel_beanstalkd.c.

Referenced by cel_bs_put(), and load_config().

◆ priority

int priority
static

Definition at line 82 of file cel_beanstalkd.c.

Referenced by cel_bs_put(), and load_config().

Generated on Wed Apr 17 2024 20:04:30 for Asterisk - The Open Source Telephony Project by doxygen 1.9.4