tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-27 07:34:15 +02:00
Code Issues Packages Projects Releases Wiki Activity

Ido*Connection: extend IsPaused() check where the difference matters

Browse Source 
refs #8727
This commit is contained in:
Alexander A. Klimov 2021-04-20 19:04:49 +02:00
parent 92df2ce2ca
commit 3d8586ccec
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/db_ido_mysql/idomysqlconnection.cpp
View File

@ -147,7 +147,7 @@ void IdoMysqlConnection::Disconnect()
void IdoMysqlConnection::NewTransaction() void IdoMysqlConnection::NewTransaction()
{ {
if (IsPaused()) if (IsPaused() && GetPauseCalled())
return; return;
#ifdef I2_DEBUG /* I2_DEBUG */ #ifdef I2_DEBUG /* I2_DEBUG */
@ -898,7 +898,7 @@ bool IdoMysqlConnection::FieldToEscapedString(const String& key, const Value& va
void IdoMysqlConnection::ExecuteQuery(const DbQuery& query) void IdoMysqlConnection::ExecuteQuery(const DbQuery& query)
{ {
if (IsPaused()) if (IsPaused() && GetPauseCalled())
return; return;
ASSERT(query.Category != DbCatInvalid); ASSERT(query.Category != DbCatInvalid);
@ -1001,7 +1001,7 @@ void IdoMysqlConnection::InternalExecuteQuery(const DbQuery& query, int typeOver
{ {
AssertOnWorkQueue(); AssertOnWorkQueue();
if (IsPaused()) { if (IsPaused() && GetPauseCalled()) {
DecreasePendingQueries(1); DecreasePendingQueries(1);
return; return;
} }

4
lib/db_ido_pgsql/idopgsqlconnection.cpp
View File

@ -713,7 +713,7 @@ bool IdoPgsqlConnection::FieldToEscapedString(const String& key, const Value& va
void IdoPgsqlConnection::ExecuteQuery(const DbQuery& query) void IdoPgsqlConnection::ExecuteQuery(const DbQuery& query)
{ {
if (IsPaused()) if (IsPaused() && GetPauseCalled())
return; return;
ASSERT(query.Category != DbCatInvalid); ASSERT(query.Category != DbCatInvalid);
@ -798,7 +798,7 @@ void IdoPgsqlConnection::InternalExecuteQuery(const DbQuery& query, int typeOver
{ {
AssertOnWorkQueue(); AssertOnWorkQueue();
if (IsPaused()) { if (IsPaused() && GetPauseCalled()) {
DecreasePendingQueries(1); DecreasePendingQueries(1);
return; return;
} }