From 20e6813461efdd86f7487f345a66491037ed9e7b Mon Sep 17 00:00:00 2001
From: Bartosz Taudul <wolf.pld@gmail.com>
Date: Mon, 1 Apr 2019 19:55:37 +0200
Subject: [PATCH] Store send queue size in mbps block.

---
 server/TracyWorker.cpp | 1 +
 server/TracyWorker.hpp | 4 +++-
 2 files changed, 4 insertions(+), 1 deletion(-)

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<float> mbps;
         float compRatio;
+        size_t queue;
     };
 
     enum class NextCallstackType
@@ -317,6 +318,7 @@ public:
     TracyMutex& GetMbpsDataLock() { return m_mbpsData.lock; }
     const std::vector<float>& 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 ); }