diff options
author | markster <markster@f38db490-d61c-443f-a65b-d21fe96a405b> | 2004-06-26 16:26:39 +0000 |
---|---|---|
committer | markster <markster@f38db490-d61c-443f-a65b-d21fe96a405b> | 2004-06-26 16:26:39 +0000 |
commit | ae9212668ca89e98be1766555bd0d954c680993e (patch) | |
tree | 076396f0ace662d7d50b1678027644073562a395 /apps/app_queue.c | |
parent | ceb8d2ba47de92710bf062a3e3cdfc4798cb31c6 (diff) |
Implement queue wide wrapuptime (bug #1707)
git-svn-id: http://svn.digium.com/svn/asterisk/trunk@3317 f38db490-d61c-443f-a65b-d21fe96a405b
Diffstat (limited to 'apps/app_queue.c')
-rwxr-xr-x | apps/app_queue.c | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/apps/app_queue.c b/apps/app_queue.c index 837099f88..102baa7e2 100755 --- a/apps/app_queue.c +++ b/apps/app_queue.c @@ -145,6 +145,7 @@ struct localuser { int musiconhold; int dataquality; int allowdisconnect; + time_t lastcall; struct member *member; struct localuser *next; }; @@ -203,6 +204,7 @@ struct ast_call_queue { int count; /* How many entries are in the queue */ int maxlen; /* Max number of entries in queue */ + int wrapuptime; /* Wrapup Time */ int dead; /* Whether this queue is dead or not */ int retry; /* Retry calling everyone after this amount of time */ @@ -518,6 +520,13 @@ static void hanguptree(struct localuser *outgoing, struct ast_channel *exception static int ring_entry(struct queue_ent *qe, struct localuser *tmp) { int res; + if (qe->parent->wrapuptime && (time(NULL) - tmp->lastcall < qe->parent->wrapuptime)) { + ast_log(LOG_DEBUG, "Wrapuptime not yet expired for %s/%s\n", tmp->tech, tmp->numsubst); + if (qe->chan->cdr) + ast_cdr_busy(qe->chan->cdr); + tmp->stillgoing = 0; + return 0; + } /* Request the peer */ tmp->chan = ast_request(tmp->tech, qe->chan->nativeformats, tmp->numsubst); if (!tmp->chan) { /* If we can't, just go on to the next call */ @@ -1019,6 +1028,7 @@ static int try_calling(struct queue_ent *qe, char *options, char *announceoverri tmp->member = cur; /* Never directly dereference! Could change on reload */ strncpy(tmp->tech, cur->tech, sizeof(tmp->tech)-1); strncpy(tmp->numsubst, cur->loc, sizeof(tmp->numsubst)-1); + tmp->lastcall = cur->lastcall; /* If we're dialing by extension, look at the extension to know what to dial */ if ((newnum = strstr(tmp->numsubst, "BYEXTENSION"))) { strncpy(restofit, newnum + strlen("BYEXTENSION"), sizeof(restofit)-1); @@ -1703,6 +1713,7 @@ static void reload_queues(void) q->callsabandoned = 0; q->callscompletedinsl = 0; q->servicelevel = 0; + q->wrapuptime = 0; free_members(q, 0); strcpy(q->moh, ""); strcpy(q->announce, ""); @@ -1780,6 +1791,8 @@ static void reload_queues(void) q->announceholdtime = (!strcasecmp(var->value,"once")) ? 1 : ast_true(var->value); } else if (!strcasecmp(var->name, "retry")) { q->retry = atoi(var->value); + } else if (!strcasecmp(var->name, "wrapuptime")) { + q->wrapuptime = atoi(var->value); } else if (!strcasecmp(var->name, "maxlen")) { q->maxlen = atoi(var->value); } else if (!strcasecmp(var->name, "servicelevel")) { |