diff --git a/channels/chan_agent.c b/channels/chan_agent.c
index 150c1e9ad25d4c3735d5cca27973c16ea970d193..9a68b815e2c75e4d5296b6658f3a668731be7090 100644
--- a/channels/chan_agent.c
+++ b/channels/chan_agent.c
@@ -272,6 +272,18 @@ static void agent_devicestate_cb(const struct ast_event *event, void *unused)
const char *device;
enum ast_device_state state;
+ state = ast_event_get_ie_uint(event, AST_EVENT_IE_STATE);
+ device = ast_event_get_ie_str(event, AST_EVENT_IE_DEVICE);
+
+ if (ast_strlen_zero(device)) {
+ return;
+ }
+
+ /* Skip Agent status */
+ if (!strncasecmp(device, "Agent/", 6)) {
+ return;
+ }
+
/* Try to be safe, but don't deadlock */
for (i = 0; i < 10; i++) {
if ((res = AST_LIST_TRYLOCK(&agents)) == 0) {
@@ -282,14 +294,6 @@ static void agent_devicestate_cb(const struct ast_event *event, void *unused)
return;
}
- state = ast_event_get_ie_uint(event, AST_EVENT_IE_STATE);
- device = ast_event_get_ie_str(event, AST_EVENT_IE_DEVICE);
-
- if (ast_strlen_zero(device)) {
- AST_LIST_UNLOCK(&agents);
- return;
- }
-
AST_LIST_TRAVERSE(&agents, p, list) {
ast_mutex_lock(&p->lock);
if (p->chan) {
@@ -514,6 +518,7 @@ static struct ast_frame *agent_read(struct ast_channel *ast)
}
p->chan = NULL;
p->inherited_devicestate = -1;
+ ast_device_state_changed("Agent/%s", p->agent);
p->acknowledged = 0;
}
} else {
@@ -729,6 +734,7 @@ static int agent_call(struct ast_channel *ast, char *dest, int timeout)
/* Agent hung-up */
p->chan = NULL;
p->inherited_devicestate = -1;
+ ast_device_state_changed("Agent/%s", p->agent);
}
if (!res) {
@@ -850,6 +856,7 @@ static int agent_hangup(struct ast_channel *ast)
ast_hangup(p->chan);
p->chan = NULL;
p->inherited_devicestate = -1;
+ ast_device_state_changed("Agent/%s", p->agent);
}
ast_debug(1, "Hungup, howlong is %d, autologoff is %d\n", howlong, p->autologoff);
if ((p->deferlogoff) || (howlong && p->autologoff && (howlong > p->autologoff))) {
diff --git a/main/channel.c b/main/channel.c
index 44371554953b54e5633e4dd42467919089929e69..d562afd690b77985f82da0358bf78d1c218c22cf 100644
--- a/main/channel.c
+++ b/main/channel.c
@@ -1277,7 +1277,7 @@ void ast_channel_free(struct ast_channel *chan)
struct ast_frame *f;
struct varshead *headp;
struct ast_datastore *datastore = NULL;
- char name[AST_CHANNEL_NAME];
+ char name[AST_CHANNEL_NAME], *dashptr;
headp=&chan->varshead;
@@ -1310,6 +1310,9 @@ void ast_channel_free(struct ast_channel *chan)
sched_context_destroy(chan->sched);
ast_copy_string(name, chan->name, sizeof(name));
+ if ((dashptr = strrchr(name, '-'))) {
+ *dashptr = '\0';
+ }
/* Stop monitoring */
if (chan->monitor)
@@ -4086,12 +4089,18 @@ void ast_set_callerid(struct ast_channel *chan, const char *cid_num, const char
int ast_setstate(struct ast_channel *chan, enum ast_channel_state state)
{
int oldstate = chan->_state;
+ char name[AST_CHANNEL_NAME], *dashptr;
if (oldstate == state)
return 0;
+ ast_copy_string(name, chan->name, sizeof(name));
+ if ((dashptr = strrchr(name, '-'))) {
+ *dashptr = '\0';
+ }
+
chan->_state = state;
- ast_device_state_changed_literal(chan->name);
+ ast_device_state_changed_literal(name);
/* setstate used to conditionally report Newchannel; this is no more */
manager_event(EVENT_FLAG_CALL,
"Newstate",
diff --git a/main/devicestate.c b/main/devicestate.c
index 6e0af66a08c9bd4730ba460f746319ff6d2a2ce5..c7fe08e39656c4296e174b49c348558e5c998597 100644
--- a/main/devicestate.c
+++ b/main/devicestate.c
@@ -457,15 +457,11 @@ static void do_state_change(const char *device)
devstate_event(device, state, CACHE_OFF);
}
-static int __ast_devstate_changed_literal(enum ast_device_state state, char *buf, int norecurse)
+int ast_devstate_changed_literal(enum ast_device_state state, const char *device)
{
- char *device;
struct state_change *change;
- char *tmp = NULL;
- ast_debug(3, "Notification of state change to be queued on device/channel %s\n", buf);
-
- device = buf;
+ ast_debug(3, "Notification of state change to be queued on device/channel %s\n", device);
if (state != AST_DEVICE_UNKNOWN) {
devstate_event(device, state, CACHE_ON);
@@ -482,37 +478,12 @@ static int __ast_devstate_changed_literal(enum ast_device_state state, char *buf
AST_LIST_UNLOCK(&state_changes);
}
- /* The problem with this API is that a device may be called with the unique
- * identifier appended or not, but it's separated from the channel name
- * with a '-', which is also a legitimate character in a channel name. So,
- * we have to force both names to get their names checked for state changes
- * to ensure that the right one gets notified. Not a huge performance hit,
- * but it might could be fixed by an enterprising programmer in trunk.
- */
- if (!norecurse && (tmp = strrchr(device, '-'))) {
- *tmp = '\0';
- __ast_devstate_changed_literal(state, device, 1);
- }
-
return 1;
}
-int ast_devstate_changed_literal(enum ast_device_state state, const char *dev)
-{
- char *buf;
-
- buf = ast_strdupa(dev);
-
- return __ast_devstate_changed_literal(state, buf, 0);
-}
-
int ast_device_state_changed_literal(const char *dev)
{
- char *buf;
-
- buf = ast_strdupa(dev);
-
- return __ast_devstate_changed_literal(AST_DEVICE_UNKNOWN, buf, 0);
+ return ast_devstate_changed_literal(AST_DEVICE_UNKNOWN, dev);
}
int ast_devstate_changed(enum ast_device_state state, const char *fmt, ...)
@@ -524,7 +495,7 @@ int ast_devstate_changed(enum ast_device_state state, const char *fmt, ...)
vsnprintf(buf, sizeof(buf), fmt, ap);
va_end(ap);
- return __ast_devstate_changed_literal(state, buf, 0);
+ return ast_devstate_changed_literal(state, buf);
}
/*! \brief Accept change notification, add it to change queue */
@@ -537,7 +508,7 @@ int ast_device_state_changed(const char *fmt, ...)
vsnprintf(buf, sizeof(buf), fmt, ap);
va_end(ap);
- return __ast_devstate_changed_literal(AST_DEVICE_UNKNOWN, buf, 0);
+ return ast_devstate_changed_literal(AST_DEVICE_UNKNOWN, buf);
}
/*! \brief Go through the dev state change queue and update changes in the dev state thread */