From ed08c95333050c59f3023752f7c89543138a1a68 Mon Sep 17 00:00:00 2001 From: Jean Christophe Roques Date: Tue, 14 Mar 2023 14:58:41 +0100 Subject: [PATCH] MON-17390 review remarks --- broker/core/src/mysql_connection.cc | 8 ++++---- broker/unified_sql/src/stream_sql.cc | 5 ++--- 2 files changed, 6 insertions(+), 7 deletions(-) diff --git a/broker/core/src/mysql_connection.cc b/broker/core/src/mysql_connection.cc index a5a7ace4c93..fa6d5990d52 100644 --- a/broker/core/src/mysql_connection.cc +++ b/broker/core/src/mysql_connection.cc @@ -224,7 +224,7 @@ void mysql_connection::_query(mysql_task* t) { } else { set_need_to_commit(); } - SPDLOG_LOGGER_DEBUG(log_v2::sql(), "mysql_connection {:p}: end run query: {}", + SPDLOG_LOGGER_TRACE(log_v2::sql(), "mysql_connection {:p}: end run query: {}", static_cast(this), task->query); } @@ -290,7 +290,7 @@ void mysql_connection::_commit(mysql_task* t) { if (res == 0) _last_access = std::time(nullptr); } else { - SPDLOG_LOGGER_DEBUG(log_v2::sql(), + SPDLOG_LOGGER_TRACE(log_v2::sql(), "mysql_connection {:p} : nothing to commit", static_cast(this)); res = 0; @@ -339,7 +339,7 @@ void mysql_connection::_prepare(mysql_task* t) { set_error_message(err_msg); } else { _stmt[task->id] = stmt; - SPDLOG_LOGGER_DEBUG(log_v2::sql(), + SPDLOG_LOGGER_TRACE(log_v2::sql(), "mysql_connection {:p}: statement prepared {} " "mysql_statement_id={}: {}", static_cast(this), task->id, @@ -431,7 +431,7 @@ void mysql_connection::_statement(mysql_task* t) { } std::this_thread::sleep_for(std::chrono::milliseconds(50)); } - SPDLOG_LOGGER_DEBUG(log_v2::sql(), + SPDLOG_LOGGER_TRACE(log_v2::sql(), "mysql_connection {:p}: end execute statement " "{} attempt {} duration {}s: {}", static_cast(this), task->statement_id, diff --git a/broker/unified_sql/src/stream_sql.cc b/broker/unified_sql/src/stream_sql.cc index 5a8fbd69eb3..565965c7f9f 100644 --- a/broker/unified_sql/src/stream_sql.cc +++ b/broker/unified_sql/src/stream_sql.cc @@ -1452,7 +1452,7 @@ void stream::_process_pb_host(const std::shared_ptr& d) { actions::custom_variables | actions::downtimes | actions::comments | actions::service_dependencies | actions::severities | actions::resources_tags | - actions::tags | actions::resources); + actions::tags); auto hst{static_cast(d.get())}; auto& h = hst->obj(); @@ -2873,8 +2873,7 @@ void stream::_process_pb_service(const std::shared_ptr& d) { _finish_action(-1, actions::host_parents | actions::comments | actions::downtimes | actions::host_dependencies | actions::service_dependencies | actions::severities | - actions::resources_tags | actions::tags | - actions::resources); + actions::resources_tags | actions::tags); // Processed object. auto svc{static_cast(d.get())}; auto& s = svc->obj();