Asterisk - The Open Source Telephony Project GIT-master-55f4e6d
Typedefs | Functions | Variables
manager_channels.c File Reference

The Asterisk Management Interface - AMI (channel event handling) More...

#include "asterisk.h"
#include "asterisk/callerid.h"
#include "asterisk/channel.h"
#include "asterisk/manager.h"
#include "asterisk/stasis_message_router.h"
#include "asterisk/pbx.h"
#include "asterisk/stasis_channels.h"
Include dependency graph for manager_channels.c:

Go to the source code of this file.

Typedefs

typedef struct ast_manager_event_blob *(* channel_snapshot_monitor) (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)
 Typedef for callbacks that get called on channel snapshot updates. More...
 

Functions

struct ast_strast_manager_build_channel_state_string (const struct ast_channel_snapshot *snapshot)
 Generate the AMI message body from a channel snapshot. More...
 
struct ast_strast_manager_build_channel_state_string_prefix (const struct ast_channel_snapshot *snapshot, const char *prefix)
 Generate the AMI message body from a channel snapshot. More...
 
static void channel_chanspy_start_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_chanspy_stop_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_dial_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 Callback processing messages for channel dialing. More...
 
static void channel_dtmf_begin_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_dtmf_end_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_fax_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_flash_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_hangup_handler_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_hangup_request_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_hold_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_mixmonitor_mute_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_mixmonitor_start_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_mixmonitor_stop_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_moh_start_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_moh_stop_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static struct ast_manager_event_blobchannel_new_accountcode (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)
 
static struct ast_manager_event_blobchannel_new_callerid (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)
 
static struct ast_manager_event_blobchannel_new_connected_line (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)
 
static struct ast_manager_event_blobchannel_newexten (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)
 
static void channel_snapshot_update (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static struct ast_manager_event_blobchannel_state_change (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)
 Handle channel state changes. More...
 
static void channel_unhold_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static void channel_wink_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
 
static int dial_status_end (const char *dialstatus)
 
int manager_channels_init (void)
 Initialize support for AMI channel events. More...
 
static void manager_channels_shutdown (void)
 
static void publish_basic_channel_event (const char *event, int class, struct ast_channel_snapshot *snapshot)
 

Variables

channel_snapshot_monitor channel_monitors []
 
static struct stasis_forwardtopic_forwarder
 The Stasis Message Bus API subscription returned by the forwarding of the channel topic to the manager topic. More...
 

Detailed Description

The Asterisk Management Interface - AMI (channel event handling)

Author
David M. Lee, II dlee@.nosp@m.digi.nosp@m.um.co.nosp@m.m

AMI generated many per-channel and global-channel events by converting Stasis messages to AMI events. It makes sense to simply put them into a single file.

Definition in file manager_channels.c.

Typedef Documentation

◆ channel_snapshot_monitor

typedef struct ast_manager_event_blob *(* channel_snapshot_monitor) (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)

Typedef for callbacks that get called on channel snapshot updates.

Definition at line 535 of file manager_channels.c.

Function Documentation

◆ ast_manager_build_channel_state_string()

struct ast_str * ast_manager_build_channel_state_string ( const struct ast_channel_snapshot snapshot)

Generate the AMI message body from a channel snapshot.

Since
12
Parameters
snapshotthe channel snapshot for which to generate an AMI message body
Return values
NULLon error
Returns
ast_str* on success (must be ast_freed by caller)

Definition at line 535 of file manager_channels.c.

537{
539}
struct ast_str * ast_manager_build_channel_state_string_prefix(const struct ast_channel_snapshot *snapshot, const char *prefix)
Generate the AMI message body from a channel snapshot.

References ast_manager_build_channel_state_string_prefix().

Referenced by action_agents(), action_confbridgelist_item(), agent_login_to_ami(), agent_logoff_to_ami(), agi_channel_to_ami(), aoc_to_ami(), call_pickup_to_ami(), channel_dial_cb(), channel_dtmf_begin_cb(), channel_dtmf_end_cb(), channel_enter_cb(), channel_fax_cb(), channel_flash_cb(), channel_hangup_handler_cb(), channel_hangup_request_cb(), channel_hold_cb(), channel_leave_cb(), channel_mixmonitor_mute_cb(), channel_moh_start_cb(), channel_snapshot_update(), channel_unhold_cb(), channel_wink_cb(), confbridge_publish_manager_event(), dahdichannel_to_ami(), generate_status(), meetme_stasis_cb(), mwi_app_event_cb(), mwi_update_cb(), publish_basic_channel_event(), queue_channel_to_ami(), queue_multi_channel_to_ami(), rtcp_report_to_ami(), send_bridge_info_item_cb(), talking_start_to_ami(), talking_stop_to_ami(), and varset_to_ami().

◆ ast_manager_build_channel_state_string_prefix()

struct ast_str * ast_manager_build_channel_state_string_prefix ( const struct ast_channel_snapshot snapshot,
const char *  prefix 
)

Generate the AMI message body from a channel snapshot.

Since
12
Parameters
snapshotthe channel snapshot for which to generate an AMI message body
prefixWhat to prepend to the channel fields
Return values
NULLon error
Returns
ast_str* on success (must be ast_freed by caller)

Definition at line 461 of file manager_channels.c.

464{
465 struct ast_str *out;
466 char *caller_name;
467 char *connected_name;
468 int res;
469
470 if (!snapshot || (snapshot->base->tech_properties & AST_CHAN_TP_INTERNAL)) {
471 return NULL;
472 }
473
474 out = ast_str_create(1024);
475 if (!out) {
476 return NULL;
477 }
478
479 caller_name = ast_escape_c_alloc(snapshot->caller->name);
480 connected_name = ast_escape_c_alloc(snapshot->connected->name);
481
482 res = ast_str_set(&out, 0,
483 "%sChannel: %s\r\n"
484 "%sChannelState: %u\r\n"
485 "%sChannelStateDesc: %s\r\n"
486 "%sCallerIDNum: %s\r\n"
487 "%sCallerIDName: %s\r\n"
488 "%sConnectedLineNum: %s\r\n"
489 "%sConnectedLineName: %s\r\n"
490 "%sLanguage: %s\r\n"
491 "%sAccountCode: %s\r\n"
492 "%sContext: %s\r\n"
493 "%sExten: %s\r\n"
494 "%sPriority: %d\r\n"
495 "%sUniqueid: %s\r\n"
496 "%sLinkedid: %s\r\n",
497 prefix, snapshot->base->name,
498 prefix, snapshot->state,
499 prefix, ast_state2str(snapshot->state),
500 prefix, S_OR(snapshot->caller->number, "<unknown>"),
501 prefix, S_OR(caller_name, "<unknown>"),
502 prefix, S_OR(snapshot->connected->number, "<unknown>"),
503 prefix, S_OR(connected_name, "<unknown>"),
504 prefix, snapshot->base->language,
505 prefix, snapshot->base->accountcode,
506 prefix, snapshot->dialplan->context,
507 prefix, snapshot->dialplan->exten,
508 prefix, snapshot->dialplan->priority,
509 prefix, snapshot->base->uniqueid,
510 prefix, snapshot->peer->linkedid);
511
512 ast_free(caller_name);
513 ast_free(connected_name);
514
515 if (!res) {
516 ast_free(out);
517 return NULL;
518 }
519
520 if (snapshot->manager_vars) {
521 struct ast_var_t *var;
522 char *val;
524 val = ast_escape_c_alloc(var->value);
525 ast_str_append(&out, 0, "%sChanVariable: %s=%s\r\n",
526 prefix,
527 var->name, S_OR(val, ""));
528 ast_free(val);
529 }
530 }
531
532 return out;
533}
#define var
Definition: ast_expr2f.c:605
#define ast_free(a)
Definition: astmm.h:180
@ AST_CHAN_TP_INTERNAL
Channels with this particular technology are an implementation detail of Asterisk and should generall...
Definition: channel.h:971
const char * ast_state2str(enum ast_channel_state state)
Gives the string form of a given channel state.
Definition: channel.c:636
static char prefix[MAX_PREFIX]
Definition: http.c:144
#define AST_LIST_TRAVERSE(head, var, field)
Loops over (traverses) the entries in a list.
Definition: linkedlists.h:491
#define NULL
Definition: resample.c:96
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 S_OR(a, b)
returns the equivalent of logic or for strings: first one if not empty, otherwise second one.
Definition: strings.h:80
#define ast_str_create(init_len)
Create a malloc'ed dynamic length string.
Definition: strings.h:659
int ast_str_set(struct ast_str **buf, ssize_t max_len, const char *fmt,...)
Set a dynamic string using variable arguments.
Definition: strings.h:1113
char * ast_escape_c_alloc(const char *s)
Escape standard 'C' sequences in the given string.
Definition: utils.c:2140
const ast_string_field language
const ast_string_field accountcode
const ast_string_field uniqueid
const ast_string_field name
const ast_string_field number
const ast_string_field name
const ast_string_field context
const ast_string_field exten
struct ast_channel_snapshot_connected * connected
struct varshead * manager_vars
struct ast_channel_snapshot_dialplan * dialplan
struct ast_channel_snapshot_peer * peer
struct ast_channel_snapshot_base * base
enum ast_channel_state state
struct ast_channel_snapshot_caller * caller
Support for dynamic strings.
Definition: strings.h:623
struct ast_var_t::@211 entries
Definition: ast_expr2.c:325
FILE * out
Definition: utils/frame.c:33

