Asterisk - The Open Source Telephony Project GIT-master-67613d1
Data Structures | Macros | Typedefs | Functions | Variables
cel.c File Reference

Channel Event Logging API. More...

#include "asterisk.h"
#include "asterisk/module.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/cel.h"
#include "asterisk/logger.h"
#include "asterisk/linkedlists.h"
#include "asterisk/utils.h"
#include "asterisk/config.h"
#include "asterisk/config_options.h"
#include "asterisk/cli.h"
#include "asterisk/astobj2.h"
#include "asterisk/stasis_message_router.h"
#include "asterisk/stasis_channels.h"
#include "asterisk/stasis_bridges.h"
#include "asterisk/bridge.h"
#include "asterisk/parking.h"
#include "asterisk/pickup.h"
#include "asterisk/core_local.h"
#include "asterisk/taskprocessor.h"
Include dependency graph for cel.c:

Go to the source code of this file.

Data Structures

struct  cel_backend
 
struct  cel_config
 A container that holds all config-related information. More...
 
struct  cel_dialstatus
 
struct  cel_linkedid
 

Macros

#define BACKEND_BUCKETS   13
 
#define CEL_MAX_EVENT_IDS   64
 Maximum possible CEL event IDs. More...
 
#define NUM_APP_BUCKETS   97
 Number of buckets for the appset container. More...
 
#define NUM_DIALSTATUS_BUCKETS   251
 Number of buckets for the dialstatus container. More...
 

Typedefs

typedef void(* cel_channel_snapshot_monitor) (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot, const struct timeval *event_time)
 Typedef for callbacks that get called on channel snapshot updates. More...
 

Functions

static void __reg_module (void)
 
static void __unreg_module (void)
 
static AO2_GLOBAL_OBJ_STATIC (cel_backends)
 
static AO2_GLOBAL_OBJ_STATIC (cel_configs)
 
static AO2_GLOBAL_OBJ_STATIC (cel_dialstatus_store)
 
static AO2_GLOBAL_OBJ_STATIC (cel_linkedids)
 
static int apps_handler (const struct aco_option *opt, struct ast_variable *var, void *obj)
 
int ast_cel_backend_register (const char *name, ast_cel_backend_cb backend_callback)
 Register a CEL backend. More...
 
int ast_cel_backend_unregister (const char *name)
 Unregister a CEL backend. More...
 
unsigned int ast_cel_check_enabled (void)
 Hashing function for cel_backend. More...
 
struct ast_eventast_cel_create_event (struct ast_channel_snapshot *snapshot, enum ast_cel_event_type event_type, const char *userdefevname, struct ast_json *extra, const char *peer)
 Allocate and populate a CEL event structure. More...
 
struct ast_eventast_cel_create_event_with_time (struct ast_channel_snapshot *snapshot, enum ast_cel_event_type event_type, const struct timeval *event_time, const char *userdefevname, struct ast_json *extra, const char *peer)
 Allocate and populate a CEL event structure. More...
 
struct ast_channelast_cel_fabricate_channel_from_event (const struct ast_event *event)
 Create a fake channel from data in a CEL event. More...
 
int ast_cel_fill_record (const struct ast_event *e, struct ast_cel_event_record *r)
 Fill in an ast_cel_event_record from a CEL event. More...
 
void * ast_cel_general_config_alloc (void)
 Allocate a CEL configuration object. More...
 
struct ast_cel_general_configast_cel_get_config (void)
 Obtain the current CEL configuration. More...
 
const char * ast_cel_get_type_name (enum ast_cel_event_type type)
 Get the name of a CEL event type. More...
 
void ast_cel_publish_event (struct ast_channel *chan, enum ast_cel_event_type event_type, struct ast_json *blob)
 Publish a CEL event. More...
 
void ast_cel_publish_user_event (struct ast_channel *chan, const char *event, const char *extra)
 Publish a CEL user event. More...
 
void ast_cel_set_config (struct ast_cel_general_config *config)
 Set the current CEL configuration. More...
 
enum ast_cel_event_type ast_cel_str_to_event_type (const char *name)
 Get the event type from a string. More...
 
struct stasis_topicast_cel_topic (void)
 Get the CEL topic. More...
 
static int ast_cel_track_event (enum ast_cel_event_type et)
 
struct ast_moduleAST_MODULE_SELF_SYM (void)
 
static void cel_attended_transfer_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static int cel_backend_send_cb (void *obj, void *arg, int flags)
 
static void cel_blind_transfer_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void cel_bridge_enter_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void cel_bridge_leave_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void cel_channel_app_change (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot, const struct timeval *event_time)
 
static void cel_channel_linkedid_change (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot, const struct timeval *event_time)
 
static void cel_channel_state_change (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot, const struct timeval *event_time)
 Handle channel state changes. More...
 
static void * cel_config_alloc (void)
 
static void cel_config_dtor (void *obj)
 Destructor for cel_config. More...
 
static void cel_dial_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static int cel_filter_channel_snapshot (struct ast_channel_snapshot *snapshot)
 
static void cel_general_config_dtor (void *obj)
 Destructor for cel_config. More...
 
static struct ast_strcel_generate_peer_str (struct ast_bridge_snapshot *bridge, struct ast_channel_snapshot *chan)
 
static void cel_generic_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
struct stasis_message_typecel_generic_type (void)
 
static int cel_linkedid_ref (const char *linkedid)
 
static void cel_local_optimization_begin_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void cel_local_optimization_cb_helper (void *data, struct stasis_subscription *sub, struct stasis_message *message, enum ast_cel_event_type event_type)
 
static void cel_local_optimization_end_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void cel_parking_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void cel_pickup_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static int cel_pre_apply_config (void)
 
static int cel_report_event (struct ast_channel_snapshot *snapshot, enum ast_cel_event_type event_type, const struct timeval *event_time, const char *userdefevname, struct ast_json *extra, const char *peer_str)
 
static void cel_snapshot_update_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static int cel_track_app (const char *const_app)
 
static void check_retire_linkedid (struct ast_channel_snapshot *snapshot, const struct timeval *event_time)
 
 CONFIG_INFO_CORE ("cel", cel_cfg_info, cel_configs, cel_config_alloc,.files=ACO_FILES(&cel_conf),.pre_apply_config=cel_pre_apply_config,)
 
static int create_routes (void)
 Create the Stasis message router and routes for CEL. More...
 
static int create_subscriptions (void)
 Create the Stasis subscriptions for CEL. More...
 
static void destroy_routes (void)
 
static void destroy_subscriptions (void)
 
static int events_handler (const struct aco_option *opt, struct ast_variable *var, void *obj)
 
static const char * get_blob_variable (struct ast_multi_channel_blob *blob, const char *varname)
 
static struct cel_dialstatusget_dialstatus (const char *uniqueid)
 
static char * handle_cli_status (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
 
static int is_valid_dialstatus (struct ast_multi_channel_blob *blob)
 
static int load_module (void)
 
static int reload_module (void)
 
static void save_dialstatus (struct ast_multi_channel_blob *blob, struct ast_channel_snapshot *snapshot)
 
 STASIS_MESSAGE_TYPE_DEFN (cel_generic_type)
 
static int unload_module (void)
 

Variables

static struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_GLOBAL_SYMBOLS | AST_MODFLAG_LOAD_ORDER , .description = "CEL Engine" , .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_CORE, .load = load_module, .unload = unload_module, .reload = reload_module, .load_pri = AST_MODPRI_CORE, .requires = "extconfig", }
 
static const struct ast_module_infoast_module_info = &__mod_info
 
static struct stasis_topiccel_aggregation_topic
 
static struct stasis_forwardcel_bridge_forwarder
 
static struct stasis_forwardcel_cel_forwarder
 
static struct stasis_forwardcel_channel_forwarder
 
cel_channel_snapshot_monitor cel_channel_monitors []
 Handlers for channel snapshot changes. More...
 
static struct aco_file cel_conf
 The config file to be processed for the module. More...
 
static const char *const cel_event_types [CEL_MAX_EVENT_IDS]
 Map of ast_cel_event_type to strings. More...
 
static struct stasis_forwardcel_parking_forwarder
 
static struct stasis_message_routercel_state_router
 
static struct stasis_topiccel_topic
 
static struct ast_cli_entry cli_status = { .handler = handle_cli_status , .summary = "Display the CEL status" ,}
 
static const struct ast_datastore_info fabricated_channel_datastore
 
static struct aco_type general_option
 An aco_type structure to link the "general" category to the ast_cel_general_config type. More...
 
static struct aco_typegeneral_options [] = ACO_TYPES(&general_option)
 
static const char * ignore_categories []
 
static struct aco_type ignore_option
 

Detailed Description

Channel Event Logging API.

Author
Steve Murphy murf@.nosp@m.digi.nosp@m.um.co.nosp@m.m
Russell Bryant russe.nosp@m.ll@d.nosp@m.igium.nosp@m..com

Definition in file cel.c.

Macro Definition Documentation

◆ BACKEND_BUCKETS

#define BACKEND_BUCKETS   13

The number of buckets into which backend names will be hashed

Definition at line 142 of file cel.c.

◆ CEL_MAX_EVENT_IDS

#define CEL_MAX_EVENT_IDS   64

Maximum possible CEL event IDs.

Note
This limit is currently imposed by the eventset definition

Definition at line 151 of file cel.c.

◆ NUM_APP_BUCKETS

#define NUM_APP_BUCKETS   97

Number of buckets for the appset container.

Definition at line 156 of file cel.c.

◆ NUM_DIALSTATUS_BUCKETS

#define NUM_DIALSTATUS_BUCKETS   251

Number of buckets for the dialstatus container.

Definition at line 161 of file cel.c.

Typedef Documentation

◆ cel_channel_snapshot_monitor

typedef void(* cel_channel_snapshot_monitor) (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot, const struct timeval *event_time)

Typedef for callbacks that get called on channel snapshot updates.

Definition at line 865 of file cel.c.

Function Documentation

◆ __reg_module()

static void __reg_module ( void  )
static

Definition at line 1811 of file cel.c.

◆ __unreg_module()

static void __unreg_module ( void  )
static

Definition at line 1811 of file cel.c.

◆ AO2_GLOBAL_OBJ_STATIC() [1/4]

static AO2_GLOBAL_OBJ_STATIC ( cel_backends  )
static

Container for CEL backend information

◆ AO2_GLOBAL_OBJ_STATIC() [2/4]

static AO2_GLOBAL_OBJ_STATIC ( cel_configs  )
static

◆ AO2_GLOBAL_OBJ_STATIC() [3/4]

static AO2_GLOBAL_OBJ_STATIC ( cel_dialstatus_store  )
static

Container for dial end multichannel blobs for holding on to dial statuses

◆ AO2_GLOBAL_OBJ_STATIC() [4/4]

static AO2_GLOBAL_OBJ_STATIC ( cel_linkedids  )
static

Container of channel references to a linkedid for CEL purposes.

◆ apps_handler()

static int apps_handler ( const struct aco_option opt,
struct ast_variable var,
void *  obj 
)
static

Definition at line 474 of file cel.c.

475{
476 struct ast_cel_general_config *cfg = obj;
477 char *apps = ast_strdupa(var->value);
478 char *cur_app;
479
480 while ((cur_app = strsep(&apps, ","))) {
481 cur_app = ast_strip(cur_app);
482 if (ast_strlen_zero(cur_app)) {
483 continue;
484 }
485
486 cur_app = ast_str_to_lower(cur_app);
487 ast_str_container_add(cfg->apps, cur_app);
488 }
489
490 return 0;
491}
#define var
Definition: ast_expr2f.c:605
#define ast_strdupa(s)
duplicate a string in memory from the stack
Definition: astmm.h:298
char * strsep(char **str, const char *delims)
static force_inline char * ast_str_to_lower(char *str)
Convert a string to all lower-case.
Definition: strings.h:1321
static force_inline int attribute_pure ast_strlen_zero(const char *s)
Definition: strings.h:65
char * ast_strip(char *s)
Strip leading/trailing whitespace from a string.
Definition: strings.h:223
int ast_str_container_add(struct ao2_container *str_container, const char *add)
Adds a string to a string container allocated by ast_str_container_alloc.
Definition: strings.c:205
Registered applications container.
Definition: pbx_app.c:67
A structure to hold CEL global configuration options.
Definition: cel.h:223
struct ao2_container * apps
Definition: cel.h:232

References ast_cel_general_config::apps, ast_str_container_add(), ast_str_to_lower(), ast_strdupa, ast_strip(), ast_strlen_zero(), strsep(), and var.

Referenced by load_module().

◆ ast_cel_backend_register()

int ast_cel_backend_register ( const char *  name,
ast_cel_backend_cb  backend_callback 
)

Register a CEL backend.

Parameters
nameName of backend to register
backend_callbackCallback to register
Return values
zeroon success
non-zeroon failure
Since
12

Definition at line 1781 of file cel.c.

