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_dialstatus_store)

static	AO2_GLOBAL_OBJ_STATIC (cel_linkedids)

static	AO2_GLOBAL_OBJ_STATIC (cel_configs)

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_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)
	Allocate and populate a CEL event structure. More...

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

struct ast_channel *	ast_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_config *	ast_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_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_topic *	ast_cel_topic (void)
	Get the CEL topic. More...

static int	ast_cel_track_event (enum ast_cel_event_type et)

struct ast_module *	AST_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_str *	cel_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_type *	cel_generic_type (void)

static int	cel_linkedid_ref (const char *linkedid)

static void	cel_local_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_dialstatus *	get_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 = "30ef0c93b36035ec78c9cfd712d36d9b" , .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_info *	ast_module_info = &__mod_info

static struct stasis_topic *	cel_aggregation_topic

static struct stasis_forward *	cel_bridge_forwarder

static struct stasis_forward *	cel_cel_forwarder

static struct stasis_forward *	cel_channel_forwarder

cel_channel_snapshot_monitor	cel_channel_monitors []

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_forward *	cel_parking_forwarder

static struct stasis_message_router *	cel_state_router

static struct stasis_topic *	cel_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_type *	general_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 141 of file cel.c.

Referenced by load_module().

◆ 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 150 of file cel.c.

◆ NUM_APP_BUCKETS

#define NUM_APP_BUCKETS 97

Number of buckets for the appset container.

Definition at line 155 of file cel.c.

Referenced by ast_cel_general_config_alloc(), and load_module().

◆ NUM_DIALSTATUS_BUCKETS

#define NUM_DIALSTATUS_BUCKETS 251

Number of buckets for the dialstatus container.

Definition at line 160 of file cel.c.

Referenced by load_module().

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 863 of file cel.c.

Function Documentation

◆ __reg_module()

static void __reg_module ( void )

static

Definition at line 1770 of file cel.c.

◆ __unreg_module()

static void __unreg_module ( void )

static

Definition at line 1770 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_dialstatus_store )

static

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

◆ AO2_GLOBAL_OBJ_STATIC() [3/4]

static AO2_GLOBAL_OBJ_STATIC ( cel_linkedids )

static

Container of channel references to a linkedid for CEL purposes.

◆ AO2_GLOBAL_OBJ_STATIC() [4/4]

static AO2_GLOBAL_OBJ_STATIC ( cel_configs )

static

◆ apps_handler()

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

static

Definition at line 472 of file cel.c.

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

Referenced by load_module().

 {
  struct ast_cel_general_config *cfg = obj;
  char *apps = ast_strdupa(var->value);
  char *cur_app;
 
  while ((cur_app = strsep(&apps, ","))) {
  cur_app = ast_strip(cur_app);
  if (ast_strlen_zero(cur_app)) {
  continue;
  }
 
  cur_app = ast_str_to_lower(cur_app);
  ast_str_container_add(cfg->apps, cur_app);
  }
 
  return 0;
 }

◆ ast_cel_backend_register()

int ast_cel_backend_register	(	const char *	name,
		ast_cel_backend_cb	backend_callback
	)

Register a CEL backend.

Parameters

name	Name of backend to register
backend_callback	Callback to register

Return values

zero	on success
non-zero	on failure

Since: 12

Definition at line 1740 of file cel.c.

References AO2_ALLOC_OPT_LOCK_NOLOCK, ao2_alloc_options, ao2_cleanup, ao2_global_obj_ref, ao2_link, ao2_ref, AST_MODFLAG_GLOBAL_SYMBOLS, AST_MODFLAG_LOAD_ORDER, AST_MODPRI_CORE, AST_MODULE_INFO(), AST_MODULE_SUPPORT_CORE, ast_strlen_zero, ASTERISK_GPL_KEY, cel_backend::callback, load_module(), cel_backend::name, NULL, RAII_VAR, reload(), reload_module(), and unload_module().

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

 {
  RAII_VAR(struct ao2_container *, backends, ao2_global_obj_ref(cel_backends), ao2_cleanup);
  struct cel_backend *backend;
 
  if (!backends || ast_strlen_zero(name) || !backend_callback) {
  return -1;
  }
 
  /* The backend object is immutable so it doesn't need a lock of its own. */
  backend = ao2_alloc_options(sizeof(*backend) + 1 + strlen(name), NULL,
  AO2_ALLOC_OPT_LOCK_NOLOCK);
  if (!backend) {
  return -1;
  }
  strcpy(backend->name, name);/* Safe */
  backend->callback = backend_callback;
 
  ao2_link(backends, backend);
  ao2_ref(backend, -1);
  return 0;
 }

◆ ast_cel_backend_unregister()

int ast_cel_backend_unregister ( const char * name )

Unregister a CEL backend.

Parameters

name	Name of backend to unregister

Return values

zero	on success
non-zero	on failure

Since: 12

Definition at line 1728 of file cel.c.

References ao2_find, ao2_global_obj_ref, ao2_ref, 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().

 {
  struct ao2_container *backends = ao2_global_obj_ref(cel_backends);
 
  if (backends) {
  ao2_find(backends, name, OBJ_SEARCH_KEY | OBJ_NODATA | OBJ_UNLINK);
  ao2_ref(backends, -1);
  }
 
  return 0;
 }

◆ 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 343 of file cel.c.

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().

 {
  unsigned int enabled;
  struct cel_config *cfg = ao2_global_obj_ref(cel_configs);
 
  enabled = (!cfg || !cfg->general) ? 0 : cfg->general->enable;
  ao2_cleanup(cfg);
  return enabled;
 }

◆ 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

snapshot	An ast_channel_snapshot of the primary channel associated with this channel event.
event_type	The type of call event being reported.
userdefevname	Custom name for the call event. (optional)
extra	An event-specific opaque JSON blob to be rendered and placed in the "CEL_EXTRA" information element of the call event. (optional)
peer_str	A list of comma-separated peer channel names. (optional)

Since: 12

Return values

The	created ast_event structure
NULL	on failure

Definition at line 517 of file cel.c.

References ast_cel_create_event_with_time(), and ast_tvnow().

Referenced by append_expected_event_snapshot().

 {
  struct timeval eventtime = ast_tvnow();
 
  return ast_cel_create_event_with_time(snapshot, event_type, &eventtime,
  userdefevname, extra, peer);
 }

◆ 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

snapshot	An ast_channel_snapshot of the primary channel associated with this channel event.
event_type	The type of call event being reported.
event_time	The time at which the event occurred.
userdefevname	Custom name for the call event. (optional)
extra	An event-specific opaque JSON blob to be rendered and placed in the "CEL_EXTRA" information element of the call event. (optional)
peer_str	A list of comma-separated peer channel names. (optional)

Since: 13.29.0; 16.6.0

Return values

The	created ast_event structure
NULL	on failure

Definition at line 527 of file cel.c.

Referenced by ast_cel_create_event(), and cel_report_event().

 {
  RAII_VAR(char *, extra_txt, NULL, ast_json_free);
  if (extra) {
  extra_txt = ast_json_dump_string(extra);
  }
  return ast_event_new(AST_EVENT_CEL,
  AST_EVENT_IE_CEL_EVENT_TYPE, AST_EVENT_IE_PLTYPE_UINT, event_type,
  AST_EVENT_IE_CEL_EVENT_TIME, AST_EVENT_IE_PLTYPE_UINT, event_time->tv_sec,
  AST_EVENT_IE_CEL_EVENT_TIME_USEC, AST_EVENT_IE_PLTYPE_UINT, event_time->tv_usec,
  AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_PLTYPE_STR, S_OR(userdefevname, ""),
  AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_PLTYPE_STR, snapshot->caller->name,
  AST_EVENT_IE_CEL_CIDNUM, AST_EVENT_IE_PLTYPE_STR, snapshot->caller->number,
  AST_EVENT_IE_CEL_CIDANI, AST_EVENT_IE_PLTYPE_STR, snapshot->caller->ani,
  AST_EVENT_IE_CEL_CIDRDNIS, AST_EVENT_IE_PLTYPE_STR, snapshot->caller->rdnis,
  AST_EVENT_IE_CEL_CIDDNID, AST_EVENT_IE_PLTYPE_STR, snapshot->caller->dnid,
  AST_EVENT_IE_CEL_EXTEN, AST_EVENT_IE_PLTYPE_STR, snapshot->dialplan->exten,
  AST_EVENT_IE_CEL_CONTEXT, AST_EVENT_IE_PLTYPE_STR, snapshot->dialplan->context,
  AST_EVENT_IE_CEL_CHANNAME, AST_EVENT_IE_PLTYPE_STR, snapshot->base->name,
  AST_EVENT_IE_CEL_APPNAME, AST_EVENT_IE_PLTYPE_STR, snapshot->dialplan->appl,
  AST_EVENT_IE_CEL_APPDATA, AST_EVENT_IE_PLTYPE_STR, snapshot->dialplan->data,
  AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_PLTYPE_UINT, snapshot->amaflags,
  AST_EVENT_IE_CEL_ACCTCODE, AST_EVENT_IE_PLTYPE_STR, snapshot->base->accountcode,
  AST_EVENT_IE_CEL_PEERACCT, AST_EVENT_IE_PLTYPE_STR, snapshot->peer->account,
  AST_EVENT_IE_CEL_UNIQUEID, AST_EVENT_IE_PLTYPE_STR, snapshot->base->uniqueid,
  AST_EVENT_IE_CEL_LINKEDID, AST_EVENT_IE_PLTYPE_STR, snapshot->peer->linkedid,
  AST_EVENT_IE_CEL_USERFIELD, AST_EVENT_IE_PLTYPE_STR, snapshot->base->userfield,
  AST_EVENT_IE_CEL_EXTRA, AST_EVENT_IE_PLTYPE_STR, S_OR(extra_txt, ""),
  AST_EVENT_IE_CEL_PEER, AST_EVENT_IE_PLTYPE_STR, S_OR(peer, ""),
  AST_EVENT_IE_END);
 }