References ast_channel_snapshot_base::accountcode, AST_CHAN_TP_INTERNAL, ast_escape_c_alloc(), ast_free, AST_LIST_TRAVERSE, ast_state2str(), ast_str_append(), ast_str_create, ast_str_set(), ast_channel_snapshot::base, ast_channel_snapshot::caller, ast_channel_snapshot::connected, ast_channel_snapshot_dialplan::context, ast_channel_snapshot::dialplan, ast_var_t::entries, ast_channel_snapshot_dialplan::exten, ast_channel_snapshot_base::language, ast_channel_snapshot_peer::linkedid, ast_channel_snapshot::manager_vars, ast_channel_snapshot_caller::name, ast_channel_snapshot_connected::name, ast_channel_snapshot_base::name, NULL, ast_channel_snapshot_caller::number, ast_channel_snapshot_connected::number, out, ast_channel_snapshot::peer, prefix, ast_channel_snapshot_dialplan::priority, S_OR, ast_channel_snapshot::state, ast_channel_snapshot_base::tech_properties, ast_channel_snapshot_base::uniqueid, and var.

Referenced by action_coreshowchannels(), ast_manager_build_channel_state_string(), attended_transfer_to_ami(), blind_transfer_to_ami(), call_pickup_to_ami(), channel_chanspy_start_cb(), channel_chanspy_stop_cb(), channel_dial_cb(), local_message_to_ami(), manager_build_parked_call_string(), multi_object_blob_to_ami(), and queue_multi_channel_to_ami().

◆ channel_chanspy_start_cb()

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

Definition at line 816 of file manager_channels.c.

818{
819 RAII_VAR(struct ast_str *, spyer_channel_string, NULL, ast_free);
820 RAII_VAR(struct ast_str *, spyee_channel_string, NULL, ast_free);
821 struct ast_channel_snapshot *spyer;
822 struct ast_channel_snapshot *spyee;
824
825 spyer = ast_multi_channel_blob_get_channel(payload, "spyer_channel");
826 if (!spyer) {
827 ast_log(AST_LOG_WARNING, "Received ChanSpy Start event with no spyer channel!\n");
828 return;
829 }
830 spyee = ast_multi_channel_blob_get_channel(payload, "spyee_channel");
831 if (!spyee) {
832 ast_log(AST_LOG_WARNING, "Received ChanSpy Start event with no spyee channel!\n");
833 return;
834 }
835
836 spyer_channel_string = ast_manager_build_channel_state_string_prefix(spyer, "Spyer");
837 if (!spyer_channel_string) {
838 return;
839 }
840 spyee_channel_string = ast_manager_build_channel_state_string_prefix(spyee, "Spyee");
841 if (!spyee_channel_string) {
842 return;
843 }
844
845 manager_event(EVENT_FLAG_CALL, "ChanSpyStart",
846 "%s%s",
847 ast_str_buffer(spyer_channel_string),
848 ast_str_buffer(spyee_channel_string));
849}
#define ast_log
Definition: astobj2.c:42
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.
#define AST_LOG_WARNING
#define manager_event(category, event, contents,...)
External routines may send asterisk manager events this way.
Definition: manager.h:253
#define EVENT_FLAG_CALL
Definition: manager.h:76
void * stasis_message_data(const struct stasis_message *msg)
Get the data contained in a message.
char * ast_str_buffer(const struct ast_str *buf)
Returns the string buffer within the ast_str buf.
Definition: strings.h:761
Structure representing a snapshot of channel state.
A multi channel blob data structure for multi_channel_blob stasis messages.
#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 ast_free, ast_log, AST_LOG_WARNING, ast_manager_build_channel_state_string_prefix(), ast_multi_channel_blob_get_channel(), ast_str_buffer(), EVENT_FLAG_CALL, manager_event, NULL, RAII_VAR, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_chanspy_stop_cb()

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

Definition at line 781 of file manager_channels.c.