1782{
1784 struct cel_backend *backend;
1785
1786 if (!backends || ast_strlen_zero(name) || !backend_callback) {
1787 return -1;
1788 }
1789
1790 /* The backend object is immutable so it doesn't need a lock of its own. */
1791 backend = ao2_alloc_options(sizeof(*backend) + 1 + strlen(name), NULL,
1793 if (!backend) {
1794 return -1;
1795 }
1796 strcpy(backend->name, name);/* Safe */
1797 backend->callback = backend_callback;
1798
1799 ao2_link(backends, backend);
1800 ao2_ref(backend, -1);
1801 return 0;
1802}
#define ao2_link(container, obj)
Add an object to a container.
Definition: astobj2.h:1532
@ AO2_ALLOC_OPT_LOCK_NOLOCK
Definition: astobj2.h:367
#define ao2_cleanup(obj)
Definition: astobj2.h:1934
#define ao2_global_obj_ref(holder)
Get a reference to the object stored in the global holder.
Definition: astobj2.h:918
#define ao2_ref(o, delta)
Reference/unreference an object and return the old refcount.
Definition: astobj2.h:459
#define ao2_alloc_options(data_size, destructor_fn, options)
Definition: astobj2.h:404
static const char name[]
Definition: format_mp3.c:68
#define NULL
Definition: resample.c:96
Generic container type.
the list of registered channel types
Definition: channel.c:121
ast_cel_backend_cb callback
Definition: cel.c:329
char name[0]
Definition: cel.c:330
#define RAII_VAR(vartype, varname, initval, dtor)
Declare a variable that will call a destructor function when it goes out of scope.
Definition: utils.h:941

References AO2_ALLOC_OPT_LOCK_NOLOCK, ao2_alloc_options, ao2_cleanup, ao2_global_obj_ref, ao2_link, ao2_ref, ast_strlen_zero(), cel_backend::callback, cel_backend::name, name, NULL, and RAII_VAR.

Referenced by load_config(), load_module(), my_load_module(), and test_cel_init_cb().

◆ ast_cel_backend_unregister()

int ast_cel_backend_unregister ( const char *  name)

Unregister a CEL backend.

Parameters
nameName of backend to unregister
Return values
zeroon success
non-zeroon failure
Since
12

Definition at line 1769 of file cel.c.

1770{
1771 struct ao2_container *backends = ao2_global_obj_ref(cel_backends);
1772
1773 if (backends) {
1775 ao2_ref(backends, -1);
1776 }
1777
1778 return 0;
1779}
#define ao2_find(container, arg, flags)
Definition: astobj2.h:1736
@ OBJ_NODATA
Definition: astobj2.h:1044
@ OBJ_UNLINK
Definition: astobj2.h:1039
@ OBJ_SEARCH_KEY
The arg parameter is a search key, but is not an object.
Definition: astobj2.h:1101

References ao2_find, ao2_global_obj_ref, ao2_ref, name, OBJ_NODATA, OBJ_SEARCH_KEY, and OBJ_UNLINK.

Referenced by cel_verify_and_cleanup_cb(), load_config(), my_unload_module(), tds_unload_module(), and unload_module().

◆ ast_cel_check_enabled()

unsigned int ast_cel_check_enabled ( void  )

Hashing function for cel_backend.

Check to see if CEL is enabled.

Comparator function for cel_backend

Hashing function for dialstatus container

Comparator function for dialstatus container

Definition at line 345 of file cel.c.

346{
347 unsigned int enabled;
348 struct cel_config *cfg = ao2_global_obj_ref(cel_configs);
349
350 enabled = (!cfg || !cfg->general) ? 0 : cfg->general->enable;
351 ao2_cleanup(cfg);
352 return enabled;
353}
static int enabled
Definition: dnsmgr.c:91
A container that holds all config-related information.
Definition: cel_custom.c:53
struct ast_cel_general_config * general
Definition: cel.c:211

References ao2_cleanup, ao2_global_obj_ref, ast_cel_general_config::enable, enabled, and cel_config::general.

Referenced by ast_cel_set_config(), handle_cli_status(), load_module(), and reload_module().

◆ ast_cel_create_event()

struct ast_event * ast_cel_create_event ( struct ast_channel_snapshot snapshot,
enum ast_cel_event_type  event_type,
const char *  userdefevname,
struct ast_json extra,
const char *  peer_str 
)

Allocate and populate a CEL event structure.

Parameters
snapshotAn ast_channel_snapshot of the primary channel associated with this channel event.
event_typeThe type of call event being reported.
userdefevnameCustom name for the call event. (optional)
extraAn event-specific opaque JSON blob to be rendered and placed in the "CEL_EXTRA" information element of the call event. (optional)
peer_strA list of comma-separated peer channel names. (optional)
Since
12
Return values
Thecreated ast_event structure
NULLon failure

Definition at line 519 of file cel.c.

522{
523 struct timeval eventtime = ast_tvnow();
524
525 return ast_cel_create_event_with_time(snapshot, event_type, &eventtime,
526 userdefevname, extra, peer);
527}
struct ast_event * ast_cel_create_event_with_time(struct ast_channel_snapshot *snapshot, enum ast_cel_event_type event_type, const struct timeval *event_time, const char *userdefevname, struct ast_json *extra, const char *peer)
Allocate and populate a CEL event structure.
Definition: cel.c:529
struct timeval ast_tvnow(void)
Returns current timeval. Meant to replace calls to gettimeofday().
Definition: time.h:159

References ast_cel_create_event_with_time(), and ast_tvnow().

Referenced by append_expected_event_snapshot().

◆ ast_cel_create_event_with_time()

struct ast_event * ast_cel_create_event_with_time ( struct ast_channel_snapshot snapshot,
enum ast_cel_event_type  event_type,
const struct timeval *  event_time,
const char *  userdefevname,
struct ast_json extra,
const char *  peer_str 
)

Allocate and populate a CEL event structure.

Parameters
snapshotAn ast_channel_snapshot of the primary channel associated with this channel event.
event_typeThe type of call event being reported.
event_timeThe time at which the event occurred.
userdefevnameCustom name for the call event. (optional)
extraAn event-specific opaque JSON blob to be rendered and placed in the "CEL_EXTRA" information element of the call event. (optional)
peer_strA list of comma-separated peer channel names. (optional)
Since
13.29.0
16.6.0
Return values
Thecreated ast_event structure
NULLon failure

Definition at line 529 of file cel.c.

532{
533 RAII_VAR(char *, extra_txt, NULL, ast_json_free);
534 if (extra) {
535 extra_txt = ast_json_dump_string(extra);
536 }
561}
struct ast_event * ast_event_new(enum ast_event_type event_type,...)
Create a new event.
Definition: event.c:402
@ AST_EVENT_IE_CEL_ACCTCODE
Channel Event AccountCode Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:205
@ AST_EVENT_IE_END
Definition: event_defs.h:70
@ AST_EVENT_IE_CEL_EXTRA
Channel Event extra data Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:259
@ AST_EVENT_IE_CEL_CONTEXT
Channel Event context name Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:175
@ AST_EVENT_IE_CEL_PEERACCT
Channel Event peeraccount Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:253
@ AST_EVENT_IE_CEL_CIDRDNIS
Channel Event CID RDNIS field Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:229
@ AST_EVENT_IE_CEL_EVENT_TIME
Channel Event Time (seconds) Used by: AST_EVENT_CEL Payload type: UINT.
Definition: event_defs.h:139
@ AST_EVENT_IE_CEL_CHANNAME
Channel Event channel name Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:181
@ AST_EVENT_IE_CEL_CIDANI
Channel Event CID ANI field Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:223
@ AST_EVENT_IE_CEL_CIDDNID
Channel Event CID dnid Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:235
@ AST_EVENT_IE_CEL_EXTEN
Channel Event extension name Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:169
@ AST_EVENT_IE_CEL_CIDNAME
Channel Event CID name Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:157
@ AST_EVENT_IE_CEL_AMAFLAGS
Channel Event AMA flags Used by: AST_EVENT_CEL Payload type: UINT.
Definition: event_defs.h:199
@ AST_EVENT_IE_CEL_USEREVENT_NAME
Channel Event User Event Name Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:151
@ AST_EVENT_IE_CEL_LINKEDID
Channel Event LinkedID Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:247
@ AST_EVENT_IE_CEL_EVENT_TIME_USEC
Channel Event Time (micro-seconds) Used by: AST_EVENT_CEL Payload type: UINT.
Definition: event_defs.h:145
@ AST_EVENT_IE_CEL_EVENT_TYPE
Channel Event Type Used by: AST_EVENT_CEL Payload type: UINT.
Definition: event_defs.h:133
@ AST_EVENT_IE_CEL_UNIQUEID
Channel Event UniqueID Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:211
@ AST_EVENT_IE_CEL_APPNAME
Channel Event app name Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:187
@ AST_EVENT_IE_CEL_APPDATA
Channel Event app args/data Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:193
@ AST_EVENT_IE_CEL_PEER
Channel Event Peer – for Things involving multiple channels, like BRIDGE Used by: AST_EVENT_CEL Paylo...
Definition: event_defs.h:241
@ AST_EVENT_IE_CEL_CIDNUM
Channel Event CID num Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:163
@ AST_EVENT_IE_CEL_USERFIELD
Channel Event Userfield Used by: AST_EVENT_CEL Payload type: STR.
Definition: event_defs.h:217
@ AST_EVENT_CEL
Definition: event_defs.h:50
@ AST_EVENT_IE_PLTYPE_UINT
Definition: event_defs.h:326
@ AST_EVENT_IE_PLTYPE_STR
Definition: event_defs.h:328
void ast_json_free(void *p)
Asterisk's custom JSON allocator. Exposed for use by unit tests.
Definition: json.c:52
#define ast_json_dump_string(root)
Encode a JSON value to a compact string.
Definition: json.h:810
#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
const ast_string_field accountcode
const ast_string_field userfield
const ast_string_field uniqueid
const ast_string_field name
const ast_string_field number
const ast_string_field rdnis
const ast_string_field ani
const ast_string_field name
const ast_string_field dnid
const ast_string_field data
const ast_string_field context
const ast_string_field exten
const ast_string_field appl
struct ast_channel_snapshot_dialplan * dialplan
struct ast_channel_snapshot_peer * peer
struct ast_channel_snapshot_base * base
struct ast_channel_snapshot_caller * caller

References ast_channel_snapshot_peer::account, ast_channel_snapshot_base::accountcode, ast_channel_snapshot::amaflags, ast_channel_snapshot_caller::ani, ast_channel_snapshot_dialplan::appl, AST_EVENT_CEL, AST_EVENT_IE_CEL_ACCTCODE, AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_CEL_APPDATA, AST_EVENT_IE_CEL_APPNAME, AST_EVENT_IE_CEL_CHANNAME, AST_EVENT_IE_CEL_CIDANI, AST_EVENT_IE_CEL_CIDDNID, AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_CEL_CIDNUM, AST_EVENT_IE_CEL_CIDRDNIS, AST_EVENT_IE_CEL_CONTEXT, AST_EVENT_IE_CEL_EVENT_TIME, AST_EVENT_IE_CEL_EVENT_TIME_USEC, AST_EVENT_IE_CEL_EVENT_TYPE, AST_EVENT_IE_CEL_EXTEN, AST_EVENT_IE_CEL_EXTRA, AST_EVENT_IE_CEL_LINKEDID, AST_EVENT_IE_CEL_PEER, AST_EVENT_IE_CEL_PEERACCT, AST_EVENT_IE_CEL_UNIQUEID, AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_CEL_USERFIELD, AST_EVENT_IE_END, AST_EVENT_IE_PLTYPE_STR, AST_EVENT_IE_PLTYPE_UINT, ast_event_new(), ast_json_dump_string, ast_json_free(), ast_channel_snapshot::base, ast_channel_snapshot::caller, ast_channel_snapshot_dialplan::context, ast_channel_snapshot_dialplan::data, ast_channel_snapshot::dialplan, ast_channel_snapshot_caller::dnid, ast_channel_snapshot_dialplan::exten, ast_channel_snapshot_peer::linkedid, ast_channel_snapshot_caller::name, ast_channel_snapshot_base::name, NULL, ast_channel_snapshot_caller::number, ast_channel_snapshot::peer, RAII_VAR, ast_channel_snapshot_caller::rdnis, S_OR, ast_channel_snapshot_base::uniqueid, and ast_channel_snapshot_base::userfield.

Referenced by ast_cel_create_event(), and cel_report_event().

◆ ast_cel_fabricate_channel_from_event()

struct ast_channel * ast_cel_fabricate_channel_from_event ( const struct ast_event event)

Create a fake channel from data in a CEL event.

Note
This function creates a fake channel containing the serialized channel data in the given cel event. It should be released with ast_channel_unref() but could be released with ast_channel_release().
Parameters
eventthe CEL event
Since
1.8
Returns
a channel with the data filled in, or NULL on error
Todo:
This function is very expensive, especially given that some CEL backends use it on every CEL event. This function really needs to go away at some point.

Definition at line 662 of file cel.c.

663{
664 struct varshead *headp;
665 struct ast_var_t *newvariable;
666 const char *mixed_name;
667 char timebuf[30];
668 struct ast_channel *tchan;
669 struct ast_cel_event_record record = {
671 };
672 struct ast_datastore *datastore;
673 char *app_data;
674 RAII_VAR(struct cel_config *, cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
675
676 if (!cfg || !cfg->general) {
677 return NULL;
678 }
679
680 /* do not call ast_channel_alloc because this is not really a real channel */
681 if (!(tchan = ast_dummy_channel_alloc())) {
682 return NULL;
683 }
684
685 headp = ast_channel_varshead(tchan);
686
687 /* first, get the variables from the event */
688 if (ast_cel_fill_record(event, &record)) {
689 ast_channel_unref(tchan);
690 return NULL;
691 }
692
693 /* next, fill the channel with their data */
694 mixed_name = (record.event_type == AST_CEL_USER_DEFINED)
695 ? record.user_defined_name : record.event_name;
696 if ((newvariable = ast_var_assign("eventtype", mixed_name))) {
697 AST_LIST_INSERT_HEAD(headp, newvariable, entries);
698 }
699
700 if (ast_strlen_zero(cfg->general->date_format)) {
701 snprintf(timebuf, sizeof(timebuf), "%ld.%06ld", (long) record.event_time.tv_sec,
702 (long) record.event_time.tv_usec);
703 } else {
704 struct ast_tm tm;
705 ast_localtime(&record.event_time, &tm, NULL);
706 ast_strftime(timebuf, sizeof(timebuf), cfg->general->date_format, &tm);
707 }
708
709 if ((newvariable = ast_var_assign("eventtime", timebuf))) {
710 AST_LIST_INSERT_HEAD(headp, newvariable, entries);
711 }
712
713 if ((newvariable = ast_var_assign("eventenum", record.event_name))) {
714 AST_LIST_INSERT_HEAD(headp, newvariable, entries);
715 }
716 if ((newvariable = ast_var_assign("userdeftype", record.user_defined_name))) {
717 AST_LIST_INSERT_HEAD(headp, newvariable, entries);
718 }
719 if ((newvariable = ast_var_assign("eventextra", record.extra))) {
720 AST_LIST_INSERT_HEAD(headp, newvariable, entries);
721 }
722
723 ast_channel_caller(tchan)->id.name.valid = 1;
725 ast_channel_caller(tchan)->id.number.valid = 1;
732
733 ast_channel_exten_set(tchan, record.extension);
734 ast_channel_context_set(tchan, record.context);
735 ast_channel_name_set(tchan, record.channel_name);
737 ast_channel_accountcode_set(tchan, record.account_code);
738 ast_channel_peeraccount_set(tchan, record.peer_account);
739 ast_channel_userfield_set(tchan, record.user_field);
740
741 if ((newvariable = ast_var_assign("BRIDGEPEER", record.peer))) {
742 AST_LIST_INSERT_HEAD(headp, newvariable, entries);
743 }
744
745 ast_channel_amaflags_set(tchan, record.amaflag);
746
747 /* We need to store an 'application name' and 'application
748 * data' on the channel for logging purposes, but the channel
749 * structure only provides a place to store pointers, and it
750 * expects these pointers to be pointing to data that does not
751 * need to be freed. This means that the channel's destructor
752 * does not attempt to free any storage that these pointers
753 * point to. However, we can't provide data in that form directly for
754 * these structure members. In order to ensure that these data
755 * elements have a lifetime that matches the channel's
756 * lifetime, we'll put them in a datastore attached to the
757 * channel, and set's the channel's pointers to point into the
758 * datastore. The datastore will then be automatically destroyed
759 * when the channel is destroyed.
760 */
761
763 ast_channel_unref(tchan);
764 return NULL;
765 }
766
767 if (!(app_data = ast_malloc(strlen(record.application_name) + strlen(record.application_data) + 2))) {
768 ast_datastore_free(datastore);
769 ast_channel_unref(tchan);
770 return NULL;
771 }
772
773 ast_channel_appl_set(tchan, strcpy(app_data, record.application_name));
774 ast_channel_data_set(tchan, strcpy(app_data + strlen(record.application_name) + 1,
775 record.application_data));
776
777 datastore->data = app_data;
778 ast_channel_datastore_add(tchan, datastore);
779
780 return tchan;
781}
if(!yyg->yy_init)
Definition: ast_expr2f.c:854
#define ast_strdup(str)
A wrapper for strdup()
Definition: astmm.h:241
#define ast_malloc(len)
A wrapper for malloc()
Definition: astmm.h:191
int ast_cel_fill_record(const struct ast_event *e, struct ast_cel_event_record *r)
Fill in an ast_cel_event_record from a CEL event.
Definition: cel.c:821
static const struct ast_datastore_info fabricated_channel_datastore
Definition: cel.c:657
@ AST_CEL_USER_DEFINED
a user-defined event, the event name field should be set
Definition: cel.h:69
#define AST_CEL_EVENT_RECORD_VERSION
struct ABI version
Definition: cel.h:143
void ast_channel_exten_set(struct ast_channel *chan, const char *value)
void ast_channel_appl_set(struct ast_channel *chan, const char *value)
void ast_channel_internal_set_fake_ids(struct ast_channel *chan, const char *uniqueid, const char *linkedid)
Set uniqueid and linkedid string value only (not time)
int ast_channel_datastore_add(struct ast_channel *chan, struct ast_datastore *datastore)
Add a datastore to a channel.
Definition: channel.c:2385
struct varshead * ast_channel_varshead(struct ast_channel *chan)
void ast_channel_data_set(struct ast_channel *chan, const char *value)
struct ast_party_redirecting * ast_channel_redirecting(struct ast_channel *chan)
struct ast_party_dialed * ast_channel_dialed(struct ast_channel *chan)
#define ast_channel_unref(c)
Decrease channel reference count.
Definition: channel.h:2958
void ast_channel_amaflags_set(struct ast_channel *chan, enum ama_flags value)
void ast_channel_context_set(struct ast_channel *chan, const char *value)
#define ast_dummy_channel_alloc()
Create a fake channel structure.
Definition: channel.h:1282
struct ast_party_caller * ast_channel_caller(struct ast_channel *chan)
#define ast_var_assign(name, value)
Definition: chanvars.h:40
#define ast_datastore_alloc(info, uid)
Definition: datastore.h:85
int ast_datastore_free(struct ast_datastore *datastore)
Free a data store object.
Definition: datastore.c:68
#define AST_LIST_INSERT_HEAD(head, elm, field)
Inserts a list entry at the head of a list.
Definition: linkedlists.h:711
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
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
Helper struct for getting the fields out of a CEL event.
Definition: cel.h:138
const char * caller_id_dnid
Definition: cel.h:157
const char * application_data
Definition: cel.h:162
const char * account_code
Definition: cel.h:163
const char * caller_id_rdnis
Definition: cel.h:156
const char * extra
Definition: cel.h:170
const char * extension
Definition: cel.h:158
const char * caller_id_num
Definition: cel.h:154
const char * channel_name
Definition: cel.h:160
const char * linked_id
Definition: cel.h:166
const char * peer_account
Definition: cel.h:164
const char * peer
Definition: cel.h:169
enum ast_cel_event_type event_type
Definition: cel.h:149
const char * unique_id
Definition: cel.h:165
const char * user_defined_name
Definition: cel.h:152
const char * context
Definition: cel.h:159
const char * application_name
Definition: cel.h:161
struct timeval event_time
Definition: cel.h:150
uint32_t version
struct ABI version
Definition: cel.h:148
const char * user_field
Definition: cel.h:168
const char * caller_id_ani
Definition: cel.h:155
const char * caller_id_name
Definition: cel.h:153
const char * event_name
Definition: cel.h:151
Main Channel structure associated with a channel.
Structure for a data store object.
Definition: datastore.h:64
void * data
Definition: datastore.h:66
struct ast_party_id id
Caller party ID.
Definition: channel.h:420
struct ast_party_id ani
Automatic Number Identification (ANI)
Definition: channel.h:427
struct ast_party_dialed::@208 number
Dialed/Called number.
char * str
Subscriber phone number (Malloced)
Definition: channel.h:386
struct ast_party_name name
Subscriber name.
Definition: channel.h:340
struct ast_party_number number
Subscriber phone number.
Definition: channel.h:342
unsigned char valid
TRUE if the name information is valid/present.
Definition: channel.h:279
char * str
Subscriber name (Malloced)
Definition: channel.h:264
unsigned char valid
TRUE if the number information is valid/present.
Definition: channel.h:297
char * str
Subscriber phone number (Malloced)
Definition: channel.h:291
struct ast_party_id from
Who is redirecting the call (Sent to the party the call is redirected toward)
Definition: channel.h:527
Definition: astman.c:222

References ast_cel_event_record::account_code, ast_cel_event_record::amaflag, ast_party_caller::ani, ao2_cleanup, ao2_global_obj_ref, ast_cel_event_record::application_data, ast_cel_event_record::application_name, AST_CEL_EVENT_RECORD_VERSION, ast_cel_fill_record(), AST_CEL_USER_DEFINED, ast_channel_amaflags_set(), ast_channel_appl_set(), ast_channel_caller(), ast_channel_context_set(), ast_channel_data_set(), ast_channel_datastore_add(), ast_channel_dialed(), ast_channel_exten_set(), ast_channel_internal_set_fake_ids(), ast_channel_redirecting(), ast_channel_unref, ast_channel_varshead(), ast_datastore_alloc, ast_datastore_free(), ast_dummy_channel_alloc, AST_LIST_INSERT_HEAD, ast_localtime(), ast_malloc, ast_strdup, ast_strftime(), ast_strlen_zero(), ast_var_assign, 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, ast_cel_event_record::context, ast_datastore::data, ast_cel_event_record::event_name, ast_cel_event_record::event_time, ast_cel_event_record::event_type, ast_cel_event_record::extension, ast_cel_event_record::extra, fabricated_channel_datastore, ast_party_redirecting::from, ast_party_caller::id, if(), ast_cel_event_record::linked_id, ast_party_id::name, NULL, ast_party_id::number, ast_party_dialed::number, ast_cel_event_record::peer, ast_cel_event_record::peer_account, RAII_VAR, ast_party_name::str, ast_party_number::str, ast_party_dialed::str, ast_cel_event_record::unique_id, ast_cel_event_record::user_defined_name, ast_cel_event_record::user_field, ast_party_name::valid, ast_party_number::valid, and ast_cel_event_record::version.

Referenced by custom_log(), and write_cel().

◆ 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.

Parameters
[in]eventthe CEL event
[out]rthe ast_cel_event_record to fill in
Since
1.8
Return values
0success
non-zerofailure

Definition at line 821 of file cel.c.

822{
824 ast_log(LOG_ERROR, "Module ABI mismatch for ast_cel_event_record. "
825 "Please ensure all modules were compiled for "
826 "this version of Asterisk.\n");
827 return -1;
828 }
829
831
834
838 } else {
839 r->user_defined_name = "";
840 }
841
860
861 return 0;
862}
#define ast_log
Definition: astobj2.c:42
const char * ast_cel_get_type_name(enum ast_cel_event_type type)
Get the name of a CEL event type.
Definition: cel.c:493
uint32_t ast_event_get_ie_uint(const struct ast_event *event, enum ast_event_ie_type ie_type)
Get the value of an information element that has an integer payload.
Definition: event.c:293
const char * ast_event_get_ie_str(const struct ast_event *event, enum ast_event_ie_type ie_type)
Get the value of an information element that has a string payload.
Definition: event.c:302
#define LOG_ERROR

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_get_type_name(), AST_CEL_USER_DEFINED, ast_event_get_ie_str(), ast_event_get_ie_uint(), AST_EVENT_IE_CEL_ACCTCODE, AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_CEL_APPDATA, AST_EVENT_IE_CEL_APPNAME, AST_EVENT_IE_CEL_CHANNAME, AST_EVENT_IE_CEL_CIDANI, AST_EVENT_IE_CEL_CIDDNID, AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_CEL_CIDNUM, AST_EVENT_IE_CEL_CIDRDNIS, AST_EVENT_IE_CEL_CONTEXT, AST_EVENT_IE_CEL_EVENT_TIME, AST_EVENT_IE_CEL_EVENT_TIME_USEC, AST_EVENT_IE_CEL_EVENT_TYPE, AST_EVENT_IE_CEL_EXTEN, AST_EVENT_IE_CEL_EXTRA, AST_EVENT_IE_CEL_LINKEDID, AST_EVENT_IE_CEL_PEER, AST_EVENT_IE_CEL_PEERACCT, AST_EVENT_IE_CEL_UNIQUEID, AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_CEL_USERFIELD, ast_log, 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, ast_cel_event_record::context, ast_cel_event_record::event_name, ast_cel_event_record::event_time, ast_cel_event_record::event_type, ast_cel_event_record::extension, ast_cel_event_record::extra, ast_cel_event_record::linked_id, LOG_ERROR, ast_cel_event_record::peer, ast_cel_event_record::peer_account, S_OR, ast_cel_event_record::unique_id, ast_cel_event_record::user_defined_name, ast_cel_event_record::user_field, and ast_cel_event_record::version.

