Skip to content

Commit

Permalink
MON-17390 review remarks
Browse files Browse the repository at this point in the history
  • Loading branch information
jean-christophe81 committed Mar 14, 2023
1 parent 345806b commit ed08c95
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 7 deletions.
8 changes: 4 additions & 4 deletions broker/core/src/mysql_connection.cc
Original file line number Diff line number Diff line change
Expand Up @@ -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<const void*>(this), task->query);
}

Expand Down Expand Up @@ -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<const void*>(this));
res = 0;
Expand Down Expand Up @@ -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<const void*>(this), task->id,
Expand Down Expand Up @@ -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<const void*>(this), task->statement_id,
Expand Down
5 changes: 2 additions & 3 deletions broker/unified_sql/src/stream_sql.cc
Original file line number Diff line number Diff line change
Expand Up @@ -1452,7 +1452,7 @@ void stream::_process_pb_host(const std::shared_ptr<io::data>& 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<const neb::pb_host*>(d.get())};
auto& h = hst->obj();

Expand Down Expand Up @@ -2873,8 +2873,7 @@ void stream::_process_pb_service(const std::shared_ptr<io::data>& 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<neb::pb_service const*>(d.get())};
auto& s = svc->obj();
Expand Down

0 comments on commit ed08c95

Please sign in to comment.