783{
784 RAII_VAR(struct ast_str *, spyer_channel_string, NULL, ast_free);
785 RAII_VAR(struct ast_str *, spyee_channel_string, NULL, ast_free);
786 struct ast_channel_snapshot *spyer;
787 struct ast_channel_snapshot *spyee;
788 const char *spyee_info = "";
790
791 spyer = ast_multi_channel_blob_get_channel(payload, "spyer_channel");
792 if (!spyer) {
793 ast_log(AST_LOG_WARNING, "Received ChanSpy Stop event with no spyer channel!\n");
794 return;
795 }
796
797 spyer_channel_string = ast_manager_build_channel_state_string_prefix(spyer, "Spyer");
798 if (!spyer_channel_string) {
799 return;
800 }
801
802 spyee = ast_multi_channel_blob_get_channel(payload, "spyee_channel");
803 if (spyee) {
804 spyee_channel_string = ast_manager_build_channel_state_string_prefix(spyee, "Spyee");
805 if (spyee_channel_string) {
806 spyee_info = ast_str_buffer(spyee_channel_string);
807 }
808 }
809
810 manager_event(EVENT_FLAG_CALL, "ChanSpyStop",
811 "%s%s",
812 ast_str_buffer(spyer_channel_string),
813 spyee_info);
814}

References ast_free, ast_log, AST_LOG_WARNING, ast_manager_build_channel_state_string_prefix(), ast_multi_channel_blob_get_channel(), ast_str_buffer(), EVENT_FLAG_CALL, manager_event, NULL, RAII_VAR, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_dial_cb()

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

Callback processing messages for channel dialing.

Definition at line 1194 of file manager_channels.c.

1196{
1198 const char *dialstatus;
1199 const char *dialstring;
1200 const char *forward;
1202 struct ast_channel_snapshot *peer;
1203 RAII_VAR(struct ast_str *, caller_event_string, NULL, ast_free);
1204 RAII_VAR(struct ast_str *, peer_event_string, NULL, ast_free);
1205
1208
1209 /* Peer is required - otherwise, who are we dialing? */
1210 ast_assert(peer != NULL);
1211 peer_event_string = ast_manager_build_channel_state_string_prefix(peer, "Dest");
1212 if (!peer_event_string) {
1213 return;
1214 }
1215
1216 if (caller && !(caller_event_string = ast_manager_build_channel_state_string(caller))) {
1217 return;
1218 }
1219
1223 if (ast_strlen_zero(dialstatus)) {
1224 manager_event(EVENT_FLAG_CALL, "DialBegin",
1225 "%s"
1226 "%s"
1227 "DialString: %s\r\n",
1228 caller_event_string ? ast_str_buffer(caller_event_string) : "",
1229 ast_str_buffer(peer_event_string),
1230 S_OR(dialstring, "unknown"));
1231 } else {
1232 int forwarded = !ast_strlen_zero(forward);
1233
1234 manager_event(EVENT_FLAG_CALL, dial_status_end(dialstatus) ? "DialEnd" : "DialState",
1235 "%s"
1236 "%s"
1237 "%s%s%s"
1238 "DialStatus: %s\r\n",
1239 caller_event_string ? ast_str_buffer(caller_event_string) : "",
1240 ast_str_buffer(peer_event_string),
1241 forwarded ? "Forward: " : "", S_OR(forward, ""), forwarded ? "\r\n" : "",
1242 S_OR(dialstatus, "unknown"));
1243 }
1244
1245}
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.
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
struct ast_str * ast_manager_build_channel_state_string(const struct ast_channel_snapshot *snapshot)
Generate the AMI message body from a channel snapshot.
static int dial_status_end(const char *dialstatus)
static force_inline int attribute_pure ast_strlen_zero(const char *s)
Definition: strings.h:65
#define ast_assert(a)
Definition: utils.h:739

References ast_assert, ast_free, ast_json_object_get(), ast_json_string_get(), ast_manager_build_channel_state_string(), ast_manager_build_channel_state_string_prefix(), ast_multi_channel_blob_get_channel(), ast_multi_channel_blob_get_json(), ast_str_buffer(), ast_strlen_zero(), ast_channel_snapshot::caller, dial_status_end(), EVENT_FLAG_CALL, manager_event, NULL, ast_channel_snapshot::peer, RAII_VAR, S_OR, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_dtmf_begin_cb()

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

Definition at line 851 of file manager_channels.c.

853{
855 RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
856 const char *digit =
858 const char *direction =
859 ast_json_string_get(ast_json_object_get(obj->blob, "direction"));
860
861 channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
862
863 if (!channel_event_string) {
864 return;
865 }
866
867 /*** DOCUMENTATION
868 <managerEvent language="en_US" name="DTMFBegin">
869 <managerEventInstance class="EVENT_FLAG_DTMF">
870 <synopsis>Raised when a DTMF digit has started on a channel.</synopsis>
871 <syntax>
872 <channel_snapshot/>
873 <parameter name="Digit">
874 <para>DTMF digit received or transmitted (0-9, A-E, # or *</para>
875 </parameter>
876 <parameter name="Direction">
877 <enumlist>
878 <enum name="Received"/>
879 <enum name="Sent"/>
880 </enumlist>
881 </parameter>
882 </syntax>
883 <see-also>
884 <ref type="managerEvent">DTMFEnd</ref>
885 </see-also>
886 </managerEventInstance>
887 </managerEvent>
888 ***/
889 manager_event(EVENT_FLAG_DTMF, "DTMFBegin",
890 "%s"
891 "Digit: %s\r\n"
892 "Direction: %s\r\n",
893 ast_str_buffer(channel_event_string),
895}
char digit
direction
#define EVENT_FLAG_DTMF
Definition: manager.h:83
Blob of data associated with a channel.
struct ast_channel_snapshot * snapshot
struct ast_json * blob

References ast_free, ast_json_object_get(), ast_json_string_get(), ast_manager_build_channel_state_string(), ast_str_buffer(), ast_channel_blob::blob, digit, EVENT_FLAG_DTMF, manager_event, NULL, RAII_VAR, ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_dtmf_end_cb()

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

Definition at line 897 of file manager_channels.c.

899{
901 RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
902 const char *digit =
904 const char *direction =
905 ast_json_string_get(ast_json_object_get(obj->blob, "direction"));
906 long duration_ms =
907 ast_json_integer_get(ast_json_object_get(obj->blob, "duration_ms"));
908
909 channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
910
911 if (!channel_event_string) {
912 return;
913 }
914
915 /*** DOCUMENTATION
916 <managerEvent language="en_US" name="DTMFEnd">
917 <managerEventInstance class="EVENT_FLAG_DTMF">
918 <synopsis>Raised when a DTMF digit has ended on a channel.</synopsis>
919 <syntax>
920 <channel_snapshot/>
921 <parameter name="Digit">
922 <para>DTMF digit received or transmitted (0-9, A-E, # or *</para>
923 </parameter>
924 <parameter name="DurationMs">
925 <para>Duration (in milliseconds) DTMF was sent/received</para>
926 </parameter>
927 <parameter name="Direction">
928 <enumlist>
929 <enum name="Received"/>
930 <enum name="Sent"/>
931 </enumlist>
932 </parameter>
933 </syntax>
934 <see-also>
935 <ref type="managerEvent">DTMFBegin</ref>
936 </see-also>
937 </managerEventInstance>
938 </managerEvent>
939 ***/
941 "%s"
942 "Digit: %s\r\n"
943 "DurationMs: %ld\r\n"
944 "Direction: %s\r\n",
945 ast_str_buffer(channel_event_string),
946 digit, duration_ms, direction);
947}
intmax_t ast_json_integer_get(const struct ast_json *integer)
Get the value from a JSON integer.
Definition: json.c:332

