aboutsummaryrefslogtreecommitdiffstats
path: root/apps/app_queue.c
diff options
context:
space:
mode:
authordvossel <dvossel@f38db490-d61c-443f-a65b-d21fe96a405b>2009-11-30 18:57:02 +0000
committerdvossel <dvossel@f38db490-d61c-443f-a65b-d21fe96a405b>2009-11-30 18:57:02 +0000
commit90f6a20df6e0b681190944020777f94717ff57ea (patch)
tree728e8ea4907ecc1541a6d28b1cfb082e8ba9827f /apps/app_queue.c
parent0bd623a7404327416e1f83f09671ef031c058b06 (diff)
Merged revisions 231556 via svnmerge from
https://origsvn.digium.com/svn/asterisk/trunk ........ r231556 | dvossel | 2009-11-30 12:55:07 -0600 (Mon, 30 Nov 2009) | 11 lines app_queue crashes randomly, often during call-transfers This patch adds a ref to the queue_ent object's parent call_queue in queue_exec() so the call_queue won't be destroyed while the the queue_ent still holds a pointer to it. (closes issue 0015686) Tested by: dvossel, aragon ........ git-svn-id: http://svn.digium.com/svn/asterisk/branches/1.6.2@231558 f38db490-d61c-443f-a65b-d21fe96a405b
Diffstat (limited to 'apps/app_queue.c')
-rw-r--r--apps/app_queue.c15
1 files changed, 13 insertions, 2 deletions
diff --git a/apps/app_queue.c b/apps/app_queue.c
index 2eea2bf8b..15c65f606 100644
--- a/apps/app_queue.c
+++ b/apps/app_queue.c
@@ -932,6 +932,11 @@ static inline void insert_entry(struct call_queue *q, struct queue_ent *prev, st
q->head = new;
}
new->next = cur;
+
+ /* every queue_ent must have a reference to it's parent call_queue, this
+ * reference does not go away until the end of the queue_ent's life, meaning
+ * that even when the queue_ent leaves the call_queue this ref must remain. */
+ queue_ref(q);
new->parent = q;
new->pos = ++(*pos);
new->opos = *pos;
@@ -5046,7 +5051,7 @@ static int queue_exec(struct ast_channel *chan, void *data)
AST_APP_ARG(rule);
);
/* Our queue entry */
- struct queue_ent qe;
+ struct queue_ent qe = { 0 };
if (ast_strlen_zero(data)) {
ast_log(LOG_WARNING, "Queue requires an argument: queuename[,options[,URL[,announceoverride[,timeout[,agi[,macro[,gosub[,rule]]]]]]]]\n");
@@ -5057,7 +5062,6 @@ static int queue_exec(struct ast_channel *chan, void *data)
AST_STANDARD_APP_ARGS(args, parse);
/* Setup our queue entry */
- memset(&qe, 0, sizeof(qe));
qe.start = time(NULL);
/* set the expire time based on the supplied timeout; */
@@ -5290,6 +5294,13 @@ stop:
if (reason != QUEUE_UNKNOWN)
set_queue_result(chan, reason);
+ if (qe.parent) {
+ /* every queue_ent is given a reference to it's parent call_queue when it joins the queue.
+ * This ref must be taken away right before the queue_ent is destroyed. In this case
+ * the queue_ent is about to be returned on the stack */
+ qe.parent = queue_unref(qe.parent);
+ }
+
return res;
}