FS-4903: --resolve add/remove records from fifo_outbound not queued so the count...

diff --git a/src/mod/applications/mod_fifo/mod_fifo.c b/src/mod/applications/mod_fifo/mod_fifo.c
index 41af0b1a168ce8545b94da10b77aaf7a7fdf6aa1..75c7006a7dee650fa4b176dd9fa47eb5cc9e6b89 100644 (file)
--- a/src/mod/applications/mod_fifo/mod_fifo.c
+++ b/src/mod/applications/mod_fifo/mod_fifo.c
@@ -4303,7 +4303,7 @@ static void fifo_member_add(char *fifo_name, char *originate_string, int simo_co
 
        sql = switch_mprintf("delete from fifo_outbound where fifo_name='%q' and uuid = '%q'", fifo_name, digest);
        switch_assert(sql);
-       fifo_execute_sql_queued(&sql, SWITCH_TRUE, SWITCH_FALSE);
+       fifo_execute_sql_queued(&sql, SWITCH_TRUE, SWITCH_TRUE);
 
 
        switch_mutex_lock(globals.mutex);
@@ -4325,7 +4325,7 @@ static void fifo_member_add(char *fifo_name, char *originate_string, int simo_co
                                                 digest, fifo_name, originate_string, simo_count, 0, timeout, lag, 0, (long) expires, globals.hostname, taking_calls,
                                                 (long)switch_epoch_time_now(NULL));
        switch_assert(sql);
-       fifo_execute_sql_queued(&sql, SWITCH_TRUE, SWITCH_FALSE);
+       fifo_execute_sql_queued(&sql, SWITCH_TRUE, SWITCH_TRUE);
        free(name_dup);
 
     cbt.buf = outbound_count; 
@@ -4360,7 +4360,7 @@ static void fifo_member_del(char *fifo_name, char *originate_string)
 
        sql = switch_mprintf("delete from fifo_outbound where fifo_name='%q' and uuid = '%q' and hostname='%q'", fifo_name, digest, globals.hostname);
        switch_assert(sql);
-       fifo_execute_sql_queued(&sql, SWITCH_TRUE, SWITCH_FALSE);
+       fifo_execute_sql_queued(&sql, SWITCH_TRUE, SWITCH_TRUE);
 
        switch_mutex_lock(globals.mutex);
        if (!(node = switch_core_hash_find(globals.fifo_hash, fifo_name))) {