References ast_free, ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_manager_build_channel_state_string(), ast_str_buffer(), ast_channel_blob::blob, digit, EVENT_FLAG_DTMF, manager_event, NULL, RAII_VAR, ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_fax_cb()

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

Definition at line 1036 of file manager_channels.c.

1038{
1039 RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
1040 RAII_VAR(struct ast_str *, event_buffer, ast_str_create(256), ast_free);
1041 struct ast_channel_blob *payload = stasis_message_data(message);
1042 const char *type = ast_json_string_get(ast_json_object_get(payload->blob, "type"));
1043 struct ast_json *operation = ast_json_object_get(payload->blob, "operation");
1044 struct ast_json *status = ast_json_object_get(payload->blob, "status");
1045 struct ast_json *local_station_id = ast_json_object_get(payload->blob, "local_station_id");
1046 struct ast_json *remote_station_id = ast_json_object_get(payload->blob, "remote_station_id");
1047 struct ast_json *fax_pages = ast_json_object_get(payload->blob, "fax_pages");
1048 struct ast_json *fax_resolution = ast_json_object_get(payload->blob, "fax_resolution");
1049 struct ast_json *fax_bitrate = ast_json_object_get(payload->blob, "fax_bitrate");
1050 struct ast_json *filenames = ast_json_object_get(payload->blob, "filenames");
1051 const char *event;
1052 size_t array_len;
1053 size_t i;
1054
1055 if (!event_buffer) {
1056 return;
1057 }
1058
1059 channel_event_string = ast_manager_build_channel_state_string(payload->snapshot);
1060 if (!channel_event_string) {
1061 return;
1062 }
1063
1064 if (!strcmp(type, "status")) {
1065 event = "FAXStatus";
1066 } else if (!strcmp(type, "receive")) {
1067 event = "ReceiveFAX";
1068 } else if (!strcmp(type, "send")) {
1069 event = "SendFAX";
1070 } else {
1071 return;
1072 }
1073
1074 if (operation) {
1075 ast_str_append(&event_buffer, 0, "Operation: %s\r\n", ast_json_string_get(operation));
1076 }
1077 if (status) {
1078 ast_str_append(&event_buffer, 0, "Status: %s\r\n", ast_json_string_get(status));
1079 }
1080 if (local_station_id) {
1081 ast_str_append(&event_buffer, 0, "LocalStationID: %s\r\n", ast_json_string_get(local_station_id));
1082 }
1083 if (remote_station_id) {
1084 ast_str_append(&event_buffer, 0, "RemoteStationID: %s\r\n", ast_json_string_get(remote_station_id));
1085 }
1086 if (fax_pages) {
1087 ast_str_append(&event_buffer, 0, "PagesTransferred: %s\r\n", ast_json_string_get(fax_pages));
1088 }
1089 if (fax_resolution) {
1090 ast_str_append(&event_buffer, 0, "Resolution: %s\r\n", ast_json_string_get(fax_resolution));
1091 }
1092 if (fax_bitrate) {
1093 ast_str_append(&event_buffer, 0, "TransferRate: %s\r\n", ast_json_string_get(fax_bitrate));
1094 }
1095 if (filenames) {
1096 array_len = ast_json_array_size(filenames);
1097 for (i = 0; i < array_len; i++) {
1098 ast_str_append(&event_buffer, 0, "FileName: %s\r\n", ast_json_string_get(ast_json_array_get(filenames, i)));
1099 }
1100 }
1101
1103 "%s"
1104 "%s",
1105 ast_str_buffer(channel_event_string),
1106 ast_str_buffer(event_buffer));
1107}
jack_status_t status
Definition: app_jack.c:146
static const char type[]
Definition: chan_ooh323.c:109
struct ast_json * ast_json_array_get(const struct ast_json *array, size_t index)
Get an element from an array.
Definition: json.c:370
size_t ast_json_array_size(const struct ast_json *array)
Get the size of a JSON array.
Definition: json.c:366
Abstract JSON element (object, array, string, int, ...).
Definition: astman.c:222

References ast_free, ast_json_array_get(), ast_json_array_size(), ast_json_object_get(), ast_json_string_get(), ast_manager_build_channel_state_string(), ast_str_append(), ast_str_buffer(), ast_str_create, ast_channel_blob::blob, EVENT_FLAG_CALL, manager_event, NULL, RAII_VAR, ast_channel_blob::snapshot, stasis_message_data(), status, and type.

Referenced by manager_channels_init().

◆ channel_flash_cb()

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

Definition at line 949 of file manager_channels.c.

951{
953 struct ast_str *channel_event_string;
954
955 channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
956 if (!channel_event_string) {
957 return;
958 }
959
960 /*** DOCUMENTATION
961 <managerEvent language="en_US" name="Flash">
962 <managerEventInstance class="EVENT_FLAG_CALL">
963 <synopsis>Raised when a hook flash occurs on a channel.</synopsis>
964 <syntax>
965 <channel_snapshot/>
966 </syntax>
967 </managerEventInstance>
968 </managerEvent>
969 ***/
971 "%s",
972 ast_str_buffer(channel_event_string));
973
974 ast_free(channel_event_string);
975}

References ast_free, ast_manager_build_channel_state_string(), ast_str_buffer(), EVENT_FLAG_CALL, manager_event, ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_hangup_handler_cb()

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

Definition at line 1005 of file manager_channels.c.

