From 400dd1607292165bccbafc4af7bce4855ac8a71c Mon Sep 17 00:00:00 2001 From: davc0n Date: Mon, 21 Apr 2025 20:42:02 +0200 Subject: debug: refactor class member vars (#10130) --- src/debug/RollingLogFollow.hpp | 46 +++++++++++++++++++++--------------------- 1 file changed, 23 insertions(+), 23 deletions(-) (limited to 'src/debug/RollingLogFollow.hpp') diff --git a/src/debug/RollingLogFollow.hpp b/src/debug/RollingLogFollow.hpp index 0042cd8d..07b4387d 100644 --- a/src/debug/RollingLogFollow.hpp +++ b/src/debug/RollingLogFollow.hpp @@ -5,55 +5,55 @@ // NOLINTNEXTLINE(readability-identifier-naming) namespace Debug { struct SRollingLogFollow { - std::unordered_map socketToRollingLogFollowQueue; - std::shared_mutex m; - bool running = false; + std::unordered_map m_socketToRollingLogFollowQueue; + std::shared_mutex m_mutex; + bool m_running = false; static constexpr size_t ROLLING_LOG_FOLLOW_TOO_BIG = 8192; // Returns true if the queue is empty for the given socket bool isEmpty(int socket) { - std::shared_lock r(m); - return socketToRollingLogFollowQueue[socket].empty(); + std::shared_lock r(m_mutex); + return m_socketToRollingLogFollowQueue[socket].empty(); } std::string debugInfo() { - std::shared_lock r(m); - return std::format("RollingLogFollow, got {} connections", socketToRollingLogFollowQueue.size()); + std::shared_lock r(m_mutex); + return std::format("RollingLogFollow, got {} connections", m_socketToRollingLogFollowQueue.size()); } std::string getLog(int socket) { - std::unique_lock w(m); + std::unique_lock w(m_mutex); - const std::string ret = socketToRollingLogFollowQueue[socket]; - socketToRollingLogFollowQueue[socket] = ""; + const std::string ret = m_socketToRollingLogFollowQueue[socket]; + m_socketToRollingLogFollowQueue[socket] = ""; return ret; }; void addLog(const std::string& log) { - std::unique_lock w(m); - running = true; + std::unique_lock w(m_mutex); + m_running = true; std::vector to_erase; - for (const auto& p : socketToRollingLogFollowQueue) - socketToRollingLogFollowQueue[p.first] += log + "\n"; + for (const auto& p : m_socketToRollingLogFollowQueue) + m_socketToRollingLogFollowQueue[p.first] += log + "\n"; } bool isRunning() { - std::shared_lock r(m); - return running; + std::shared_lock r(m_mutex); + return m_running; } void stopFor(int socket) { - std::unique_lock w(m); - socketToRollingLogFollowQueue.erase(socket); - if (socketToRollingLogFollowQueue.empty()) - running = false; + std::unique_lock w(m_mutex); + m_socketToRollingLogFollowQueue.erase(socket); + if (m_socketToRollingLogFollowQueue.empty()) + m_running = false; } void startFor(int socket) { - std::unique_lock w(m); - socketToRollingLogFollowQueue[socket] = std::format("[LOG] Following log to socket: {} started\n", socket); - running = true; + std::unique_lock w(m_mutex); + m_socketToRollingLogFollowQueue[socket] = std::format("[LOG] Following log to socket: {} started\n", socket); + m_running = true; } static SRollingLogFollow& get() { -- cgit v1.2.3