summaryrefslogtreecommitdiff
path: root/src/debug/RollingLogFollow.hpp
diff options
context:
space:
mode:
authorVaxry <43317083+vaxerski@users.noreply.github.com>2025-12-18 17:23:24 +0000
committerGitHub <noreply@github.com>2025-12-18 17:23:24 +0000
commit6175ecd4c4ba817c4620f66a75e1e11da7c7a8ca (patch)
treecf73852f1fc08b1dcee5a3a7380f914aaad9c50a /src/debug/RollingLogFollow.hpp
parentf88deb928a0f7dc02f427473f8c29e8f2bed14a3 (diff)
debug: move to hyprutils' logger (#12673)
Diffstat (limited to 'src/debug/RollingLogFollow.hpp')
-rw-r--r--src/debug/RollingLogFollow.hpp66
1 files changed, 0 insertions, 66 deletions
diff --git a/src/debug/RollingLogFollow.hpp b/src/debug/RollingLogFollow.hpp
deleted file mode 100644
index 07b4387d..00000000
--- a/src/debug/RollingLogFollow.hpp
+++ /dev/null
@@ -1,66 +0,0 @@
-#pragma once
-
-#include <shared_mutex>
-
-// NOLINTNEXTLINE(readability-identifier-naming)
-namespace Debug {
- struct SRollingLogFollow {
- 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_mutex);
- return m_socketToRollingLogFollowQueue[socket].empty();
- }
-
- std::string debugInfo() {
- 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_mutex);
-
- 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_mutex);
- m_running = true;
- std::vector<int> to_erase;
- for (const auto& p : m_socketToRollingLogFollowQueue)
- m_socketToRollingLogFollowQueue[p.first] += log + "\n";
- }
-
- bool isRunning() {
- std::shared_lock<std::shared_mutex> r(m_mutex);
- return m_running;
- }
-
- void stopFor(int socket) {
- 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_mutex);
- m_socketToRollingLogFollowQueue[socket] = std::format("[LOG] Following log to socket: {} started\n", socket);
- m_running = true;
- }
-
- static SRollingLogFollow& get() {
- static SRollingLogFollow instance;
- static std::mutex gm;
- std::lock_guard<std::mutex> lock(gm);
- return instance;
- };
- };
-}