提交 8c51cc29 authored 作者: Anthony Minessale's avatar Anthony Minessale

small fix to sql shipping stuff

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@1963 d0543943-73ff-0310-b7d9-9358b9ac24b2
上级 aee6cc27
...@@ -92,7 +92,7 @@ SWITCH_DECLARE_DATA extern switch_directories SWITCH_GLOBAL_dirs; ...@@ -92,7 +92,7 @@ SWITCH_DECLARE_DATA extern switch_directories SWITCH_GLOBAL_dirs;
#define SWITCH_MAX_STATE_HANDLERS 30 #define SWITCH_MAX_STATE_HANDLERS 30
#define SWITCH_TRUE 1 #define SWITCH_TRUE 1
#define SWITCH_FALSE 0 #define SWITCH_FALSE 0
#define SWITCH_CORE_QUEUE_LEN 20000 #define SWITCH_CORE_QUEUE_LEN 100000
typedef enum { typedef enum {
SWITCH_XML_SECTION_RESULT = 0, SWITCH_XML_SECTION_RESULT = 0,
......
...@@ -2730,7 +2730,7 @@ static void *SWITCH_THREAD_FUNC switch_core_sql_thread(switch_thread_t *thread, ...@@ -2730,7 +2730,7 @@ static void *SWITCH_THREAD_FUNC switch_core_sql_thread(switch_thread_t *thread,
uint32_t itterations = 0; uint32_t itterations = 0;
uint8_t trans = 0; uint8_t trans = 0;
switch_time_t last_commit = switch_time_now(); 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) { if (!runtime.event_db) {
runtime.event_db = switch_core_db_handle(); runtime.event_db = switch_core_db_handle();
...@@ -2810,7 +2810,7 @@ static void core_event_handler(switch_event_t *event) ...@@ -2810,7 +2810,7 @@ static void core_event_handler(switch_event_t *event)
switch (event->event_id) { switch (event->event_id) {
case SWITCH_EVENT_CHANNEL_DESTROY: 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; break;
case SWITCH_EVENT_CHANNEL_CREATE: case SWITCH_EVENT_CHANNEL_CREATE:
sql = switch_core_db_mprintf("insert into channels (uuid,created,name,state) values('%q','%q','%q','%q')", sql = switch_core_db_mprintf("insert into channels (uuid,created,name,state) values('%q','%q','%q','%q')",
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论