From 6175ecd4c4ba817c4620f66a75e1e11da7c7a8ca Mon Sep 17 00:00:00 2001 From: Vaxry <43317083+vaxerski@users.noreply.github.com> Date: Thu, 18 Dec 2025 17:23:24 +0000 Subject: debug: move to hyprutils' logger (#12673) --- src/debug/RollingLogFollow.hpp | 66 ------------------------------------------ 1 file changed, 66 deletions(-) delete mode 100644 src/debug/RollingLogFollow.hpp (limited to 'src/debug/RollingLogFollow.hpp') 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 - -// NOLINTNEXTLINE(readability-identifier-naming) -namespace Debug { - struct SRollingLogFollow { - 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_mutex); - return m_socketToRollingLogFollowQueue[socket].empty(); - } - - std::string debugInfo() { - 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_mutex); - - const std::string ret = m_socketToRollingLogFollowQueue[socket]; - m_socketToRollingLogFollowQueue[socket] = ""; - - return ret; - }; - - void addLog(const std::string& log) { - std::unique_lock w(m_mutex); - m_running = true; - std::vector to_erase; - for (const auto& p : m_socketToRollingLogFollowQueue) - m_socketToRollingLogFollowQueue[p.first] += log + "\n"; - } - - bool isRunning() { - std::shared_lock r(m_mutex); - return m_running; - } - - void stopFor(int socket) { - 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_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 lock(gm); - return instance; - }; - }; -} -- cgit v1.2.3