summaryrefslogtreecommitdiff
path: root/src/debug/RollingLogFollow.hpp
diff options
context:
space:
mode:
authordavc0n <dconti.dev@gmail.com>2025-04-21 20:42:02 +0200
committerGitHub <noreply@github.com>2025-04-21 20:42:02 +0200
commit400dd1607292165bccbafc4af7bce4855ac8a71c (patch)
tree22ae7686c979713750825b56b5d56695d8f3b8a2 /src/debug/RollingLogFollow.hpp
parenta3b96961a2d89b0a2e213f9dcf755e4cab98ac1d (diff)
debug: refactor class member vars (#10130)
Diffstat (limited to 'src/debug/RollingLogFollow.hpp')
-rw-r--r--src/debug/RollingLogFollow.hpp46
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() {