diff options
| author | davc0n <dconti.dev@gmail.com> | 2025-04-21 20:42:02 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-04-21 20:42:02 +0200 |
| commit | 400dd1607292165bccbafc4af7bce4855ac8a71c (patch) | |
| tree | 22ae7686c979713750825b56b5d56695d8f3b8a2 /src/debug/RollingLogFollow.hpp | |
| parent | a3b96961a2d89b0a2e213f9dcf755e4cab98ac1d (diff) | |
debug: refactor class member vars (#10130)
Diffstat (limited to 'src/debug/RollingLogFollow.hpp')
| -rw-r--r-- | src/debug/RollingLogFollow.hpp | 46 |
1 files changed, 23 insertions, 23 deletions
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<int, std::string> socketToRollingLogFollowQueue; - std::shared_mutex m; - bool running = false; + std::unordered_map<int, std::string> 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<std::shared_mutex> r(m); - return socketToRollingLogFollowQueue[socket].empty(); + std::shared_lock<std::shared_mutex> r(m_mutex); + return m_socketToRollingLogFollowQueue[socket].empty(); } std::string debugInfo() { - std::shared_lock<std::shared_mutex> r(m); - return std::format("RollingLogFollow, got {} connections", socketToRollingLogFollowQueue.size()); + std::shared_lock<std::shared_mutex> r(m_mutex); + return std::format("RollingLogFollow, got {} connections", m_socketToRollingLogFollowQueue.size()); } std::string getLog(int socket) { - std::unique_lock<std::shared_mutex> w(m); + std::unique_lock<std::shared_mutex> 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<std::shared_mutex> w(m); - running = true; + std::unique_lock<std::shared_mutex> w(m_mutex); + m_running = true; std::vector<int> 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<std::shared_mutex> r(m); - return running; + std::shared_lock<std::shared_mutex> r(m_mutex); + return m_running; } void stopFor(int socket) { - std::unique_lock<std::shared_mutex> w(m); - socketToRollingLogFollowQueue.erase(socket); - if (socketToRollingLogFollowQueue.empty()) - running = false; + std::unique_lock<std::shared_mutex> w(m_mutex); + m_socketToRollingLogFollowQueue.erase(socket); + if (m_socketToRollingLogFollowQueue.empty()) + m_running = false; } void startFor(int socket) { - std::unique_lock<std::shared_mutex> w(m); - socketToRollingLogFollowQueue[socket] = std::format("[LOG] Following log to socket: {} started\n", socket); - running = true; + std::unique_lock<std::shared_mutex> w(m_mutex); + m_socketToRollingLogFollowQueue[socket] = std::format("[LOG] Following log to socket: {} started\n", socket); + m_running = true; } static SRollingLogFollow& get() { |
