server_common/f8
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码格式化

Browse Source
This commit is contained in:
aozhiwei 2019-02-11 15:12:38 +08:00
parent e37e25567e
commit fa71782ccc
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
cpp/dbpool.cc
View File

@ -230,10 +230,10 @@ namespace f8
int ret = last_query_->ExecQuery(node->_sql_fmt.c_str(), node->_sql_params); int ret = last_query_->ExecQuery(node->_sql_fmt.c_str(), node->_sql_params);
if (ret < 0) { if (ret < 0) {
f8::MsgQueue::Instance()->PostMsg_r(exec_async_query_msgid, f8::MsgQueue::Instance()->PostMsg_r(exec_async_query_msgid,
a8::XParams() a8::XParams()
.SetSender(node->context_id) .SetSender(node->context_id)
.SetParam1(AQE_SYNTAX_ERROR) .SetParam1(AQE_SYNTAX_ERROR)
.SetParam2(last_query_->GetError())); .SetParam2(last_query_->GetError()));
} else { } else {
DataSet* data_set = new DataSet(); DataSet* data_set = new DataSet();
data_set->reserve(last_query_->RowsNum()); data_set->reserve(last_query_->RowsNum());
@ -247,10 +247,10 @@ namespace f8
last_query_->Next(); last_query_->Next();
} }
f8::MsgQueue::Instance()->PostMsg_r(exec_async_query_msgid, f8::MsgQueue::Instance()->PostMsg_r(exec_async_query_msgid,
a8::XParams() a8::XParams()
.SetSender(node->context_id) .SetSender(node->context_id)
.SetParam1(AQE_NO_ERROR) .SetParam1(AQE_NO_ERROR)
.SetParam2((void*)data_set)); .SetParam2((void*)data_set));
} }
} }
break; break;
@ -313,11 +313,11 @@ namespace f8
/*mysql_init()不是完全线程安全的，但是只要成功调用一次就后就线程安全了， /*mysql_init()不是完全线程安全的，但是只要成功调用一次就后就线程安全了，
如果有多线程并发使用mysql_init()，建议在程序初始化时空调一次mysql_init()，他的这点特性很像qsort() 如果有多线程并发使用mysql_init()，建议在程序初始化时空调一次mysql_init()，他的这点特性很像qsort()
*/ */
a8::mysql::Connection conn; a8::mysql::Connection conn;
#endif #endif
curr_seqid = 1000001; curr_seqid = 1000001;
exec_async_query_msgid = MsgQueue::Instance()->AllocIMMsgId(); exec_async_query_msgid = MsgQueue::Instance()->AllocIMMsgId();
} }
void SetThreadNum(int thread_num) void SetThreadNum(int thread_num)
{ {