RedisConnection: Don't log queries that are going to be discarded

This commit is contained in:
Yonas Habteab 2022-09-08 16:31:47 +02:00 committed by Alexander A. Klimov
parent 0fbb0332a6
commit a656444d78
1 changed files with 12 additions and 8 deletions

View File

@ -115,7 +115,7 @@ void LogQuery(RedisConnection::Query& query, Log& msg)
*/
void RedisConnection::FireAndForgetQuery(RedisConnection::Query query, RedisConnection::QueryPriority priority, QueryAffects affects)
{
{
if (LogDebug >= Logger::GetMinLogSeverity()) {
Log msg (LogDebug, "IcingaDB", "Firing and forgetting query:");
LogQuery(query, msg);
}
@ -138,9 +138,11 @@ void RedisConnection::FireAndForgetQuery(RedisConnection::Query query, RedisConn
*/
void RedisConnection::FireAndForgetQueries(RedisConnection::Queries queries, RedisConnection::QueryPriority priority, QueryAffects affects)
{
for (auto& query : queries) {
Log msg (LogDebug, "IcingaDB", "Firing and forgetting query:");
LogQuery(query, msg);
if (LogDebug >= Logger::GetMinLogSeverity()) {
for (auto& query : queries) {
Log msg(LogDebug, "IcingaDB", "Firing and forgetting query:");
LogQuery(query, msg);
}
}
auto item (Shared<Queries>::Make(std::move(queries)));
@ -163,7 +165,7 @@ void RedisConnection::FireAndForgetQueries(RedisConnection::Queries queries, Red
*/
RedisConnection::Reply RedisConnection::GetResultOfQuery(RedisConnection::Query query, RedisConnection::QueryPriority priority, QueryAffects affects)
{
{
if (LogDebug >= Logger::GetMinLogSeverity()) {
Log msg (LogDebug, "IcingaDB", "Executing query:");
LogQuery(query, msg);
}
@ -194,9 +196,11 @@ RedisConnection::Reply RedisConnection::GetResultOfQuery(RedisConnection::Query
*/
RedisConnection::Replies RedisConnection::GetResultsOfQueries(RedisConnection::Queries queries, RedisConnection::QueryPriority priority, QueryAffects affects)
{
for (auto& query : queries) {
Log msg (LogDebug, "IcingaDB", "Executing query:");
LogQuery(query, msg);
if (LogDebug >= Logger::GetMinLogSeverity()) {
for (auto& query : queries) {
Log msg(LogDebug, "IcingaDB", "Executing query:");
LogQuery(query, msg);
}
}
std::promise<Replies> promise;