manager_bridges.c File Reference

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

#include "asterisk.h"
#include "asterisk/stasis_bridges.h"
#include "asterisk/stasis_channels.h"
#include "asterisk/manager.h"
#include "asterisk/stasis_message_router.h"

Include dependency graph for manager_bridges.c:

Go to the source code of this file.

Data Structures
struct	bridge_list_data

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

Functions
struct ast_str *	ast_manager_build_bridge_state_string (const struct ast_bridge_snapshot *snapshot)
	Generate the AMI message body from a bridge snapshot. More...
struct ast_str *	ast_manager_build_bridge_state_string_prefix (const struct ast_bridge_snapshot *snapshot, const char *prefix)
	Generate the AMI message body from a bridge snapshot. More...
static struct ast_manager_event_blob *	bridge_create (struct ast_bridge_snapshot *old_snapshot, struct ast_bridge_snapshot *new_snapshot)
	Handle bridge creation. More...
static struct ast_manager_event_blob *	bridge_destroy (struct ast_bridge_snapshot *old_snapshot, struct ast_bridge_snapshot *new_snapshot)
	Handle bridge destruction. More...
static void	bridge_merge_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	bridge_snapshot_update (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static struct ast_manager_event_blob *	bridge_video_update (struct ast_bridge_snapshot *old_snapshot, struct ast_bridge_snapshot *new_snapshot)
	Handle video source updates. More...
static void	channel_enter_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	channel_leave_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static int	manager_bridge_destroy (struct mansession *s, const struct message *m)
static int	manager_bridge_info (struct mansession *s, const struct message *m)
static int	manager_bridge_kick (struct mansession *s, const struct message *m)
static int	manager_bridges_list (struct mansession *s, const struct message *m)
static void	manager_bridging_cleanup (void)
int	manager_bridging_init (void)
	Initialize support for AMI channel events. More...
static int	send_bridge_info_item_cb (void *obj, void *arg, void *data, int flags)
static int	send_bridge_list_item_cb (void *obj, void *arg, void *data, int flags)

Variables
bridge_snapshot_monitor	bridge_monitors []
static struct stasis_message_router *	bridge_state_router
	Message router for cached bridge state snapshot updates. More...
static struct stasis_forward *	topic_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 (bridge event handling)

Author

Kinsey Moore kmoor.nosp@m.e@di.nosp@m.gium..nosp@m.com

Definition in file manager_bridges.c.

Typedef Documentation

bridge_snapshot_monitor

typedef struct ast_manager_event_blob *(* bridge_snapshot_monitor) (struct ast_bridge_snapshot *old_snapshot, struct ast_bridge_snapshot *new_snapshot)

Typedef for callbacks that get called on channel snapshot updates.

Definition at line 267 of file manager_bridges.c.

Function Documentation

ast_manager_build_bridge_state_string()

struct ast_str * ast_manager_build_bridge_state_string

(

const struct ast_bridge_snapshot *

snapshot

)

Generate the AMI message body from a bridge snapshot.

Since

12

Parameters

snapshot

the bridge 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 267 of file manager_bridges.c.

{
    return ast_manager_build_bridge_state_string_prefix(snapshot, "");
}

References ast_manager_build_bridge_state_string_prefix().

Referenced by blind_transfer_to_ami(), bridge_snapshot_update(), channel_enter_cb(), channel_leave_cb(), confbridge_publish_manager_event(), manager_bridge_info(), and send_bridge_list_item_cb().

ast_manager_build_bridge_state_string_prefix()

struct ast_str * ast_manager_build_bridge_state_string_prefix	(	const struct ast_bridge_snapshot *	snapshot,
		const char *	prefix
	)

Generate the AMI message body from a bridge snapshot.

Since

12

Parameters

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

Return values

NULL

on error

Returns

ast_str* on success (must be ast_freed by caller)

Definition at line 223 of file manager_bridges.c.

{
    struct ast_str *out = ast_str_create(128);
    int res;
 
    if (!out) {
        return NULL;
    }
 
    res = ast_str_set(&out, 0,
        "%sBridgeUniqueid: %s\r\n"
        "%sBridgeType: %s\r\n"
        "%sBridgeTechnology: %s\r\n"
        "%sBridgeCreator: %s\r\n"
        "%sBridgeName: %s\r\n"
        "%sBridgeNumChannels: %u\r\n"
        "%sBridgeVideoSourceMode: %s\r\n",
        prefix, snapshot->uniqueid,
        prefix, snapshot->subclass,
        prefix, snapshot->technology,
        prefix, ast_strlen_zero(snapshot->creator) ? "<unknown>": snapshot->creator,
        prefix, ast_strlen_zero(snapshot->name) ? "<unknown>": snapshot->name,
        prefix, snapshot->num_channels,
        prefix, ast_bridge_video_mode_to_string(snapshot->video_mode));
    if (!res) {
        ast_free(out);
        return NULL;
    }
 
    if (snapshot->video_mode != AST_BRIDGE_VIDEO_MODE_NONE
        && !ast_strlen_zero(snapshot->video_source_id)) {
        res = ast_str_append(&out, 0, "%sBridgeVideoSource: %s\r\n",
            prefix, snapshot->video_source_id);
        if (!res) {
            ast_free(out);
            return NULL;
        }
    }
 
    return out;
}

References AST_BRIDGE_VIDEO_MODE_NONE, ast_bridge_video_mode_to_string(), ast_free, ast_str_append(), ast_str_create, ast_str_set(), ast_strlen_zero(), ast_bridge_snapshot::creator, ast_bridge_snapshot::name, NULL, ast_bridge_snapshot::num_channels, out, prefix, ast_bridge_snapshot::subclass, ast_bridge_snapshot::technology, ast_bridge_snapshot::uniqueid, ast_bridge_snapshot::video_mode, and ast_bridge_snapshot::video_source_id.

Referenced by ast_manager_build_bridge_state_string(), attended_transfer_to_ami(), bridge_merge_cb(), and multi_object_blob_to_ami().

bridge_create()

static struct ast_manager_event_blob * bridge_create ( struct ast_bridge_snapshot *  old_snapshot, struct ast_bridge_snapshot *  new_snapshot  )

static

Handle bridge creation.

Definition at line 279 of file manager_bridges.c.

{
    if (!new_snapshot || old_snapshot) {
        return NULL;
    }
 
    return ast_manager_event_blob_create(
        EVENT_FLAG_CALL, "BridgeCreate", NO_EXTRA_FIELDS);
}

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

bridge_destroy()

static struct ast_manager_event_blob * bridge_destroy ( struct ast_bridge_snapshot *  old_snapshot, struct ast_bridge_snapshot *  new_snapshot  )

static

Handle bridge destruction.

Definition at line 311 of file manager_bridges.c.

{
    if (new_snapshot || !old_snapshot) {
        return NULL;
    }
 
    return ast_manager_event_blob_create(
        EVENT_FLAG_CALL, "BridgeDestroy", NO_EXTRA_FIELDS);
}

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

bridge_merge_cb()

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

static

Definition at line 362 of file manager_bridges.c.

{
    struct ast_bridge_merge_message *merge_msg = stasis_message_data(message);
    RAII_VAR(struct ast_str *, to_text, NULL, ast_free);
    RAII_VAR(struct ast_str *, from_text, NULL, ast_free);
 
    ast_assert(merge_msg->to != NULL);
    ast_assert(merge_msg->from != NULL);
 
    to_text = ast_manager_build_bridge_state_string_prefix(merge_msg->to, "To");
    from_text = ast_manager_build_bridge_state_string_prefix(merge_msg->from, "From");
    if (!to_text || !from_text) {
        return;
    }
 
    /*** DOCUMENTATION
        <managerEvent language="en_US" name="BridgeMerge">
            <managerEventInstance class="EVENT_FLAG_CALL">
                <synopsis>Raised when two bridges are merged.</synopsis>
                <syntax>
                    <bridge_snapshot prefix="To"/>
                    <bridge_snapshot prefix="From"/>
                </syntax>
            </managerEventInstance>
        </managerEvent>
    ***/
    manager_event(EVENT_FLAG_CALL, "BridgeMerge",
        "%s"
        "%s",
        ast_str_buffer(to_text),
        ast_str_buffer(from_text));
}

References ast_assert, ast_free, ast_manager_build_bridge_state_string_prefix(), ast_str_buffer(), EVENT_FLAG_CALL, ast_bridge_merge_message::from, manager_event, NULL, RAII_VAR, stasis_message_data(), and ast_bridge_merge_message::to.

Referenced by manager_bridging_init().

bridge_snapshot_update()

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

static

Definition at line 329 of file manager_bridges.c.

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

References ao2_cleanup, ARRAY_LEN, ast_free, ast_manager_build_bridge_state_string(), ast_str_buffer(), bridge_monitors, manager_event, NULL, RAII_VAR, stasis_message_data(), and update().

Referenced by manager_bridging_init().

bridge_video_update()

static struct ast_manager_event_blob * bridge_video_update ( struct ast_bridge_snapshot *  old_snapshot, struct ast_bridge_snapshot *  new_snapshot  )

static

Handle video source updates.

Definition at line 292 of file manager_bridges.c.

{
    if (!new_snapshot || !old_snapshot) {
        return NULL;
    }
 
    if (!strcmp(old_snapshot->video_source_id, new_snapshot->video_source_id)) {
        return NULL;
    }
 
    return ast_manager_event_blob_create(
        EVENT_FLAG_CALL, "BridgeVideoSourceUpdate",
        "BridgePreviousVideoSource: %s\r\n",
        old_snapshot->video_source_id);
}

References ast_manager_event_blob_create(), EVENT_FLAG_CALL, NULL, and ast_bridge_snapshot::video_source_id.

channel_enter_cb()

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

static

Definition at line 396 of file manager_bridges.c.

{
    static const char *swap_name = "SwapUniqueid: ";
    struct ast_bridge_blob *blob = stasis_message_data(message);
    RAII_VAR(struct ast_str *, bridge_text, NULL, ast_free);
    RAII_VAR(struct ast_str *, channel_text, NULL, ast_free);
    const char *swap_id;
 
    bridge_text = ast_manager_build_bridge_state_string(blob->bridge);
    channel_text = ast_manager_build_channel_state_string(blob->channel);
    if (!bridge_text || !channel_text) {
        return;
    }
 
    swap_id = ast_json_string_get(ast_json_object_get(blob->blob, "swap"));
 
    manager_event(EVENT_FLAG_CALL, "BridgeEnter",
        "%s"
        "%s"
        "%s%s%s",
        ast_str_buffer(bridge_text),
        ast_str_buffer(channel_text),
        swap_id ? swap_name : "",
        S_OR(swap_id, ""),
        swap_id ? "\r\n" : "");
}

References ast_free, ast_json_object_get(), ast_json_string_get(), ast_manager_build_bridge_state_string(), ast_manager_build_channel_state_string(), ast_str_buffer(), ast_bridge_blob::blob, EVENT_FLAG_CALL, manager_event, NULL, RAII_VAR, S_OR, and stasis_message_data().

Referenced by manager_bridging_init().

channel_leave_cb()

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

static

Definition at line 424 of file manager_bridges.c.

{
    struct ast_bridge_blob *blob = stasis_message_data(message);
    RAII_VAR(struct ast_str *, bridge_text, NULL, ast_free);
    RAII_VAR(struct ast_str *, channel_text, NULL, ast_free);
 
    bridge_text = ast_manager_build_bridge_state_string(blob->bridge);
    channel_text = ast_manager_build_channel_state_string(blob->channel);
    if (!bridge_text || !channel_text) {
        return;
    }
 
    manager_event(EVENT_FLAG_CALL, "BridgeLeave",
        "%s"
        "%s",
        ast_str_buffer(bridge_text),
        ast_str_buffer(channel_text));
}

References ast_free, ast_manager_build_bridge_state_string(), ast_manager_build_channel_state_string(), ast_str_buffer(), ast_bridge_blob::blob, EVENT_FLAG_CALL, manager_event, NULL, RAII_VAR, and stasis_message_data().

Referenced by manager_bridging_init().

manager_bridge_destroy()

static int manager_bridge_destroy ( struct mansession *  s, const struct message *  m  )

static

Definition at line 606 of file manager_bridges.c.

{
    const char *bridge_uniqueid = astman_get_header(m, "BridgeUniqueid");
    struct ast_bridge *bridge;
 
    if (ast_strlen_zero(bridge_uniqueid)) {
        astman_send_error(s, m, "BridgeUniqueid must be provided");
        return 0;
    }
 
    bridge = ast_bridge_find_by_id(bridge_uniqueid);
    if (!bridge) {
        astman_send_error(s, m, "Specified BridgeUniqueid not found");
        return 0;
    }
    ast_bridge_destroy(bridge, 0);
 
    astman_send_ack(s, m, "Bridge has been destroyed");
 
    return 0;
}

References ast_bridge_destroy(), ast_bridge_find_by_id(), ast_strlen_zero(), astman_get_header(), astman_send_ack(), and astman_send_error().

Referenced by manager_bridging_init().

manager_bridge_info()

static int manager_bridge_info ( struct mansession *  s, const struct message *  m  )

static

Definition at line 557 of file manager_bridges.c.

{
    const char *id = astman_get_header(m, "ActionID");
    const char *bridge_uniqueid = astman_get_header(m, "BridgeUniqueid");
    RAII_VAR(struct ast_str *, bridge_info, NULL, ast_free);
    RAII_VAR(struct ast_bridge_snapshot *, snapshot, NULL, ao2_cleanup);
    struct bridge_list_data list_data = { 0 };
 
    if (ast_strlen_zero(bridge_uniqueid)) {
        astman_send_error(s, m, "BridgeUniqueid must be provided");
        return 0;
    }
 
    snapshot = ast_bridge_get_snapshot_by_uniqueid(bridge_uniqueid);
    if (!snapshot) {
        astman_send_error(s, m, "Specified BridgeUniqueid not found");
        return 0;
    }
 
    bridge_info = ast_manager_build_bridge_state_string(snapshot);
    if (!bridge_info) {
        astman_send_error(s, m, "Internal error");
        return -1;
    }
 
    list_data.id_text = ast_str_create(128);
    if (!list_data.id_text) {
        astman_send_error(s, m, "Internal error");
        return -1;
    }
 
    if (!ast_strlen_zero(id)) {
        ast_str_set(&list_data.id_text, 0, "ActionID: %s\r\n", id);
    }
 
    astman_send_listack(s, m, "Bridge channel listing will follow", "start");
 
    ao2_callback_data(snapshot->channels, OBJ_NODATA, send_bridge_info_item_cb, s, &list_data);
 
    astman_send_list_complete_start(s, m, "BridgeInfoComplete", list_data.count);
    if (!ast_strlen_zero(ast_str_buffer(bridge_info))) {
        astman_append(s, "%s", ast_str_buffer(bridge_info));
    }
    astman_send_list_complete_end(s);
    ast_free(list_data.id_text);
 
    return 0;
}

References ao2_callback_data, ao2_cleanup, ast_bridge_get_snapshot_by_uniqueid(), ast_free, ast_manager_build_bridge_state_string(), ast_str_buffer(), ast_str_create, ast_str_set(), ast_strlen_zero(), astman_append(), astman_get_header(), astman_send_error(), astman_send_list_complete_end(), astman_send_list_complete_start(), astman_send_listack(), bridge_list_data::count, bridge_list_data::id_text, NULL, OBJ_NODATA, RAII_VAR, and send_bridge_info_item_cb().

Referenced by manager_bridging_init().

manager_bridge_kick()

static int manager_bridge_kick ( struct mansession *  s, const struct message *  m  )

static

Definition at line 628 of file manager_bridges.c.

{
    const char *bridge_uniqueid = astman_get_header(m, "BridgeUniqueid");
    const char *channel_name = astman_get_header(m, "Channel");
    RAII_VAR(struct ast_bridge *, bridge, NULL, ao2_cleanup);
    RAII_VAR(struct ast_channel *, channel, NULL, ao2_cleanup);
 
    if (ast_strlen_zero(channel_name)) {
        astman_send_error(s, m, "Channel must be provided");
        return 0;
    }
 
    channel = ast_channel_get_by_name(channel_name);
    if (!channel) {
        astman_send_error(s, m, "Channel does not exist");
        return 0;
    }
 
    if (ast_strlen_zero(bridge_uniqueid)) {
        /* get the bridge from the channel */
        ast_channel_lock(channel);
        bridge = ast_channel_get_bridge(channel);
        ast_channel_unlock(channel);
        if (!bridge) {
            astman_send_error(s, m, "Channel is not in a bridge");
            return 0;
        }
    } else {
        bridge = ast_bridge_find_by_id(bridge_uniqueid);
        if (!bridge || ast_test_flag(&bridge->feature_flags, AST_BRIDGE_FLAG_INVISIBLE)) {
            astman_send_error(s, m, "Bridge not found");
            return 0;
        }
    }
 
    if (ast_bridge_kick(bridge, channel)) {
        astman_send_error(s, m, "Channel kick from bridge failed");
        return 0;
    }
 
    astman_send_ack(s, m, "Channel has been kicked");
    return 0;
}

References ao2_cleanup, ast_bridge_find_by_id(), AST_BRIDGE_FLAG_INVISIBLE, ast_bridge_kick(), ast_channel_get_bridge(), ast_channel_get_by_name(), ast_channel_lock, ast_channel_unlock, ast_strlen_zero(), ast_test_flag, astman_get_header(), astman_send_ack(), astman_send_error(), NULL, and RAII_VAR.

Referenced by manager_bridging_init().

manager_bridges_list()

static int manager_bridges_list ( struct mansession *  s, const struct message *  m  )

static

Definition at line 486 of file manager_bridges.c.

{
    const char *id = astman_get_header(m, "ActionID");
    const char *type_filter = astman_get_header(m, "BridgeType");
    struct ao2_container *bridges;
    struct bridge_list_data list_data = { 0 };
 
    bridges = ast_bridges();
    if (!bridges) {
        astman_send_error(s, m, "Internal error");
        return -1;
    }
 
    list_data.id_text = ast_str_create(128);
    if (!list_data.id_text) {
        ao2_ref(bridges, -1);
        astman_send_error(s, m, "Internal error");
        return -1;
    }
 
    if (!ast_strlen_zero(id)) {
        ast_str_set(&list_data.id_text, 0, "ActionID: %s\r\n", id);
    }
    list_data.type_filter = type_filter;
 
    astman_send_listack(s, m, "Bridge listing will follow", "start");
 
    ao2_callback_data(bridges, OBJ_NODATA, send_bridge_list_item_cb, s, &list_data);
 
    astman_send_list_complete_start(s, m, "BridgeListComplete", list_data.count);
    astman_send_list_complete_end(s);
 
    ast_free(list_data.id_text);
    ao2_ref(bridges, -1);
 
    return 0;
}

References ao2_callback_data, ao2_ref, ast_bridges(), ast_free, ast_str_create, ast_str_set(), ast_strlen_zero(), astman_get_header(), astman_send_error(), astman_send_list_complete_end(), astman_send_list_complete_start(), astman_send_listack(), bridges, bridge_list_data::count, bridge_list_data::id_text, OBJ_NODATA, send_bridge_list_item_cb(), and bridge_list_data::type_filter.

Referenced by manager_bridging_init().

manager_bridging_cleanup()

static void manager_bridging_cleanup ( void  )

static

Definition at line 672 of file manager_bridges.c.

{
    stasis_forward_cancel(topic_forwarder);
    topic_forwarder = NULL;
 
    ast_manager_unregister("BridgeList");
    ast_manager_unregister("BridgeInfo");
    ast_manager_unregister("BridgeDestroy");
    ast_manager_unregister("BridgeKick");
}

References ast_manager_unregister(), NULL, stasis_forward_cancel(), and topic_forwarder.

Referenced by manager_bridging_init().

manager_bridging_init()

int manager_bridging_init

(

void

)

Initialize support for AMI channel events.

Return values

0	on success.
non-zero	on error.

Since

12

Definition at line 683 of file manager_bridges.c.

{
    int ret = 0;
    struct stasis_topic *manager_topic;
    struct stasis_topic *bridge_topic;
 
    if (bridge_state_router) {
        /* Already initialized */
        return 0;
    }
 
    ast_register_cleanup(manager_bridging_cleanup);
 
    manager_topic = ast_manager_get_topic();
    if (!manager_topic) {
        return -1;
    }
 
    bridge_topic = ast_bridge_topic_all();
    if (!bridge_topic) {
        return -1;
    }
 
    topic_forwarder = stasis_forward_all(bridge_topic, manager_topic);
    if (!topic_forwarder) {
        return -1;
    }
 
    bridge_state_router = ast_manager_get_message_router();
    if (!bridge_state_router) {
        return -1;
    }
 
    ret |= stasis_message_router_add(bridge_state_router,
        ast_bridge_snapshot_type(), bridge_snapshot_update, NULL);
 
    ret |= stasis_message_router_add(bridge_state_router,
        ast_bridge_merge_message_type(), bridge_merge_cb, NULL);
 
    ret |= stasis_message_router_add(bridge_state_router,
        ast_channel_entered_bridge_type(), channel_enter_cb, NULL);
 
    ret |= stasis_message_router_add(bridge_state_router,
        ast_channel_left_bridge_type(), channel_leave_cb, NULL);
 
    ret |= ast_manager_register_xml_core("BridgeList", 0, manager_bridges_list);
    ret |= ast_manager_register_xml_core("BridgeInfo", 0, manager_bridge_info);
    ret |= ast_manager_register_xml_core("BridgeDestroy", 0, manager_bridge_destroy);
    ret |= ast_manager_register_xml_core("BridgeKick", 0, manager_bridge_kick);
 
    /* If somehow we failed to add any routes, just shut down the whole
     * thing and fail it.
     */
    if (ret) {
        manager_bridging_cleanup();
        return -1;
    }
 
    return 0;
}

References ast_bridge_merge_message_type(), ast_bridge_snapshot_type(), ast_bridge_topic_all(), ast_channel_entered_bridge_type(), ast_channel_left_bridge_type(), ast_manager_get_message_router(), ast_manager_get_topic(), ast_manager_register_xml_core, ast_register_cleanup(), bridge_merge_cb(), bridge_snapshot_update(), bridge_state_router, channel_enter_cb(), channel_leave_cb(), manager_bridge_destroy(), manager_bridge_info(), manager_bridge_kick(), manager_bridges_list(), manager_bridging_cleanup(), manager_topic, NULL, stasis_forward_all(), stasis_message_router_add(), and topic_forwarder.

Referenced by subscribe_all().

send_bridge_info_item_cb()

static int send_bridge_info_item_cb ( void *  obj, void *  arg, void *  data, int  flags  )

static

Definition at line 524 of file manager_bridges.c.

{
    char *uniqueid = obj;
    struct mansession *s = arg;
    struct bridge_list_data *list_data = data;
    RAII_VAR(struct ast_channel_snapshot *, snapshot, NULL, ao2_cleanup);
    RAII_VAR(struct ast_str *, channel_text, NULL, ast_free);
 
    snapshot = ast_channel_snapshot_get_latest(uniqueid);
    if (!snapshot) {
        return 0;
    }
 
    if (snapshot->base->tech_properties & AST_CHAN_TP_INTERNAL) {
        return 0;
    }
 
    channel_text = ast_manager_build_channel_state_string(snapshot);
    if (!channel_text) {
        return 0;
    }
 
    astman_append(s,
        "Event: BridgeInfoChannel\r\n"
        "%s"
        "%s"
        "\r\n",
        ast_str_buffer(list_data->id_text),
        ast_str_buffer(channel_text));
    ++list_data->count;
    return 0;
}

References ao2_cleanup, AST_CHAN_TP_INTERNAL, ast_channel_snapshot_get_latest(), ast_free, ast_manager_build_channel_state_string(), ast_str_buffer(), astman_append(), bridge_list_data::count, bridge_list_data::id_text, NULL, and RAII_VAR.

Referenced by manager_bridge_info().

send_bridge_list_item_cb()

static int send_bridge_list_item_cb ( void *  obj, void *  arg, void *  data, int  flags  )

static

Definition at line 450 of file manager_bridges.c.

{
    struct ast_bridge *bridge = obj;
    RAII_VAR(struct ast_bridge_snapshot *, snapshot, ast_bridge_get_snapshot(bridge), ao2_cleanup);
    struct mansession *s = arg;
    struct bridge_list_data *list_data = data;
    struct ast_str * bridge_info;
 
    if (!snapshot) {
        return 0;
    }
 
    if (!ast_strlen_zero(list_data->type_filter)
        && strcmp(list_data->type_filter, snapshot->technology)) {
        return 0;
    }
 
    bridge_info = ast_manager_build_bridge_state_string(snapshot);
    if (!bridge_info) {
        return 0;
    }
 
    astman_append(s,
        "Event: BridgeListItem\r\n"
        "%s"
        "%s"
        "\r\n",
        ast_str_buffer(list_data->id_text),
        ast_str_buffer(bridge_info));
    ++list_data->count;
 
    ast_free(bridge_info);
 
    return 0;
}

References ao2_cleanup, ast_bridge_get_snapshot(), ast_free, ast_manager_build_bridge_state_string(), ast_str_buffer(), ast_strlen_zero(), astman_append(), bridge_list_data::count, bridge_list_data::id_text, RAII_VAR, and bridge_list_data::type_filter.

Referenced by manager_bridges_list().

Variable Documentation

bridge_monitors

bridge_snapshot_monitor bridge_monitors[]

Initial value:

= {
    bridge_create,
    bridge_video_update,
    bridge_destroy,
}

Definition at line 323 of file manager_bridges.c.

Referenced by bridge_snapshot_update().

bridge_state_router

struct stasis_message_router* bridge_state_router

static

Message router for cached bridge state snapshot updates.

Definition at line 34 of file manager_bridges.c.

Referenced by manager_bridging_init().

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 221 of file manager_bridges.c.

Referenced by manager_bridging_cleanup(), and manager_bridging_init().