浏览代码

db_mysql: handle SSL and submit query

S-P Chan 1 年之前
父节点
当前提交
51d9f92eca
共有 1 个文件被更改,包括 8 次插入1 次删除
  1. 8 1
      src/modules/db_mysql/km_dbase.c

+ 8 - 1
src/modules/db_mysql/km_dbase.c

@@ -38,6 +38,8 @@
 #include "../../core/mem/mem.h"
 #include "../../core/dprint.h"
 #include "../../core/async_task.h"
+
+#define KSR_RTHREAD_NEED_4PP
 #include "../../core/rthreads.h"
 #include "../../lib/srdb1/db_query.h"
 #include "../../lib/srdb1/db_ut.h"
@@ -67,7 +69,7 @@ static char *mysql_sql_buf;
  * \param _s executed query
  * \return zero on success, negative value on failure
  */
-static int db_mysql_submit_query(const db1_con_t *_h, const str *_s)
+static int db_mysql_submit_query_impl(const db1_con_t *_h, const str *_s)
 {
 	time_t t;
 	int i, code;
@@ -128,6 +130,11 @@ static int db_mysql_submit_query(const db1_con_t *_h, const str *_s)
 }
 
 
+static int db_mysql_submit_query(const db1_con_t *_h, const str *_s)
+{
+	return run_thread4PP((_thread_proto4PP)db_mysql_submit_query_impl,
+			(void *)_h, (void *)_s);
+}
 /**
  *
  */