tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-09-23 09:48:05 +02:00
Code Issues Packages Projects Releases Wiki Activity

WIP

Browse Source
This commit is contained in:
Henrik Triem 2020-09-10 14:10:34 +02:00
parent 133fe227aa
commit faa98d51c1
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
lib/db_ido_mysql/idomysqlconnection.cpp
View File

@ -513,6 +513,7 @@ void IdoMysqlConnection::AsyncQuery(const String& query, const std::function<voi
*/ */
aq.Callback = callback; aq.Callback = callback;
m_AsyncQueries.emplace_back(std::move(aq)); m_AsyncQueries.emplace_back(std::move(aq));
DecreasePendingQueries(1);
if (m_AsyncQueries.size() > 25000) { if (m_AsyncQueries.size() > 25000) {
FinishAsyncQueries(); FinishAsyncQueries();
@ -534,7 +535,7 @@ void IdoMysqlConnection::FinishAsyncQueries()
auto lostQueries = queries.size() - offset; auto lostQueries = queries.size() - offset;
if (lostQueries > 0) { if (lostQueries > 0) {
DecreasePendingQueries(lostQueries, false); //DecreasePendingQueries(lostQueries, false);
} }
}); });
@ -546,7 +547,7 @@ void IdoMysqlConnection::FinishAsyncQueries()
Defer decreaseQueries ([this, &offset, &count]() { Defer decreaseQueries ([this, &offset, &count]() {
offset += count; offset += count;
DecreasePendingQueries(count); //DecreasePendingQueries(count);
}); });
for (std::vector<IdoAsyncQuery>::size_type i = offset; i < queries.size(); i++) { for (std::vector<IdoAsyncQuery>::size_type i = offset; i < queries.size(); i++) {