1007{
1008 RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
1009 struct ast_channel_blob *payload = stasis_message_data(message);
1010 const char *action = ast_json_string_get(ast_json_object_get(payload->blob, "type"));
1011 const char *handler = ast_json_string_get(ast_json_object_get(payload->blob, "handler"));
1012 const char *event;
1013
1014 channel_event_string = ast_manager_build_channel_state_string(payload->snapshot);
1015
1016 if (!channel_event_string) {
1017 return;
1018 }
1019
1020 if (!strcmp(action, "run")) {
1021 event = "HangupHandlerRun";
1022 } else if (!strcmp(action, "pop")) {
1023 event = "HangupHandlerPop";
1024 } else if (!strcmp(action, "push")) {
1025 event = "HangupHandlerPush";
1026 } else {
1027 return;
1028 }
1030 "%s"
1031 "Handler: %s\r\n",
1032 ast_str_buffer(channel_event_string),
1033 handler);
1034}
#define EVENT_FLAG_DIALPLAN
Definition: manager.h:86
static void handler(const char *name, int response_code, struct ast_variable *get_params, struct ast_variable *path_vars, struct ast_variable *headers, struct ast_json *body, struct ast_ari_response *response)
Definition: test_ari.c:59

References ast_free, ast_json_object_get(), ast_json_string_get(), ast_manager_build_channel_state_string(), ast_str_buffer(), ast_channel_blob::blob, EVENT_FLAG_DIALPLAN, handler(), manager_event, NULL, RAII_VAR, ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_hangup_request_cb()

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

Definition at line 733 of file manager_channels.c.

736{
738 struct ast_str *extra;
739 struct ast_str *channel_event_string;
740 struct ast_json *cause;
741 int is_soft;
742 char *manager_event = "HangupRequest";
743
744 if (!obj->snapshot) {
745 /* No snapshot? Likely an earlier allocation failure creating it. */
746 return;
747 }
748
749 extra = ast_str_create(20);
750 if (!extra) {
751 return;
752 }
753
754 channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
755 if (!channel_event_string) {
756 ast_free(extra);
757 return;
758 }
759
760 cause = ast_json_object_get(obj->blob, "cause");
761 if (cause) {
762 ast_str_append(&extra, 0,
763 "Cause: %jd\r\n",
764 ast_json_integer_get(cause));
765 }
766
767 is_soft = ast_json_is_true(ast_json_object_get(obj->blob, "soft"));
768 if (is_soft) {
769 manager_event = "SoftHangupRequest";
770 }
771
773 "%s%s",
774 ast_str_buffer(channel_event_string),
775 ast_str_buffer(extra));
776
777 ast_free(channel_event_string);
778 ast_free(extra);
779}
int ast_json_is_true(const struct ast_json *value)
Check if value is JSON true.
Definition: json.c:263

References ast_free, ast_json_integer_get(), ast_json_is_true(), ast_json_object_get(), ast_manager_build_channel_state_string(), ast_str_append(), ast_str_buffer(), ast_str_create, ast_channel_blob::blob, EVENT_FLAG_CALL, manager_event, ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_hold_cb()

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

Definition at line 1247 of file manager_channels.c.

1249{
1251 struct ast_str *musicclass_string = ast_str_create(32);
1252 struct ast_str *channel_event_string;
1253
1254 if (!musicclass_string) {
1255 return;
1256 }
1257
1258 channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
1259 if (!channel_event_string) {
1260 ast_free(musicclass_string);
1261 return;
1262 }
1263
1264 if (obj->blob) {
1265 const char *musicclass;
1266
1267 musicclass = ast_json_string_get(ast_json_object_get(obj->blob, "musicclass"));
1268
1269 if (!ast_strlen_zero(musicclass)) {
1270 ast_str_set(&musicclass_string, 0, "MusicClass: %s\r\n", musicclass);
1271 }
1272 }
1273
1275 "%s"
1276 "%s",
1277 ast_str_buffer(channel_event_string),
1278 ast_str_buffer(musicclass_string));
1279
1280 ast_free(musicclass_string);
1281 ast_free(channel_event_string);
1282}

References ast_free, ast_json_object_get(), ast_json_string_get(), ast_manager_build_channel_state_string(), ast_str_buffer(), ast_str_create, ast_str_set(), ast_strlen_zero(), ast_channel_blob::blob, EVENT_FLAG_CALL, manager_event, ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_mixmonitor_mute_cb()

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

Definition at line 1153 of file manager_channels.c.

1155{
1156 RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
1157 RAII_VAR(struct ast_str *, event_buffer, ast_str_create(64), ast_free);
1158 struct ast_channel_blob *payload = stasis_message_data(message);
1159 struct ast_json *direction = ast_json_object_get(payload->blob, "direction");
1160 const int state = ast_json_is_true(ast_json_object_get(payload->blob, "state"));
1161
1162 if (!event_buffer) {
1163 return;
1164 }
1165
1166 channel_event_string = ast_manager_build_channel_state_string(payload->snapshot);
1167 if (!channel_event_string) {
1168 return;
1169 }
1170
1171 if (direction) {
1172 ast_str_append(&event_buffer, 0, "Direction: %s\r\n", ast_json_string_get(direction));
1173 }
1174 ast_str_append(&event_buffer, 0, "State: %s\r\n", state ? "1" : "0");
1175
1176 manager_event(EVENT_FLAG_CALL, "MixMonitorMute",
1177 "%s"
1178 "%s",
1179 ast_str_buffer(channel_event_string),
1180 ast_str_buffer(event_buffer));
1181
1182}

References ast_free, ast_json_is_true(), ast_json_object_get(), ast_json_string_get(), ast_manager_build_channel_state_string(), ast_str_append(), ast_str_buffer(), ast_str_create, ast_channel_blob::blob, EVENT_FLAG_CALL, manager_event, NULL, RAII_VAR, ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_mixmonitor_start_cb()

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

Definition at line 1137 of file manager_channels.c.

1139{
1140 struct ast_channel_blob *payload = stasis_message_data(message);
1141
1142 publish_basic_channel_event("MixMonitorStart", EVENT_FLAG_CALL, payload->snapshot);
1143}
static void publish_basic_channel_event(const char *event, int class, struct ast_channel_snapshot *snapshot)

References EVENT_FLAG_CALL, publish_basic_channel_event(), ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_mixmonitor_stop_cb()

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

Definition at line 1145 of file manager_channels.c.

1147{
1148 struct ast_channel_blob *payload = stasis_message_data(message);
1149
1150 publish_basic_channel_event("MixMonitorStop", EVENT_FLAG_CALL, payload->snapshot);
1151}

References EVENT_FLAG_CALL, publish_basic_channel_event(), ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_moh_start_cb()

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

Definition at line 1109 of file manager_channels.c.

