small fix to sql shipping stuff

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@1963 d0543943-73ff-0310-b7d9-9358b9ac24b2

diff --git a/src/include/switch_types.h b/src/include/switch_types.h
index b120b0a2477bf24a5b416561525916227fcb34ad..fb6a92533fbd669727311df237b9f8d639b2dfcb 100644 (file)
--- a/src/include/switch_types.h
+++ b/src/include/switch_types.h
@@ -92,7 +92,7 @@ SWITCH_DECLARE_DATA extern switch_directories SWITCH_GLOBAL_dirs;
 #define SWITCH_MAX_STATE_HANDLERS 30
 #define SWITCH_TRUE 1
 #define SWITCH_FALSE 0
-#define SWITCH_CORE_QUEUE_LEN 20000
+#define SWITCH_CORE_QUEUE_LEN 100000
 
 typedef enum {
        SWITCH_XML_SECTION_RESULT = 0,

diff --git a/src/switch_core.c b/src/switch_core.c
index 25b687b42242652e04561787d9f450dceb02dbab..596b5e9aa08f5000b82c25c63bfc358146625272 100644 (file)
--- a/src/switch_core.c
+++ b/src/switch_core.c
@@ -2730,7 +2730,7 @@ static void *SWITCH_THREAD_FUNC switch_core_sql_thread(switch_thread_t *thread,
        uint32_t itterations = 0;
        uint8_t trans = 0;
        switch_time_t last_commit = switch_time_now();
-       uint32_t freq = 1000, target = 500, diff = 0;
+       uint32_t freq = 1000, target = 1000, diff = 0;
        
        if (!runtime.event_db) {
                runtime.event_db = switch_core_db_handle();
@@ -2810,7 +2810,7 @@ static void core_event_handler(switch_event_t *event)
 
        switch (event->event_id) {
        case SWITCH_EVENT_CHANNEL_DESTROY:
-               switch_core_db_mprintf("delete from channels where uuid='%s'", switch_event_get_header(event, "unique-id"));
+               sql = switch_core_db_mprintf("delete from channels where uuid='%s'", switch_event_get_header(event, "unique-id"));
                break;
        case SWITCH_EVENT_CHANNEL_CREATE:
                sql = switch_core_db_mprintf("insert into channels (uuid,created,name,state) values('%q','%q','%q','%q')",