diff --git a/server/TracyWorker.cpp b/server/TracyWorker.cpp index 8397b93f..b710f69a 100644 --- a/server/TracyWorker.cpp +++ b/server/TracyWorker.cpp @@ -1784,6 +1784,7 @@ void Worker::Exec() m_mbpsData.mbps.erase( m_mbpsData.mbps.begin() ); m_mbpsData.mbps.emplace_back( bytes / ( td * 125.f ) ); m_mbpsData.compRatio = float( bytes ) / decBytes; + m_mbpsData.queue = m_serverQueryQueue.size(); t0 = t1; bytes = 0; decBytes = 0; diff --git a/server/TracyWorker.hpp b/server/TracyWorker.hpp index 630a0476..799dc859 100644 --- a/server/TracyWorker.hpp +++ b/server/TracyWorker.hpp @@ -186,11 +186,12 @@ private: struct MbpsBlock { - MbpsBlock() : mbps( 64 ), compRatio( 1.0 ) {} + MbpsBlock() : mbps( 64 ), compRatio( 1.0 ), queue( 0 ) {} TracyMutex lock; std::vector mbps; float compRatio; + size_t queue; }; enum class NextCallstackType @@ -317,6 +318,7 @@ public: TracyMutex& GetMbpsDataLock() { return m_mbpsData.lock; } const std::vector& GetMbpsData() const { return m_mbpsData.mbps; } float GetCompRatio() const { return m_mbpsData.compRatio; } + size_t GetSendQueueSize() const { return m_mbpsData.queue; } bool HasData() const { return m_hasData.load( std::memory_order_acquire ); } bool IsConnected() const { return m_connected.load( std::memory_order_relaxed ); }