◆ 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

event the 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 660 of file cel.c.

Referenced by custom_log(), and write_cel().

 {
  struct varshead *headp;
  struct ast_var_t *newvariable;
  const char *mixed_name;
  char timebuf[30];
  struct ast_channel *tchan;
  struct ast_cel_event_record record = {
  .version = AST_CEL_EVENT_RECORD_VERSION,
  };
  struct ast_datastore *datastore;
  char *app_data;
  RAII_VAR(struct cel_config *, cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
 
  if (!cfg || !cfg->general) {
  return NULL;
  }
 
  /* do not call ast_channel_alloc because this is not really a real channel */
  if (!(tchan = ast_dummy_channel_alloc())) {
  return NULL;
  }
 
  headp = ast_channel_varshead(tchan);
 
  /* first, get the variables from the event */
  if (ast_cel_fill_record(event, &record)) {
  ast_channel_unref(tchan);
  return NULL;
  }
 
  /* next, fill the channel with their data */
  mixed_name = (record.event_type == AST_CEL_USER_DEFINED)
  ? record.user_defined_name : record.event_name;
  if ((newvariable = ast_var_assign("eventtype", mixed_name))) {
  AST_LIST_INSERT_HEAD(headp, newvariable, entries);
  }
 
  if (ast_strlen_zero(cfg->general->date_format)) {
  snprintf(timebuf, sizeof(timebuf), "%ld.%06ld", (long) record.event_time.tv_sec,
  (long) record.event_time.tv_usec);
  } else {
  struct ast_tm tm;
  ast_localtime(&record.event_time, &tm, NULL);
  ast_strftime(timebuf, sizeof(timebuf), cfg->general->date_format, &tm);
  }
 
  if ((newvariable = ast_var_assign("eventtime", timebuf))) {
  AST_LIST_INSERT_HEAD(headp, newvariable, entries);
  }
 
  if ((newvariable = ast_var_assign("eventenum", record.event_name))) {
  AST_LIST_INSERT_HEAD(headp, newvariable, entries);
  }
  if ((newvariable = ast_var_assign("userdeftype", record.user_defined_name))) {
  AST_LIST_INSERT_HEAD(headp, newvariable, entries);
  }
  if ((newvariable = ast_var_assign("eventextra", record.extra))) {
  AST_LIST_INSERT_HEAD(headp, newvariable, entries);
  }
 
  ast_channel_caller(tchan)->id.name.valid = 1;
  ast_channel_caller(tchan)->id.name.str = ast_strdup(record.caller_id_name);
  ast_channel_caller(tchan)->id.number.valid = 1;
  ast_channel_caller(tchan)->id.number.str = ast_strdup(record.caller_id_num);
  ast_channel_caller(tchan)->ani.number.valid = 1;
  ast_channel_caller(tchan)->ani.number.str = ast_strdup(record.caller_id_ani);
  ast_channel_redirecting(tchan)->from.number.valid = 1;
  ast_channel_redirecting(tchan)->from.number.str = ast_strdup(record.caller_id_rdnis);
  ast_channel_dialed(tchan)->number.str = ast_strdup(record.caller_id_dnid);
 
  ast_channel_exten_set(tchan, record.extension);
  ast_channel_context_set(tchan, record.context);
  ast_channel_name_set(tchan, record.channel_name);
  ast_channel_internal_set_fake_ids(tchan, record.unique_id, record.linked_id);
  ast_channel_accountcode_set(tchan, record.account_code);
  ast_channel_peeraccount_set(tchan, record.peer_account);
  ast_channel_userfield_set(tchan, record.user_field);
 
  if ((newvariable = ast_var_assign("BRIDGEPEER", record.peer))) {
  AST_LIST_INSERT_HEAD(headp, newvariable, entries);
  }
 
  ast_channel_amaflags_set(tchan, record.amaflag);
 
  /* We need to store an 'application name' and 'application
  * data' on the channel for logging purposes, but the channel
  * structure only provides a place to store pointers, and it
  * expects these pointers to be pointing to data that does not
  * need to be freed. This means that the channel's destructor
  * does not attempt to free any storage that these pointers
  * point to. However, we can't provide data in that form directly for
  * these structure members. In order to ensure that these data
  * elements have a lifetime that matches the channel's
  * lifetime, we'll put them in a datastore attached to the
  * channel, and set's the channel's pointers to point into the
  * datastore. The datastore will then be automatically destroyed
  * when the channel is destroyed.
  */
 
  if (!(datastore = ast_datastore_alloc(&fabricated_channel_datastore, NULL))) {
  ast_channel_unref(tchan);
  return NULL;
  }
 
  if (!(app_data = ast_malloc(strlen(record.application_name) + strlen(record.application_data) + 2))) {
  ast_datastore_free(datastore);
  ast_channel_unref(tchan);
  return NULL;
  }
 
  ast_channel_appl_set(tchan, strcpy(app_data, record.application_name));
  ast_channel_data_set(tchan, strcpy(app_data + strlen(record.application_name) + 1,
  record.application_data));
 
  datastore->data = app_data;
  ast_channel_datastore_add(tchan, datastore);
 
  return tchan;
 }

◆ 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]	event	the CEL event
[out]	r	the ast_cel_event_record to fill in

Since: 1.8

Return values

0	success
non-zero	failure

Definition at line 819 of file cel.c.

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

 {
  if (r->version != AST_CEL_EVENT_RECORD_VERSION) {
  ast_log(LOG_ERROR, "Module ABI mismatch for ast_cel_event_record. "
  "Please ensure all modules were compiled for "
  "this version of Asterisk.\n");
  return -1;
  }
 
  r->event_type = ast_event_get_ie_uint(e, AST_EVENT_IE_CEL_EVENT_TYPE);
 
  r->event_time.tv_sec = ast_event_get_ie_uint(e, AST_EVENT_IE_CEL_EVENT_TIME);
  r->event_time.tv_usec = ast_event_get_ie_uint(e, AST_EVENT_IE_CEL_EVENT_TIME_USEC);
 
  r->event_name = ast_cel_get_type_name(r->event_type);
  if (r->event_type == AST_CEL_USER_DEFINED) {
  r->user_defined_name = ast_event_get_ie_str(e, AST_EVENT_IE_CEL_USEREVENT_NAME);
  } else {
  r->user_defined_name = "";
  }
 
  r->caller_id_name = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_CIDNAME), "");
  r->caller_id_num = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_CIDNUM), "");
  r->caller_id_ani = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_CIDANI), "");
  r->caller_id_rdnis = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_CIDRDNIS), "");
  r->caller_id_dnid = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_CIDDNID), "");
  r->extension = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_EXTEN), "");
  r->context = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_CONTEXT), "");
  r->channel_name = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_CHANNAME), "");
  r->application_name = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_APPNAME), "");
  r->application_data = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_APPDATA), "");
  r->account_code = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_ACCTCODE), "");
  r->peer_account = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_PEERACCT), "");
  r->unique_id = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_UNIQUEID), "");
  r->linked_id = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_LINKEDID), "");
  r->amaflag = ast_event_get_ie_uint(e, AST_EVENT_IE_CEL_AMAFLAGS);
  r->user_field = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_USERFIELD), "");
  r->peer = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_PEER), "");
  r->extra = S_OR(ast_event_get_ie_str(e, AST_EVENT_IE_CEL_EXTRA), "");
 
  return 0;
 }