Referenced by ast_cel_fabricate_channel_from_event(), cel_bs_put(), manager_log(), odbc_log(), pgsql_log(), radius_log(), and tds_log().

◆ ast_cel_general_config_alloc()

void * ast_cel_general_config_alloc ( void  )

Allocate a CEL configuration object.

Return values
NULLon error
Thenew CEL configuration object

Definition at line 189 of file cel.c.

190{
192
193 if (!(cfg = ao2_alloc(sizeof(*cfg), cel_general_config_dtor))) {
194 return NULL;
195 }
196
197 if (ast_string_field_init(cfg, 64)) {
198 return NULL;
199 }
200
201 if (!(cfg->apps = ast_str_container_alloc(NUM_APP_BUCKETS))) {
202 return NULL;
203 }
204
205 ao2_ref(cfg, +1);
206 return cfg;
207}
#define ao2_alloc(data_size, destructor_fn)
Definition: astobj2.h:409
static void cel_general_config_dtor(void *obj)
Destructor for cel_config.
Definition: cel.c:181
#define NUM_APP_BUCKETS
Number of buckets for the appset container.
Definition: cel.c:156
#define ast_string_field_init(x, size)
Initialize a field pool and fields.
Definition: stringfields.h:359
#define ast_str_container_alloc(buckets)
Allocates a hash container for bare strings.
Definition: strings.h:1365

References ao2_alloc, ao2_cleanup, ao2_ref, ast_str_container_alloc, ast_string_field_init, cel_general_config_dtor(), NULL, NUM_APP_BUCKETS, and RAII_VAR.

Referenced by cel_config_alloc(), and load_module().

◆ ast_cel_get_config()

struct ast_cel_general_config * ast_cel_get_config ( void  )

Obtain the current CEL configuration.

Since
12

The configuration is a ref counted object. The caller of this function must decrement the ref count when finished with the configuration.

Return values
NULLon error
Thecurrent CEL configuration

Definition at line 1731 of file cel.c.