1111{
1112 struct ast_channel_blob *payload = stasis_message_data(message);
1113 struct ast_json *blob = payload->blob;
1114 RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
1115
1116 channel_event_string = ast_manager_build_channel_state_string(payload->snapshot);
1117 if (!channel_event_string) {
1118 return;
1119 }
1120
1121 manager_event(EVENT_FLAG_CALL, "MusicOnHoldStart",
1122 "%s"
1123 "Class: %s\r\n",
1124 ast_str_buffer(channel_event_string),
1126
1127}

References ast_free, ast_json_object_get(), ast_json_string_get(), ast_manager_build_channel_state_string(), ast_str_buffer(), ast_channel_blob::blob, EVENT_FLAG_CALL, manager_event, NULL, RAII_VAR, ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_moh_stop_cb()

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

Definition at line 1129 of file manager_channels.c.

1131{
1132 struct ast_channel_blob *payload = stasis_message_data(message);
1133
1134 publish_basic_channel_event("MusicOnHoldStop", EVENT_FLAG_CALL, payload->snapshot);
1135}

References EVENT_FLAG_CALL, publish_basic_channel_event(), ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_new_accountcode()

static struct ast_manager_event_blob * channel_new_accountcode ( struct ast_channel_snapshot old_snapshot,
struct ast_channel_snapshot new_snapshot 
)
static

Definition at line 662 of file manager_channels.c.

665{
666 if (!old_snapshot) {
667 return NULL;
668 }
669
670 if (!strcmp(old_snapshot->base->accountcode, new_snapshot->base->accountcode)) {
671 return NULL;
672 }
673
675 EVENT_FLAG_CALL, "NewAccountCode",
676 "OldAccountCode: %s\r\n", old_snapshot->base->accountcode);
677}
struct ast_manager_event_blob * ast_manager_event_blob_create(int event_flags, const char *manager_event, const char *extra_fields_fmt,...)
Construct a ast_manager_event_blob.
Definition: manager.c:10564

References ast_channel_snapshot_base::accountcode, ast_manager_event_blob_create(), ast_channel_snapshot::base, EVENT_FLAG_CALL, and NULL.

◆ channel_new_callerid()

static struct ast_manager_event_blob * channel_new_callerid ( struct ast_channel_snapshot old_snapshot,
struct ast_channel_snapshot new_snapshot 
)
static

Definition at line 614 of file manager_channels.c.

617{
618 struct ast_manager_event_blob *res;
619 char *callerid;
620
621 /* No NewCallerid event on first channel snapshot */
622 if (!old_snapshot) {
623 return NULL;
624 }
625
626 if (ast_channel_snapshot_caller_id_equal(old_snapshot, new_snapshot)) {
627 return NULL;
628 }
629
630 if (!(callerid = ast_escape_c_alloc(
631 ast_describe_caller_presentation(new_snapshot->caller->pres)))) {
632 return NULL;
633 }
634
636 EVENT_FLAG_CALL, "NewCallerid",
637 "CID-CallingPres: %d (%s)\r\n",
638 new_snapshot->caller->pres,
639 callerid);
640
641 ast_free(callerid);
642 return res;
643}
const char * ast_describe_caller_presentation(int data)
Convert caller ID pres value to explanatory string.
Definition: callerid.c:1364
int ast_channel_snapshot_caller_id_equal(const struct ast_channel_snapshot *old_snapshot, const struct ast_channel_snapshot *new_snapshot)
Compares the callerid info of two snapshots.
Struct containing info for an AMI event to send out.
Definition: manager.h:502

References ast_channel_snapshot_caller_id_equal(), ast_describe_caller_presentation(), ast_escape_c_alloc(), ast_free, ast_manager_event_blob_create(), ast_channel_snapshot::caller, EVENT_FLAG_CALL, NULL, and ast_channel_snapshot_caller::pres.

◆ channel_new_connected_line()

static struct ast_manager_event_blob * channel_new_connected_line ( struct ast_channel_snapshot old_snapshot,
struct ast_channel_snapshot new_snapshot 
)
static

Definition at line 645 of file manager_channels.c.

648{
649 /* No NewConnectedLine event on first channel snapshot */
650 if (!old_snapshot) {
651 return NULL;
652 }
653
654 if (ast_channel_snapshot_connected_line_equal(old_snapshot, new_snapshot)) {
655 return NULL;
656 }
657
659 EVENT_FLAG_CALL, "NewConnectedLine", "%s", "");
660}
int ast_channel_snapshot_connected_line_equal(const struct ast_channel_snapshot *old_snapshot, const struct ast_channel_snapshot *new_snapshot)
Compares the connected line info of two snapshots.

References ast_channel_snapshot_connected_line_equal(), ast_manager_event_blob_create(), EVENT_FLAG_CALL, and NULL.

◆ channel_newexten()

static struct ast_manager_event_blob * channel_newexten ( struct ast_channel_snapshot old_snapshot,
struct ast_channel_snapshot new_snapshot 
)
static

Definition at line 584 of file manager_channels.c.

587{
588 /* Empty application is not valid for a Newexten event */
589 if (ast_strlen_zero(new_snapshot->dialplan->appl)) {
590 return NULL;
591 }
592
593 /* Ignore any updates if we're hungup */
594 if (ast_test_flag(&new_snapshot->flags, AST_FLAG_DEAD)) {
595 return NULL;
596 }
597
598 /* Ignore updates if the CEP is unchanged */
599 if (old_snapshot && ast_channel_snapshot_cep_equal(old_snapshot, new_snapshot)) {
600 return NULL;
601 }
602
603 /* DEPRECATED: Extension field deprecated in 12; remove in 14 */
605 EVENT_FLAG_DIALPLAN, "Newexten",
606 "Extension: %s\r\n"
607 "Application: %s\r\n"
608 "AppData: %s\r\n",
609 new_snapshot->dialplan->exten,
610 new_snapshot->dialplan->appl,
611 new_snapshot->dialplan->data);
612}
@ AST_FLAG_DEAD
Definition: channel.h:1045
int ast_channel_snapshot_cep_equal(const struct ast_channel_snapshot *old_snapshot, const struct ast_channel_snapshot *new_snapshot)
Compares the context, exten and priority of two snapshots.
const ast_string_field data
const ast_string_field appl
struct ast_flags flags
#define ast_test_flag(p, flag)
Definition: utils.h:63

References ast_channel_snapshot_dialplan::appl, ast_channel_snapshot_cep_equal(), AST_FLAG_DEAD, ast_manager_event_blob_create(), ast_strlen_zero(), ast_test_flag, ast_channel_snapshot_dialplan::data, ast_channel_snapshot::dialplan, EVENT_FLAG_DIALPLAN, ast_channel_snapshot_dialplan::exten, ast_channel_snapshot::flags, and NULL.

◆ channel_snapshot_update()

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

Definition at line 687 of file manager_channels.c.

