cry/Hyprland
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

debug: refactor class member vars (#10130)

Browse source
This commit is contained in:
davc0n 2025-04-21 20:42:02 +02:00 • committed by GitHub
parent a3b96961a2
commit 400dd16072
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
15 changed files with 218 additions and 218 deletions
Download patch file Download diff file Expand all files Collapse all files

46
src/debug/RollingLogFollow.hpp
View file

@ -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() {