From 59053fcddde81be5239ff1b4a3fd553362df1ae8 Mon Sep 17 00:00:00 2001 From: Aaron Po Date: Sun, 19 Jul 2026 04:10:33 -0400 Subject: [PATCH] Formatted src/services/logging --- .../src/services/logging/log_dispatcher.cc | 88 +++++++++---------- 1 file changed, 44 insertions(+), 44 deletions(-) diff --git a/tooling/pipeline/src/services/logging/log_dispatcher.cc b/tooling/pipeline/src/services/logging/log_dispatcher.cc index f9e8308c..d19b9f0f 100644 --- a/tooling/pipeline/src/services/logging/log_dispatcher.cc +++ b/tooling/pipeline/src/services/logging/log_dispatcher.cc @@ -16,25 +16,25 @@ namespace { [[nodiscard]] constexpr std::string_view PipelinePhaseToString( PipelinePhase phase) { - switch (phase) { - case PipelinePhase::Startup: - return "Startup"; - case PipelinePhase::Enrichment: - return "Enrichment"; - case PipelinePhase::UserGeneration: - return "User Generation"; - case PipelinePhase::BreweryAndBeerGeneration: - return "Brewery & Beer Gen"; - case PipelinePhase::CheckinGeneration: - return "Checkin Gen"; - case PipelinePhase::RatingGeneration: - return "Rating Gen"; - case PipelinePhase::FollowGeneration: - return "Follow Gen"; - case PipelinePhase::Teardown: - return "Teardown"; - } - return "Unknown"; + switch (phase) { + case PipelinePhase::Startup: + return "Startup"; + case PipelinePhase::Enrichment: + return "Enrichment"; + case PipelinePhase::UserGeneration: + return "User Generation"; + case PipelinePhase::BreweryAndBeerGeneration: + return "Brewery & Beer Gen"; + case PipelinePhase::CheckinGeneration: + return "Checkin Gen"; + case PipelinePhase::RatingGeneration: + return "Rating Gen"; + case PipelinePhase::FollowGeneration: + return "Follow Gen"; + case PipelinePhase::Teardown: + return "Teardown"; + } + return "Unknown"; } } // namespace @@ -42,35 +42,35 @@ LogDispatcher::LogDispatcher(BoundedChannel& channel) : channel_(channel) {} void LogDispatcher::Run() { - auto logger = spdlog::default_logger(); + auto logger = spdlog::default_logger(); - while (true) { - auto entry = channel_.Receive(); - if (!entry.has_value()) { - // Channel is closed and drained. - break; - } + while (true) { + auto entry = channel_.Receive(); + if (!entry.has_value()) { + // Channel is closed and drained. + break; + } - const auto& log = entry.value(); + const auto& log = entry.value(); - logger->log(ToSpdlogLevel(log.level), - "{:<20} │ thread: {:016x} │ [{}:{}] │ {}", - PipelinePhaseToString(log.phase), - std::hash{}(log.thread_id), - log.origin.file_name(), log.origin.line(), log.message); - } + logger->log(ToSpdlogLevel(log.level), + "{:<20} │ thread: {:016x} │ [{}:{}] │ {}", + PipelinePhaseToString(log.phase), + std::hash{}(log.thread_id), + log.origin.file_name(), log.origin.line(), log.message); + } } spdlog::level::level_enum LogDispatcher::ToSpdlogLevel(LogLevel level) { - switch (level) { - case LogLevel::Debug: - return spdlog::level::debug; - case LogLevel::Info: - return spdlog::level::info; - case LogLevel::Warn: - return spdlog::level::warn; - case LogLevel::Error: - return spdlog::level::err; - } - return spdlog::level::info; + switch (level) { + case LogLevel::Debug: + return spdlog::level::debug; + case LogLevel::Info: + return spdlog::level::info; + case LogLevel::Warn: + return spdlog::level::warn; + case LogLevel::Error: + return spdlog::level::err; + } + return spdlog::level::info; }