1732{
1733 RAII_VAR(struct cel_config *, mod_cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
1734
1735 if (!mod_cfg || !mod_cfg->general) {
1736 return NULL;
1737 }
1738
1739 ao2_ref(mod_cfg->general, +1);
1740 return mod_cfg->general;
1741}

References ao2_cleanup, ao2_global_obj_ref, ao2_ref, NULL, and RAII_VAR.

Referenced by test_cel_init_cb().

◆ ast_cel_get_type_name()

const char * ast_cel_get_type_name ( enum ast_cel_event_type  type)

Get the name of a CEL event type.

Parameters
typethe type to get the name of
Since
1.8
Returns
the string representation of the type

Definition at line 493 of file cel.c.

494{
495 return S_OR(cel_event_types[type], "Unknown");
496}
static const char *const cel_event_types[CEL_MAX_EVENT_IDS]
Map of ast_cel_event_type to strings.
Definition: cel.c:306
static const char type[]
Definition: chan_ooh323.c:109

References cel_event_types, S_OR, and type.

Referenced by ast_cel_fill_record(), cel_generic_cb(), dump_event(), and handle_cli_status().

◆ ast_cel_publish_event()

void ast_cel_publish_event ( struct ast_channel chan,
enum ast_cel_event_type  event_type,
struct ast_json blob 
)

Publish a CEL event.

Since
12
Parameters
chanThis is the primary channel associated with this channel event.
event_typeThis is the type of call event being reported.
blobThis contains any additional parameters that need to be conveyed for this event.

Definition at line 1707 of file cel.c.

1710{
1711 struct ast_json *cel_blob;
1712 struct stasis_message *message;
1713
1714 cel_blob = ast_json_pack("{s: i, s: o}",
1715 "event_type", event_type,
1716 "event_details", ast_json_ref(blob));
1717
1719 if (message) {
1721 }
1723 ast_json_unref(cel_blob);
1724}
struct stasis_topic * ast_cel_topic(void)
Get the CEL topic.
Definition: cel.c:1726
struct stasis_message_type * cel_generic_type(void)
const char * ast_channel_uniqueid(const struct ast_channel *chan)
struct stasis_message * ast_channel_blob_create_from_cache(const char *uniqueid, struct stasis_message_type *type, struct ast_json *blob)
Create a ast_channel_blob message, pulling channel state from the cache.
void ast_json_unref(struct ast_json *value)
Decrease refcount on value. If refcount reaches zero, value is freed.
Definition: json.c:73
struct ast_json * ast_json_pack(char const *format,...)
Helper for creating complex JSON values.
Definition: json.c:612
struct ast_json * ast_json_ref(struct ast_json *value)
Increase refcount on value.
Definition: json.c:67
void stasis_publish(struct stasis_topic *topic, struct stasis_message *message)
Publish a message to a topic's subscribers.
Definition: stasis.c:1511
Abstract JSON element (object, array, string, int, ...).

References ao2_cleanup, ast_cel_topic(), ast_channel_blob_create_from_cache(), ast_channel_uniqueid(), ast_json_pack(), ast_json_ref(), ast_json_unref(), cel_generic_type(), and stasis_publish().

Referenced by ast_cel_publish_user_event(), and celgenuserevent_exec().

◆ ast_cel_publish_user_event()

void ast_cel_publish_user_event ( struct ast_channel chan,
const char *  event,
const char *  extra 
)

Publish a CEL user event.

Since
18
Note
This serves as a wrapper function around ast_cel_publish_event() to help pack the extra details before publishing.
Parameters
chanThis is the primary channel associated with this channel event.
eventThis is the user event being reported.
extraThis contains any extra parameters that need to be conveyed for this event.

Definition at line 1692 of file cel.c.

1695{
1696 RAII_VAR(struct ast_json *, blob, NULL, ast_json_unref);
1697
1698 blob = ast_json_pack("{s: s, s: {s: s}}",
1699 "event", event,
1700 "extra", "extra", S_OR(extra, ""));
1701 if (!blob) {
1702 return;
1703 }
1705}
void ast_cel_publish_event(struct ast_channel *chan, enum ast_cel_event_type event_type, struct ast_json *blob)
Publish a CEL event.
Definition: cel.c:1707

References ast_cel_publish_event(), AST_CEL_USER_DEFINED, ast_json_pack(), ast_json_unref(), NULL, RAII_VAR, and S_OR.

◆ ast_cel_set_config()

void ast_cel_set_config ( struct ast_cel_general_config config)

Set the current CEL configuration.

Since
12
Parameters
configThe new CEL configuration

Definition at line 1743 of file cel.c.

1744{
1745 int was_enabled;
1746 int is_enabled;
1747 struct ast_cel_general_config *cleanup_config;
1748 struct cel_config *mod_cfg = ao2_global_obj_ref(cel_configs);
1749
1750 if (mod_cfg) {
1751 was_enabled = ast_cel_check_enabled();
1752
1753 cleanup_config = mod_cfg->general;
1755 mod_cfg->general = config;
1756 ao2_cleanup(cleanup_config);
1757
1759 if (!was_enabled && is_enabled) {
1760 create_routes();
1761 } else if (was_enabled && !is_enabled) {
1763 }
1764
1765 ao2_ref(mod_cfg, -1);
1766 }
1767}
#define ao2_bump(obj)
Bump refcount on an AO2 object by one, returning the object.
Definition: astobj2.h:480
static void destroy_routes(void)
Definition: cel.c:1437
static int create_routes(void)
Create the Stasis message router and routes for CEL.
Definition: cel.c:1521
unsigned int ast_cel_check_enabled(void)
Hashing function for cel_backend.
Definition: cel.c:345
static const char config[]
Definition: chan_ooh323.c:111
static int is_enabled(void)
Helper function to check if module is enabled.
Definition: res_ari.c:159

References ao2_bump, ao2_cleanup, ao2_global_obj_ref, ao2_ref, ast_cel_check_enabled(), config, create_routes(), destroy_routes(), cel_config::general, and is_enabled().

Referenced by cel_verify_and_cleanup_cb(), and test_cel_init_cb().

◆ ast_cel_str_to_event_type()

enum ast_cel_event_type ast_cel_str_to_event_type ( const char *  name)

Get the event type from a string.

Parameters
namethe event type name as a string
Since
1.8
Returns
the ast_cel_event_type given by the string

Definition at line 420 of file cel.c.

421{
422 unsigned int i;
423
424 for (i = 0; i < ARRAY_LEN(cel_event_types); i++) {
425 if (cel_event_types[i] && !strcasecmp(name, cel_event_types[i])) {
426 return i;
427 }
428 }
429
430 ast_log(LOG_ERROR, "Unknown event name '%s'\n", name);
432}
@ AST_CEL_INVALID_VALUE
Definition: cel.h:42
#define ARRAY_LEN(a)
Definition: utils.h:666

References ARRAY_LEN, AST_CEL_INVALID_VALUE, ast_log, cel_event_types, LOG_ERROR, and name.

Referenced by events_handler().

◆ ast_cel_topic()

struct stasis_topic * ast_cel_topic ( void  )

Get the CEL topic.

Return values
TheCEL topic
NULLif not allocated

Definition at line 1726 of file cel.c.

1727{
1728 return cel_topic;
1729}
static struct stasis_topic * cel_topic
Definition: cel.c:118

References cel_topic.

Referenced by ast_cel_publish_event(), and create_subscriptions().

◆ ast_cel_track_event()

static int ast_cel_track_event ( enum ast_cel_event_type  et)
static

Definition at line 434 of file cel.c.

435{
436 RAII_VAR(struct cel_config *, cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
437
438 if (!cfg || !cfg->general) {
439 return 0;
440 }
441
442 return (cfg->general->events & ((int64_t) 1 << et)) ? 1 : 0;
443}

References ao2_cleanup, ao2_global_obj_ref, and RAII_VAR.

Referenced by cel_channel_linkedid_change(), cel_channel_state_change(), and cel_report_event().

◆ AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM ( void  )

Definition at line 1811 of file cel.c.

◆ cel_attended_transfer_cb()

static void cel_attended_transfer_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 1307 of file cel.c.

1310{
1312 struct ast_json *extra = NULL;
1313 struct ast_bridge_snapshot *bridge1, *bridge2;
1314 struct ast_channel_snapshot *channel1, *channel2;
1315
1316 /* Make sure bridge1 is always non-NULL */
1317 if (!xfer->to_transferee.bridge_snapshot) {
1318 bridge1 = xfer->to_transfer_target.bridge_snapshot;
1319 bridge2 = xfer->to_transferee.bridge_snapshot;
1320 channel1 = xfer->to_transfer_target.channel_snapshot;
1321 channel2 = xfer->to_transferee.channel_snapshot;
1322 } else {
1323 bridge1 = xfer->to_transferee.bridge_snapshot;
1324 bridge2 = xfer->to_transfer_target.bridge_snapshot;
1325 channel1 = xfer->to_transferee.channel_snapshot;
1326 channel2 = xfer->to_transfer_target.channel_snapshot;
1327 }
1328
1329 switch (xfer->dest_type) {
1331 return;
1332 /* handle these three the same */
1336 extra = ast_json_pack("{s: s, s: s, s: s, s: s, s: s, s: s, s: s, s: s}",
1337 "bridge1_id", bridge1->uniqueid,
1338 "channel2_name", channel2->base->name,
1339 "channel2_uniqueid", channel2->base->uniqueid,
1340 "bridge2_id", bridge2->uniqueid,
1341 "transferee_channel_name", xfer->transferee ? xfer->transferee->base->name : "N/A",
1342 "transferee_channel_uniqueid", xfer->transferee ? xfer->transferee->base->uniqueid : "N/A",
1343 "transfer_target_channel_name", xfer->target ? xfer->target->base->name : "N/A",
1344 "transfer_target_channel_uniqueid", xfer->target ? xfer->target->base->uniqueid : "N/A");
1345 if (!extra) {
1346 return;
1347 }
1348 break;
1351 extra = ast_json_pack("{s: s, s: s, s: s, s: s, s: s, s: s, s: s, s: s}",
1352 "bridge1_id", bridge1->uniqueid,
1353 "channel2_name", channel2->base->name,
1354 "channel2_uniqueid", channel2->base->uniqueid,
1355 "app", xfer->dest.app,
1356 "transferee_channel_name", xfer->transferee ? xfer->transferee->base->name : "N/A",
1357 "transferee_channel_uniqueid", xfer->transferee ? xfer->transferee->base->uniqueid : "N/A",
1358 "transfer_target_channel_name", xfer->target ? xfer->target->base->name : "N/A",
1359 "transfer_target_channel_uniqueid", xfer->target ? xfer->target->base->uniqueid : "N/A");
1360 if (!extra) {
1361 return;
1362 }
1363 break;
1364 }
1366 NULL, extra, NULL);
1367 ast_json_unref(extra);
1368}
static int cel_report_event(struct ast_channel_snapshot *snapshot, enum ast_cel_event_type event_type, const struct timeval *event_time, const char *userdefevname, struct ast_json *extra, const char *peer_str)
Definition: cel.c:571
@ AST_CEL_ATTENDEDTRANSFER
a transfer occurs
Definition: cel.h:67
void * stasis_message_data(const struct stasis_message *msg)
Get the data contained in a message.
const struct timeval * stasis_message_timestamp(const struct stasis_message *msg)
Get the time when a message was created.
@ AST_ATTENDED_TRANSFER_DEST_FAIL
@ AST_ATTENDED_TRANSFER_DEST_BRIDGE_MERGE
@ AST_ATTENDED_TRANSFER_DEST_LOCAL_APP
@ AST_ATTENDED_TRANSFER_DEST_LINK
@ AST_ATTENDED_TRANSFER_DEST_APP
@ AST_ATTENDED_TRANSFER_DEST_THREEWAY
Message representing attended transfer.
union ast_attended_transfer_message::@284 dest
enum ast_attended_transfer_dest_type dest_type
struct ast_bridge_channel_snapshot_pair to_transfer_target
struct ast_channel_snapshot * transferee
struct ast_bridge_channel_snapshot_pair to_transferee
struct ast_channel_snapshot * target
struct ast_bridge_snapshot * bridge_snapshot
struct ast_channel_snapshot * channel_snapshot
Structure that contains a snapshot of information about a bridge.
Definition: bridge.h:314
const ast_string_field uniqueid
Definition: bridge.h:328
Structure representing a snapshot of channel state.

References ast_attended_transfer_message::app, AST_ATTENDED_TRANSFER_DEST_APP, AST_ATTENDED_TRANSFER_DEST_BRIDGE_MERGE, AST_ATTENDED_TRANSFER_DEST_FAIL, AST_ATTENDED_TRANSFER_DEST_LINK, AST_ATTENDED_TRANSFER_DEST_LOCAL_APP, AST_ATTENDED_TRANSFER_DEST_THREEWAY, AST_CEL_ATTENDEDTRANSFER, ast_json_pack(), ast_json_unref(), ast_channel_snapshot::base, ast_bridge_channel_snapshot_pair::bridge_snapshot, cel_report_event(), ast_bridge_channel_snapshot_pair::channel_snapshot, ast_attended_transfer_message::dest, ast_attended_transfer_message::dest_type, ast_channel_snapshot_base::name, NULL, stasis_message_data(), stasis_message_timestamp(), ast_attended_transfer_message::target, ast_attended_transfer_message::to_transfer_target, ast_attended_transfer_message::to_transferee, ast_attended_transfer_message::transferee, ast_bridge_snapshot::uniqueid, and ast_channel_snapshot_base::uniqueid.

Referenced by create_routes().

◆ cel_backend_send_cb()

static int cel_backend_send_cb ( void *  obj,
void *  arg,
int  flags 
)
static

Definition at line 563 of file cel.c.

564{
565 struct cel_backend *backend = obj;
566
567 backend->callback(arg);
568 return 0;
569}

References cel_backend::callback.

Referenced by cel_report_event().

◆ cel_blind_transfer_cb()

static void cel_blind_transfer_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 1281 of file cel.c.

1284{
1286 struct ast_channel_snapshot *chan_snapshot = transfer_msg->transferer;
1287 struct ast_bridge_snapshot *bridge_snapshot = transfer_msg->bridge;
1288 struct ast_json *extra;
1289
1290 if (transfer_msg->result != AST_BRIDGE_TRANSFER_SUCCESS) {
1291 return;
1292 }
1293
1294 extra = ast_json_pack("{s: s, s: s, s: s, s: s, s: s}",
1295 "extension", transfer_msg->exten,
1296 "context", transfer_msg->context,
1297 "bridge_id", bridge_snapshot->uniqueid,
1298 "transferee_channel_name", transfer_msg->transferee ? transfer_msg->transferee->base->name : "N/A",
1299 "transferee_channel_uniqueid", transfer_msg->transferee ? transfer_msg->transferee->base->uniqueid : "N/A");
1300 if (extra) {
1302 NULL, extra, NULL);
1303 ast_json_unref(extra);
1304 }
1305}
@ AST_BRIDGE_TRANSFER_SUCCESS
Definition: bridge.h:1100
@ AST_CEL_BLINDTRANSFER
a transfer occurs
Definition: cel.h:65
Message published during a blind transfer.
char exten[AST_MAX_EXTENSION]
struct ast_bridge_snapshot * bridge
struct ast_channel_snapshot * transferer
struct ast_channel_snapshot * transferee
enum ast_transfer_result result
char context[AST_MAX_CONTEXT]

References AST_BRIDGE_TRANSFER_SUCCESS, AST_CEL_BLINDTRANSFER, ast_json_pack(), ast_json_unref(), ast_channel_snapshot::base, ast_blind_transfer_message::bridge, cel_report_event(), ast_blind_transfer_message::context, ast_blind_transfer_message::exten, ast_channel_snapshot_base::name, NULL, ast_blind_transfer_message::result, stasis_message_data(), stasis_message_timestamp(), ast_blind_transfer_message::transferee, ast_blind_transfer_message::transferer, ast_bridge_snapshot::uniqueid, and ast_channel_snapshot_base::uniqueid.

Referenced by create_routes().

◆ cel_bridge_enter_cb()

static void cel_bridge_enter_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 1049 of file cel.c.

1052{
1054 struct ast_bridge_snapshot *snapshot = blob->bridge;
1055 struct ast_channel_snapshot *chan_snapshot = blob->channel;
1056 RAII_VAR(struct ast_json *, extra, NULL, ast_json_unref);
1057 RAII_VAR(struct ast_str *, peer_str, NULL, ast_free);
1058
1059 if (cel_filter_channel_snapshot(chan_snapshot)) {
1060 return;
1061 }
1062
1063 extra = ast_json_pack("{s: s, s: s}",
1064 "bridge_id", snapshot->uniqueid,
1065 "bridge_technology", snapshot->technology);
1066 if (!extra) {
1067 return;
1068 }
1069
1070 peer_str = cel_generate_peer_str(snapshot, chan_snapshot);
1071 if (!peer_str) {
1072 return;
1073 }
1074
1076 NULL, extra, ast_str_buffer(peer_str));
1077}
#define ast_free(a)
Definition: astmm.h:180
static int cel_filter_channel_snapshot(struct ast_channel_snapshot *snapshot)
Definition: cel.c:988
static struct ast_str * cel_generate_peer_str(struct ast_bridge_snapshot *bridge, struct ast_channel_snapshot *chan)
Definition: cel.c:1011
@ AST_CEL_BRIDGE_ENTER
channel enters a bridge
Definition: cel.h:57
char * ast_str_buffer(const struct ast_str *buf)
Returns the string buffer within the ast_str buf.
Definition: strings.h:761
Blob of data associated with a bridge.
struct ast_bridge_snapshot * bridge
struct ast_channel_snapshot * channel
struct ast_json * blob
const ast_string_field technology
Definition: bridge.h:328
Support for dynamic strings.
Definition: strings.h:623

References AST_CEL_BRIDGE_ENTER, ast_free, ast_json_pack(), ast_json_unref(), ast_str_buffer(), ast_bridge_blob::blob, ast_bridge_blob::bridge, cel_filter_channel_snapshot(), cel_generate_peer_str(), cel_report_event(), ast_bridge_blob::channel, NULL, RAII_VAR, stasis_message_data(), stasis_message_timestamp(), ast_bridge_snapshot::technology, and ast_bridge_snapshot::uniqueid.

Referenced by create_routes().

◆ cel_bridge_leave_cb()

static void cel_bridge_leave_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 1079 of file cel.c.

1082{
1084 struct ast_bridge_snapshot *snapshot = blob->bridge;
1085 struct ast_channel_snapshot *chan_snapshot = blob->channel;
1086 RAII_VAR(struct ast_json *, extra, NULL, ast_json_unref);
1087 RAII_VAR(struct ast_str *, peer_str, NULL, ast_free);
1088
1089 if (cel_filter_channel_snapshot(chan_snapshot)) {
1090 return;
1091 }
1092
1093 extra = ast_json_pack("{s: s, s: s}",
1094 "bridge_id", snapshot->uniqueid,
1095 "bridge_technology", snapshot->technology);
1096 if (!extra) {
1097 return;
1098 }
1099
1100 peer_str = cel_generate_peer_str(snapshot, chan_snapshot);
1101 if (!peer_str) {
1102 return;
1103 }
1104
1106 NULL, extra, ast_str_buffer(peer_str));
1107}
@ AST_CEL_BRIDGE_EXIT
channel exits a bridge
Definition: cel.h:59

References AST_CEL_BRIDGE_EXIT, ast_free, ast_json_pack(), ast_json_unref(), ast_str_buffer(), ast_bridge_blob::blob, ast_bridge_blob::bridge, cel_filter_channel_snapshot(), cel_generate_peer_str(), cel_report_event(), ast_bridge_blob::channel, NULL, RAII_VAR, stasis_message_data(), stasis_message_timestamp(), ast_bridge_snapshot::technology, and ast_bridge_snapshot::uniqueid.

Referenced by create_routes().

◆ cel_channel_app_change()

static void cel_channel_app_change ( struct ast_channel_snapshot old_snapshot,
struct ast_channel_snapshot new_snapshot,
const struct timeval *  event_time 
)
static

Definition at line 957 of file cel.c.

