kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-10-16 09:46:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

manager: Add state list commands

Browse Source 
This patch adds three new AMI commands:
 * ExtensionStateList (pbx.c) - list all known extension state hints
   and their current statuses. Events emitted by the list action are
   equivalent to the ExtensionStatus events.
 * PresenceStateList (res_manager_presencestate) - list all known
   presence state values. Events emitted are generated by the stasis
   message type, and hence are PresenceStateChange events.
 * DeviceStateList (res_manager_devicestate) - list all known device
   state values. Events emitted are generated by the stasis message
   type, and hence are DeviceStateChange events.

Patch-by: Matt Jordan
Review: https://reviewboard.asterisk.org/r/3799/


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@419806 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
Kinsey Moore
2014-07-30 18:32:25 +00:00
parent cac711fc95
commit 485d0379ae
4 changed files with 320 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

101
res/res_manager_devicestate.c
View File

@@ -20,16 +20,107 @@
<support_level>core</support_level>
***/
/*** DOCUMENTATION
<manager name="DeviceStateList" language="en_US">
<synopsis>
List the current known device states.
</synopsis>
<syntax>
<xi:include xpointer="xpointer(/docs/manager[@name='Login']/syntax/parameter[@name='ActionID'])" />
</syntax>
<description>
<para>This will list out all known device states in a
sequence of <replaceable>DeviceStateChange</replaceable> events.
When finished, a <replaceable>DeviceStateListComplete</replaceable> event
will be emitted.</para>
</description>
<see-also>
<ref type="managerEvent">DeviceStateChange</ref>
<ref type="function">DEVICE_STATE</ref>
</see-also>
<responses>
<list-elements>
<xi:include xpointer="xpointer(/docs/managerEvent[@name='DeviceStateChange'])" />
</list-elements>
<managerEvent name="DeviceStateListComplete" language="en_US">
<managerEventInstance class="EVENT_FLAG_COMMAND">
<synopsis>
Indicates the end of the list the current known extension states.
</synopsis>
<syntax>
<parameter name="EventList">
<para>Conveys the status of the event list.</para>
</parameter>
<parameter name="ListItems">
<para>Conveys the number of statuses reported.</para>
</parameter>
</syntax>
</managerEventInstance>
</managerEvent>
</responses>
</manager>
***/
#include "asterisk.h"
#include "asterisk/module.h"
#include "asterisk/manager.h"
#include "asterisk/stasis.h"
#include "asterisk/devicestate.h"
static struct stasis_forward *topic_forwarder;
static int action_devicestatelist(struct mansession *s, const struct message *m)
{
RAII_VAR(struct ao2_container *, device_states, NULL, ao2_cleanup);
const char *action_id = astman_get_header(m, "ActionID");
struct stasis_message *msg;
struct ao2_iterator it_states;
int count = 0;
device_states = stasis_cache_dump_by_eid(ast_device_state_cache(),
ast_device_state_message_type(), NULL);
if (!device_states) {
astman_send_error(s, m, "Memory Allocation Failure");
return 0;
}
astman_send_listack(s, m, "Device State Changes will follow", "start");
it_states = ao2_iterator_init(device_states, 0);
for (; (msg = ao2_iterator_next(&it_states)); ao2_ref(msg, -1)) {
struct ast_manager_event_blob *blob = stasis_message_to_ami(msg);
if (!blob) {
continue;
}
count++;
astman_append(s, "Event: %s\r\n", blob->manager_event);
if (!ast_strlen_zero(action_id)) {
astman_append(s, "ActionID: %s\r\n", action_id);
}
astman_append(s, "%s\r\n", blob->extra_fields);
ao2_ref(blob, -1);
}
ao2_iterator_destroy(&it_states);
astman_append(s, "Event: DeviceStateListComplete\r\n");
if (!ast_strlen_zero(action_id)) {
astman_append(s, "ActionID: %s\r\n", action_id);
}
astman_append(s, "EventList: Complete\r\n"
"ListItems: %d\r\n\r\n", count);
return 0;
}
static int unload_module(void)
{
topic_forwarder = stasis_forward_cancel(topic_forwarder);
ast_manager_unregister("DeviceStateList");
return 0;
}
@@ -41,8 +132,16 @@ static int load_module(void)
if (!manager_topic) {
return AST_MODULE_LOAD_DECLINE;
}
topic_forwarder = stasis_forward_all(ast_device_state_topic_all(), manager_topic);
if (!topic_forwarder) {
return AST_MODULE_LOAD_DECLINE;
}
if (ast_manager_register_xml("DeviceStateList", EVENT_FLAG_CALL | EVENT_FLAG_REPORTING,
action_devicestatelist)) {
topic_forwarder = stasis_forward_cancel(topic_forwarder);
return AST_MODULE_LOAD_DECLINE;
}
return AST_MODULE_LOAD_SUCCESS;
}