diff options
author | markster <markster@f38db490-d61c-443f-a65b-d21fe96a405b> | 2003-02-04 15:48:42 +0000 |
---|---|---|
committer | markster <markster@f38db490-d61c-443f-a65b-d21fe96a405b> | 2003-02-04 15:48:42 +0000 |
commit | bfeaccab3dc438565ef03fa961fee49805fd6eb8 (patch) | |
tree | 517ee94a20886f04c78a05a553831f5b081fed76 /pbx/pbx_spool.c | |
parent | 151774c059eebca84557de8bed5495b523bdd8b2 (diff) |
Version 0.3.0 from FTP
git-svn-id: http://svn.digium.com/svn/asterisk/trunk@600 f38db490-d61c-443f-a65b-d21fe96a405b
Diffstat (limited to 'pbx/pbx_spool.c')
-rwxr-xr-x | pbx/pbx_spool.c | 365 |
1 files changed, 365 insertions, 0 deletions
diff --git a/pbx/pbx_spool.c b/pbx/pbx_spool.c new file mode 100755 index 000000000..67682702d --- /dev/null +++ b/pbx/pbx_spool.c @@ -0,0 +1,365 @@ +/* + * Asterisk -- A telephony toolkit for Linux. + * + * Full-featured outgoing call spool support + * + * Copyright (C) 2002, Digium + * + * Mark Spencer <markster@digium.com> + * + * This program is free software, distributed under the terms of + * the GNU General Public License + */ + +#include <asterisk/lock.h> +#include <asterisk/file.h> +#include <asterisk/logger.h> +#include <asterisk/channel.h> +#include <asterisk/pbx.h> +#include <asterisk/module.h> +#include <asterisk/options.h> +#include <pthread.h> +#include <sys/stat.h> +#include <errno.h> +#include <time.h> +#include <utime.h> +#include <stdlib.h> +#include <unistd.h> +#include <dirent.h> +#include <string.h> +#include <string.h> +#include <stdio.h> +#include <unistd.h> +#include "../astconf.h" + +/* + * pbx_spool is similar in spirit to qcall, but with substantially enhanced functionality... + * The spool file contains a header + */ + +static char *tdesc = "Outgoing Spool Support"; +static char qdir[255]; + +struct outgoing { + char fn[256]; + /* Current number of retries */ + int retries; + /* Maximum number of retries permitted */ + int maxretries; + /* How long to wait between retries (in seconds) */ + int retrytime; + /* How long to wait for an answer */ + int waittime; + + /* What to connect to outgoing */ + char tech[256]; + char dest[256]; + + /* If application */ + char app[256]; + char data[256]; + + /* If extension/context/priority */ + char exten[256]; + char context[256]; + int priority; + + /* CallerID Information */ + char callerid[256]; + + /* Channel variables */ + char variable[10*256]; + + /* Maximum length of call */ + int maxlen; + +}; + +static void init_outgoing(struct outgoing *o) +{ + memset(o, 0, sizeof(struct outgoing)); + o->priority = 1; + o->retrytime = 300; + o->waittime = 45; +} + +static int apply_outgoing(struct outgoing *o, char *fn, FILE *f) +{ + char buf[256]; + char *c, *c2; + int lineno = 0; + while(!feof(f)) { + fgets(buf, sizeof(buf), f); + lineno++; + if (!feof(f)) { + /* Trim comments */ + c = strchr(buf, '#'); + if (c) + *c = '\0'; + c = strchr(buf, ';'); + if (c) + *c = '\0'; + + /* Trim trailing white space */ + while(strlen(buf) && buf[strlen(buf) - 1] < 33) + buf[strlen(buf) - 1] = '\0'; + if (strlen(buf)) { + c = strchr(buf, ':'); + if (c) { + *c = '\0'; + c++; + while(*c < 33) + c++; +#if 0 + printf("'%s' is '%s' at line %d\n", buf, c, lineno); +#endif + if (!strcasecmp(buf, "channel")) { + strncpy(o->tech, c, sizeof(o->tech) - 1); + if ((c2 = strchr(o->tech, '/'))) { + *c2 = '\0'; + c2++; + strncpy(o->dest, c2, sizeof(o->dest) - 1); + } else { + ast_log(LOG_NOTICE, "Channel should be in form Tech/Dest at line %d of %s\n", lineno, fn); + strcpy(o->tech, ""); + } + } else if (!strcasecmp(buf, "callerid")) { + strncpy(o->callerid, c, sizeof(o->callerid) - 1); + } else if (!strcasecmp(buf, "application")) { + strncpy(o->app, c, sizeof(o->app) - 1); + } else if (!strcasecmp(buf, "data")) { + strncpy(o->data, c, sizeof(o->data) - 1); + } else if (!strcasecmp(buf, "maxretries")) { + if (sscanf(c, "%d", &o->maxretries) != 1) { + ast_log(LOG_WARNING, "Invalid max retries at line %d of %s\n", lineno, fn); + o->maxretries = 0; + } + } else if (!strcasecmp(buf, "context")) { + strncpy(o->context, c, sizeof(o->context) - 1); + } else if (!strcasecmp(buf, "extension")) { + strncpy(o->exten, c, sizeof(o->exten) - 1); + } else if (!strcasecmp(buf, "priority")) { + if ((sscanf(c, "%d", &o->priority) != 1) || (o->priority < 1)) { + ast_log(LOG_WARNING, "Invalid priority at line %d of %s\n", lineno, fn); + o->priority = 1; + } + } else if (!strcasecmp(buf, "retrytime")) { + if ((sscanf(c, "%d", &o->retrytime) != 1) || (o->retrytime < 1)) { + ast_log(LOG_WARNING, "Invalid retrytime at line %d of %s\n", lineno, fn); + o->retrytime = 300; + } + } else if (!strcasecmp(buf, "waittime")) { + if ((sscanf(c, "%d", &o->waittime) != 1) || (o->waittime < 1)) { + ast_log(LOG_WARNING, "Invalid retrytime at line %d of %s\n", lineno, fn); + o->waittime = 45; + } + } else if (!strcasecmp(buf, "retry")) { + o->retries++; + } else if (!strcasecmp(buf, "setvar")) { /* JDG variable support */ + strncat(o->variable, c, sizeof(o->variable) - strlen(o->variable) - 1); + strncat(o->variable, "|", sizeof(o->variable) - strlen(o->variable) - 1); + + } else { + ast_log(LOG_WARNING, "Unknown keyword '%s' at line %d of %s\n", buf, lineno, fn); + } + } else + ast_log(LOG_NOTICE, "Syntax error at line %d of %s\n", lineno, fn); + } + } + } + strncpy(o->fn, fn, sizeof(o->fn) - 1); + /* Check sanity of times */ + if (o->retrytime < o->waittime + 5) + o->retrytime = o->waittime + 5; + if (!strlen(o->tech) || !strlen(o->dest) || (!strlen(o->app) && !strlen(o->exten))) { + ast_log(LOG_WARNING, "At least one of app or extension must be specified, along with tech and dest in file %s\n", fn); + return -1; + } + return 0; +} + +static void *attempt_thread(void *data) +{ + struct outgoing *o = data; + int res, reason; + if (strlen(o->app)) { + if (option_verbose > 2) + ast_verbose(VERBOSE_PREFIX_3 "Attempting call on %s/%s for application %s(%s) (Retry %d)\n", o->tech, o->dest, o->app, o->data, o->retries); + res = ast_pbx_outgoing_app(o->tech, AST_FORMAT_SLINEAR, o->dest, o->waittime * 1000, o->app, o->data, &reason, 2 /* wait to finish */, o->callerid); + } else { + if (option_verbose > 2) + ast_verbose(VERBOSE_PREFIX_3 "Attempting call on %s/%s for %s@%s:%d (Retry %d)\n", o->tech, o->dest, o->exten, o->context,o->priority, o->retries); + res = ast_pbx_outgoing_exten(o->tech, AST_FORMAT_SLINEAR, o->dest, o->waittime * 1000, o->context, o->exten, o->priority, &reason, 2 /* wait to finish */, o->callerid, o->variable ); + } + if (res) { + ast_log(LOG_NOTICE, "Call failed to go through, reason %d\n", reason); + if (o->retries >= o->maxretries + 1) { + /* Max retries exceeded */ + ast_log(LOG_EVENT, "Queued call to %s/%s expired without completion after %d attempt(s)\n", o->tech, o->dest, o->retries - 1); + unlink(o->fn); + } + } else { + ast_log(LOG_NOTICE, "Call completed to %s/%s\n", o->tech, o->dest); + ast_log(LOG_EVENT, "Queued call to %s/%s completed\n", o->tech, o->dest); + unlink(o->fn); + } + free(o); + return NULL; +} + +static void launch_service(struct outgoing *o) +{ + pthread_t t; + pthread_attr_t attr; + pthread_attr_init(&attr); + pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); + if (pthread_create(&t,&attr,attempt_thread, o) == -1) { + ast_log(LOG_WARNING, "Unable to create thread :(\n"); + free(o); + } +} + +static int scan_service(char *fn, time_t now, time_t atime) +{ + struct outgoing *o; + struct utimbuf tbuf; + FILE *f; + o = malloc(sizeof(struct outgoing)); + if (o) { + init_outgoing(o); + f = fopen(fn, "r+"); + if (f) { + if (!apply_outgoing(o, fn, f)) { + /* Update the file time */ + tbuf.actime = atime; + tbuf.modtime = now + o->retrytime; + if (utime(o->fn, &tbuf)) + ast_log(LOG_WARNING, "Unable to set utime on %s: %s\n", fn, strerror(errno)); + /* Increment retries */ + o->retries++; +#if 0 + printf("Retries: %d, max: %d\n", o->retries, o->maxretries); +#endif + if (o->retries <= o->maxretries + 1) { + /* Add a retry line at the end */ + fseek(f, 0L, SEEK_END); + fprintf(f, "Retry: %d (%ld)\n", o->retries, now); + fclose(f); + now += o->retrytime; + launch_service(o); + return now; + } else { + ast_log(LOG_EVENT, "Queued call to %s/%s expired without completion after %d attempt(s)\n", o->tech, o->dest, o->retries - 1); + fclose(f); + free(o); + unlink(fn); + return 0; + } + } else { + free(o); + ast_log(LOG_WARNING, "Invalid file contents in %s, deleting\n", fn); + fclose(f); + unlink(fn); + } + } else { + free(o); + ast_log(LOG_WARNING, "Unable to open %s: %s, deleting\n", fn, strerror(errno)); + unlink(fn); + } + } else + ast_log(LOG_WARNING, "Out of memory :(\n"); + return -1; +} + +static void *scan_thread(void *unused) +{ + struct stat st; + DIR *dir; + struct dirent *de; + char fn[256]; + int res; + time_t last = 0, next = 0, now; + for(;;) { + /* Wait a sec */ + sleep(1); + time(&now); + if (!stat(qdir, &st)) { + if ((st.st_mtime != last) || (next && (now > next))) { +#if 0 + printf("atime: %ld, mtime: %ld, ctime: %ld\n", st.st_atime, st.st_mtime, st.st_ctime); + printf("Ooh, something changed / timeout\n"); +#endif + next = 0; + last = st.st_mtime; + dir = opendir(qdir); + if (dir) { + while((de = readdir(dir))) { + snprintf(fn, sizeof(fn), "%s/%s", qdir, de->d_name); + if (!stat(fn, &st)) { + if (S_ISREG(st.st_mode)) { + if (st.st_mtime <= now) { + res = scan_service(fn, now, st.st_atime); + if (res > 0) { + /* Update next service time */ + if (!next || (res < next)) { + next = res; + } + } else if (res) + ast_log(LOG_WARNING, "Failed to scan service '%s'\n", fn); + } else { + /* Update "next" update if necessary */ + if (!next || (st.st_mtime < next)) + next = st.st_mtime; + } + } + } else + ast_log(LOG_WARNING, "Unable to stat %s: %s\n", fn, strerror(errno)); + } + closedir(dir); + } else + ast_log(LOG_WARNING, "Unable to open directory %s: %s\n", qdir, strerror(errno)); + } + } else + ast_log(LOG_WARNING, "Unable to stat %s\n", qdir); + } + return NULL; +} + +int unload_module(void) +{ + return -1; +} + +int load_module(void) +{ + pthread_t thread; + pthread_attr_t attr; + snprintf((char *)qdir,sizeof(qdir)-1,"%s/%s",(char *)ast_config_AST_SPOOL_DIR,"outgoing"); +printf("%s\n",qdir); + if (mkdir(qdir, 0700) && (errno != EEXIST)) { + ast_log(LOG_WARNING, "Unable to create queue directory %s -- outgoing spool disabled\n", qdir); + return 0; + } + pthread_attr_init(&attr); + pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); + if (pthread_create(&thread,&attr,scan_thread, NULL) == -1) { + ast_log(LOG_WARNING, "Unable to create thread :(\n"); + return -1; + } + return 0; +} + +char *description(void) +{ + return tdesc; +} + +int usecount(void) +{ + return 1; +} + +char *key() +{ + return ASTERISK_GPL_KEY; +} |