961{
962 if (old_snapshot && !strcmp(old_snapshot->dialplan->appl, new_snapshot->dialplan->appl)) {
963 return;
964 }
965
966 /* old snapshot has an application, end it */
967 if (old_snapshot && !ast_strlen_zero(old_snapshot->dialplan->appl)) {
968 cel_report_event(old_snapshot, AST_CEL_APP_END, event_time, NULL, NULL, NULL);
969 }
970
971 /* new snapshot has an application, start it */
972 if (!ast_strlen_zero(new_snapshot->dialplan->appl)) {
973 cel_report_event(new_snapshot, AST_CEL_APP_START, event_time, NULL, NULL, NULL);
974 }
975}
@ AST_CEL_APP_END
an app ends
Definition: cel.h:55
@ AST_CEL_APP_START
an app starts
Definition: cel.h:53

References ast_channel_snapshot_dialplan::appl, AST_CEL_APP_END, AST_CEL_APP_START, ast_strlen_zero(), cel_report_event(), ast_channel_snapshot::dialplan, and NULL.

◆ cel_channel_linkedid_change()

static void cel_channel_linkedid_change ( struct ast_channel_snapshot old_snapshot,
struct ast_channel_snapshot new_snapshot,
const struct timeval *  event_time 
)
static

Definition at line 938 of file cel.c.

942{
943 if (!old_snapshot) {
944 return;
945 }
946
947 ast_assert(!ast_strlen_zero(new_snapshot->peer->linkedid));
948 ast_assert(!ast_strlen_zero(old_snapshot->peer->linkedid));
949
951 && strcmp(old_snapshot->peer->linkedid, new_snapshot->peer->linkedid)) {
952 cel_linkedid_ref(new_snapshot->peer->linkedid);
953 check_retire_linkedid(old_snapshot, event_time);
954 }
955}
static int cel_linkedid_ref(const char *linkedid)
Definition: cel.c:783
static int ast_cel_track_event(enum ast_cel_event_type et)
Definition: cel.c:434
static void check_retire_linkedid(struct ast_channel_snapshot *snapshot, const struct timeval *event_time)
Definition: cel.c:616
@ AST_CEL_LINKEDID_END
the last channel with the given linkedid is retired
Definition: cel.h:71
#define ast_assert(a)
Definition: utils.h:739

References ast_assert, AST_CEL_LINKEDID_END, ast_cel_track_event(), ast_strlen_zero(), cel_linkedid_ref(), check_retire_linkedid(), ast_channel_snapshot_peer::linkedid, and ast_channel_snapshot::peer.

◆ cel_channel_state_change()

static void cel_channel_state_change ( struct ast_channel_snapshot old_snapshot,
struct ast_channel_snapshot new_snapshot,
const struct timeval *  event_time 
)
static

Handle channel state changes.

Definition at line 898 of file cel.c.

902{
903 int is_hungup, was_hungup;
904
905 if (!old_snapshot) {
906 cel_report_event(new_snapshot, AST_CEL_CHANNEL_START, event_time, NULL, NULL, NULL);
907 return;
908 }
909
910 was_hungup = ast_test_flag(&old_snapshot->flags, AST_FLAG_DEAD) ? 1 : 0;
911 is_hungup = ast_test_flag(&new_snapshot->flags, AST_FLAG_DEAD) ? 1 : 0;
912
913 if (!was_hungup && is_hungup) {
914 struct ast_json *extra;
915 struct cel_dialstatus *dialstatus = get_dialstatus(new_snapshot->base->uniqueid);
916
917 extra = ast_json_pack("{s: i, s: s, s: s}",
918 "hangupcause", new_snapshot->hangup->cause,
919 "hangupsource", new_snapshot->hangup->source,
920 "dialstatus", dialstatus ? dialstatus->dialstatus : "");
921 cel_report_event(new_snapshot, AST_CEL_HANGUP, event_time, NULL, extra, NULL);
922 ast_json_unref(extra);
924
925 cel_report_event(new_snapshot, AST_CEL_CHANNEL_END, event_time, NULL, NULL, NULL);
927 check_retire_linkedid(new_snapshot, event_time);
928 }
929 return;
930 }
931
932 if (old_snapshot->state != new_snapshot->state && new_snapshot->state == AST_STATE_UP) {
933 cel_report_event(new_snapshot, AST_CEL_ANSWER, event_time, NULL, NULL, NULL);
934 return;
935 }
936}
static struct cel_dialstatus * get_dialstatus(const char *uniqueid)
Definition: cel.c:870
@ AST_CEL_CHANNEL_END
channel end
Definition: cel.h:47
@ AST_CEL_ANSWER
A ringing phone is answered.
Definition: cel.h:51
@ AST_CEL_HANGUP
hangup terminates connection
Definition: cel.h:49
@ AST_CEL_CHANNEL_START
channel birth
Definition: cel.h:45
@ AST_FLAG_DEAD
Definition: channel.h:1045
@ AST_STATE_UP
Definition: channelstate.h:42
enum ast_channel_state state
struct ast_flags flags
struct ast_channel_snapshot_hangup * hangup
char dialstatus[0]
Definition: cel.c:177
#define ast_test_flag(p, flag)
Definition: utils.h:63

References ao2_cleanup, AST_CEL_ANSWER, AST_CEL_CHANNEL_END, AST_CEL_CHANNEL_START, AST_CEL_HANGUP, AST_CEL_LINKEDID_END, ast_cel_track_event(), AST_FLAG_DEAD, ast_json_pack(), ast_json_unref(), AST_STATE_UP, ast_test_flag, ast_channel_snapshot::base, ast_channel_snapshot_hangup::cause, cel_report_event(), check_retire_linkedid(), cel_dialstatus::dialstatus, ast_channel_snapshot::flags, get_dialstatus(), ast_channel_snapshot::hangup, NULL, ast_channel_snapshot_hangup::source, ast_channel_snapshot::state, and ast_channel_snapshot_base::uniqueid.

◆ cel_config_alloc()

static void * cel_config_alloc ( void  )
static

Definition at line 225 of file cel.c.

226{
227 RAII_VAR(struct cel_config *, cfg, NULL, ao2_cleanup);
228
229 if (!(cfg = ao2_alloc(sizeof(*cfg), cel_config_dtor))) {
230 return NULL;
231 }
232
233 if (!(cfg->general = ast_cel_general_config_alloc())) {
234 return NULL;
235 }
236
237 ao2_ref(cfg, +1);
238 return cfg;
239}
void * ast_cel_general_config_alloc(void)
Allocate a CEL configuration object.
Definition: cel.c:189
static void cel_config_dtor(void *obj)
Destructor for cel_config.
Definition: cel.c:218

References ao2_alloc, ao2_cleanup, ao2_ref, ast_cel_general_config_alloc(), cel_config_dtor(), NULL, and RAII_VAR.

Referenced by load_module().

◆ cel_config_dtor()

static void cel_config_dtor ( void *  obj)
static

Destructor for cel_config.

Definition at line 218 of file cel.c.

219{
220 struct cel_config *cfg = obj;
221 ao2_cleanup(cfg->general);
222 cfg->general = NULL;
223}

References ao2_cleanup, cel_config::general, and NULL.

Referenced by cel_config_alloc().

◆ cel_dial_cb()

static void cel_dial_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 1231 of file cel.c.

1233{
1235 struct ast_channel_snapshot *snapshot;
1236
1237 snapshot = ast_multi_channel_blob_get_channel(blob, "caller");
1238 if (!snapshot || cel_filter_channel_snapshot(snapshot)) {
1239 return;
1240 }
1241
1242 if (!ast_strlen_zero(get_blob_variable(blob, "forward"))) {
1243 struct ast_json *extra;
1244
1245 extra = ast_json_pack("{s: s}", "forward", get_blob_variable(blob, "forward"));
1246 if (extra) {
1248 NULL, extra, NULL);
1249 ast_json_unref(extra);
1250 }
1251 }
1252
1253 if (is_valid_dialstatus(blob)) {
1254 save_dialstatus(blob, snapshot);
1255 }
1256}
static int is_valid_dialstatus(struct ast_multi_channel_blob *blob)
Definition: cel.c:1202
static void save_dialstatus(struct ast_multi_channel_blob *blob, struct ast_channel_snapshot *snapshot)
Definition: cel.c:1158
static const char * get_blob_variable(struct ast_multi_channel_blob *blob, const char *varname)
Definition: cel.c:882
@ AST_CEL_FORWARD
this call was forwarded somewhere else
Definition: cel.h:75
struct ast_channel_snapshot * ast_multi_channel_blob_get_channel(struct ast_multi_channel_blob *obj, const char *role)
Retrieve a channel snapshot associated with a specific role from a ast_multi_channel_blob.
A multi channel blob data structure for multi_channel_blob stasis messages.
struct ast_json * blob

References AST_CEL_FORWARD, ast_json_pack(), ast_json_unref(), ast_multi_channel_blob_get_channel(), ast_strlen_zero(), ast_multi_channel_blob::blob, cel_filter_channel_snapshot(), cel_report_event(), get_blob_variable(), is_valid_dialstatus(), NULL, save_dialstatus(), stasis_message_data(), and stasis_message_timestamp().

Referenced by create_routes().

◆ cel_filter_channel_snapshot()

static int cel_filter_channel_snapshot ( struct ast_channel_snapshot snapshot)
static

Definition at line 988 of file cel.c.

989{
990 if (!snapshot) {
991 return 0;
992 }
993 return snapshot->base->tech_properties & AST_CHAN_TP_INTERNAL;
994}
@ AST_CHAN_TP_INTERNAL
Channels with this particular technology are an implementation detail of Asterisk and should generall...
Definition: channel.h:971

References AST_CHAN_TP_INTERNAL, ast_channel_snapshot::base, and ast_channel_snapshot_base::tech_properties.

Referenced by cel_bridge_enter_cb(), cel_bridge_leave_cb(), cel_dial_cb(), and cel_snapshot_update_cb().

◆ cel_general_config_dtor()

static void cel_general_config_dtor ( void *  obj)
static

Destructor for cel_config.

Definition at line 181 of file cel.c.

182{
183 struct ast_cel_general_config *cfg = obj;
185 ao2_cleanup(cfg->apps);
186 cfg->apps = NULL;
187}
#define ast_string_field_free_memory(x)
free all memory - to be called before destroying the object
Definition: stringfields.h:374

References ao2_cleanup, ast_cel_general_config::apps, ast_string_field_free_memory, and NULL.

Referenced by ast_cel_general_config_alloc().

◆ cel_generate_peer_str()

static struct ast_str * cel_generate_peer_str ( struct ast_bridge_snapshot bridge,
struct ast_channel_snapshot chan 
)
static

Definition at line 1011 of file cel.c.

1014{
1015 struct ast_str *peer_str = ast_str_create(32);
1016 struct ao2_iterator i;
1017 char *current_chan = NULL;
1018
1019 if (!peer_str) {
1020 return NULL;
1021 }
1022
1023 for (i = ao2_iterator_init(bridge->channels, 0);
1024 (current_chan = ao2_iterator_next(&i));
1025 ao2_cleanup(current_chan)) {
1026 struct ast_channel_snapshot *current_snapshot;
1027
1028 /* Don't add the channel for which this message is being generated */
1029 if (!strcmp(current_chan, chan->base->uniqueid)) {
1030 continue;
1031 }
1032
1033 current_snapshot = ast_channel_snapshot_get_latest(current_chan);
1034 if (!current_snapshot) {
1035 continue;
1036 }
1037
1038 ast_str_append(&peer_str, 0, "%s,", current_snapshot->base->name);
1039 ao2_cleanup(current_snapshot);
1040 }
1042
1043 /* Rip off the trailing comma */
1044 ast_str_truncate(peer_str, -1);
1045
1046 return peer_str;
1047}
#define ao2_iterator_next(iter)
Definition: astobj2.h:1911
struct ao2_iterator ao2_iterator_init(struct ao2_container *c, int flags) attribute_warn_unused_result
Create an iterator for a container.
void ao2_iterator_destroy(struct ao2_iterator *iter)
Destroy a container iterator.
struct ast_channel_snapshot * ast_channel_snapshot_get_latest(const char *uniqueid)
Obtain the latest ast_channel_snapshot from the Stasis Message Bus API cache. This is an ao2 object,...
char * ast_str_truncate(struct ast_str *buf, ssize_t len)
Truncates the enclosed string to the given length.
Definition: strings.h:786
int ast_str_append(struct ast_str **buf, ssize_t max_len, const char *fmt,...)
Append to a thread local dynamic string.
Definition: strings.h:1139
#define ast_str_create(init_len)
Create a malloc'ed dynamic length string.
Definition: strings.h:659
When we need to walk through a container, we use an ao2_iterator to keep track of the current positio...
Definition: astobj2.h:1821
struct ao2_container * channels
Definition: bridge.h:331

References ao2_cleanup, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ast_channel_snapshot_get_latest(), ast_str_append(), ast_str_create, ast_str_truncate(), ast_channel_snapshot::base, ast_bridge_snapshot::channels, ast_channel_snapshot_base::name, NULL, and ast_channel_snapshot_base::uniqueid.

Referenced by cel_bridge_enter_cb(), and cel_bridge_leave_cb().

◆ cel_generic_cb()

static void cel_generic_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 1258 of file cel.c.

1261{
1263 int event_type = ast_json_integer_get(ast_json_object_get(obj->blob, "event_type"));
1264 struct ast_json *event_details = ast_json_object_get(obj->blob, "event_details");
1265
1266 switch (event_type) {
1268 {
1269 const char *event = ast_json_string_get(ast_json_object_get(event_details, "event"));
1270 struct ast_json *extra = ast_json_object_get(event_details, "extra");
1272 event, extra, NULL);
1273 break;
1274 }
1275 default:
1276 ast_log(LOG_ERROR, "Unhandled %s event blob\n", ast_cel_get_type_name(event_type));
1277 break;
1278 }
1279}
const char * ast_json_string_get(const struct ast_json *string)
Get the value of a JSON string.
Definition: json.c:283
struct ast_json * ast_json_object_get(struct ast_json *object, const char *key)
Get a field from a JSON object.
Definition: json.c:407
intmax_t ast_json_integer_get(const struct ast_json *integer)
Get the value from a JSON integer.
Definition: json.c:332
Blob of data associated with a channel.
struct ast_channel_snapshot * snapshot
struct ast_json * blob

References ast_cel_get_type_name(), AST_CEL_USER_DEFINED, ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_log, ast_channel_blob::blob, cel_report_event(), LOG_ERROR, NULL, ast_channel_blob::snapshot, stasis_message_data(), and stasis_message_timestamp().

Referenced by create_routes().

◆ cel_generic_type()

struct stasis_message_type * cel_generic_type ( void  )

◆ cel_linkedid_ref()

static int cel_linkedid_ref ( const char *  linkedid)
static

Definition at line 783 of file cel.c.

