From: Anthony Minessale <anthm@freeswitch.org>
Date: Fri, 17 Dec 2010 22:06:11 +0000 (-0600)
Subject: FS-2879
X-Git-Tag: v1.2-rc1~223^2~9^2~8^2~10
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=ee562c82e1e3e321c2ece3b5970114a31b693f33;p=thirdparty%2Ffreeswitch.git

FS-2879
---

diff --git a/src/mod/applications/mod_fifo/mod_fifo.c b/src/mod/applications/mod_fifo/mod_fifo.c
index 3943ac6ea6..f275363706 100644
--- a/src/mod/applications/mod_fifo/mod_fifo.c
+++ b/src/mod/applications/mod_fifo/mod_fifo.c
@@ -3075,16 +3075,24 @@ SWITCH_STANDARD_APP(fifo_function)
   done:
 
 	switch_mutex_lock(globals.mutex);
-	if (node && node->ready == FIFO_DELAY_DESTROY && node->consumer_count == 0 && node_caller_count(node) == 0) {
-		switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_NOTICE, "%s removed.\n", node->name);
-		switch_core_hash_delete(globals.fifo_hash, node->name);
+	if (node && node->ready == FIFO_DELAY_DESTROY) {
+		int doit = 0;
+
 		switch_thread_rwlock_wrlock(node->rwlock);
-		node->ready = 0;
-		switch_mutex_lock(node->mutex);
-		switch_core_hash_destroy(&node->consumer_hash);
-		switch_mutex_unlock(node->mutex);
+		doit = node->consumer_count == 0 && node_caller_count(node) == 0;
 		switch_thread_rwlock_unlock(node->rwlock);
-		switch_core_destroy_memory_pool(&node->pool);
+
+		if (doit) {
+			switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_NOTICE, "%s removed.\n", node->name);
+			switch_core_hash_delete(globals.fifo_hash, node->name);
+
+			node->ready = 0;
+			switch_mutex_lock(node->mutex);
+			switch_core_hash_destroy(&node->consumer_hash);
+			switch_mutex_unlock(node->mutex);
+			switch_thread_rwlock_unlock(node->rwlock);
+			switch_core_destroy_memory_pool(&node->pool);
+		}
 
 	}
 	switch_mutex_unlock(globals.mutex);