[svn-commits] trunk r28832 - in /trunk: pbx/pbx_spool.c sample.call

[svn-commits at lists.digium.com]

Author: russell
Date: Fri May 19 17:51:44 2006
New Revision: 28832

URL: http://svn.digium.com/view/asterisk?rev=28832&view=rev
Log:
Make the new behavior where the timestamp is checked on the call file before
deleting it optional, defaulting to the old behavior, where it is always
deleted (issue #6750, jcollie)

Modified:
    trunk/pbx/pbx_spool.c
    trunk/sample.call

Modified: trunk/pbx/pbx_spool.c
URL: http://svn.digium.com/view/asterisk/trunk/pbx/pbx_spool.c?rev=28832&r1=28831&r2=28832&view=diff
==============================================================================
--- trunk/pbx/pbx_spool.c (original)
+++ trunk/pbx/pbx_spool.c Fri May 19 17:51:44 2006
@@ -52,6 +52,14 @@
  * pbx_spool is similar in spirit to qcall, but with substantially enhanced functionality...
  * The spool file contains a header 
  */
+
+enum {
+	/*! Always delete the call file after a call succeeds or the
+	 * maximum number of retries is exceeded, even if the
+	 * modification time of the call file is in the future.
+	 */
+	SPOOL_FLAG_ALWAYS_DELETE = (1 << 0)
+};
 
 static char qdir[255];
 
@@ -93,6 +101,9 @@
 	
 	/* Maximum length of call */
 	int maxlen;
+
+	/* options */
+	struct ast_flags options;
 };
 
 static void init_outgoing(struct outgoing *o)
@@ -101,6 +112,7 @@
 	o->priority = 1;
 	o->retrytime = 300;
 	o->waittime = 45;
+	ast_set_flag(&o->options, SPOOL_FLAG_ALWAYS_DELETE);
 }
 
 static void free_outgoing(struct outgoing *o)
@@ -214,6 +226,8 @@
 						ast_log(LOG_WARNING, "Malformed \"%s\" argument.  Should be \"%s: variable=value\"\n", buf, buf);
 				} else if (!strcasecmp(buf, "account")) {
 					ast_copy_string(o->account, c, sizeof(o->account));
+				} else if (!strcasecmp(buf, "alwaysdelete")) {
+					ast_set2_flag(&o->options, ast_true(c), SPOOL_FLAG_ALWAYS_DELETE);
 				} else {
 					ast_log(LOG_WARNING, "Unknown keyword '%s' at line %d of %s\n", buf, lineno, fn);
 				}
@@ -250,11 +264,23 @@
 	}
 }
 
+static void check_unlink(struct outgoing *o)
+{
+	if (ast_test_flag(&o->options, SPOOL_FLAG_ALWAYS_DELETE))
+		unlink(o->fn);
+	else {
+		struct stat current_file_status;
+	
+		if (!stat(o->fn, &current_file_status))
+			if (time(NULL) >= current_file_status.st_mtime)
+				unlink(o->fn);
+	}
+}
+
 static void *attempt_thread(void *data)
 {
 	struct outgoing *o = data;
 	int res, reason;
-	struct stat current_file_status;
 	if (!ast_strlen_zero(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);
@@ -269,7 +295,7 @@
 		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, ((o->retries - 1) != 1) ? "s" : "");
-			unlink(o->fn);
+			check_unlink(o);
 		} else {
 			/* Notate that the call is still active */
 			safe_append(o, time(NULL), "EndRetry");
@@ -277,10 +303,7 @@
 	} 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);
-		if (!stat(o->fn, &current_file_status)) {
-			if (time(NULL) >= current_file_status.st_atime)
-				unlink(o->fn);
-		}
+		check_unlink(o);
 	}
 	free_outgoing(o);
 	return NULL;

Modified: trunk/sample.call
URL: http://svn.digium.com/view/asterisk/trunk/sample.call?rev=28832&r1=28831&r2=28832&view=diff
==============================================================================
--- trunk/sample.call (original)
+++ trunk/sample.call Fri May 19 17:51:44 2006
@@ -50,6 +50,17 @@
 #Account: mysuperfunaccountcode
 
 #
+# Normally, a call file is always deleted after the call is successful
+# or the maximum number of tries is reached even if the modification
+# time of the call file was changed during the call to be in the
+# future.  By Setting AlwaysDelete to No the modification time of the
+# call file will be checked after the call is completed or the maximum
+# number of retries is reached.  If the modification time is in the
+# future, the call file will not be deleted.
+#
+#AlwaysDelete: Yes
+
+#
 # You can set channel variables that will be passed to the channel.
 # This includes writable dialplan functions. To set a writable dialplan
 # function, the module containing this function *must* be loaded.