689{
690 RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
692 size_t i;
693
695
696 for (i = 0; i < ARRAY_LEN(channel_monitors); ++i) {
698 ev = channel_monitors[i](update->old_snapshot, update->new_snapshot);
699
700 if (!ev) {
701 continue;
702 }
703
704 /* If we haven't already, build the channel event string */
705 if (!channel_event_string) {
706 channel_event_string =
708 if (!channel_event_string) {
709 return;
710 }
711 }
712
713 manager_event(ev->event_flags, ev->manager_event, "%s%s",
714 ast_str_buffer(channel_event_string),
715 ev->extra_fields);
716 }
717}
#define ao2_cleanup(obj)
Definition: astobj2.h:1934
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
channel_snapshot_monitor channel_monitors[]
Structure representing a change of snapshot of channel state.
#define ARRAY_LEN(a)
Definition: utils.h:666

References ao2_cleanup, ARRAY_LEN, ast_free, ast_manager_build_channel_state_string(), ast_str_buffer(), channel_monitors, manager_event, NULL, RAII_VAR, stasis_message_data(), and update().

Referenced by manager_channels_init().

◆ channel_state_change()

static struct ast_manager_event_blob * channel_state_change ( struct ast_channel_snapshot old_snapshot,
struct ast_channel_snapshot new_snapshot 
)
static

Handle channel state changes.

Definition at line 547 of file manager_channels.c.

550{
551 int is_hungup, was_hungup;
552
553 /* The Newchannel, Newstate and Hangup events are closely related, in
554 * in that they are mutually exclusive, basically different flavors
555 * of a new channel state event.
556 */
557
558 if (!old_snapshot) {
560 EVENT_FLAG_CALL, "Newchannel", NO_EXTRA_FIELDS);
561 }
562
563 was_hungup = ast_test_flag(&old_snapshot->flags, AST_FLAG_DEAD) ? 1 : 0;
564 is_hungup = ast_test_flag(&new_snapshot->flags, AST_FLAG_DEAD) ? 1 : 0;
565
566 if (!was_hungup && is_hungup) {
568 EVENT_FLAG_CALL, "Hangup",
569 "Cause: %d\r\n"
570 "Cause-txt: %s\r\n",
571 new_snapshot->hangup->cause,
572 ast_cause2str(new_snapshot->hangup->cause));
573 }
574
575 if (old_snapshot->state != new_snapshot->state) {
577 EVENT_FLAG_CALL, "Newstate", NO_EXTRA_FIELDS);
578 }
579
580 /* No event */
581 return NULL;
582}
const char * ast_cause2str(int cause) attribute_pure
Gives the string form of a given cause code.
Definition: channel.c:612
#define NO_EXTRA_FIELDS
Definition: manager.h:533
struct ast_channel_snapshot_hangup * hangup

References ast_cause2str(), AST_FLAG_DEAD, ast_manager_event_blob_create(), ast_test_flag, ast_channel_snapshot_hangup::cause, EVENT_FLAG_CALL, ast_channel_snapshot::flags, ast_channel_snapshot::hangup, NO_EXTRA_FIELDS, NULL, and ast_channel_snapshot::state.

◆ channel_unhold_cb()

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

Definition at line 1284 of file manager_channels.c.

1286{
1288 struct ast_str *channel_event_string;
1289
1290 channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
1291 if (!channel_event_string) {
1292 return;
1293 }
1294
1296 "%s",
1297 ast_str_buffer(channel_event_string));
1298
1299 ast_free(channel_event_string);
1300}

References ast_free, ast_manager_build_channel_state_string(), ast_str_buffer(), EVENT_FLAG_CALL, manager_event, ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ channel_wink_cb()

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

Definition at line 977 of file manager_channels.c.

979{
981 struct ast_str *channel_event_string;
982
983 channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
984 if (!channel_event_string) {
985 return;
986 }
987
988 /*** DOCUMENTATION
989 <managerEvent language="en_US" name="Wink">
990 <managerEventInstance class="EVENT_FLAG_CALL">
991 <synopsis>Raised when a wink occurs on a channel.</synopsis>
992 <syntax>
993 <channel_snapshot/>
994 </syntax>
995 </managerEventInstance>
996 </managerEvent>
997 ***/
999 "%s",
1000 ast_str_buffer(channel_event_string));
1001
1002 ast_free(channel_event_string);
1003}

References ast_free, ast_manager_build_channel_state_string(), ast_str_buffer(), EVENT_FLAG_CALL, manager_event, ast_channel_blob::snapshot, and stasis_message_data().

Referenced by manager_channels_init().

◆ dial_status_end()

static int dial_status_end ( const char *  dialstatus)
static

Definition at line 1184 of file manager_channels.c.

1185{
1186 return (strcmp(dialstatus, "RINGING") &&
1187 strcmp(dialstatus, "PROCEEDING") &&
1188 strcmp(dialstatus, "PROGRESS"));
1189}

Referenced by channel_dial_cb().

◆ manager_channels_init()

int manager_channels_init ( void  )

Initialize support for AMI channel events.

Return values
0on success.
non-zeroon error.
Since
12

Definition at line 1308 of file manager_channels.c.

