mirror of
https://github.com/Icinga/icinga2.git
synced 2025-06-01 12:20:20 +02:00
parent
b0e6eb0ca4
commit
1bd235b9fb
@ -39,7 +39,7 @@ REGISTER_TYPE(IdoMysqlConnection);
|
|||||||
REGISTER_STATSFUNCTION(IdoMysqlConnection, &IdoMysqlConnection::StatsFunc);
|
REGISTER_STATSFUNCTION(IdoMysqlConnection, &IdoMysqlConnection::StatsFunc);
|
||||||
|
|
||||||
IdoMysqlConnection::IdoMysqlConnection(void)
|
IdoMysqlConnection::IdoMysqlConnection(void)
|
||||||
: m_QueryQueue(1000000)
|
: m_QueryQueue(10000000)
|
||||||
{ }
|
{ }
|
||||||
|
|
||||||
void IdoMysqlConnection::OnConfigLoaded(void)
|
void IdoMysqlConnection::OnConfigLoaded(void)
|
||||||
@ -453,6 +453,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);
|
||||||
|
|
||||||
|
if (m_AsyncQueries.size() > 25000) {
|
||||||
|
FinishAsyncQueries();
|
||||||
|
InternalNewTransaction();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void IdoMysqlConnection::FinishAsyncQueries(void)
|
void IdoMysqlConnection::FinishAsyncQueries(void)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user