◆ ast_cel_general_config_alloc()

void* ast_cel_general_config_alloc ( void )

Allocate a CEL configuration object.

Return values

NULL	on error
The	new CEL configuration object

Definition at line 188 of file cel.c.

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().

 {
  RAII_VAR(struct ast_cel_general_config *, cfg, NULL, ao2_cleanup);
 
  if (!(cfg = ao2_alloc(sizeof(*cfg), cel_general_config_dtor))) {
  return NULL;
  }
 
  if (ast_string_field_init(cfg, 64)) {
  return NULL;
  }
 
  if (!(cfg->apps = ast_str_container_alloc(NUM_APP_BUCKETS))) {
  return NULL;
  }
 
  ao2_ref(cfg, +1);
  return cfg;
 }

◆ 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

NULL	on error
The	current CEL configuration

Definition at line 1690 of file cel.c.

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

Referenced by test_cel_init_cb().

 {
  RAII_VAR(struct cel_config *, mod_cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
 
  if (!mod_cfg || !mod_cfg->general) {
  return NULL;
  }
 
  ao2_ref(mod_cfg->general, +1);
  return mod_cfg->general;
 }

◆ 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

type	the type to get the name of

Since: 1.8

Returns: the string representation of the type

Definition at line 491 of file cel.c.

References cel_event_types, and S_OR.

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

 {
  return S_OR(cel_event_types[type], "Unknown");
 }

◆ 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

chan	This is the primary channel associated with this channel event.
event_type	This is the type of call event being reported.
blob	This contains any additional parameters that need to be conveyed for this event.

Definition at line 1666 of file cel.c.

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 celgenuserevent_exec().

 {
  struct ast_json *cel_blob;
  struct stasis_message *message;
 
  cel_blob = ast_json_pack("{s: i, s: o}",
  "event_type", event_type,
  "event_details", ast_json_ref(blob));
 
  message = ast_channel_blob_create_from_cache(ast_channel_uniqueid(chan), cel_generic_type(), cel_blob);
  if (message) {
  stasis_publish(ast_cel_topic(), message);
  }
  ao2_cleanup(message);
  ast_json_unref(cel_blob);
 }

◆ ast_cel_set_config()

void ast_cel_set_config ( struct ast_cel_general_config * config )

Set the current CEL configuration.

Since: 12

Parameters

config The new CEL configuration

Definition at line 1702 of file cel.c.

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().

 {
  int was_enabled;
  int is_enabled;
  struct ast_cel_general_config *cleanup_config;
  struct cel_config *mod_cfg = ao2_global_obj_ref(cel_configs);
 
  if (mod_cfg) {
  was_enabled = ast_cel_check_enabled();
 
  cleanup_config = mod_cfg->general;
  ao2_bump(config);
  mod_cfg->general = config;
  ao2_cleanup(cleanup_config);
 
  is_enabled = ast_cel_check_enabled();
  if (!was_enabled && is_enabled) {
  create_routes();
  } else if (was_enabled && !is_enabled) {
  destroy_routes();
  }
 
  ao2_ref(mod_cfg, -1);
  }
 }

◆ 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

name	the event type name as a string

Since: 1.8

Returns: the ast_cel_event_type given by the string

Definition at line 418 of file cel.c.

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

Referenced by events_handler().

 {
  unsigned int i;
 
  for (i = 0; i < ARRAY_LEN(cel_event_types); i++) {
  if (cel_event_types[i] && !strcasecmp(name, cel_event_types[i])) {
  return i;
  }
  }
 
  ast_log(LOG_ERROR, "Unknown event name '%s'\n", name);
  return AST_CEL_INVALID_VALUE;
 }

◆ ast_cel_topic()

struct stasis_topic* ast_cel_topic ( void )

Get the CEL topic.

Return values

The	CEL topic
NULL	if not allocated

Definition at line 1685 of file cel.c.

References cel_topic.

Referenced by ast_cel_publish_event(), and create_subscriptions().

 {
  return cel_topic;
 }

◆ ast_cel_track_event()

static int ast_cel_track_event ( enum ast_cel_event_type et )

static

Definition at line 432 of file cel.c.

References ao2_cleanup, ao2_global_obj_ref, and RAII_VAR.

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

 {
  RAII_VAR(struct cel_config *, cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
 
  if (!cfg || !cfg->general) {
  return 0;
  }
 
  return (cfg->general->events & ((int64_t) 1 << et)) ? 1 : 0;
 }

◆ AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM ( void )

Definition at line 1770 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 1305 of file cel.c.

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_channel_snapshot_base::uniqueid, and ast_bridge_snapshot::uniqueid.

Referenced by create_routes().

 {
  struct ast_attended_transfer_message *xfer = stasis_message_data(message);
  struct ast_json *extra = NULL;
  struct ast_bridge_snapshot *bridge1, *bridge2;
  struct ast_channel_snapshot *channel1, *channel2;
 
  /* Make sure bridge1 is always non-NULL */
  if (!xfer->to_transferee.bridge_snapshot) {
  bridge1 = xfer->to_transfer_target.bridge_snapshot;
  bridge2 = xfer->to_transferee.bridge_snapshot;
  channel1 = xfer->to_transfer_target.channel_snapshot;
  channel2 = xfer->to_transferee.channel_snapshot;
  } else {
  bridge1 = xfer->to_transferee.bridge_snapshot;
  bridge2 = xfer->to_transfer_target.bridge_snapshot;
  channel1 = xfer->to_transferee.channel_snapshot;
  channel2 = xfer->to_transfer_target.channel_snapshot;
  }
 
  switch (xfer->dest_type) {
  case AST_ATTENDED_TRANSFER_DEST_FAIL:
  return;
  /* handle these three the same */
  case AST_ATTENDED_TRANSFER_DEST_BRIDGE_MERGE:
  case AST_ATTENDED_TRANSFER_DEST_LINK:
  case AST_ATTENDED_TRANSFER_DEST_THREEWAY:
  extra = ast_json_pack("{s: s, s: s, s: s, s: s, s: s, s: s, s: s, s: s}",
  "bridge1_id", bridge1->uniqueid,
  "channel2_name", channel2->base->name,
  "channel2_uniqueid", channel2->base->uniqueid,
  "bridge2_id", bridge2->uniqueid,
  "transferee_channel_name", xfer->transferee ? xfer->transferee->base->name : "N/A",
  "transferee_channel_uniqueid", xfer->transferee ? xfer->transferee->base->uniqueid : "N/A",
  "transfer_target_channel_name", xfer->target ? xfer->target->base->name : "N/A",
  "transfer_target_channel_uniqueid", xfer->target ? xfer->target->base->uniqueid : "N/A");
  if (!extra) {
  return;
  }
  break;
  case AST_ATTENDED_TRANSFER_DEST_APP:
  case AST_ATTENDED_TRANSFER_DEST_LOCAL_APP:
  extra = ast_json_pack("{s: s, s: s, s: s, s: s, s: s, s: s, s: s, s: s}",
  "bridge1_id", bridge1->uniqueid,
  "channel2_name", channel2->base->name,
  "channel2_uniqueid", channel2->base->uniqueid,
  "app", xfer->dest.app,
  "transferee_channel_name", xfer->transferee ? xfer->transferee->base->name : "N/A",
  "transferee_channel_uniqueid", xfer->transferee ? xfer->transferee->base->uniqueid : "N/A",
  "transfer_target_channel_name", xfer->target ? xfer->target->base->name : "N/A",
  "transfer_target_channel_uniqueid", xfer->target ? xfer->target->base->uniqueid : "N/A");
  if (!extra) {
  return;
  }
  break;
  }
  cel_report_event(channel1, AST_CEL_ATTENDEDTRANSFER, stasis_message_timestamp(message),
  NULL, extra, NULL);
  ast_json_unref(extra);
 }

◆ cel_backend_send_cb()

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

static

Definition at line 561 of file cel.c.

References cel_backend::callback.

Referenced by cel_report_event().

 {
  struct cel_backend *backend = obj;
 
  backend->callback(arg);
  return 0;
 }

◆ cel_blind_transfer_cb()

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

static

Definition at line 1279 of file cel.c.

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_channel_snapshot_base::uniqueid, and ast_bridge_snapshot::uniqueid.

Referenced by create_routes().

 {
  struct ast_blind_transfer_message *transfer_msg = stasis_message_data(message);
  struct ast_channel_snapshot *chan_snapshot = transfer_msg->transferer;
  struct ast_bridge_snapshot *bridge_snapshot = transfer_msg->bridge;
  struct ast_json *extra;
 
  if (transfer_msg->result != AST_BRIDGE_TRANSFER_SUCCESS) {
  return;
  }
 
  extra = ast_json_pack("{s: s, s: s, s: s, s: s, s: s}",
  "extension", transfer_msg->exten,
  "context", transfer_msg->context,
  "bridge_id", bridge_snapshot->uniqueid,
  "transferee_channel_name", transfer_msg->transferee ? transfer_msg->transferee->base->name : "N/A",
  "transferee_channel_uniqueid", transfer_msg->transferee ? transfer_msg->transferee->base->uniqueid : "N/A");
  if (extra) {
  cel_report_event(chan_snapshot, AST_CEL_BLINDTRANSFER, stasis_message_timestamp(message),
  NULL, extra, NULL);
  ast_json_unref(extra);
  }
 }

◆ cel_bridge_enter_cb()

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

static

Definition at line 1047 of file cel.c.

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().

 {
  struct ast_bridge_blob *blob = stasis_message_data(message);
  struct ast_bridge_snapshot *snapshot = blob->bridge;
  struct ast_channel_snapshot *chan_snapshot = blob->channel;
  RAII_VAR(struct ast_json *, extra, NULL, ast_json_unref);
  RAII_VAR(struct ast_str *, peer_str, NULL, ast_free);
 
  if (cel_filter_channel_snapshot(chan_snapshot)) {
  return;
  }
 
  extra = ast_json_pack("{s: s, s: s}",
  "bridge_id", snapshot->uniqueid,
  "bridge_technology", snapshot->technology);
  if (!extra) {
  return;
  }
 
  peer_str = cel_generate_peer_str(snapshot, chan_snapshot);
  if (!peer_str) {
  return;
  }
 
  cel_report_event(chan_snapshot, AST_CEL_BRIDGE_ENTER, stasis_message_timestamp(message),
  NULL, extra, ast_str_buffer(peer_str));
 }

◆ cel_bridge_leave_cb()

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

static

Definition at line 1077 of file cel.c.

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().

 {
  struct ast_bridge_blob *blob = stasis_message_data(message);
  struct ast_bridge_snapshot *snapshot = blob->bridge;
  struct ast_channel_snapshot *chan_snapshot = blob->channel;
  RAII_VAR(struct ast_json *, extra, NULL, ast_json_unref);
  RAII_VAR(struct ast_str *, peer_str, NULL, ast_free);
 
  if (cel_filter_channel_snapshot(chan_snapshot)) {
  return;
  }
 
  extra = ast_json_pack("{s: s, s: s}",
  "bridge_id", snapshot->uniqueid,
  "bridge_technology", snapshot->technology);
  if (!extra) {
  return;
  }
 
  peer_str = cel_generate_peer_str(snapshot, chan_snapshot);
  if (!peer_str) {
  return;
  }
 
  cel_report_event(chan_snapshot, AST_CEL_BRIDGE_EXIT, stasis_message_timestamp(message),
  NULL, extra, ast_str_buffer(peer_str));
 }

◆ 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 955 of file cel.c.

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.

 {
  if (old_snapshot && !strcmp(old_snapshot->dialplan->appl, new_snapshot->dialplan->appl)) {
  return;
  }
 
  /* old snapshot has an application, end it */
  if (old_snapshot && !ast_strlen_zero(old_snapshot->dialplan->appl)) {
  cel_report_event(old_snapshot, AST_CEL_APP_END, event_time, NULL, NULL, NULL);
  }
 
  /* new snapshot has an application, start it */
  if (!ast_strlen_zero(new_snapshot->dialplan->appl)) {
  cel_report_event(new_snapshot, AST_CEL_APP_START, event_time, NULL, NULL, 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 936 of file cel.c.

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.

 {
  if (!old_snapshot) {
  return;
  }
 
  ast_assert(!ast_strlen_zero(new_snapshot->peer->linkedid));
  ast_assert(!ast_strlen_zero(old_snapshot->peer->linkedid));
 
  if (ast_cel_track_event(AST_CEL_LINKEDID_END)
  && strcmp(old_snapshot->peer->linkedid, new_snapshot->peer->linkedid)) {
  cel_linkedid_ref(new_snapshot->peer->linkedid);
  check_retire_linkedid(old_snapshot, event_time);
  }
 }

◆ 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 896 of file cel.c.

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.

 {
  int is_hungup, was_hungup;
 
  if (!old_snapshot) {
  cel_report_event(new_snapshot, AST_CEL_CHANNEL_START, event_time, NULL, NULL, NULL);
  return;
  }
 
  was_hungup = ast_test_flag(&old_snapshot->flags, AST_FLAG_DEAD) ? 1 : 0;
  is_hungup = ast_test_flag(&new_snapshot->flags, AST_FLAG_DEAD) ? 1 : 0;
 
  if (!was_hungup && is_hungup) {
  struct ast_json *extra;
  struct cel_dialstatus *dialstatus = get_dialstatus(new_snapshot->base->uniqueid);
 
  extra = ast_json_pack("{s: i, s: s, s: s}",
  "hangupcause", new_snapshot->hangup->cause,
  "hangupsource", new_snapshot->hangup->source,
  "dialstatus", dialstatus ? dialstatus->dialstatus : "");
  cel_report_event(new_snapshot, AST_CEL_HANGUP, event_time, NULL, extra, NULL);
  ast_json_unref(extra);
  ao2_cleanup(dialstatus);
 
  cel_report_event(new_snapshot, AST_CEL_CHANNEL_END, event_time, NULL, NULL, NULL);
  if (ast_cel_track_event(AST_CEL_LINKEDID_END)) {
  check_retire_linkedid(new_snapshot, event_time);
  }
  return;
  }
 
  if (old_snapshot->state != new_snapshot->state && new_snapshot->state == AST_STATE_UP) {
  cel_report_event(new_snapshot, AST_CEL_ANSWER, event_time, NULL, NULL, NULL);
  return;
  }
 }

◆ cel_config_alloc()

static void* cel_config_alloc ( void )

static

Definition at line 224 of file cel.c.

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

Referenced by load_module().

 {
  RAII_VAR(struct cel_config *, cfg, NULL, ao2_cleanup);
 
  if (!(cfg = ao2_alloc(sizeof(*cfg), cel_config_dtor))) {
  return NULL;
  }
 
  if (!(cfg->general = ast_cel_general_config_alloc())) {
  return NULL;
  }
 
  ao2_ref(cfg, +1);
  return cfg;
 }

◆ cel_config_dtor()

static void cel_config_dtor ( void * obj )

static

Destructor for cel_config.

Definition at line 217 of file cel.c.

References ao2_cleanup, cel_config::general, and NULL.

Referenced by cel_config_alloc().

 {
  struct cel_config *cfg = obj;
  ao2_cleanup(cfg->general);
  cfg->general = NULL;
 }

◆ cel_dial_cb()

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

static

Definition at line 1229 of file cel.c.

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().

 {
  struct ast_multi_channel_blob *blob = stasis_message_data(message);
  struct ast_channel_snapshot *snapshot;
 
  snapshot = ast_multi_channel_blob_get_channel(blob, "caller");
  if (!snapshot || cel_filter_channel_snapshot(snapshot)) {
  return;
  }
 
  if (!ast_strlen_zero(get_blob_variable(blob, "forward"))) {
  struct ast_json *extra;
 
  extra = ast_json_pack("{s: s}", "forward", get_blob_variable(blob, "forward"));
  if (extra) {
  cel_report_event(snapshot, AST_CEL_FORWARD, stasis_message_timestamp(message),
  NULL, extra, NULL);
  ast_json_unref(extra);
  }
  }
 
  if (is_valid_dialstatus(blob)) {
  save_dialstatus(blob, snapshot);
  }
 }

◆ cel_filter_channel_snapshot()

static int cel_filter_channel_snapshot ( struct ast_channel_snapshot * snapshot )

static

Definition at line 986 of file cel.c.

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().

 {
  if (!snapshot) {
  return 0;
  }
  return snapshot->base->tech_properties & AST_CHAN_TP_INTERNAL;
 }

◆ cel_general_config_dtor()

static void cel_general_config_dtor ( void * obj )

static

Destructor for cel_config.

Definition at line 180 of file cel.c.

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

Referenced by ast_cel_general_config_alloc().

 {
  struct ast_cel_general_config *cfg = obj;
  ast_string_field_free_memory(cfg);
  ao2_cleanup(cfg->apps);
  cfg->apps = NULL;
 }

◆ 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 1009 of file cel.c.

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().

 {
  struct ast_str *peer_str = ast_str_create(32);
  struct ao2_iterator i;
  char *current_chan = NULL;
 
  if (!peer_str) {
  return NULL;
  }
 
  for (i = ao2_iterator_init(bridge->channels, 0);
  (current_chan = ao2_iterator_next(&i));
  ao2_cleanup(current_chan)) {
  struct ast_channel_snapshot *current_snapshot;
 
  /* Don't add the channel for which this message is being generated */
  if (!strcmp(current_chan, chan->base->uniqueid)) {
  continue;
  }
 
  current_snapshot = ast_channel_snapshot_get_latest(current_chan);
  if (!current_snapshot) {
  continue;
  }
 
  ast_str_append(&peer_str, 0, "%s,", current_snapshot->base->name);
  ao2_cleanup(current_snapshot);
  }
  ao2_iterator_destroy(&i);
 
  /* Rip off the trailing comma */
  ast_str_truncate(peer_str, -1);
 
  return peer_str;
 }

◆ cel_generic_cb()

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

static

Definition at line 1256 of file cel.c.

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().

 {
  struct ast_channel_blob *obj = stasis_message_data(message);
  int event_type = ast_json_integer_get(ast_json_object_get(obj->blob, "event_type"));
  struct ast_json *event_details = ast_json_object_get(obj->blob, "event_details");
 
  switch (event_type) {
  case AST_CEL_USER_DEFINED:
  {
  const char *event = ast_json_string_get(ast_json_object_get(event_details, "event"));
  struct ast_json *extra = ast_json_object_get(event_details, "extra");
  cel_report_event(obj->snapshot, event_type, stasis_message_timestamp(message),
  event, extra, NULL);
  break;
  }
  default:
  ast_log(LOG_ERROR, "Unhandled %s event blob\n", ast_cel_get_type_name(event_type));
  break;
  }
 }

◆ cel_generic_type()

struct stasis_message_type* cel_generic_type ( void )

Referenced by ast_cel_publish_event(), create_routes(), load_module(), and unload_module().

◆ cel_linkedid_ref()

static int cel_linkedid_ref ( const char * linkedid )

static

Definition at line 781 of file cel.c.

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(), cel_report_event(), and cel_track_app().

 {
  RAII_VAR(struct ao2_container *, linkedids, ao2_global_obj_ref(cel_linkedids), ao2_cleanup);
  struct cel_linkedid *lid;
 
  if (ast_strlen_zero(linkedid)) {
  ast_log(LOG_ERROR, "The linkedid should never be empty\n");
  return -1;
  }
  if (!linkedids) {
  /* The CEL module is shutdown. Abort. */
  return -1;
  }
 
  ao2_lock(linkedids);
  lid = ao2_find(linkedids, (void *) linkedid, OBJ_SEARCH_KEY);
  if (!lid) {
  /*
  * Changes to the lid->count member are protected by the
  * container lock so the lid object does not need its own lock.
  */
  lid = ao2_alloc_options(sizeof(*lid) + strlen(linkedid) + 1, NULL,
  AO2_ALLOC_OPT_LOCK_NOLOCK);
  if (!lid) {
  ao2_unlock(linkedids);
  return -1;
  }
  strcpy(lid->id, linkedid);/* Safe */
 
  ao2_link(linkedids, lid);
  }
  ++lid->count;
  ao2_unlock(linkedids);
  ao2_ref(lid, -1);
 
  return 0;
 }

◆ cel_local_cb()

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

static

Definition at line 1392 of file cel.c.

References AST_CEL_LOCAL_OPTIMIZE, 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().

 {
  struct ast_multi_channel_blob *obj = stasis_message_data(message);
  struct ast_channel_snapshot *localone = ast_multi_channel_blob_get_channel(obj, "1");
  struct ast_channel_snapshot *localtwo = ast_multi_channel_blob_get_channel(obj, "2");
  struct ast_json *extra;
 
  if (!localone || !localtwo) {
  return;
  }
 
  extra = ast_json_pack("{s: s, s: s}",
  "local_two", localtwo->base->name,
  "local_two_uniqueid", localtwo->base->uniqueid);
  if (!extra) {
  return;
  }
 
  cel_report_event(localone, AST_CEL_LOCAL_OPTIMIZE, stasis_message_timestamp(message), NULL, extra, NULL);
  ast_json_unref(extra);
 }

◆ cel_parking_cb()

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

static

Definition at line 1107 of file cel.c.

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().

 {
  struct ast_parked_call_payload *parked_payload = stasis_message_data(message);
  RAII_VAR(struct ast_json *, extra, NULL, ast_json_unref);
  const char *reason = NULL;
 
  switch (parked_payload->event_type) {
  case PARKED_CALL:
  extra = ast_json_pack("{s: s, s: s}",
  "parker_dial_string", parked_payload->parker_dial_string,
  "parking_lot", parked_payload->parkinglot);
  if (extra) {
  cel_report_event(parked_payload->parkee, AST_CEL_PARK_START, stasis_message_timestamp(message),
  NULL, extra, NULL);
  }
  return;
  case PARKED_CALL_TIMEOUT:
  reason = "ParkedCallTimeOut";
  break;
  case PARKED_CALL_GIVEUP:
  reason = "ParkedCallGiveUp";
  break;
  case PARKED_CALL_UNPARKED:
  reason = "ParkedCallUnparked";
  break;
  case PARKED_CALL_FAILED:
  reason = "ParkedCallFailed";
  break;
  case PARKED_CALL_SWAP:
  reason = "ParkedCallSwap";
  break;
  }
 
  if (parked_payload->retriever) {
  extra = ast_json_pack("{s: s, s: s}",
  "reason", reason ?: "",
  "retriever", parked_payload->retriever->base->name);
  } else {
  extra = ast_json_pack("{s: s}", "reason", reason ?: "");
  }
 
  if (extra) {
  cel_report_event(parked_payload->parkee, AST_CEL_PARK_END, stasis_message_timestamp(message),
  NULL, extra, NULL);
  }
 }

◆ cel_pickup_cb()

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

static

Definition at line 1368 of file cel.c.

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().

 {
  struct ast_multi_channel_blob *obj = stasis_message_data(message);
  struct ast_channel_snapshot *channel = ast_multi_channel_blob_get_channel(obj, "channel");
  struct ast_channel_snapshot *target = ast_multi_channel_blob_get_channel(obj, "target");
  struct ast_json *extra;
 
  if (!channel || !target) {
  return;
  }
 
  extra = ast_json_pack("{s: s, s: s}",
  "pickup_channel", channel->base->name,
  "pickup_channel_uniqueid", channel->base->uniqueid);
  if (!extra) {
  return;
  }
 
  cel_report_event(target, AST_CEL_PICKUP, stasis_message_timestamp(message), NULL, extra, NULL);
  ast_json_unref(extra);
 }

◆ cel_pre_apply_config()

static int cel_pre_apply_config ( void )

static

Definition at line 276 of file cel.c.

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.

 {
  struct cel_config *cfg = aco_pending_config(&cel_cfg_info);
 
  if (!cfg->general) {
  return -1;
  }
 
  if (!ao2_container_count(cfg->general->apps)) {
  return 0;
  }
 
  if (cfg->general->events & ((int64_t) 1 << AST_CEL_APP_START)) {
  return 0;
  }
 
  if (cfg->general->events & ((int64_t) 1 << AST_CEL_APP_END)) {
  return 0;
  }
 
  ast_log(LOG_ERROR, "Applications are listed to be tracked, but APP events are not tracked\n");
  return -1;
 }

◆ 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 569 of file cel.c.

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_cb(), cel_parking_cb(), cel_pickup_cb(), and check_retire_linkedid().

 {
  struct ast_event *ev;
  RAII_VAR(struct cel_config *, cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
  RAII_VAR(struct ao2_container *, backends, ao2_global_obj_ref(cel_backends), ao2_cleanup);
 
  if (!cfg || !cfg->general || !cfg->general->enable || !backends) {
  return 0;
  }
 
  /* Record the linkedid of new channels if we are tracking LINKEDID_END even if we aren't
  * reporting on CHANNEL_START so we can track when to send LINKEDID_END */
  if (event_type == AST_CEL_CHANNEL_START
  && ast_cel_track_event(AST_CEL_LINKEDID_END)) {
  if (cel_linkedid_ref(snapshot->peer->linkedid)) {
  return -1;
  }
  }
 
  if (!ast_cel_track_event(event_type)) {
  return 0;
  }
 
  if ((event_type == AST_CEL_APP_START || event_type == AST_CEL_APP_END)
  && !cel_track_app(snapshot->dialplan->appl)) {
  return 0;
  }
 
  ev = ast_cel_create_event_with_time(snapshot, event_type, event_time, userdefevname, extra, peer_str);
  if (!ev) {
  return -1;
  }
 
  /* Distribute event to backends */
  ao2_callback(backends, OBJ_MULTIPLE | OBJ_NODATA, cel_backend_send_cb, ev);
  ast_event_destroy(ev);
 
  return 0;
 }

◆ cel_snapshot_update_cb()

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

static

Definition at line 994 of file cel.c.

References ARRAY_LEN, cel_channel_monitors, cel_filter_channel_snapshot(), ast_channel_snapshot_update::new_snapshot, ast_channel_snapshot_update::old_snapshot, stasis_message_data(), stasis_message_timestamp(), and update().

Referenced by create_routes().

 {
  struct ast_channel_snapshot_update *update = stasis_message_data(message);
  size_t i;
 
  if (cel_filter_channel_snapshot(update->old_snapshot) || cel_filter_channel_snapshot(update->new_snapshot)) {
  return;
  }
 
  for (i = 0; i < ARRAY_LEN(cel_channel_monitors); ++i) {
  cel_channel_monitors[i](update->old_snapshot, update->new_snapshot, stasis_message_timestamp(message));
  }
 }

◆ cel_track_app()

static int cel_track_app ( const char * const_app )

static

Definition at line 496 of file cel.c.

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

Referenced by cel_report_event().

 {
  RAII_VAR(struct cel_config *, cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
  RAII_VAR(char *, app, NULL, ao2_cleanup);
  char *app_lower;
 
  if (!cfg || !cfg->general) {
  return 0;
  }
 
  app_lower = ast_str_to_lower(ast_strdupa(const_app));
  app = ao2_find(cfg->general->apps, app_lower, OBJ_SEARCH_KEY);
  if (!app) {
  return 0;
  }
 
  return 1;
 }

◆ check_retire_linkedid()

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

static

Definition at line 614 of file cel.c.

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().

 {
  RAII_VAR(struct ao2_container *, linkedids, ao2_global_obj_ref(cel_linkedids), ao2_cleanup);
  struct cel_linkedid *lid;
 
  if (!linkedids || ast_strlen_zero(snapshot->peer->linkedid)) {
  /* The CEL module is shutdown. Abort. */
  return;
  }
 
  ao2_lock(linkedids);
 
  lid = ao2_find(linkedids, (void *) snapshot->peer->linkedid, OBJ_SEARCH_KEY);
  if (!lid) {
  ao2_unlock(linkedids);
 
  /*
  * The user may have done a reload to start tracking linkedids
  * when a call was already in progress. This is an unusual kind
  * of change to make after starting Asterisk.
  */
  ast_log(LOG_ERROR, "Something weird happened, couldn't find linkedid %s\n",
  snapshot->peer->linkedid);
  return;
  }
 
  if (!--lid->count) {
  /* No channels use this linkedid anymore. */
  ao2_unlink(linkedids, lid);
  ao2_unlock(linkedids);
 
  cel_report_event(snapshot, AST_CEL_LINKEDID_END, event_time, NULL, NULL, NULL);
  } else {
  ao2_unlock(linkedids);
  }
  ao2_ref(lid, -1);
 }

◆ 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 1500 of file cel.c.

References AO2_STRING_FIELD_CMP_FN, AO2_STRING_FIELD_HASH_FN, 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_end_type(), ast_log, AST_LOG_ERROR, ast_parked_call_type(), AST_TASKPROCESSOR_HIGH_WATER_LEVEL, 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_cb(), cel_parking_cb(), cel_pickup_cb(), cel_snapshot_update_cb(), 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().

 {
  int ret = 0;
 
  cel_state_router = stasis_message_router_create(cel_aggregation_topic);
  if (!cel_state_router) {
  return -1;
  }
  stasis_message_router_set_congestion_limits(cel_state_router, -1,
  6 * AST_TASKPROCESSOR_HIGH_WATER_LEVEL);
 
  ret |= stasis_message_router_add(cel_state_router,
  ast_channel_snapshot_type(),
  cel_snapshot_update_cb,
  NULL);
 
  ret |= stasis_message_router_add(cel_state_router,
  ast_channel_dial_type(),
  cel_dial_cb,
  NULL);
 
  ret |= stasis_message_router_add(cel_state_router,
  ast_channel_entered_bridge_type(),
  cel_bridge_enter_cb,
  NULL);
 
  ret |= stasis_message_router_add(cel_state_router,
  ast_channel_left_bridge_type(),
  cel_bridge_leave_cb,
  NULL);
 
  ret |= stasis_message_router_add(cel_state_router,
  ast_parked_call_type(),
  cel_parking_cb,
  NULL);
 
  ret |= stasis_message_router_add(cel_state_router,
  cel_generic_type(),
  cel_generic_cb,
  NULL);
 
  ret |= stasis_message_router_add(cel_state_router,
  ast_blind_transfer_type(),
  cel_blind_transfer_cb,
  NULL);
 
  ret |= stasis_message_router_add(cel_state_router,
  ast_attended_transfer_type(),
  cel_attended_transfer_cb,
  NULL);
 
  ret |= stasis_message_router_add(cel_state_router,
  ast_call_pickup_type(),
  cel_pickup_cb,
  NULL);
 
  ret |= stasis_message_router_add(cel_state_router,
  ast_local_optimization_end_type(),
  cel_local_cb,
  NULL);
 
  if (ret) {
  ast_log(AST_LOG_ERROR, "Failed to register for Stasis messages\n");
  }
 
  return ret;
 }

◆ create_subscriptions()

static int create_subscriptions ( void )

static

Create the Stasis subscriptions for CEL.

Definition at line 1454 of file cel.c.

References ast_bridge_topic_all(), ast_cel_topic(), ast_channel_topic_all(), ast_parking_topic(), stasis_forward_all(), and stasis_topic_create().

Referenced by load_module().

 {
  cel_aggregation_topic = stasis_topic_create("cel:aggregator");
  if (!cel_aggregation_topic) {
  return -1;
  }
 
  cel_topic = stasis_topic_create("cel:misc");
  if (!cel_topic) {
  return -1;
  }
 
  cel_channel_forwarder = stasis_forward_all(
  ast_channel_topic_all(),
  cel_aggregation_topic);
  if (!cel_channel_forwarder) {
  return -1;
  }
 
  cel_bridge_forwarder = stasis_forward_all(
  ast_bridge_topic_all(),
  cel_aggregation_topic);
  if (!cel_bridge_forwarder) {
  return -1;
  }
 
  cel_parking_forwarder = stasis_forward_all(
  ast_parking_topic(),
  cel_aggregation_topic);
  if (!cel_parking_forwarder) {
  return -1;
  }
 
  cel_cel_forwarder = stasis_forward_all(
  ast_cel_topic(),
  cel_aggregation_topic);
  if (!cel_cel_forwarder) {
  return -1;
  }
 
  return 0;
 }

◆ destroy_routes()

static void destroy_routes ( void )

static

Definition at line 1416 of file cel.c.

References NULL, and stasis_message_router_unsubscribe_and_join().

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

 {
  stasis_message_router_unsubscribe_and_join(cel_state_router);
  cel_state_router = NULL;
 }

◆ destroy_subscriptions()

static void destroy_subscriptions ( void )

static

Definition at line 1422 of file cel.c.

References ao2_cleanup, NULL, and stasis_forward_cancel().

Referenced by unload_module().

 {
  ao2_cleanup(cel_aggregation_topic);
  cel_aggregation_topic = NULL;
  ao2_cleanup(cel_topic);
  cel_topic = NULL;
 
  cel_channel_forwarder = stasis_forward_cancel(cel_channel_forwarder);
  cel_bridge_forwarder = stasis_forward_cancel(cel_bridge_forwarder);
  cel_parking_forwarder = stasis_forward_cancel(cel_parking_forwarder);
  cel_cel_forwarder = stasis_forward_cancel(cel_cel_forwarder);
 }

◆ events_handler()

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

static

Definition at line 443 of file cel.c.

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 ast_variable::value.

Referenced by load_module().

 {
  struct ast_cel_general_config *cfg = obj;
  char *events = ast_strdupa(var->value);
  char *cur_event;
 
  while ((cur_event = strsep(&events, ","))) {
  enum ast_cel_event_type event_type;
 
  cur_event = ast_strip(cur_event);
  if (ast_strlen_zero(cur_event)) {
  continue;
  }
 
  event_type = ast_cel_str_to_event_type(cur_event);
 
  if (event_type == AST_CEL_ALL) {
  /* All events */
  cfg->events = (int64_t) -1;
  } else if (event_type == AST_CEL_INVALID_VALUE) {
  return -1;
  } else {
  cfg->events |= ((int64_t) 1 << event_type);
  }
  }
 
  return 0;
 }

◆ get_blob_variable()

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

static

Definition at line 880 of file cel.c.

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().

 {
  struct ast_json *json = ast_multi_channel_blob_get_json(blob);
  if (!json) {
  return NULL;
  }
 
  json = ast_json_object_get(json, varname);
  if (!json) {
  return NULL;
  }
 
  return ast_json_string_get(json);
 }

◆ get_dialstatus()

static struct cel_dialstatus* get_dialstatus ( const char * uniqueid )

static

Definition at line 868 of file cel.c.

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

Referenced by cel_channel_state_change().

 {
  struct ao2_container *dial_statuses = ao2_global_obj_ref(cel_dialstatus_store);
  struct cel_dialstatus *dialstatus = NULL;
 
  if (dial_statuses) {
  dialstatus = ao2_find(dial_statuses, uniqueid, OBJ_SEARCH_KEY | OBJ_UNLINK);
  ao2_ref(dial_statuses, -1);
  }
  return dialstatus;
 }

◆ handle_cli_status()

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

static

Definition at line 353 of file cel.c.

References ao2_cleanup, ao2_global_obj_ref, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, app, ast_cli_args::argc, 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, ast_cli_args::fd, name, cel_backend::name, NULL, RAII_VAR, and ast_cli_entry::usage.

 {
  unsigned int i;
  RAII_VAR(struct cel_config *, cfg, ao2_global_obj_ref(cel_configs), ao2_cleanup);
  RAII_VAR(struct ao2_container *, backends, ao2_global_obj_ref(cel_backends), ao2_cleanup);
  struct ao2_iterator iter;
  char *app;
 
  switch (cmd) {
  case CLI_INIT:
  e->command = "cel show status";
  e->usage =
  "Usage: cel show status\n"
  " Displays the Channel Event Logging system status.\n";
  return NULL;
  case CLI_GENERATE:
  return NULL;
  case CLI_HANDLER:
  break;
  }
 
  if (a->argc > 3) {
  return CLI_SHOWUSAGE;
  }
 
  ast_cli(a->fd, "CEL Logging: %s\n", ast_cel_check_enabled() ? "Enabled" : "Disabled");
 
  if (!cfg || !cfg->general || !cfg->general->enable) {
  return CLI_SUCCESS;
  }
 
  for (i = 0; i < (sizeof(cfg->general->events) * 8); i++) {
  const char *name;
 
  if (!(cfg->general->events & ((int64_t) 1 << i))) {
  continue;
  }
 
  name = ast_cel_get_type_name(i);
  if (strcasecmp(name, "Unknown")) {
  ast_cli(a->fd, "CEL Tracking Event: %s\n", name);
  }
  }
 
  iter = ao2_iterator_init(cfg->general->apps, 0);
  for (; (app = ao2_iterator_next(&iter)); ao2_ref(app, -1)) {
  ast_cli(a->fd, "CEL Tracking Application: %s\n", app);
  }
  ao2_iterator_destroy(&iter);
 
  if (backends) {
  struct cel_backend *backend;
 
  iter = ao2_iterator_init(backends, 0);
  for (; (backend = ao2_iterator_next(&iter)); ao2_ref(backend, -1)) {
  ast_cli(a->fd, "CEL Event Subscriber: %s\n", backend->name);
  }
  ao2_iterator_destroy(&iter);
  }
 
  return CLI_SUCCESS;
 }

◆ is_valid_dialstatus()

static int is_valid_dialstatus ( struct ast_multi_channel_blob * blob )

static

Definition at line 1200 of file cel.c.

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

Referenced by cel_dial_cb().

 {
  const char *dialstatus = get_blob_variable(blob, "dialstatus");
  int res = 0;
 
  if (ast_strlen_zero(dialstatus)) {
  res = 0;
  } else if (!strcasecmp(dialstatus, "CHANUNAVAIL")) {
  res = 1;
  } else if (!strcasecmp(dialstatus, "CONGESTION")) {
  res = 1;
  } else if (!strcasecmp(dialstatus, "NOANSWER")) {
  res = 1;
  } else if (!strcasecmp(dialstatus, "BUSY")) {
  res = 1;
  } else if (!strcasecmp(dialstatus, "ANSWER")) {
  res = 1;
  } else if (!strcasecmp(dialstatus, "CANCEL")) {
  res = 1;
  } else if (!strcasecmp(dialstatus, "DONTCALL")) {
  res = 1;
  } else if (!strcasecmp(dialstatus, "TORTURE")) {
  res = 1;
  } else if (!strcasecmp(dialstatus, "INVALIDARGS")) {
  res = 1;
  }
  return res;
 }

◆ load_module()

static int load_module ( void )

static

Definition at line 1571 of file cel.c.

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(), container, create_routes(), create_subscriptions(), date_format, events_handler(), FLDSET, cel_config::general, LOG_NOTICE, NULL, NUM_APP_BUCKETS, NUM_DIALSTATUS_BUCKETS, OPT_BOOL_T, OPT_STRINGFIELD_T, STASIS_MESSAGE_TYPE_INIT, and STRFLDSET.

Referenced by ast_cel_backend_register().

 {
  struct ao2_container *container;
 
  container = ao2_container_alloc_hash(AO2_ALLOC_OPT_LOCK_MUTEX, 0,
  NUM_APP_BUCKETS, cel_linkedid_hash_fn, NULL, cel_linkedid_cmp_fn);
  ao2_global_obj_replace_unref(cel_linkedids, container);
  ao2_cleanup(container);
  if (!container) {
  return AST_MODULE_LOAD_FAILURE;
  }
 
  container = ao2_container_alloc_hash(AO2_ALLOC_OPT_LOCK_MUTEX, 0,
  NUM_DIALSTATUS_BUCKETS, cel_dialstatus_hash_fn, NULL, cel_dialstatus_cmp_fn);
  ao2_global_obj_replace_unref(cel_dialstatus_store, container);
  ao2_cleanup(container);
  if (!container) {
  return AST_MODULE_LOAD_FAILURE;
  }
 
  if (STASIS_MESSAGE_TYPE_INIT(cel_generic_type)) {
  return AST_MODULE_LOAD_FAILURE;
  }
 
  if (ast_cli_register(&cli_status)) {
  return AST_MODULE_LOAD_FAILURE;
  }
 
  container = ao2_container_alloc_hash(AO2_ALLOC_OPT_LOCK_MUTEX, 0, BACKEND_BUCKETS,
  cel_backend_hash_fn, NULL, cel_backend_cmp_fn);
  ao2_global_obj_replace_unref(cel_backends, container);
  ao2_cleanup(container);
  if (!container) {
  return AST_MODULE_LOAD_FAILURE;
  }
 
  if (aco_info_init(&cel_cfg_info)) {
  return AST_MODULE_LOAD_FAILURE;
  }
 
  aco_option_register(&cel_cfg_info, "enable", ACO_EXACT, general_options, "no", OPT_BOOL_T, 1, FLDSET(struct ast_cel_general_config, enable));
  aco_option_register(&cel_cfg_info, "dateformat", ACO_EXACT, general_options, "", OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_cel_general_config, date_format));
  aco_option_register_custom(&cel_cfg_info, "apps", ACO_EXACT, general_options, "", apps_handler, 0);
  aco_option_register_custom(&cel_cfg_info, "events", ACO_EXACT, general_options, "", events_handler, 0);
 
  if (aco_process_config(&cel_cfg_info, 0)) {
  struct cel_config *cel_cfg = cel_config_alloc();
 
  if (!cel_cfg) {
  return AST_MODULE_LOAD_FAILURE;
  }
 
  /* We couldn't process the configuration so create a default config. */
  if (!aco_set_defaults(&general_option, "general", cel_cfg->general)) {
  ast_log(LOG_NOTICE, "Failed to process CEL configuration; using defaults\n");
  ao2_global_obj_replace_unref(cel_configs, cel_cfg);
  }
  ao2_ref(cel_cfg, -1);
  }
 
  if (create_subscriptions()) {
  return AST_MODULE_LOAD_FAILURE;
  }
 
  if (ast_cel_check_enabled() && create_routes()) {
  return AST_MODULE_LOAD_FAILURE;
  }
 
  return AST_MODULE_LOAD_SUCCESS;
 }

◆ reload_module()

static int reload_module ( void )

static

Definition at line 1642 of file cel.c.

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

Referenced by ast_cel_backend_register().

 {
  unsigned int was_enabled = ast_cel_check_enabled();
  unsigned int is_enabled;
 
  if (aco_process_config(&cel_cfg_info, 1) == ACO_PROCESS_ERROR) {
  return -1;
  }
 
  is_enabled = ast_cel_check_enabled();
 
  if (!was_enabled && is_enabled) {
  if (create_routes()) {
  return -1;
  }
  } else if (was_enabled && !is_enabled) {
  destroy_routes();
  }
 
  ast_verb(3, "CEL logging %sabled.\n", is_enabled ? "en" : "dis");
 
  return 0;
 }

◆ save_dialstatus()

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

static

Definition at line 1156 of file cel.c.

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, ast_channel_snapshot_base::uniqueid, and cel_dialstatus::uniqueid.

Referenced by cel_dial_cb().

 {
  struct ao2_container *dial_statuses = ao2_global_obj_ref(cel_dialstatus_store);
  const char *dialstatus_string = get_blob_variable(blob, "dialstatus");
  struct cel_dialstatus *dialstatus;
  size_t dialstatus_string_len;
 
  if (!dial_statuses || ast_strlen_zero(dialstatus_string)) {
  ao2_cleanup(dial_statuses);
  return;
  }
 
  dialstatus = ao2_find(dial_statuses, snapshot->base->uniqueid, OBJ_SEARCH_KEY);
  if (dialstatus) {
  if (!strcasecmp(dialstatus_string, "ANSWER") && strcasecmp(dialstatus->dialstatus, "ANSWER")) {
  /* In the case of an answer after we already have a dial status we give
  * priority to the answer since the call was, well, answered. In the case of
  * failure dial status results we simply let the first failure be the status.
  */
  ao2_unlink(dial_statuses, dialstatus);
  ao2_ref(dialstatus, -1);
  } else {
  ao2_ref(dialstatus, -1);
  ao2_ref(dial_statuses, -1);
  return;
  }
  }
 
  dialstatus_string_len = strlen(dialstatus_string) + 1;
  dialstatus = ao2_alloc_options(sizeof(*dialstatus) + dialstatus_string_len, NULL,
  AO2_ALLOC_OPT_LOCK_NOLOCK);
  if (!dialstatus) {
  ao2_ref(dial_statuses, -1);
  return;
  }
 
  ast_copy_string(dialstatus->uniqueid, snapshot->base->uniqueid, sizeof(dialstatus->uniqueid));
  ast_copy_string(dialstatus->dialstatus, dialstatus_string, dialstatus_string_len);
 
  ao2_link(dial_statuses, dialstatus);
  ao2_ref(dialstatus, -1);
  ao2_ref(dial_statuses, -1);
 }

◆ STASIS_MESSAGE_TYPE_DEFN()

STASIS_MESSAGE_TYPE_DEFN ( cel_generic_type )

◆ unload_module()

static int unload_module ( void )

static

Definition at line 1435 of file cel.c.

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

Referenced by ast_cel_backend_register().

 {
  destroy_routes();
  destroy_subscriptions();
  STASIS_MESSAGE_TYPE_CLEANUP(cel_generic_type);
 
  ast_cli_unregister(&cli_status);
  aco_info_destroy(&cel_cfg_info);
  ao2_global_obj_release(cel_configs);
  ao2_global_obj_release(cel_dialstatus_store);
  ao2_global_obj_release(cel_linkedids);
  ao2_global_obj_release(cel_backends);
 
  return 0;
 }

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 = "30ef0c93b36035ec78c9cfd712d36d9b" , .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 1770 of file cel.c.

◆ ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 1770 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 120 of file cel.c.

◆ cel_bridge_forwarder

struct stasis_forward* cel_bridge_forwarder

static

Subscription for forwarding the channel caching topic

Definition at line 126 of file cel.c.

◆ cel_cel_forwarder

struct stasis_forward* cel_cel_forwarder

static

Subscription for forwarding the CEL-specific topic

Definition at line 132 of file cel.c.

◆ cel_channel_forwarder

struct stasis_forward* cel_channel_forwarder

static

Subscription for forwarding the channel caching topic

Definition at line 123 of file cel.c.

◆ cel_channel_monitors

cel_channel_snapshot_monitor cel_channel_monitors[]

Initial value:

= {
 cel_channel_app_change,
 cel_channel_state_change,
 cel_channel_linkedid_change,
}

Definition at line 980 of file cel.c.

Referenced by cel_snapshot_update_cb().

◆ cel_conf

struct aco_file cel_conf

static

Initial value:

= {
 .filename = "cel.conf", 
 .types = ACO_TYPES(&general_option, &ignore_option), 
}

The config file to be processed for the module.

Definition at line 264 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 305 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 129 of file cel.c.

◆ cel_state_router

struct stasis_message_router* cel_state_router

static

Message router for state that CEL needs to know about

Definition at line 114 of file cel.c.

◆ cel_topic

struct stasis_topic* cel_topic

static

Topic for CEL-specific messages

Definition at line 117 of file cel.c.

Referenced by ast_cel_topic().

◆ cli_status

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

static

Definition at line 416 of file cel.c.

◆ fabricated_channel_datastore

const struct ast_datastore_info fabricated_channel_datastore

static

Initial value:

= {
 .type = "CEL fabricated channel",
 .destroy = ast_free_ptr,
}

Definition at line 655 of file cel.c.

◆ 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 241 of file cel.c.

◆ general_options

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

static

Definition at line 300 of file cel.c.

◆ ignore_categories

const char* ignore_categories[]

static

Initial value:

= {
 "manager",
 "radius",
 NULL,
}

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

Definition at line 250 of file cel.c.

◆ ignore_option

struct aco_type ignore_option

static

Definition at line 256 of file cel.c.

Data Structures

Macros

Typedefs

Functions

Variables

Detailed Description

Macro Definition Documentation

◆ BACKEND_BUCKETS

◆ CEL_MAX_EVENT_IDS

◆ NUM_APP_BUCKETS

◆ NUM_DIALSTATUS_BUCKETS

Typedef Documentation

◆ cel_channel_snapshot_monitor

Function Documentation

◆ __reg_module()

◆ __unreg_module()

◆ AO2_GLOBAL_OBJ_STATIC() [1/4]

◆ AO2_GLOBAL_OBJ_STATIC() [2/4]

◆ AO2_GLOBAL_OBJ_STATIC() [3/4]

◆ AO2_GLOBAL_OBJ_STATIC() [4/4]

◆ apps_handler()

◆ ast_cel_backend_register()

◆ ast_cel_backend_unregister()

◆ ast_cel_check_enabled()

◆ ast_cel_create_event()

◆ ast_cel_create_event_with_time()

◆ ast_cel_fabricate_channel_from_event()

◆ ast_cel_fill_record()

◆ ast_cel_general_config_alloc()

◆ ast_cel_get_config()

◆ ast_cel_get_type_name()

◆ ast_cel_publish_event()

◆ ast_cel_set_config()

◆ ast_cel_str_to_event_type()

◆ ast_cel_topic()

◆ ast_cel_track_event()

◆ AST_MODULE_SELF_SYM()

◆ cel_attended_transfer_cb()

◆ cel_backend_send_cb()

◆ cel_blind_transfer_cb()

◆ cel_bridge_enter_cb()

◆ cel_bridge_leave_cb()

◆ cel_channel_app_change()

◆ cel_channel_linkedid_change()

◆ cel_channel_state_change()

◆ cel_config_alloc()

◆ cel_config_dtor()

◆ cel_dial_cb()

◆ cel_filter_channel_snapshot()

◆ cel_general_config_dtor()

◆ cel_generate_peer_str()

◆ cel_generic_cb()

◆ cel_generic_type()

◆ cel_linkedid_ref()

◆ cel_local_cb()

◆ cel_parking_cb()

◆ cel_pickup_cb()

◆ cel_pre_apply_config()

◆ cel_report_event()

◆ cel_snapshot_update_cb()

◆ cel_track_app()

◆ check_retire_linkedid()

◆ CONFIG_INFO_CORE()

◆ create_routes()

◆ create_subscriptions()

◆ destroy_routes()

◆ destroy_subscriptions()

◆ events_handler()

◆ get_blob_variable()

◆ get_dialstatus()

◆ handle_cli_status()

◆ is_valid_dialstatus()

◆ load_module()

◆ reload_module()

◆ save_dialstatus()

◆ STASIS_MESSAGE_TYPE_DEFN()

◆ unload_module()

Variable Documentation

◆ __mod_info

◆ ast_module_info