1309{
1310 int ret = 0;
1312 struct stasis_topic *channel_topic;
1313 struct stasis_message_router *message_router;
1314
1316 if (!manager_topic) {
1317 return -1;
1318 }
1319 message_router = ast_manager_get_message_router();
1320 if (!message_router) {
1321 return -1;
1322 }
1323 channel_topic = ast_channel_topic_all();
1324 if (!channel_topic) {
1325 return -1;
1326 }
1327
1329 if (!topic_forwarder) {
1330 return -1;
1331 }
1332
1334
1335 /* The snapshot type has a special handler as it can result in multiple
1336 * manager events being queued due to aspects of the snapshot itself
1337 * changing.
1338 */
1339 ret |= stasis_message_router_add(message_router,
1341
1342 ret |= stasis_message_router_add(message_router,
1344
1345 ret |= stasis_message_router_add(message_router,
1347
1348 ret |= stasis_message_router_add(message_router,
1350
1351 ret |= stasis_message_router_add(message_router,
1353
1354 ret |= stasis_message_router_add(message_router,
1356 NULL);
1357
1358 ret |= stasis_message_router_add(message_router,
1360
1361 ret |= stasis_message_router_add(message_router,
1363
1364 ret |= stasis_message_router_add(message_router,
1366
1367 ret |= stasis_message_router_add(message_router,
1369
1370 ret |= stasis_message_router_add(message_router,
1372 NULL);
1373
1374 ret |= stasis_message_router_add(message_router,
1376
1377 ret |= stasis_message_router_add(message_router,
1379 NULL);
1380
1381 ret |= stasis_message_router_add(message_router,
1383
1384 ret |= stasis_message_router_add(message_router,
1386
1387 ret |= stasis_message_router_add(message_router,
1389
1390 ret |= stasis_message_router_add(message_router,
1392
1393 ret |= stasis_message_router_add(message_router,
1395
1396 /* If somehow we failed to add any routes, just shut down the whole
1397 * thing and fail it.
1398 */
1399 if (ret) {
1401 return -1;
1402 }
1403
1404 return 0;
1405}
int ast_register_cleanup(void(*func)(void))
Register a function to be executed before Asterisk gracefully exits.
Definition: clicompat.c:19
struct stasis_message_router * ast_manager_get_message_router(void)
Get the stasis_message_router for AMI.
Definition: manager.c:1885
struct stasis_topic * ast_manager_get_topic(void)
Get the Stasis Message Bus API topic for AMI.
Definition: manager.c:1880
static struct stasis_topic * manager_topic
A stasis_topic that all topics AMI cares about will be forwarded to.
Definition: manager.c:1644
struct stasis_message_type * ast_channel_mixmonitor_mute_type(void)
Message type for muting or unmuting mixmonitor on a channel.
struct stasis_topic * ast_channel_topic_all(void)
A topic which publishes the events for all channels.
struct stasis_message_type * ast_channel_hold_type(void)
Message type for when a channel is placed on hold.
struct stasis_message_type * ast_channel_chanspy_start_type(void)
Message type for when a channel starts spying on another channel.
struct stasis_message_type * ast_channel_chanspy_stop_type(void)
Message type for when a channel stops spying on another channel.
struct stasis_message_type * ast_channel_dtmf_begin_type(void)
Message type for when DTMF begins on a channel.
struct stasis_message_type * ast_channel_mixmonitor_stop_type(void)
Message type for stopping mixmonitor on a channel.
struct stasis_message_type * ast_channel_hangup_handler_type(void)
Message type for hangup handler related actions.
struct stasis_message_type * ast_channel_dial_type(void)
Message type for when a channel dials another channel.
struct stasis_message_type * ast_channel_moh_stop_type(void)
Message type for stopping music on hold on a channel.
struct stasis_message_type * ast_channel_unhold_type(void)
Message type for when a channel is removed from hold.
struct stasis_message_type * ast_channel_hangup_request_type(void)
Message type for when a hangup is requested on a channel.
struct stasis_message_type * ast_channel_flash_type(void)
Message type for when a hook flash occurs on a channel.
struct stasis_message_type * ast_channel_snapshot_type(void)
Message type for ast_channel_snapshot_update.
struct stasis_message_type * ast_channel_fax_type(void)
Message type for a fax operation.
struct stasis_message_type * ast_channel_dtmf_end_type(void)
Message type for when DTMF ends on a channel.
struct stasis_message_type * ast_channel_wink_type(void)
Message type for when a wink occurs on a channel.
struct stasis_message_type * ast_channel_moh_start_type(void)
Message type for starting music on hold on a channel.
struct stasis_message_type * ast_channel_mixmonitor_start_type(void)
Message type for starting mixmonitor on a channel.
static void channel_flash_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_hangup_handler_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_chanspy_stop_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_snapshot_update(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_mixmonitor_start_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_dtmf_end_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_mixmonitor_stop_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_dial_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
Callback processing messages for channel dialing.
static void channel_hold_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_moh_start_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_wink_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_fax_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_chanspy_start_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_hangup_request_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_dtmf_begin_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_moh_stop_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void channel_mixmonitor_mute_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void manager_channels_shutdown(void)
static struct stasis_forward * topic_forwarder
The Stasis Message Bus API subscription returned by the forwarding of the channel topic to the manage...
static void channel_unhold_cb(void *data, struct stasis_subscription *sub, struct stasis_message *message)
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
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.

References ast_channel_chanspy_start_type(), ast_channel_chanspy_stop_type(), ast_channel_dial_type(), ast_channel_dtmf_begin_type(), ast_channel_dtmf_end_type(), ast_channel_fax_type(), ast_channel_flash_type(), ast_channel_hangup_handler_type(), ast_channel_hangup_request_type(), ast_channel_hold_type(), ast_channel_mixmonitor_mute_type(), ast_channel_mixmonitor_start_type(), ast_channel_mixmonitor_stop_type(), ast_channel_moh_start_type(), ast_channel_moh_stop_type(), ast_channel_snapshot_type(), ast_channel_topic_all(), ast_channel_unhold_type(), ast_channel_wink_type(), ast_manager_get_message_router(), ast_manager_get_topic(), ast_register_cleanup(), channel_chanspy_start_cb(), channel_chanspy_stop_cb(), channel_dial_cb(), channel_dtmf_begin_cb(), channel_dtmf_end_cb(), channel_fax_cb(), channel_flash_cb(), channel_hangup_handler_cb(), channel_hangup_request_cb(), channel_hold_cb(), channel_mixmonitor_mute_cb(), channel_mixmonitor_start_cb(), channel_mixmonitor_stop_cb(), channel_moh_start_cb(), channel_moh_stop_cb(), channel_snapshot_update(), channel_unhold_cb(), channel_wink_cb(), manager_channels_shutdown(), manager_topic, NULL, stasis_forward_all(), stasis_message_router_add(), and topic_forwarder.

Referenced by subscribe_all().

◆ manager_channels_shutdown()

static void manager_channels_shutdown ( void  )
static

Definition at line 1302 of file manager_channels.c.

1303{
1306}
struct stasis_forward * stasis_forward_cancel(struct stasis_forward *forward)
Definition: stasis.c:1548

References NULL, stasis_forward_cancel(), and topic_forwarder.

Referenced by manager_channels_init().

◆ publish_basic_channel_event()

static void publish_basic_channel_event ( const char *  event,
int  class,
struct ast_channel_snapshot snapshot 
)
static

Definition at line 719 of file manager_channels.c.

720{
721 RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
722
723 channel_event_string = ast_manager_build_channel_state_string(snapshot);
724 if (!channel_event_string) {
725 return;
726 }
727
728 manager_event(class, event,
729 "%s",
730 ast_str_buffer(channel_event_string));
731}

References ast_free, ast_manager_build_channel_state_string(), ast_str_buffer(), manager_event, NULL, and RAII_VAR.

Referenced by channel_mixmonitor_start_cb(), channel_mixmonitor_stop_cb(), and channel_moh_stop_cb().

Variable Documentation

◆ channel_monitors

channel_snapshot_monitor channel_monitors[]

Definition at line 679 of file manager_channels.c.

Referenced by channel_snapshot_update().

◆ topic_forwarder

struct stasis_forward* topic_forwarder
static

The Stasis Message Bus API subscription returned by the forwarding of the channel topic to the manager topic.

Definition at line 459 of file manager_channels.c.

Referenced by manager_channels_init(), and manager_channels_shutdown().