784{
785 RAII_VAR(struct ao2_container *, linkedids, ao2_global_obj_ref(cel_linkedids), ao2_cleanup);
786 struct cel_linkedid *lid;
787
788 if (ast_strlen_zero(linkedid)) {
789 ast_log(LOG_ERROR, "The linkedid should never be empty\n");
790 return -1;
791 }
792 if (!linkedids) {
793 /* The CEL module is shutdown. Abort. */
794 return -1;
795 }
796
797 ao2_lock(linkedids);
798 lid = ao2_find(linkedids, (void *) linkedid, OBJ_SEARCH_KEY);
799 if (!lid) {
800 /*
801 * Changes to the lid->count member are protected by the
802 * container lock so the lid object does not need its own lock.
803 */
804 lid = ao2_alloc_options(sizeof(*lid) + strlen(linkedid) + 1, NULL,
806 if (!lid) {
807 ao2_unlock(linkedids);
808 return -1;
809 }
810 strcpy(lid->id, linkedid);/* Safe */
811
812 ao2_link(linkedids, lid);
813 }
814 ++lid->count;
815 ao2_unlock(linkedids);
816 ao2_ref(lid, -1);
817
818 return 0;
819}
#define ao2_unlock(a)
Definition: astobj2.h:729
#define ao2_lock(a)
Definition: astobj2.h:717
unsigned int count
Definition: cel.c:165
char id[0]
Definition: cel.c:167

References AO2_ALLOC_OPT_LOCK_NOLOCK, ao2_alloc_options, ao2_cleanup, ao2_find, ao2_global_obj_ref, ao2_link, ao2_lock, ao2_ref, ao2_unlock, ast_log, ast_strlen_zero(), cel_linkedid::count, cel_linkedid::id, LOG_ERROR, NULL, OBJ_SEARCH_KEY, and RAII_VAR.

Referenced by cel_channel_linkedid_change(), and cel_report_event().

◆ cel_local_optimization_begin_cb()

static void cel_local_optimization_begin_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 1430 of file cel.c.

1433{
1435}
static void cel_local_optimization_cb_helper(void *data, struct stasis_subscription *sub, struct stasis_message *message, enum ast_cel_event_type event_type)
Definition: cel.c:1395
@ AST_CEL_LOCAL_OPTIMIZE_BEGIN
A local channel optimization has begun.
Definition: cel.h:79
struct stasis_forward * sub
Definition: res_corosync.c:240

References AST_CEL_LOCAL_OPTIMIZE_BEGIN, cel_local_optimization_cb_helper(), and sub.

Referenced by create_routes().

◆ cel_local_optimization_cb_helper()

static void cel_local_optimization_cb_helper ( void *  data,
struct stasis_subscription sub,
struct stasis_message message,
enum ast_cel_event_type  event_type 
)
static

Definition at line 1395 of file cel.c.

1399{
1401 struct ast_channel_snapshot *localone = ast_multi_channel_blob_get_channel(obj, "1");
1402 struct ast_channel_snapshot *localtwo = ast_multi_channel_blob_get_channel(obj, "2");
1403 struct ast_json *extra;
1404
1405 if (!localone || !localtwo) {
1406 return;
1407 }
1408
1409 extra = ast_json_pack("{s: s, s: s}",
1410 "local_two", localtwo->base->name,
1411 "local_two_uniqueid", localtwo->base->uniqueid);
1412 if (!extra) {
1413 return;
1414 }
1415
1416 cel_report_event(localone, event_type, stasis_message_timestamp(message), NULL, extra, NULL);
1417 ast_json_unref(extra);
1418}

References ast_json_pack(), ast_json_unref(), ast_multi_channel_blob_get_channel(), ast_channel_snapshot::base, cel_report_event(), ast_channel_snapshot_base::name, NULL, stasis_message_data(), stasis_message_timestamp(), and ast_channel_snapshot_base::uniqueid.

Referenced by cel_local_optimization_begin_cb(), and cel_local_optimization_end_cb().

◆ cel_local_optimization_end_cb()

static void cel_local_optimization_end_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 1420 of file cel.c.

1423{
1424 /* The AST_CEL_LOCAL_OPTIMIZE event has always been triggered by the end of optimization.
1425 This can either be used as an indication that the call was locally optimized, or as
1426 the END event in combination with the subsequently added BEGIN event. */
1428}
@ AST_CEL_LOCAL_OPTIMIZE
A local channel optimization occurred, this marks the end.
Definition: cel.h:77

References AST_CEL_LOCAL_OPTIMIZE, cel_local_optimization_cb_helper(), and sub.

Referenced by create_routes().

◆ cel_parking_cb()

static void cel_parking_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 1109 of file cel.c.

1112{
1113 struct ast_parked_call_payload *parked_payload = stasis_message_data(message);
1114 RAII_VAR(struct ast_json *, extra, NULL, ast_json_unref);
1115 const char *reason = NULL;
1116
1117 switch (parked_payload->event_type) {
1118 case PARKED_CALL:
1119 extra = ast_json_pack("{s: s, s: s}",
1120 "parker_dial_string", parked_payload->parker_dial_string,
1121 "parking_lot", parked_payload->parkinglot);
1122 if (extra) {
1124 NULL, extra, NULL);
1125 }
1126 return;
1128 reason = "ParkedCallTimeOut";
1129 break;
1130 case PARKED_CALL_GIVEUP:
1131 reason = "ParkedCallGiveUp";
1132 break;
1134 reason = "ParkedCallUnparked";
1135 break;
1136 case PARKED_CALL_FAILED:
1137 reason = "ParkedCallFailed";
1138 break;
1139 case PARKED_CALL_SWAP:
1140 reason = "ParkedCallSwap";
1141 break;
1142 }
1143
1144 if (parked_payload->retriever) {
1145 extra = ast_json_pack("{s: s, s: s}",
1146 "reason", reason ?: "",
1147 "retriever", parked_payload->retriever->base->name);
1148 } else {
1149 extra = ast_json_pack("{s: s}", "reason", reason ?: "");
1150 }
1151
1152 if (extra) {
1154 NULL, extra, NULL);
1155 }
1156}
@ AST_CEL_PARK_START
a channel is parked
Definition: cel.h:61
@ AST_CEL_PARK_END
channel out of the park
Definition: cel.h:63
@ PARKED_CALL
Definition: parking.h:47
@ PARKED_CALL_TIMEOUT
Definition: parking.h:48
@ PARKED_CALL_UNPARKED
Definition: parking.h:50
@ PARKED_CALL_FAILED
Definition: parking.h:51
@ PARKED_CALL_GIVEUP
Definition: parking.h:49
@ PARKED_CALL_SWAP
Definition: parking.h:52
A parked call message payload.
Definition: parking.h:59
const ast_string_field parkinglot
Definition: parking.h:69
struct ast_channel_snapshot * retriever
Definition: parking.h:61
struct ast_channel_snapshot * parkee
Definition: parking.h:60
enum ast_parked_call_event_type event_type
Definition: parking.h:62
const ast_string_field parker_dial_string
Definition: parking.h:69

References AST_CEL_PARK_END, AST_CEL_PARK_START, ast_json_pack(), ast_json_unref(), ast_channel_snapshot::base, cel_report_event(), ast_parked_call_payload::event_type, ast_channel_snapshot_base::name, NULL, PARKED_CALL, PARKED_CALL_FAILED, PARKED_CALL_GIVEUP, PARKED_CALL_SWAP, PARKED_CALL_TIMEOUT, PARKED_CALL_UNPARKED, ast_parked_call_payload::parkee, ast_parked_call_payload::parker_dial_string, ast_parked_call_payload::parkinglot, RAII_VAR, ast_parked_call_payload::retriever, stasis_message_data(), and stasis_message_timestamp().

Referenced by create_routes().

◆ cel_pickup_cb()

static void cel_pickup_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 1370 of file cel.c.

1373{
1375 struct ast_channel_snapshot *channel = ast_multi_channel_blob_get_channel(obj, "channel");
1376 struct ast_channel_snapshot *target = ast_multi_channel_blob_get_channel(obj, "target");
1377 struct ast_json *extra;
1378
1379 if (!channel || !target) {
1380 return;
1381 }
1382
1383 extra = ast_json_pack("{s: s, s: s}",
1384 "pickup_channel", channel->base->name,
1385 "pickup_channel_uniqueid", channel->base->uniqueid);
1386 if (!extra) {
1387 return;
1388 }
1389
1391 ast_json_unref(extra);
1392}
@ AST_CEL_PICKUP
a directed pickup was performed on this channel
Definition: cel.h:73

References AST_CEL_PICKUP, ast_json_pack(), ast_json_unref(), ast_multi_channel_blob_get_channel(), ast_channel_snapshot::base, cel_report_event(), ast_channel_snapshot_base::name, NULL, stasis_message_data(), stasis_message_timestamp(), and ast_channel_snapshot_base::uniqueid.

Referenced by create_routes().

◆ cel_pre_apply_config()

static int cel_pre_apply_config ( void  )
static

Definition at line 277 of file cel.c.

278{
279 struct cel_config *cfg = aco_pending_config(&cel_cfg_info);
280
281 if (!cfg->general) {
282 return -1;
283 }
284
285 if (!ao2_container_count(cfg->general->apps)) {
286 return 0;
287 }
288
289 if (cfg->general->events & ((int64_t) 1 << AST_CEL_APP_START)) {
290 return 0;
291 }
292
293 if (cfg->general->events & ((int64_t) 1 << AST_CEL_APP_END)) {
294 return 0;
295 }
296
297 ast_log(LOG_ERROR, "Applications are listed to be tracked, but APP events are not tracked\n");
298 return -1;
299}
int ao2_container_count(struct ao2_container *c)
Returns the number of elements in a container.
void * aco_pending_config(struct aco_info *info)
Get pending config changes.
int64_t events
Definition: cel.h:228

References aco_pending_config(), ao2_container_count(), ast_cel_general_config::apps, AST_CEL_APP_END, AST_CEL_APP_START, ast_log, ast_cel_general_config::events, cel_config::general, and LOG_ERROR.

◆ cel_report_event()

static int cel_report_event ( struct ast_channel_snapshot snapshot,
enum ast_cel_event_type  event_type,
const struct timeval *  event_time,
const char *  userdefevname,
struct ast_json extra,
const char *  peer_str 
)
static

Definition at line 571 of file cel.c.

575{
576 struct ast_event *ev;
577 RAII_VAR(struct cel_config *, cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
579
580 if (!cfg || !cfg->general || !cfg->general->enable || !backends) {
581 return 0;
582 }
583
584 /* Record the linkedid of new channels if we are tracking LINKEDID_END even if we aren't
585 * reporting on CHANNEL_START so we can track when to send LINKEDID_END */
586 if (event_type == AST_CEL_CHANNEL_START
588 if (cel_linkedid_ref(snapshot->peer->linkedid)) {
589 return -1;
590 }
591 }
592
593 if (!ast_cel_track_event(event_type)) {
594 return 0;
595 }
596
597 if ((event_type == AST_CEL_APP_START || event_type == AST_CEL_APP_END)
598 && !cel_track_app(snapshot->dialplan->appl)) {
599 return 0;
600 }
601
602 ev = ast_cel_create_event_with_time(snapshot, event_type, event_time, userdefevname, extra, peer_str);
603 if (!ev) {
604 return -1;
605 }
606
607 /* Distribute event to backends */
610
611 return 0;
612}
#define ao2_callback(c, flags, cb_fn, arg)
ao2_callback() is a generic function that applies cb_fn() to all objects in a container,...
Definition: astobj2.h:1693
@ OBJ_MULTIPLE
Definition: astobj2.h:1049
static int cel_track_app(const char *const_app)
Definition: cel.c:498
static int cel_backend_send_cb(void *obj, void *arg, int flags)
Definition: cel.c:563
void ast_event_destroy(struct ast_event *event)
Destroy an event.
Definition: event.c:524
An event.
Definition: event.c:81

References ao2_callback, ao2_cleanup, ao2_global_obj_ref, ast_channel_snapshot_dialplan::appl, AST_CEL_APP_END, AST_CEL_APP_START, AST_CEL_CHANNEL_START, ast_cel_create_event_with_time(), AST_CEL_LINKEDID_END, ast_cel_track_event(), ast_event_destroy(), cel_backend_send_cb(), cel_linkedid_ref(), cel_track_app(), ast_channel_snapshot::dialplan, ast_channel_snapshot_peer::linkedid, OBJ_MULTIPLE, OBJ_NODATA, ast_channel_snapshot::peer, and RAII_VAR.

Referenced by cel_attended_transfer_cb(), cel_blind_transfer_cb(), cel_bridge_enter_cb(), cel_bridge_leave_cb(), cel_channel_app_change(), cel_channel_state_change(), cel_dial_cb(), cel_generic_cb(), cel_local_optimization_cb_helper(), cel_parking_cb(), cel_pickup_cb(), and check_retire_linkedid().

◆ cel_snapshot_update_cb()

static void cel_snapshot_update_cb ( void *  data,
struct stasis_subscription sub,
struct stasis_message message 
)
static

Definition at line 996 of file cel.c.

998{
1000 size_t i;
1001
1002 if (cel_filter_channel_snapshot(update->old_snapshot) || cel_filter_channel_snapshot(update->new_snapshot)) {
1003 return;
1004 }
1005
1006 for (i = 0; i < ARRAY_LEN(cel_channel_monitors); ++i) {
1007 cel_channel_monitors[i](update->old_snapshot, update->new_snapshot, stasis_message_timestamp(message));
1008 }
1009}
cel_channel_snapshot_monitor cel_channel_monitors[]
Handlers for channel snapshot changes.
Definition: cel.c:982
static void update(int code_size, int y, int wi, int fi, int dq, int sr, int dqsez, struct g726_state *state_ptr)
Definition: codec_g726.c:367
Structure representing a change of snapshot of channel state.

References ARRAY_LEN, cel_channel_monitors, cel_filter_channel_snapshot(), stasis_message_data(), stasis_message_timestamp(), and update().

Referenced by create_routes().

◆ cel_track_app()

static int cel_track_app ( const char *  const_app)
static

Definition at line 498 of file cel.c.

499{
500 RAII_VAR(struct cel_config *, cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
501 RAII_VAR(char *, app, NULL, ao2_cleanup);
502 char *app_lower;
503
504 if (!cfg || !cfg->general) {
505 return 0;
506 }
507
508 app_lower = ast_str_to_lower(ast_strdupa(const_app));
509 app = ao2_find(cfg->general->apps, app_lower, OBJ_SEARCH_KEY);
510 if (!app) {
511 return 0;
512 }
513
514 return 1;
515}
static const char app[]
Definition: app_adsiprog.c:56

References ao2_cleanup, ao2_find, ao2_global_obj_ref, app, ast_str_to_lower(), ast_strdupa, NULL, OBJ_SEARCH_KEY, and RAII_VAR.

Referenced by cel_report_event().

◆ check_retire_linkedid()

static void check_retire_linkedid ( struct ast_channel_snapshot snapshot,
const struct timeval *  event_time 
)
static

Definition at line 616 of file cel.c.

617{
618 RAII_VAR(struct ao2_container *, linkedids, ao2_global_obj_ref(cel_linkedids), ao2_cleanup);
619 struct cel_linkedid *lid;
620
621 if (!linkedids || ast_strlen_zero(snapshot->peer->linkedid)) {
622 /* The CEL module is shutdown. Abort. */
623 return;
624 }
625
626 ao2_lock(linkedids);
627
628 lid = ao2_find(linkedids, (void *) snapshot->peer->linkedid, OBJ_SEARCH_KEY);
629 if (!lid) {
630 ao2_unlock(linkedids);
631
632 /*
633 * The user may have done a reload to start tracking linkedids
634 * when a call was already in progress. This is an unusual kind
635 * of change to make after starting Asterisk.
636 */
637 ast_log(LOG_ERROR, "Something weird happened, couldn't find linkedid %s\n",
638 snapshot->peer->linkedid);
639 return;
640 }
641
642 if (!--lid->count) {
643 /* No channels use this linkedid anymore. */
644 ao2_unlink(linkedids, lid);
645 ao2_unlock(linkedids);
646
647 cel_report_event(snapshot, AST_CEL_LINKEDID_END, event_time, NULL, NULL, NULL);
648 } else {
649 ao2_unlock(linkedids);
650 }
651 ao2_ref(lid, -1);
652}
#define ao2_unlink(container, obj)
Remove an object from a container.
Definition: astobj2.h:1578

References ao2_cleanup, ao2_find, ao2_global_obj_ref, ao2_lock, ao2_ref, ao2_unlink, ao2_unlock, AST_CEL_LINKEDID_END, ast_log, ast_strlen_zero(), cel_report_event(), cel_linkedid::count, ast_channel_snapshot_peer::linkedid, LOG_ERROR, NULL, OBJ_SEARCH_KEY, ast_channel_snapshot::peer, and RAII_VAR.

Referenced by cel_channel_linkedid_change(), and cel_channel_state_change().

◆ CONFIG_INFO_CORE()

CONFIG_INFO_CORE ( "cel"  ,
cel_cfg_info  ,
cel_configs  ,
cel_config_alloc  ,
files = ACO_FILES(&cel_conf),
pre_apply_config = cel_pre_apply_config 
)

◆ create_routes()

static int create_routes ( void  )
static

Create the Stasis message router and routes for CEL.

Definition at line 1521 of file cel.c.

1522{
1523 int ret = 0;
1524
1526 if (!cel_state_router) {
1527 return -1;
1528 }
1531
1535 NULL);
1536
1540 NULL);
1541
1545 NULL);
1546
1550 NULL);
1551
1555 NULL);
1556
1560 NULL);
1561
1565 NULL);
1566
1570 NULL);
1571
1575 NULL);
1576
1580 NULL);
1581
1585 NULL);
1586
1587 if (ret) {
1588 ast_log(AST_LOG_ERROR, "Failed to register for Stasis messages\n");
1589 }
1590
1591 return ret;
1592}
static void cel_local_optimization_end_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:1420
static void cel_bridge_leave_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:1079
static void cel_dial_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:1231
static void cel_snapshot_update_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:996
static void cel_pickup_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:1370
static void cel_blind_transfer_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:1281
static void cel_attended_transfer_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:1307
static void cel_generic_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:1258
static void cel_parking_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:1109
static struct stasis_message_router * cel_state_router
Definition: cel.c:115
static void cel_local_optimization_begin_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:1430
static void cel_bridge_enter_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Definition: cel.c:1049
static struct stasis_topic * cel_aggregation_topic
Definition: cel.c:121
struct stasis_message_type * ast_local_optimization_end_type(void)
Message type for when a local channel optimization completes.
struct stasis_message_type * ast_local_optimization_begin_type(void)
Message type for when a local channel optimization begins.
struct stasis_message_type * ast_parked_call_type(void)
accessor for the parked call stasis message type
struct stasis_message_type * ast_channel_dial_type(void)
Message type for when a channel dials another channel.
struct stasis_message_type * ast_channel_snapshot_type(void)
Message type for ast_channel_snapshot_update.
#define AST_LOG_ERROR
struct stasis_message_type * ast_call_pickup_type(void)
accessor for call pickup message type
struct stasis_message_type * ast_channel_entered_bridge_type(void)
Message type for ast_channel enter bridge blob messages.
struct stasis_message_type * ast_blind_transfer_type(void)
Message type for ast_blind_transfer_message.
struct stasis_message_type * ast_attended_transfer_type(void)
Message type for ast_attended_transfer_message.
struct stasis_message_type * ast_channel_left_bridge_type(void)
Message type for ast_channel leave bridge blob messages.
int stasis_message_router_set_congestion_limits(struct stasis_message_router *router, long low_water, long high_water)
Set the high and low alert water marks of the stasis message router.
#define stasis_message_router_create(topic)
Create a new message router object.
int stasis_message_router_add(struct stasis_message_router *router, struct stasis_message_type *message_type, stasis_subscription_cb callback, void *data)
Add a route to a message router.
#define AST_TASKPROCESSOR_HIGH_WATER_LEVEL
Definition: taskprocessor.h:64

