From 6c4f7c9e076a9363373672e067015be11b728b87 Mon Sep 17 00:00:00 2001
From: Anthony Minessale <anthony.minessale@gmail.com>
Date: Fri, 20 Mar 2009 15:28:50 +0000
Subject: [PATCH] MODAPP-237

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@12685 d0543943-73ff-0310-b7d9-9358b9ac24b2
---
 conf/autoload_configs/fifo.conf.xml      |  2 +-
 src/mod/applications/mod_fifo/mod_fifo.c | 10 +++++++++-
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/conf/autoload_configs/fifo.conf.xml b/conf/autoload_configs/fifo.conf.xml
index ab34f57cad..ff99134848 100644
--- a/conf/autoload_configs/fifo.conf.xml
+++ b/conf/autoload_configs/fifo.conf.xml
@@ -1,7 +1,7 @@
 <configuration name="fifo.conf" description="FIFO Configuration">
   <fifos>
     <fifo name="cool_fifo@$${domain}" importance="0">
-      <!--<member timeout="60" simo="1" lag="20">user/1005@$${domain}</member>-->
+      <!--<member timeout="60" simo="1" lag="20">{member_wait=nowait}user/1005@$${domain}</member>-->
     </fifo>
   </fifos>
 </configuration>
diff --git a/src/mod/applications/mod_fifo/mod_fifo.c b/src/mod/applications/mod_fifo/mod_fifo.c
index 15e63fd9b1..66f696e24b 100644
--- a/src/mod/applications/mod_fifo/mod_fifo.c
+++ b/src/mod/applications/mod_fifo/mod_fifo.c
@@ -449,6 +449,7 @@ static void *SWITCH_THREAD_FUNC o_thread_run(switch_thread_t *thread, void *obj)
 	switch_caller_extension_t *extension = NULL;
 	char *app_name, *arg = NULL;
 	char sql[256] = "";
+	const char *member_wait = NULL;
 
 	switch_snprintf(sql, sizeof(sql), "update fifo_outbound set use_count=use_count+1 where uuid='%s'", h->uuid);
 	fifo_execute_sql(sql, globals.sql_mutex);
@@ -462,10 +463,17 @@ static void *SWITCH_THREAD_FUNC o_thread_run(switch_thread_t *thread, void *obj)
 	
 
 	channel = switch_core_session_get_channel(session);
+
+	if ((member_wait = switch_channel_get_variable(channel, "member_wait"))) {
+		if (strcasecmp(member_wait, "wait") && strcasecmp(member_wait, "nowait")) {
+			member_wait = NULL;
+		}
+	}
+
 	switch_channel_set_variable(channel, "fifo_outbound_uuid", h->uuid);
 	switch_core_event_hook_add_state_change(session, hanguphook);
 	app_name = "fifo";
-	arg = switch_core_session_sprintf(session, "%s out wait", h->node_name);
+	arg = switch_core_session_sprintf(session, "%s out %s", h->node_name, member_wait ? member_wait : "wait");
 	extension = switch_caller_extension_new(session, app_name, arg);
 	switch_caller_extension_add_application(session, extension, app_name, arg);
 	switch_channel_set_caller_extension(channel, extension);