tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-11-04 05:34:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge COMMIT and BEGIN into the previous MySQL query

Browse Source 
refs #8738
This commit is contained in:
Gunnar Beutner 2015-03-14 07:58:55 +01:00
parent c7c49d7219
commit 316eee799e
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/db_ido_mysql/idomysqlconnection.cpp
View File

@ -132,8 +132,8 @@ void IdoMysqlConnection::TxTimerHandler(void)
void IdoMysqlConnection::NewTransaction(void) void IdoMysqlConnection::NewTransaction(void)
{ {
m_QueryQueue.Enqueue(boost::bind(&IdoMysqlConnection::FinishAsyncQueries, this, true));
m_QueryQueue.Enqueue(boost::bind(&IdoMysqlConnection::InternalNewTransaction, this)); m_QueryQueue.Enqueue(boost::bind(&IdoMysqlConnection::InternalNewTransaction, this));
m_QueryQueue.Enqueue(boost::bind(&IdoMysqlConnection::FinishAsyncQueries, this, true));
} }
void IdoMysqlConnection::InternalNewTransaction(void) void IdoMysqlConnection::InternalNewTransaction(void)
@ -143,8 +143,8 @@ void IdoMysqlConnection::InternalNewTransaction(void)
if (!GetConnected()) if (!GetConnected())
return; return;
Query("COMMIT"); AsyncQuery("COMMIT");
Query("BEGIN"); AsyncQuery("BEGIN");
} }
void IdoMysqlConnection::ReconnectTimerHandler(void) void IdoMysqlConnection::ReconnectTimerHandler(void)
@ -382,7 +382,11 @@ void IdoMysqlConnection::AsyncQuery(const String& query, const boost::function<v
aq.Query = query; aq.Query = query;
aq.Callback = callback; aq.Callback = callback;
m_AsyncQueries.push_back(aq); m_AsyncQueries.push_back(aq);
m_QueryQueue.Enqueue(boost::bind(&IdoMysqlConnection::FinishAsyncQueries, this, false));
if (m_AsyncQueries.size() > 500)
FinishAsyncQueries(true);
else
m_QueryQueue.Enqueue(boost::bind(&IdoMysqlConnection::FinishAsyncQueries, this, false));
} }
void IdoMysqlConnection::FinishAsyncQueries(bool force) void IdoMysqlConnection::FinishAsyncQueries(bool force)