From 430bb3bfb3841fcf48996c8cc0ef76f7f88e582e Mon Sep 17 00:00:00 2001 From: Matthew Jordan Date: Tue, 20 Aug 2013 00:08:33 +0000 Subject: Let Queue wrap up time influence member availability Queue members who happen to be in multiple queues at the same time may not have any wrap up time. This problem occurred due to a code change in Asterisk 11.3.0 that unified device state tracking of Queue members in multiple Queues (which fixed some other problems, but unfortunately caused this one). This patch fixes the behavior by having the is_member_available function check the queue's wrap up time and the time of the member's last call, such that for a particular queue, the member won't be considered available if their last call is within the wrap up time. (closes issue ASTERISK-22189) Reported by: Tony Lewis Tested by: Tony Lewis ........ Merged revisions 396948 from http://svn.asterisk.org/svn/asterisk/branches/11 git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@396949 65c4cc65-6c06-0410-ace0-fbb531ad65f3 --- apps/app_queue.c | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/apps/app_queue.c b/apps/app_queue.c index aa9602521..30b5ed670 100644 --- a/apps/app_queue.c +++ b/apps/app_queue.c @@ -2064,7 +2064,7 @@ static void update_status(struct call_queue *q, struct member *m, const int stat * \retval 1 if the member is available * \retval 0 if the member is not available */ -static int is_member_available(struct member *mem) +static int is_member_available(struct call_queue *q, struct member *mem) { int available = 0; @@ -2089,6 +2089,10 @@ static int is_member_available(struct member *mem) break; } + /* Let wrapuptimes override device state availability */ + if (mem->lastcall && q->wrapuptime && (time(NULL) - q->wrapuptime < mem->lastcall)) { + available = 0; + } return available; } @@ -2139,7 +2143,7 @@ static void device_state_cb(void *unused, struct stasis_subscription *sub, struc /* check every member until we find one NOT_INUSE */ if (!avail) { - avail = is_member_available(m); + avail = is_member_available(q, m); } if (avail && found_member) { /* early exit as we've found an available member and the member of interest */ @@ -3703,7 +3707,7 @@ static int num_available_members(struct call_queue *q) mem_iter = ao2_iterator_init(q->members, 0); while ((mem = ao2_iterator_next(&mem_iter))) { - avl += is_member_available(mem); + avl += is_member_available(q, mem); ao2_ref(mem, -1); /* If autofill is not enabled or if the queue's strategy is ringall, then @@ -6227,7 +6231,7 @@ static int add_to_queue(const char *queuename, const char *interface, const char member_add_to_queue(q, new_member); queue_publish_member_blob(queue_member_added_type(), queue_member_blob_create(q, new_member)); - if (is_member_available(new_member)) { + if (is_member_available(q, new_member)) { ast_devstate_changed(AST_DEVICE_NOT_INUSE, AST_DEVSTATE_CACHABLE, "Queue:%s_avail", q->name); } @@ -6313,7 +6317,7 @@ static int set_member_paused(const char *queuename, const char *interface, const dump_queue_members(q); } - if (is_member_available(mem)) { + if (is_member_available(q, mem)) { ast_devstate_changed(AST_DEVICE_NOT_INUSE, AST_DEVSTATE_CACHABLE, "Queue:%s_avail", q->name); } else if (!num_available_members(q)) { ast_devstate_changed(AST_DEVICE_INUSE, AST_DEVSTATE_CACHABLE, "Queue:%s_avail", q->name); -- cgit v1.2.3