References ast_attended_transfer_type(), ast_blind_transfer_type(), ast_call_pickup_type(), ast_channel_dial_type(), ast_channel_entered_bridge_type(), ast_channel_left_bridge_type(), ast_channel_snapshot_type(), ast_local_optimization_begin_type(), ast_local_optimization_end_type(), ast_log, AST_LOG_ERROR, ast_parked_call_type(), AST_TASKPROCESSOR_HIGH_WATER_LEVEL, cel_aggregation_topic, cel_attended_transfer_cb(), cel_blind_transfer_cb(), cel_bridge_enter_cb(), cel_bridge_leave_cb(), cel_dial_cb(), cel_generic_cb(), cel_generic_type(), cel_local_optimization_begin_cb(), cel_local_optimization_end_cb(), cel_parking_cb(), cel_pickup_cb(), cel_snapshot_update_cb(), cel_state_router, NULL, stasis_message_router_add(), stasis_message_router_create, and stasis_message_router_set_congestion_limits().

Referenced by ast_cel_set_config(), load_module(), and reload_module().

◆ create_subscriptions()

static int create_subscriptions ( void  )
static

Create the Stasis subscriptions for CEL.

Definition at line 1475 of file cel.c.

1476{
1477 cel_aggregation_topic = stasis_topic_create("cel:aggregator");
1478 if (!cel_aggregation_topic) {
1479 return -1;
1480 }
1481
1482 cel_topic = stasis_topic_create("cel:misc");
1483 if (!cel_topic) {
1484 return -1;
1485 }
1486
1490 if (!cel_channel_forwarder) {
1491 return -1;
1492 }
1493
1497 if (!cel_bridge_forwarder) {
1498 return -1;
1499 }
1500
1504 if (!cel_parking_forwarder) {
1505 return -1;
1506 }
1507
1509 ast_cel_topic(),
1511 if (!cel_cel_forwarder) {
1512 return -1;
1513 }
1514
1515 return 0;
1516}
static struct stasis_forward * cel_cel_forwarder
Definition: cel.c:133
static struct stasis_forward * cel_channel_forwarder
Definition: cel.c:124
static struct stasis_forward * cel_bridge_forwarder
Definition: cel.c:127
static struct stasis_forward * cel_parking_forwarder
Definition: cel.c:130
struct stasis_topic * ast_parking_topic(void)
accessor for the parking stasis topic
Definition: parking.c:67
struct stasis_topic * ast_channel_topic_all(void)
A topic which publishes the events for all channels.
struct stasis_topic * stasis_topic_create(const char *name)
Create a new topic.
Definition: stasis.c:617
struct stasis_forward * stasis_forward_all(struct stasis_topic *from_topic, struct stasis_topic *to_topic)
Create a subscription which forwards all messages from one topic to another.
Definition: stasis.c:1578
struct stasis_topic * ast_bridge_topic_all(void)
A topic which publishes the events for all bridges.

References ast_bridge_topic_all(), ast_cel_topic(), ast_channel_topic_all(), ast_parking_topic(), cel_aggregation_topic, cel_bridge_forwarder, cel_cel_forwarder, cel_channel_forwarder, cel_parking_forwarder, cel_topic, stasis_forward_all(), and stasis_topic_create().

Referenced by load_module().

◆ destroy_routes()

static void destroy_routes ( void  )
static

Definition at line 1437 of file cel.c.

1438{
1441}
void stasis_message_router_unsubscribe_and_join(struct stasis_message_router *router)
Unsubscribe the router from the upstream topic, blocking until the final message has been processed.

References cel_state_router, NULL, and stasis_message_router_unsubscribe_and_join().

Referenced by ast_cel_set_config(), reload_module(), and unload_module().

◆ destroy_subscriptions()

static void destroy_subscriptions ( void  )
static

◆ events_handler()

static int events_handler ( const struct aco_option opt,
struct ast_variable var,
void *  obj 
)
static

Definition at line 445 of file cel.c.

446{
447 struct ast_cel_general_config *cfg = obj;
448 char *events = ast_strdupa(var->value);
449 char *cur_event;
450
451 while ((cur_event = strsep(&events, ","))) {
452 enum ast_cel_event_type event_type;
453
454 cur_event = ast_strip(cur_event);
455 if (ast_strlen_zero(cur_event)) {
456 continue;
457 }
458
459 event_type = ast_cel_str_to_event_type(cur_event);
460
461 if (event_type == AST_CEL_ALL) {
462 /* All events */
463 cfg->events = (int64_t) -1;
464 } else if (event_type == AST_CEL_INVALID_VALUE) {
465 return -1;
466 } else {
467 cfg->events |= ((int64_t) 1 << event_type);
468 }
469 }
470
471 return 0;
472}
static const struct adsi_event events[]
Definition: app_adsiprog.c:85
enum ast_cel_event_type ast_cel_str_to_event_type(const char *name)
Get the event type from a string.
Definition: cel.c:420
ast_cel_event_type
CEL event types.
Definition: cel.h:41
@ AST_CEL_ALL
Definition: cel.h:43

References AST_CEL_ALL, AST_CEL_INVALID_VALUE, ast_cel_str_to_event_type(), ast_strdupa, ast_strip(), ast_strlen_zero(), events, ast_cel_general_config::events, strsep(), and var.

Referenced by load_module().

◆ get_blob_variable()

static const char * get_blob_variable ( struct ast_multi_channel_blob blob,
const char *  varname 
)
static

Definition at line 882 of file cel.c.

883{
884 struct ast_json *json = ast_multi_channel_blob_get_json(blob);
885 if (!json) {
886 return NULL;
887 }
888
889 json = ast_json_object_get(json, varname);
890 if (!json) {
891 return NULL;
892 }
893
894 return ast_json_string_get(json);
895}
struct ast_json * ast_multi_channel_blob_get_json(struct ast_multi_channel_blob *obj)
Retrieve the JSON blob from a ast_multi_channel_blob. Returned ast_json is still owned by obj.

References ast_json_object_get(), ast_json_string_get(), ast_multi_channel_blob_get_json(), and NULL.

Referenced by cel_dial_cb(), is_valid_dialstatus(), and save_dialstatus().

◆ get_dialstatus()

static struct cel_dialstatus * get_dialstatus ( const char *  uniqueid)
static

Definition at line 870 of file cel.c.

871{
872 struct ao2_container *dial_statuses = ao2_global_obj_ref(cel_dialstatus_store);
874
875 if (dial_statuses) {
877 ao2_ref(dial_statuses, -1);
878 }
879 return dialstatus;
880}
char uniqueid[AST_MAX_UNIQUEID]
Definition: cel.c:175

References ao2_find, ao2_global_obj_ref, ao2_ref, cel_dialstatus::dialstatus, NULL, OBJ_SEARCH_KEY, OBJ_UNLINK, and cel_dialstatus::uniqueid.

Referenced by cel_channel_state_change().

◆ handle_cli_status()

static char * handle_cli_status ( struct ast_cli_entry e,
int  cmd,
struct ast_cli_args a 
)
static

Definition at line 355 of file cel.c.

