mirror of
https://github.com/Icinga/icinga2.git
synced 2025-07-27 07:34:15 +02:00
IDO-MySQL: Make sure InternalNewTransaction() and FinishAsyncQueries() get executed during high load
This commit is contained in:
parent
cc9451b828
commit
98457f746b
@ -165,8 +165,7 @@ void IdoMysqlConnection::NewTransaction()
|
|||||||
<< "Scheduling new transaction and finishing async queries.";
|
<< "Scheduling new transaction and finishing async queries.";
|
||||||
#endif /* I2_DEBUG */
|
#endif /* I2_DEBUG */
|
||||||
|
|
||||||
m_QueryQueue.Enqueue(std::bind(&IdoMysqlConnection::InternalNewTransaction, this), PriorityNormal);
|
m_QueryQueue.Enqueue(std::bind(&IdoMysqlConnection::InternalNewTransaction, this), PriorityHigh);
|
||||||
m_QueryQueue.Enqueue(std::bind(&IdoMysqlConnection::FinishAsyncQueries, this), PriorityNormal);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void IdoMysqlConnection::InternalNewTransaction()
|
void IdoMysqlConnection::InternalNewTransaction()
|
||||||
@ -180,6 +179,8 @@ void IdoMysqlConnection::InternalNewTransaction()
|
|||||||
|
|
||||||
AsyncQuery("COMMIT");
|
AsyncQuery("COMMIT");
|
||||||
AsyncQuery("BEGIN");
|
AsyncQuery("BEGIN");
|
||||||
|
|
||||||
|
FinishAsyncQueries();
|
||||||
}
|
}
|
||||||
|
|
||||||
void IdoMysqlConnection::ReconnectTimerHandler()
|
void IdoMysqlConnection::ReconnectTimerHandler()
|
||||||
|
Loading…
x
Reference in New Issue
Block a user