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)
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 274 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
ast_str*	on success (must be ast_freed by caller)

Definition at line 267 of file manager_bridges.c.

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

{
   return ast_manager_build_bridge_state_string_prefix(snapshot, "");
}

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
ast_str*	on success (must be ast_freed by caller)

Definition at line 223 of file manager_bridges.c.

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

{
   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;
}

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.

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

{
   if (!new_snapshot || old_snapshot) {
      return NULL;
   }

   return ast_manager_event_blob_create(
      EVENT_FLAG_CALL, "BridgeCreate", NO_EXTRA_FIELDS);
}

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.

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

{
   if (new_snapshot || !old_snapshot) {
      return NULL;
   }

   return ast_manager_event_blob_create(
      EVENT_FLAG_CALL, "BridgeDestroy", NO_EXTRA_FIELDS);
}

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.

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

{
   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
      <managerEventInstance>
         <synopsis>Raised when two bridges are merged.</synopsis>
         <syntax>
            <bridge_snapshot prefix="To"/>
            <bridge_snapshot prefix="From"/>
         </syntax>
      </managerEventInstance>
   ***/
   manager_event(EVENT_FLAG_CALL, "BridgeMerge",
      "%s"
      "%s",
      ast_str_buffer(to_text),
      ast_str_buffer(from_text));
}

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.

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

Referenced by manager_bridging_init().

{
   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);
   }
}

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

Definition at line 292 of file manager_bridges.c.

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

{
   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);
}

channel_enter_cb()

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

static

Definition at line 394 of file manager_bridges.c.

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, ast_bridge_blob::bridge, ast_bridge_blob::channel, EVENT_FLAG_CALL, manager_event, NULL, RAII_VAR, S_OR, and stasis_message_data().

Referenced by manager_bridging_init().

{
   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" : "");
}

channel_leave_cb()

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

static

Definition at line 422 of file manager_bridges.c.

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

Referenced by manager_bridging_init().

{
   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));
}

manager_bridge_destroy()

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

static

Definition at line 604 of file manager_bridges.c.

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

{
   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;
}

manager_bridge_info()

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

static

Definition at line 555 of file manager_bridges.c.

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

{
   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;
}

manager_bridge_kick()

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

static

Definition at line 626 of file manager_bridges.c.

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

{
   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;
}

manager_bridges_list()

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

static

Definition at line 484 of file manager_bridges.c.

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

{
   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;
}

manager_bridging_cleanup()

static void manager_bridging_cleanup ( void  )

static

Definition at line 670 of file manager_bridges.c.

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

Referenced by manager_bridging_init().

{
   stasis_forward_cancel(topic_forwarder);
   topic_forwarder = NULL;

   ast_manager_unregister("BridgeList");
   ast_manager_unregister("BridgeInfo");
   ast_manager_unregister("BridgeDestroy");
   ast_manager_unregister("BridgeKick");
}

manager_bridging_init()

int manager_bridging_init

(

void

)

Initialize support for AMI channel events.

Returns

0 on success.

non-zero on error.

Since

12

Definition at line 681 of file manager_bridges.c.

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

Referenced by subscribe_all().

{
   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;
}

send_bridge_info_item_cb()

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

static

Definition at line 522 of file manager_bridges.c.

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

{
   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;
}

send_bridge_list_item_cb()

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

static

Definition at line 448 of file manager_bridges.c.

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

{
   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;
}

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.

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.