356{
357 unsigned int i;
358 RAII_VAR(struct cel_config *, cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
360 struct ao2_iterator iter;
361 char *app;
362
363 switch (cmd) {
364 case CLI_INIT:
365 e->command = "cel show status";
366 e->usage =
367 "Usage: cel show status\n"
368 " Displays the Channel Event Logging system status.\n";
369 return NULL;
370 case CLI_GENERATE:
371 return NULL;
372 case CLI_HANDLER:
373 break;
374 }
375
376 if (a->argc > 3) {
377 return CLI_SHOWUSAGE;
378 }
379
380 ast_cli(a->fd, "CEL Logging: %s\n", ast_cel_check_enabled() ? "Enabled" : "Disabled");
381
382 if (!cfg || !cfg->general || !cfg->general->enable) {
383 return CLI_SUCCESS;
384 }
385
386 for (i = 0; i < (sizeof(cfg->general->events) * 8); i++) {
387 const char *name;
388
389 if (!(cfg->general->events & ((int64_t) 1 << i))) {
390 continue;
391 }
392
394 if (strcasecmp(name, "Unknown")) {
395 ast_cli(a->fd, "CEL Tracking Event: %s\n", name);
396 }
397 }
398
399 iter = ao2_iterator_init(cfg->general->apps, 0);
400 for (; (app = ao2_iterator_next(&iter)); ao2_ref(app, -1)) {
401 ast_cli(a->fd, "CEL Tracking Application: %s\n", app);
402 }
404
405 if (backends) {
406 struct cel_backend *backend;
407
408 iter = ao2_iterator_init(backends, 0);
409 for (; (backend = ao2_iterator_next(&iter)); ao2_ref(backend, -1)) {
410 ast_cli(a->fd, "CEL Event Subscriber: %s\n", backend->name);
411 }
413 }
414
415 return CLI_SUCCESS;
416}
#define CLI_SHOWUSAGE
Definition: cli.h:45
#define CLI_SUCCESS
Definition: cli.h:44
void ast_cli(int fd, const char *fmt,...)
Definition: clicompat.c:6
@ CLI_HANDLER
Definition: cli.h:154
@ CLI_INIT
Definition: cli.h:152
@ CLI_GENERATE
Definition: cli.h:153
char * command
Definition: cli.h:186
const char * usage
Definition: cli.h:177
static struct test_val a

References a, ao2_cleanup, ao2_global_obj_ref, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, app, ast_cel_check_enabled(), ast_cel_get_type_name(), ast_cli(), CLI_GENERATE, CLI_HANDLER, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, cel_backend::name, name, NULL, RAII_VAR, and ast_cli_entry::usage.

◆ is_valid_dialstatus()

static int is_valid_dialstatus ( struct ast_multi_channel_blob blob)
static

Definition at line 1202 of file cel.c.

1203{
1204 const char *dialstatus = get_blob_variable(blob, "dialstatus");
1205 int res = 0;
1206
1207 if (ast_strlen_zero(dialstatus)) {
1208 res = 0;
1209 } else if (!strcasecmp(dialstatus, "CHANUNAVAIL")) {
1210 res = 1;
1211 } else if (!strcasecmp(dialstatus, "CONGESTION")) {
1212 res = 1;
1213 } else if (!strcasecmp(dialstatus, "NOANSWER")) {
1214 res = 1;
1215 } else if (!strcasecmp(dialstatus, "BUSY")) {
1216 res = 1;
1217 } else if (!strcasecmp(dialstatus, "ANSWER")) {
1218 res = 1;
1219 } else if (!strcasecmp(dialstatus, "CANCEL")) {
1220 res = 1;
1221 } else if (!strcasecmp(dialstatus, "DONTCALL")) {
1222 res = 1;
1223 } else if (!strcasecmp(dialstatus, "TORTURE")) {
1224 res = 1;
1225 } else if (!strcasecmp(dialstatus, "INVALIDARGS")) {
1226 res = 1;
1227 }
1228 return res;
1229}

References ast_strlen_zero(), cel_dialstatus::dialstatus, and get_blob_variable().

Referenced by cel_dial_cb().

◆ load_module()

static int load_module ( void  )
static

Definition at line 1597 of file cel.c.

1598{
1599 struct ao2_container *container;
1600
1602 NUM_APP_BUCKETS, cel_linkedid_hash_fn, NULL, cel_linkedid_cmp_fn);
1605 if (!container) {
1607 }
1608
1610 NUM_DIALSTATUS_BUCKETS, cel_dialstatus_hash_fn, NULL, cel_dialstatus_cmp_fn);
1611 ao2_global_obj_replace_unref(cel_dialstatus_store, container);
1613 if (!container) {
1615 }
1616
1619 }
1620
1623 }
1624
1626 cel_backend_hash_fn, NULL, cel_backend_cmp_fn);
1629 if (!container) {
1631 }
1632
1633 if (aco_info_init(&cel_cfg_info)) {
1635 }
1636
1637 aco_option_register(&cel_cfg_info, "enable", ACO_EXACT, general_options, "no", OPT_BOOL_T, 1, FLDSET(struct ast_cel_general_config, enable));
1638 aco_option_register(&cel_cfg_info, "dateformat", ACO_EXACT, general_options, "", OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_cel_general_config, date_format));
1639 aco_option_register_custom(&cel_cfg_info, "apps", ACO_EXACT, general_options, "", apps_handler, 0);
1640 aco_option_register_custom(&cel_cfg_info, "events", ACO_EXACT, general_options, "", events_handler, 0);
1641
1642 if (aco_process_config(&cel_cfg_info, 0)) {
1643 struct cel_config *cel_cfg = cel_config_alloc();
1644
1645 if (!cel_cfg) {
1647 }
1648
1649 /* We couldn't process the configuration so create a default config. */
1650 if (!aco_set_defaults(&general_option, "general", cel_cfg->general)) {
1651 ast_log(LOG_NOTICE, "Failed to process CEL configuration; using defaults\n");
1652 ao2_global_obj_replace_unref(cel_configs, cel_cfg);
1653 }
1654 ao2_ref(cel_cfg, -1);
1655 }
1656
1657 if (create_subscriptions()) {
1659 }
1660
1663 }
1664
1666}
@ AO2_ALLOC_OPT_LOCK_MUTEX
Definition: astobj2.h:363
#define ao2_global_obj_replace_unref(holder, obj)
Replace an ao2 object in the global holder, throwing away any old object.
Definition: astobj2.h:901
#define ao2_container_alloc_hash(ao2_options, container_options, n_buckets, hash_fn, sort_fn, cmp_fn)
Allocate and initialize a hash container with the desired number of buckets.
Definition: astobj2.h:1303
#define BACKEND_BUCKETS
Definition: cel.c:142
static struct ast_cli_entry cli_status
Definition: cel.c:418
static int create_subscriptions(void)
Create the Stasis subscriptions for CEL.
Definition: cel.c:1475
static struct aco_type general_option
An aco_type structure to link the "general" category to the ast_cel_general_config type.
Definition: cel.c:242
static int events_handler(const struct aco_option *opt, struct ast_variable *var, void *obj)
Definition: cel.c:445
#define NUM_DIALSTATUS_BUCKETS
Number of buckets for the dialstatus container.
Definition: cel.c:161
static struct aco_type * general_options[]
Definition: cel.c:301
static int apps_handler(const struct aco_option *opt, struct ast_variable *var, void *obj)
Definition: cel.c:474
static void * cel_config_alloc(void)
Definition: cel.c:225
#define ast_cli_register(e)
Registers a command or an array of commands.
Definition: cli.h:256
@ ACO_EXACT
int aco_set_defaults(struct aco_type *type, const char *category, void *obj)
Set all default options of obj.
#define STRFLDSET(type,...)
Convert a struct and a list of stringfield fields to an argument list of field offsets.
int aco_info_init(struct aco_info *info)
Initialize an aco_info structure.
#define FLDSET(type,...)
Convert a struct and list of fields to an argument list of field offsets.
#define aco_option_register(info, name, matchtype, types, default_val, opt_type, flags,...)
Register a config option.
@ OPT_BOOL_T
Type for default option handler for bools (ast_true/ast_false)
@ OPT_STRINGFIELD_T
Type for default option handler for stringfields.
#define aco_option_register_custom(info, name, matchtype, types, default_val, handler, flags)
Register a config option.
enum aco_process_status aco_process_config(struct aco_info *info, int reload)
Process a config info via the options registered with an aco_info.
#define LOG_NOTICE
@ AST_MODULE_LOAD_FAILURE
Module could not be loaded properly.
Definition: module.h:102
@ AST_MODULE_LOAD_SUCCESS
Definition: module.h:70
struct ao2_container * container
Definition: res_fax.c:501
#define STASIS_MESSAGE_TYPE_INIT(name)
Boiler-plate messaging macro for initializing message types.
Definition: stasis.h:1493

References ACO_EXACT, aco_info_init(), aco_option_register, aco_option_register_custom, aco_process_config(), aco_set_defaults(), AO2_ALLOC_OPT_LOCK_MUTEX, ao2_cleanup, ao2_container_alloc_hash, ao2_global_obj_replace_unref, ao2_ref, apps_handler(), ast_cel_check_enabled(), ast_cli_register, ast_log, AST_MODULE_LOAD_FAILURE, AST_MODULE_LOAD_SUCCESS, BACKEND_BUCKETS, cel_config_alloc(), cel_generic_type(), cli_status, container, create_routes(), create_subscriptions(), events_handler(), FLDSET, cel_config::general, general_option, general_options, LOG_NOTICE, NULL, NUM_APP_BUCKETS, NUM_DIALSTATUS_BUCKETS, OPT_BOOL_T, OPT_STRINGFIELD_T, STASIS_MESSAGE_TYPE_INIT, and STRFLDSET.

◆ reload_module()

static int reload_module ( void  )
static

Definition at line 1668 of file cel.c.

1669{
1670 unsigned int was_enabled = ast_cel_check_enabled();
1671 unsigned int is_enabled;
1672
1673 if (aco_process_config(&cel_cfg_info, 1) == ACO_PROCESS_ERROR) {
1674 return -1;
1675 }
1676
1678
1679 if (!was_enabled && is_enabled) {
1680 if (create_routes()) {
1681 return -1;
1682 }
1683 } else if (was_enabled && !is_enabled) {
1685 }
1686
1687 ast_verb(3, "CEL logging %sabled.\n", is_enabled ? "en" : "dis");
1688
1689 return 0;
1690}
@ ACO_PROCESS_ERROR
Their was an error and no changes were applied.
#define ast_verb(level,...)

References aco_process_config(), ACO_PROCESS_ERROR, ast_cel_check_enabled(), ast_verb, create_routes(), destroy_routes(), and is_enabled().

◆ save_dialstatus()

static void save_dialstatus ( struct ast_multi_channel_blob blob,
struct ast_channel_snapshot snapshot 
)
static

Definition at line 1158 of file cel.c.

1159{
1160 struct ao2_container *dial_statuses = ao2_global_obj_ref(cel_dialstatus_store);
1161 const char *dialstatus_string = get_blob_variable(blob, "dialstatus");
1162 struct cel_dialstatus *dialstatus;
1163 size_t dialstatus_string_len;
1164
1165 if (!dial_statuses || ast_strlen_zero(dialstatus_string)) {
1166 ao2_cleanup(dial_statuses);
1167 return;
1168 }
1169
1170 dialstatus = ao2_find(dial_statuses, snapshot->base->uniqueid, OBJ_SEARCH_KEY);
1171 if (dialstatus) {
1172 if (!strcasecmp(dialstatus_string, "ANSWER") && strcasecmp(dialstatus->dialstatus, "ANSWER")) {
1173 /* In the case of an answer after we already have a dial status we give
1174 * priority to the answer since the call was, well, answered. In the case of
1175 * failure dial status results we simply let the first failure be the status.
1176 */
1177 ao2_unlink(dial_statuses, dialstatus);
1178 ao2_ref(dialstatus, -1);
1179 } else {
1180 ao2_ref(dialstatus, -1);
1181 ao2_ref(dial_statuses, -1);
1182 return;
1183 }
1184 }
1185
1186 dialstatus_string_len = strlen(dialstatus_string) + 1;
1187 dialstatus = ao2_alloc_options(sizeof(*dialstatus) + dialstatus_string_len, NULL,
1189 if (!dialstatus) {
1190 ao2_ref(dial_statuses, -1);
1191 return;
1192 }
1193
1194 ast_copy_string(dialstatus->uniqueid, snapshot->base->uniqueid, sizeof(dialstatus->uniqueid));
1195 ast_copy_string(dialstatus->dialstatus, dialstatus_string, dialstatus_string_len);
1196
1197 ao2_link(dial_statuses, dialstatus);
1198 ao2_ref(dialstatus, -1);
1199 ao2_ref(dial_statuses, -1);
1200}
void ast_copy_string(char *dst, const char *src, size_t size)
Size-limited null-terminating string copy.
Definition: strings.h:425

References AO2_ALLOC_OPT_LOCK_NOLOCK, ao2_alloc_options, ao2_cleanup, ao2_find, ao2_global_obj_ref, ao2_link, ao2_ref, ao2_unlink, ast_copy_string(), ast_strlen_zero(), ast_channel_snapshot::base, cel_dialstatus::dialstatus, get_blob_variable(), NULL, OBJ_SEARCH_KEY, and ast_channel_snapshot_base::uniqueid.

Referenced by cel_dial_cb().

◆ STASIS_MESSAGE_TYPE_DEFN()

STASIS_MESSAGE_TYPE_DEFN ( cel_generic_type  )

◆ unload_module()

static int unload_module ( void  )
static

Definition at line 1456 of file cel.c.

1457{
1461
1463 aco_info_destroy(&cel_cfg_info);
1464 ao2_global_obj_release(cel_configs);
1465 ao2_global_obj_release(cel_dialstatus_store);
1466 ao2_global_obj_release(cel_linkedids);
1467 ao2_global_obj_release(cel_backends);
1468
1469 return 0;
1470}
#define ao2_global_obj_release(holder)
Release the ao2 object held in the global holder.
Definition: astobj2.h:859
static void destroy_subscriptions(void)
Definition: cel.c:1443
int ast_cli_unregister(struct ast_cli_entry *e)
Unregisters a command or an array of commands.
Definition: main/cli.c:2429
void aco_info_destroy(struct aco_info *info)
Destroy an initialized aco_info struct.
#define STASIS_MESSAGE_TYPE_CLEANUP(name)
Boiler-plate messaging macro for cleaning up message types.
Definition: stasis.h:1515

References aco_info_destroy(), ao2_global_obj_release, ast_cli_unregister(), cel_generic_type(), cli_status, destroy_routes(), destroy_subscriptions(), and STASIS_MESSAGE_TYPE_CLEANUP.

Variable Documentation

◆ __mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_GLOBAL_SYMBOLS | AST_MODFLAG_LOAD_ORDER , .description = "CEL Engine" , .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_CORE, .load = load_module, .unload = unload_module, .reload = reload_module, .load_pri = AST_MODPRI_CORE, .requires = "extconfig", }
static

Definition at line 1811 of file cel.c.

◆ ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info
static

Definition at line 1811 of file cel.c.

◆ cel_aggregation_topic

struct stasis_topic* cel_aggregation_topic
static

Aggregation topic for all topics CEL needs to know about

Definition at line 121 of file cel.c.

Referenced by create_routes(), create_subscriptions(), and destroy_subscriptions().

◆ cel_bridge_forwarder

struct stasis_forward* cel_bridge_forwarder
static

Subscription for forwarding the channel caching topic

Definition at line 127 of file cel.c.

Referenced by create_subscriptions(), and destroy_subscriptions().

◆ cel_cel_forwarder

struct stasis_forward* cel_cel_forwarder
static

Subscription for forwarding the CEL-specific topic

Definition at line 133 of file cel.c.

Referenced by create_subscriptions(), and destroy_subscriptions().

◆ cel_channel_forwarder

struct stasis_forward* cel_channel_forwarder
static

Subscription for forwarding the channel caching topic

Definition at line 124 of file cel.c.

Referenced by create_subscriptions(), and destroy_subscriptions().

◆ cel_channel_monitors

cel_channel_snapshot_monitor cel_channel_monitors[]
Initial value:
= {
}
static void cel_channel_linkedid_change(struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot, const struct timeval *event_time)
Definition: cel.c:938
static void cel_channel_state_change(struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot, const struct timeval *event_time)
Handle channel state changes.
Definition: cel.c:898
static void cel_channel_app_change(struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot, const struct timeval *event_time)
Definition: cel.c:957

Handlers for channel snapshot changes.

Note
Order of the handlers matters. Application changes must come before state changes to ensure that hangup notifications occur after application changes. Linkedid checking should always come last.

Definition at line 982 of file cel.c.

Referenced by cel_snapshot_update_cb().

◆ cel_conf

struct aco_file cel_conf
static
Initial value:
= {
.filename = "cel.conf",
}
static struct aco_type ignore_option
Definition: cel.c:257
#define ACO_TYPES(...)
A helper macro to ensure that aco_info types always have a sentinel.

The config file to be processed for the module.

Definition at line 265 of file cel.c.

◆ cel_event_types

const char* const cel_event_types[CEL_MAX_EVENT_IDS]
static

Map of ast_cel_event_type to strings.

Definition at line 306 of file cel.c.

Referenced by ast_cel_get_type_name(), and ast_cel_str_to_event_type().

◆ cel_parking_forwarder

struct stasis_forward* cel_parking_forwarder
static

Subscription for forwarding the parking topic

Definition at line 130 of file cel.c.

Referenced by create_subscriptions(), and destroy_subscriptions().

◆ cel_state_router

struct stasis_message_router* cel_state_router
static

Message router for state that CEL needs to know about

Definition at line 115 of file cel.c.

Referenced by create_routes(), and destroy_routes().

◆ cel_topic

struct stasis_topic* cel_topic
static

Topic for CEL-specific messages

Definition at line 118 of file cel.c.

Referenced by ast_cel_topic(), create_subscriptions(), and destroy_subscriptions().

◆ cli_status

struct ast_cli_entry cli_status = { .handler = handle_cli_status , .summary = "Display the CEL status" ,}
static

Definition at line 418 of file cel.c.

Referenced by load_module(), and unload_module().

◆ fabricated_channel_datastore

const struct ast_datastore_info fabricated_channel_datastore
static
Initial value:
= {
.type = "CEL fabricated channel",
.destroy = ast_free_ptr,
}
void ast_free_ptr(void *ptr)
free() wrapper
Definition: astmm.c:1739

Definition at line 657 of file cel.c.

Referenced by ast_cel_fabricate_channel_from_event().

◆ general_option

struct aco_type general_option
static

An aco_type structure to link the "general" category to the ast_cel_general_config type.

Definition at line 242 of file cel.c.

Referenced by load_module().

◆ general_options

struct aco_type* general_options[] = ACO_TYPES(&general_option)
static

Definition at line 301 of file cel.c.

Referenced by load_module().

◆ ignore_categories

const char* ignore_categories[]
static
Initial value:
= {
"manager",
"radius",
}

Config sections used by existing modules. Do not add to this list.

Definition at line 251 of file cel.c.

◆ ignore_option

struct aco_type ignore_option
static

Definition at line 257 of file cel.c.