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.

Functions
struct ast_str *	ast_manager_build_channel_state_string (const struct ast_channel_snapshot *snapshot)
	Generate the AMI message body from a channel snapshot.
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.
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.
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_blob *	channel_new_accountcode (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)
static struct ast_manager_event_blob *	channel_new_callerid (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)
static struct ast_manager_event_blob *	channel_new_connected_line (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)
static struct ast_manager_event_blob *	channel_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_blob *	channel_state_change (struct ast_channel_snapshot *old_snapshot, struct ast_channel_snapshot *new_snapshot)
	Handle channel state changes.
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.
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_forward *	topic_forwarder
	The Stasis Message Bus API subscription returned by the forwarding of the channel topic to the manager topic.

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 617 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

snapshot

the channel snapshot for which to generate an AMI message body

Return values

NULL

on error

Returns

ast_str* on success (must be ast_freed by caller)

Definition at line 617 of file manager_channels.c.

{
    return ast_manager_build_channel_state_string_prefix(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

snapshot	the channel snapshot for which to generate an AMI message body
prefix	What to prepend to the channel fields

Return values

NULL

on error

Returns

ast_str* on success (must be ast_freed by caller)

Definition at line 539 of file manager_channels.c.

{
    struct ast_str *out;
    char *caller_name;
    char *connected_name;
    int res;
 
    if (!snapshot || (snapshot->base->tech_properties & AST_CHAN_TP_INTERNAL)) {
        return NULL;
    }
 
    out = ast_str_create(1024);
    if (!out) {
        return NULL;
    }
 
    caller_name = ast_escape_c_alloc(snapshot->caller->name);
    connected_name = ast_escape_c_alloc(snapshot->connected->name);
 
    res = ast_str_set(&out, 0,
        "%sChannel: %s\r\n"
        "%sChannelState: %u\r\n"
        "%sChannelStateDesc: %s\r\n"
        "%sCallerIDNum: %s\r\n"
        "%sCallerIDName: %s\r\n"
        "%sConnectedLineNum: %s\r\n"
        "%sConnectedLineName: %s\r\n"
        "%sLanguage: %s\r\n"
        "%sAccountCode: %s\r\n"
        "%sContext: %s\r\n"
        "%sExten: %s\r\n"
        "%sPriority: %d\r\n"
        "%sUniqueid: %s\r\n"
        "%sLinkedid: %s\r\n",
        prefix, snapshot->base->name,
        prefix, snapshot->state,
        prefix, ast_state2str(snapshot->state),
        prefix, S_OR(snapshot->caller->number, "<unknown>"),
        prefix, S_OR(caller_name, "<unknown>"),
        prefix, S_OR(snapshot->connected->number, "<unknown>"),
        prefix, S_OR(connected_name, "<unknown>"),
        prefix, snapshot->base->language,
        prefix, snapshot->base->accountcode,
        prefix, snapshot->dialplan->context,
        prefix, snapshot->dialplan->exten,
        prefix, snapshot->dialplan->priority,
        prefix, snapshot->base->uniqueid,
        prefix, snapshot->peer->linkedid);
 
    ast_free(caller_name);
    ast_free(connected_name);
 
    if (!res) {
        ast_free(out);
        return NULL;
    }
 
    if (!ast_strlen_zero(snapshot->base->tenantid)) {
        ast_str_append(&out, 0, "%sTenantid: %s\r\n", prefix, snapshot->base->tenantid);
    }
 
    if (snapshot->manager_vars) {
        struct ast_var_t *var;
        char *val;
        AST_LIST_TRAVERSE(snapshot->manager_vars, var, entries) {
            val = ast_escape_c_alloc(var->value);
            ast_str_append(&out, 0, "%sChanVariable: %s=%s\r\n",
                       prefix,
                       var->name, S_OR(val, ""));
            ast_free(val);
        }
    }
 
    return out;
}

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_strlen_zero(), 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::tenantid, 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 917 of file manager_channels.c.

{
    RAII_VAR(struct ast_str *, spyer_channel_string, NULL, ast_free);
    RAII_VAR(struct ast_str *, spyee_channel_string, NULL, ast_free);
    struct ast_channel_snapshot *spyer;
    struct ast_channel_snapshot *spyee;
    struct ast_multi_channel_blob *payload = stasis_message_data(message);
 
    spyer = ast_multi_channel_blob_get_channel(payload, "spyer_channel");
    if (!spyer) {
        ast_log(AST_LOG_WARNING, "Received ChanSpy Start event with no spyer channel!\n");
        return;
    }
    spyee = ast_multi_channel_blob_get_channel(payload, "spyee_channel");
    if (!spyee) {
        ast_log(AST_LOG_WARNING, "Received ChanSpy Start event with no spyee channel!\n");
        return;
    }
 
    spyer_channel_string = ast_manager_build_channel_state_string_prefix(spyer, "Spyer");
    if (!spyer_channel_string) {
        return;
    }
    spyee_channel_string = ast_manager_build_channel_state_string_prefix(spyee, "Spyee");
    if (!spyee_channel_string) {
        return;
    }
 
    manager_event(EVENT_FLAG_CALL, "ChanSpyStart",
              "%s%s",
              ast_str_buffer(spyer_channel_string),
              ast_str_buffer(spyee_channel_string));
}

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 882 of file manager_channels.c.

{
    RAII_VAR(struct ast_str *, spyer_channel_string, NULL, ast_free);
    RAII_VAR(struct ast_str *, spyee_channel_string, NULL, ast_free);
    struct ast_channel_snapshot *spyer;
    struct ast_channel_snapshot *spyee;
    const char *spyee_info = "";
    struct ast_multi_channel_blob *payload = stasis_message_data(message);
 
    spyer = ast_multi_channel_blob_get_channel(payload, "spyer_channel");
    if (!spyer) {
        ast_log(AST_LOG_WARNING, "Received ChanSpy Stop event with no spyer channel!\n");
        return;
    }
 
    spyer_channel_string = ast_manager_build_channel_state_string_prefix(spyer, "Spyer");
    if (!spyer_channel_string) {
        return;
    }
 
    spyee = ast_multi_channel_blob_get_channel(payload, "spyee_channel");
    if (spyee) {
        spyee_channel_string = ast_manager_build_channel_state_string_prefix(spyee, "Spyee");
        if (spyee_channel_string) {
            spyee_info = ast_str_buffer(spyee_channel_string);
        }
    }
 
    manager_event(EVENT_FLAG_CALL, "ChanSpyStop",
              "%s%s",
              ast_str_buffer(spyer_channel_string),
              spyee_info);
}

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 1315 of file manager_channels.c.

{
    struct ast_multi_channel_blob *obj = stasis_message_data(message);
    const char *dialstatus;
    const char *dialstring;
    const char *forward;
    struct ast_channel_snapshot *caller;
    struct ast_channel_snapshot *peer;
    RAII_VAR(struct ast_str *, caller_event_string, NULL, ast_free);
    RAII_VAR(struct ast_str *, peer_event_string, NULL, ast_free);
 
    caller = ast_multi_channel_blob_get_channel(obj, "caller");
    peer = ast_multi_channel_blob_get_channel(obj, "peer");
 
    /* Peer is required - otherwise, who are we dialing? */
    ast_assert(peer != NULL);
    peer_event_string = ast_manager_build_channel_state_string_prefix(peer, "Dest");
    if (!peer_event_string) {
        return;
    }
 
    if (caller && !(caller_event_string = ast_manager_build_channel_state_string(caller))) {
        return;
    }
 
    dialstatus = ast_json_string_get(ast_json_object_get(ast_multi_channel_blob_get_json(obj), "dialstatus"));
    dialstring = ast_json_string_get(ast_json_object_get(ast_multi_channel_blob_get_json(obj), "dialstring"));
    forward = ast_json_string_get(ast_json_object_get(ast_multi_channel_blob_get_json(obj), "forward"));
    if (ast_strlen_zero(dialstatus)) {
        manager_event(EVENT_FLAG_CALL, "DialBegin",
                "%s"
                "%s"
                "DialString: %s\r\n",
                caller_event_string ? ast_str_buffer(caller_event_string) : "",
                ast_str_buffer(peer_event_string),
                S_OR(dialstring, "unknown"));
    } else {
        int forwarded = !ast_strlen_zero(forward);
 
        manager_event(EVENT_FLAG_CALL, dial_status_end(dialstatus) ? "DialEnd" : "DialState",
                "%s"
                "%s"
                "%s%s%s"
                "DialStatus: %s\r\n",
                caller_event_string ? ast_str_buffer(caller_event_string) : "",
                ast_str_buffer(peer_event_string),
                forwarded ? "Forward: " : "", S_OR(forward, ""), forwarded ? "\r\n" : "",
                S_OR(dialstatus, "unknown"));
    }
 
}

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 952 of file manager_channels.c.

{
    struct ast_channel_blob *obj = stasis_message_data(message);
    RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
    const char *digit =
        ast_json_string_get(ast_json_object_get(obj->blob, "digit"));
    const char *direction =
        ast_json_string_get(ast_json_object_get(obj->blob, "direction"));
 
    channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
 
    if (!channel_event_string) {
        return;
    }
 
    /*** DOCUMENTATION
        <managerEvent language="en_US" name="DTMFBegin">
            <managerEventInstance class="EVENT_FLAG_DTMF">
                <since>
                    <version>16.24.0</version>
                    <version>18.10.0</version>
                    <version>19.2.0</version>
                </since>
                <synopsis>Raised when a DTMF digit has started on a channel.</synopsis>
                    <syntax>
                        <channel_snapshot/>
                        <parameter name="Digit">
                            <para>DTMF digit received or transmitted (0-9, A-E, # or *</para>
                        </parameter>
                        <parameter name="Direction">
                            <enumlist>
                                <enum name="Received"/>
                                <enum name="Sent"/>
                            </enumlist>
                        </parameter>
                    </syntax>
                    <see-also>
                        <ref type="managerEvent">DTMFEnd</ref>
                    </see-also>
            </managerEventInstance>
        </managerEvent>
    ***/
    manager_event(EVENT_FLAG_DTMF, "DTMFBegin",
        "%s"
        "Digit: %s\r\n"
        "Direction: %s\r\n",
        ast_str_buffer(channel_event_string),
        digit, direction);
}

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 1003 of file manager_channels.c.

{
    struct ast_channel_blob *obj = stasis_message_data(message);
    RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
    const char *digit =
        ast_json_string_get(ast_json_object_get(obj->blob, "digit"));
    const char *direction =
        ast_json_string_get(ast_json_object_get(obj->blob, "direction"));
    long duration_ms =
        ast_json_integer_get(ast_json_object_get(obj->blob, "duration_ms"));
 
    channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
 
    if (!channel_event_string) {
        return;
    }
 
    /*** DOCUMENTATION
        <managerEvent language="en_US" name="DTMFEnd">
            <managerEventInstance class="EVENT_FLAG_DTMF">
                <since>
                    <version>16.24.0</version>
                    <version>18.10.0</version>
                    <version>19.2.0</version>
                </since>
                <synopsis>Raised when a DTMF digit has ended on a channel.</synopsis>
                    <syntax>
                        <channel_snapshot/>
                        <parameter name="Digit">
                            <para>DTMF digit received or transmitted (0-9, A-E, # or *</para>
                        </parameter>
                        <parameter name="DurationMs">
                            <para>Duration (in milliseconds) DTMF was sent/received</para>
                        </parameter>
                        <parameter name="Direction">
                            <enumlist>
                                <enum name="Received"/>
                                <enum name="Sent"/>
                            </enumlist>
                        </parameter>
                    </syntax>
                    <see-also>
                        <ref type="managerEvent">DTMFBegin</ref>
                    </see-also>
            </managerEventInstance>
        </managerEvent>
    ***/
    manager_event(EVENT_FLAG_DTMF, "DTMFEnd",
        "%s"
        "Digit: %s\r\n"
        "DurationMs: %ld\r\n"
        "Direction: %s\r\n",
        ast_str_buffer(channel_event_string),
        digit, duration_ms, direction);
}

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 1157 of file manager_channels.c.

{
    RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
    RAII_VAR(struct ast_str *, event_buffer, ast_str_create(256), ast_free);
    struct ast_channel_blob *payload = stasis_message_data(message);
    const char *type = ast_json_string_get(ast_json_object_get(payload->blob, "type"));
    struct ast_json *operation = ast_json_object_get(payload->blob, "operation");
    struct ast_json *status = ast_json_object_get(payload->blob, "status");
    struct ast_json *local_station_id = ast_json_object_get(payload->blob, "local_station_id");
    struct ast_json *remote_station_id = ast_json_object_get(payload->blob, "remote_station_id");
    struct ast_json *fax_pages = ast_json_object_get(payload->blob, "fax_pages");
    struct ast_json *fax_resolution = ast_json_object_get(payload->blob, "fax_resolution");
    struct ast_json *fax_bitrate = ast_json_object_get(payload->blob, "fax_bitrate");
    struct ast_json *filenames = ast_json_object_get(payload->blob, "filenames");
    const char *event;
    size_t array_len;
    size_t i;
 
    if (!event_buffer) {
        return;
    }
 
    channel_event_string = ast_manager_build_channel_state_string(payload->snapshot);
    if (!channel_event_string) {
        return;
    }
 
    if (!strcmp(type, "status")) {
        event = "FAXStatus";
    } else if (!strcmp(type, "receive")) {
        event = "ReceiveFAX";
    } else if (!strcmp(type, "send")) {
        event = "SendFAX";
    } else {
        return;
    }
 
    if (operation) {
        ast_str_append(&event_buffer, 0, "Operation: %s\r\n", ast_json_string_get(operation));
    }
    if (status) {
        ast_str_append(&event_buffer, 0, "Status: %s\r\n", ast_json_string_get(status));
    }
    if (local_station_id) {
        ast_str_append(&event_buffer, 0, "LocalStationID: %s\r\n", ast_json_string_get(local_station_id));
    }
    if (remote_station_id) {
        ast_str_append(&event_buffer, 0, "RemoteStationID: %s\r\n", ast_json_string_get(remote_station_id));
    }
    if (fax_pages) {
        ast_str_append(&event_buffer, 0, "PagesTransferred: %s\r\n", ast_json_string_get(fax_pages));
    }
    if (fax_resolution) {
        ast_str_append(&event_buffer, 0, "Resolution: %s\r\n", ast_json_string_get(fax_resolution));
    }
    if (fax_bitrate) {
        ast_str_append(&event_buffer, 0, "TransferRate: %s\r\n", ast_json_string_get(fax_bitrate));
    }
    if (filenames) {
        array_len = ast_json_array_size(filenames);
        for (i = 0; i < array_len; i++) {
            ast_str_append(&event_buffer, 0, "FileName: %s\r\n", ast_json_string_get(ast_json_array_get(filenames, i)));
        }
    }
 
    manager_event(EVENT_FLAG_CALL, event,
        "%s"
        "%s",
        ast_str_buffer(channel_event_string),
        ast_str_buffer(event_buffer));
}

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 1060 of file manager_channels.c.

{
    struct ast_channel_blob *obj = stasis_message_data(message);
    struct ast_str *channel_event_string;
 
    channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
    if (!channel_event_string) {
        return;
    }
 
    /*** DOCUMENTATION
        <managerEvent language="en_US" name="Flash">
            <managerEventInstance class="EVENT_FLAG_CALL">
                <since>
                    <version>16.24.0</version>
                    <version>18.10.0</version>
                    <version>19.2.0</version>
                </since>
                <synopsis>Raised when a hook flash occurs on a channel.</synopsis>
                    <syntax>
                        <channel_snapshot/>
                    </syntax>
            </managerEventInstance>
        </managerEvent>
    ***/
    manager_event(EVENT_FLAG_CALL, "Flash",
        "%s",
        ast_str_buffer(channel_event_string));
 
    ast_free(channel_event_string);
}

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 1126 of file manager_channels.c.

{
    RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
    struct ast_channel_blob *payload = stasis_message_data(message);
    const char *action = ast_json_string_get(ast_json_object_get(payload->blob, "type"));
    const char *handler = ast_json_string_get(ast_json_object_get(payload->blob, "handler"));
    const char *event;
 
    channel_event_string = ast_manager_build_channel_state_string(payload->snapshot);
 
    if (!channel_event_string) {
        return;
    }
 
    if (!strcmp(action, "run")) {
        event = "HangupHandlerRun";
    } else if (!strcmp(action, "pop")) {
        event = "HangupHandlerPop";
    } else if (!strcmp(action, "push")) {
        event = "HangupHandlerPush";
    } else {
        return;
    }
    manager_event(EVENT_FLAG_DIALPLAN, event,
        "%s"
        "Handler: %s\r\n",
        ast_str_buffer(channel_event_string),
        handler);
}

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 826 of file manager_channels.c.

{
    struct ast_channel_blob *obj = stasis_message_data(message);
    struct ast_str *extra;
    struct ast_str *channel_event_string;
    struct ast_json *cause;
    struct ast_json *tech_cause;
    int is_soft;
    char *manager_event = "HangupRequest";
 
    if (!obj->snapshot) {
        /* No snapshot?  Likely an earlier allocation failure creating it. */
        return;
    }
 
    extra = ast_str_create(20);
    if (!extra) {
        return;
    }
 
    channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
    if (!channel_event_string) {
        ast_free(extra);
        return;
    }
 
    cause = ast_json_object_get(obj->blob, "cause");
    if (cause) {
        ast_str_append(&extra, 0,
            "Cause: %jd\r\n",
            ast_json_integer_get(cause));
    }
 
    tech_cause = ast_json_object_get(obj->blob, "tech_cause");
    if (tech_cause) {
        ast_str_append(&extra, 0,
            "TechCause: %jd\r\n",
            ast_json_integer_get(tech_cause));
    }
 
    is_soft = ast_json_is_true(ast_json_object_get(obj->blob, "soft"));
    if (is_soft) {
        manager_event = "SoftHangupRequest";
    }
 
    manager_event(EVENT_FLAG_CALL, manager_event,
        "%s%s",
        ast_str_buffer(channel_event_string),
        ast_str_buffer(extra));
 
    ast_free(channel_event_string);
    ast_free(extra);
}

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 1368 of file manager_channels.c.

{
    struct ast_channel_blob *obj = stasis_message_data(message);
    struct ast_str *musicclass_string = ast_str_create(32);
    struct ast_str *channel_event_string;
 
    if (!musicclass_string) {
        return;
    }
 
    channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
    if (!channel_event_string) {
        ast_free(musicclass_string);
        return;
    }
 
    if (obj->blob) {
        const char *musicclass;
 
        musicclass = ast_json_string_get(ast_json_object_get(obj->blob, "musicclass"));
 
        if (!ast_strlen_zero(musicclass)) {
            ast_str_set(&musicclass_string, 0, "MusicClass: %s\r\n", musicclass);
        }
    }
 
    manager_event(EVENT_FLAG_CALL, "Hold",
        "%s"
        "%s",
        ast_str_buffer(channel_event_string),
        ast_str_buffer(musicclass_string));
 
    ast_free(musicclass_string);
    ast_free(channel_event_string);
}

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 1274 of file manager_channels.c.

{
    RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
    RAII_VAR(struct ast_str *, event_buffer, ast_str_create(64), ast_free);
    struct ast_channel_blob *payload = stasis_message_data(message);
    struct ast_json *direction = ast_json_object_get(payload->blob, "direction");
    const int state = ast_json_is_true(ast_json_object_get(payload->blob, "state"));
 
    if (!event_buffer) {
        return;
    }
 
    channel_event_string = ast_manager_build_channel_state_string(payload->snapshot);
    if (!channel_event_string) {
        return;
    }
 
    if (direction) {
        ast_str_append(&event_buffer, 0, "Direction: %s\r\n", ast_json_string_get(direction));
    }
    ast_str_append(&event_buffer, 0, "State: %s\r\n", state ? "1" : "0");
 
    manager_event(EVENT_FLAG_CALL, "MixMonitorMute",
        "%s"
        "%s",
        ast_str_buffer(channel_event_string),
        ast_str_buffer(event_buffer));
 
}

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 1258 of file manager_channels.c.

{
    struct ast_channel_blob *payload = stasis_message_data(message);
 
    publish_basic_channel_event("MixMonitorStart", EVENT_FLAG_CALL, payload->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 1266 of file manager_channels.c.

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

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 1230 of file manager_channels.c.

{
    struct ast_channel_blob *payload = stasis_message_data(message);
    struct ast_json *blob = payload->blob;
    RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
 
    channel_event_string = ast_manager_build_channel_state_string(payload->snapshot);
    if (!channel_event_string) {
        return;
    }
 
    manager_event(EVENT_FLAG_CALL, "MusicOnHoldStart",
        "%s"
        "Class: %s\r\n",
        ast_str_buffer(channel_event_string),
        ast_json_string_get(ast_json_object_get(blob, "class")));
 
}

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 1250 of file manager_channels.c.

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

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 755 of file manager_channels.c.

{
    if (!old_snapshot) {
        return NULL;
    }
 
    if (!strcmp(old_snapshot->base->accountcode, new_snapshot->base->accountcode)) {
        return NULL;
    }
 
    return ast_manager_event_blob_create(
        EVENT_FLAG_CALL, "NewAccountCode",
        "OldAccountCode: %s\r\n", old_snapshot->base->accountcode);
}

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 707 of file manager_channels.c.

{
    struct ast_manager_event_blob *res;
    char *callerid;
 
    /* No NewCallerid event on first channel snapshot */
    if (!old_snapshot) {
        return NULL;
    }
 
    if (ast_channel_snapshot_caller_id_equal(old_snapshot, new_snapshot)) {
        return NULL;
    }
 
    if (!(callerid = ast_escape_c_alloc(
              ast_describe_caller_presentation(new_snapshot->caller->pres)))) {
        return NULL;
    }
 
    res = ast_manager_event_blob_create(
        EVENT_FLAG_CALL, "NewCallerid",
        "CID-CallingPres: %d (%s)\r\n",
        new_snapshot->caller->pres,
        callerid);
 
    ast_free(callerid);
    return res;
}

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 738 of file manager_channels.c.

{
    /* No NewConnectedLine event on first channel snapshot */
    if (!old_snapshot) {
        return NULL;
    }
 
    if (ast_channel_snapshot_connected_line_equal(old_snapshot, new_snapshot)) {
        return NULL;
    }
 
    return ast_manager_event_blob_create(
        EVENT_FLAG_CALL, "NewConnectedLine", "%s", "");
}

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 677 of file manager_channels.c.

{
    /* Empty application is not valid for a Newexten event */
    if (ast_strlen_zero(new_snapshot->dialplan->appl)) {
        return NULL;
    }
 
    /* Ignore any updates if we're hungup */
    if (ast_test_flag(&new_snapshot->flags, AST_FLAG_DEAD)) {
        return NULL;
    }
 
    /* Ignore updates if the CEP is unchanged */
    if (old_snapshot && ast_channel_snapshot_cep_equal(old_snapshot, new_snapshot)) {
        return NULL;
    }
 
    /* DEPRECATED: Extension field deprecated in 12; remove in 14 */
    return ast_manager_event_blob_create(
        EVENT_FLAG_DIALPLAN, "Newexten",
        "Extension: %s\r\n"
        "Application: %s\r\n"
        "AppData: %s\r\n",
        new_snapshot->dialplan->exten,
        new_snapshot->dialplan->appl,
        new_snapshot->dialplan->data);
}

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 780 of file manager_channels.c.

{
    RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
    struct ast_channel_snapshot_update *update;
    size_t i;
 
    update = stasis_message_data(message);
 
    for (i = 0; i < ARRAY_LEN(channel_monitors); ++i) {
        RAII_VAR(struct ast_manager_event_blob *, ev, NULL, ao2_cleanup);
        ev = channel_monitors[i](update->old_snapshot, update->new_snapshot);
 
        if (!ev) {
            continue;
        }
 
        /* If we haven't already, build the channel event string */
        if (!channel_event_string) {
            channel_event_string =
                ast_manager_build_channel_state_string(update->new_snapshot);
            if (!channel_event_string) {
                return;
            }
        }
 
        manager_event(ev->event_flags, ev->manager_event, "%s%s",
            ast_str_buffer(channel_event_string),
            ev->extra_fields);
    }
}

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 629 of file manager_channels.c.

{
    int is_hungup, was_hungup;
 
    /* The Newchannel, Newstate and Hangup events are closely related, in
     * in that they are mutually exclusive, basically different flavors
     * of a new channel state event.
     */
 
    if (!old_snapshot) {
        return ast_manager_event_blob_create(
            EVENT_FLAG_CALL, "Newchannel", NO_EXTRA_FIELDS);
    }
 
    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) {
        if (new_snapshot->hangup->tech_cause) {
            return ast_manager_event_blob_create(
                EVENT_FLAG_CALL, "Hangup",
                "Cause: %d\r\n"
                "Cause-txt: %s\r\n"
                "TechCause: %d\r\n",
                new_snapshot->hangup->cause,
                ast_cause2str(new_snapshot->hangup->cause),
                new_snapshot->hangup->tech_cause);
        } else {
            return ast_manager_event_blob_create(
                EVENT_FLAG_CALL, "Hangup",
                "Cause: %d\r\n"
                "Cause-txt: %s\r\n",
                new_snapshot->hangup->cause,
                ast_cause2str(new_snapshot->hangup->cause));
        }
    }
 
    if (old_snapshot->state != new_snapshot->state) {
        return ast_manager_event_blob_create(
            EVENT_FLAG_CALL, "Newstate", NO_EXTRA_FIELDS);
    }
 
    /* No event */
    return NULL;
}

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, ast_channel_snapshot::state, and ast_channel_snapshot_hangup::tech_cause.

channel_unhold_cb()

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

static

Definition at line 1405 of file manager_channels.c.

{
    struct ast_channel_blob *obj = stasis_message_data(message);
    struct ast_str *channel_event_string;
 
    channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
    if (!channel_event_string) {
        return;
    }
 
    manager_event(EVENT_FLAG_CALL, "Unhold",
        "%s",
        ast_str_buffer(channel_event_string));
 
    ast_free(channel_event_string);
}

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 1093 of file manager_channels.c.

{
    struct ast_channel_blob *obj = stasis_message_data(message);
    struct ast_str *channel_event_string;
 
    channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
    if (!channel_event_string) {
        return;
    }
 
    /*** DOCUMENTATION
        <managerEvent language="en_US" name="Wink">
            <managerEventInstance class="EVENT_FLAG_CALL">
                <since>
                    <version>16.24.0</version>
                    <version>18.10.0</version>
                    <version>19.2.0</version>
                </since>
                <synopsis>Raised when a wink occurs on a channel.</synopsis>
                    <syntax>
                        <channel_snapshot/>
                    </syntax>
            </managerEventInstance>
        </managerEvent>
    ***/
    manager_event(EVENT_FLAG_CALL, "Wink",
        "%s",
        ast_str_buffer(channel_event_string));
 
    ast_free(channel_event_string);
}

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 1305 of file manager_channels.c.

{
    return (strcmp(dialstatus, "RINGING") &&
            strcmp(dialstatus, "PROCEEDING") &&
            strcmp(dialstatus, "PROGRESS"));
}

Referenced by channel_dial_cb().

manager_channels_init()

int manager_channels_init

(

void

)

Initialize support for AMI channel events.

Return values

0	on success.
non-zero	on error.

Since

12

Definition at line 1429 of file manager_channels.c.

{
    int ret = 0;
    struct stasis_topic *manager_topic;
    struct stasis_topic *channel_topic;
    struct stasis_message_router *message_router;
 
    manager_topic = ast_manager_get_topic();
    if (!manager_topic) {
        return -1;
    }
    message_router = ast_manager_get_message_router();
    if (!message_router) {
        return -1;
    }
    channel_topic = ast_channel_topic_all();
    if (!channel_topic) {
        return -1;
    }
 
    topic_forwarder = stasis_forward_all(channel_topic, manager_topic);
    if (!topic_forwarder) {
        return -1;
    }
 
    ast_register_cleanup(manager_channels_shutdown);
 
    /* The snapshot type has a special handler as it can result in multiple
     * manager events being queued due to aspects of the snapshot itself
     * changing.
     */
    ret |= stasis_message_router_add(message_router,
        ast_channel_snapshot_type(), channel_snapshot_update, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_dtmf_begin_type(), channel_dtmf_begin_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_dtmf_end_type(), channel_dtmf_end_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_flash_type(), channel_flash_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_wink_type(), channel_wink_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_hangup_request_type(), channel_hangup_request_cb,
        NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_dial_type(), channel_dial_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_hold_type(), channel_hold_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_unhold_type(), channel_unhold_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_fax_type(), channel_fax_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_chanspy_start_type(), channel_chanspy_start_cb,
        NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_chanspy_stop_type(), channel_chanspy_stop_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_hangup_handler_type(), channel_hangup_handler_cb,
        NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_moh_start_type(), channel_moh_start_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_moh_stop_type(), channel_moh_stop_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_mixmonitor_start_type(), channel_mixmonitor_start_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_mixmonitor_stop_type(), channel_mixmonitor_stop_cb, NULL);
 
    ret |= stasis_message_router_add(message_router,
        ast_channel_mixmonitor_mute_type(), channel_mixmonitor_mute_cb, NULL);
 
    /* If somehow we failed to add any routes, just shut down the whole
     * thing and fail it.
     */
    if (ret) {
        manager_channels_shutdown();
        return -1;
    }
 
    return 0;
}

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 1423 of file manager_channels.c.

{
    stasis_forward_cancel(topic_forwarder);
    topic_forwarder = NULL;
}

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 812 of file manager_channels.c.

{
    RAII_VAR(struct ast_str *, channel_event_string, NULL, ast_free);
 
    channel_event_string = ast_manager_build_channel_state_string(snapshot);
    if (!channel_event_string) {
        return;
    }
 
    manager_event(class, event,
        "%s",
        ast_str_buffer(channel_event_string));
}

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 772 of file manager_channels.c.

                                              {
    channel_state_change,
    channel_newexten,
    channel_new_callerid,
    channel_new_accountcode,
    channel_new_connected_line,
};

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 537 of file manager_channels.c.

Referenced by manager_channels_init(), and manager_channels_shutdown().