[asterisk-commits] russell: trunk r91778 - in /trunk: ./ main/autoservice.c

[SVN commits to the Asterisk project]

Author: russell
Date: Fri Dec  7 10:11:00 2007
New Revision: 91778

URL: http://svn.digium.com/view/asterisk?view=rev&rev=91778
Log:
Merged revisions 91777 via svnmerge from 
https://origsvn.digium.com/svn/asterisk/branches/1.4

........
r91777 | russell | 2007-12-07 10:08:35 -0600 (Fri, 07 Dec 2007) | 6 lines

* Add a bit more of a verbose comment as to why a hangup frame needs to be
  queued up if autoservice gets a NULL return from ast_read().
* Make the process of queueing the hangup frame more efficient by putting the
  frame where it is going to end up and avoiding some locking and extra memory
  allocations and freeing.

........

Modified:
    trunk/   (props changed)
    trunk/main/autoservice.c

Propchange: trunk/
------------------------------------------------------------------------------
Binary property 'branch-1.4-merged' - no diff available.

Modified: trunk/main/autoservice.c
URL: http://svn.digium.com/view/asterisk/trunk/main/autoservice.c?view=diff&rev=91778&r1=91777&r2=91778
==============================================================================
--- trunk/main/autoservice.c (original)
+++ trunk/main/autoservice.c Fri Dec  7 10:11:00 2007
@@ -59,9 +59,23 @@
 
 static pthread_t asthread = AST_PTHREADT_NULL;
 
+static void defer_frame(struct ast_channel *chan, struct ast_frame *f)
+{
+	struct ast_frame *dup_f;
+	struct asent *as;
+
+	AST_RWLIST_WRLOCK(&aslist);
+	AST_RWLIST_TRAVERSE(&aslist, as, list) {
+		if (as->chan != chan)
+			continue;
+		if ((dup_f = ast_frdup(f)))
+			AST_LIST_INSERT_TAIL(&as->dtmf_frames, dup_f, frame_list);
+	}
+	AST_RWLIST_UNLOCK(&aslist);
+}
+
 static void *autoservice_run(void *ign)
 {
-
 	for (;;) {
 		struct ast_channel *mons[MAX_AUTOMONS], *chan;
 		struct asent *as;
@@ -82,8 +96,18 @@
 			struct ast_frame *f = ast_read(chan);
 	
 			if (!f) {
-				/* NULL means we got a hangup*/
-				ast_queue_hangup(chan);
+				struct ast_frame hangup_frame = { 0, };
+				/* No frame means the channel has been hung up.
+				 * A hangup frame needs to be queued here as ast_waitfor() may
+				 * never return again for the condition to be detected outside
+				 * of autoservice.  So, we'll leave a HANGUP queued up so the
+				 * thread in charge of this channel will know. */
+
+				hangup_frame.frametype = AST_FRAME_CONTROL;
+				hangup_frame.subclass = AST_CONTROL_HANGUP;
+
+				defer_frame(chan, &hangup_frame);
+
 				continue;
 			}
 			
@@ -98,18 +122,8 @@
 			case AST_FRAME_TEXT:
 			case AST_FRAME_IMAGE:
 			case AST_FRAME_HTML:
-			{
-				struct ast_frame *dup_f;
-
-				AST_RWLIST_WRLOCK(&aslist);
-				AST_RWLIST_TRAVERSE(&aslist, as, list) {
-					if (as->chan != chan)
-						continue;
-					if ((dup_f = ast_frdup(f)))
-						AST_LIST_INSERT_TAIL(&as->dtmf_frames, dup_f, frame_list);
-				}
-				AST_RWLIST_UNLOCK(&aslist);
-			}
+				defer_frame(chan, f);
+				break;
 
 			/* Throw these frames away */
 			case AST_FRAME_VOICE: