mirror of
https://github.com/wolfpld/tracy.git
synced 2025-03-20 07:40:02 +08:00
Store send queue size in mbps block.
This commit is contained in:
parent
d8d30bd875
commit
20e6813461
@ -1784,6 +1784,7 @@ void Worker::Exec()
|
|||||||
m_mbpsData.mbps.erase( m_mbpsData.mbps.begin() );
|
m_mbpsData.mbps.erase( m_mbpsData.mbps.begin() );
|
||||||
m_mbpsData.mbps.emplace_back( bytes / ( td * 125.f ) );
|
m_mbpsData.mbps.emplace_back( bytes / ( td * 125.f ) );
|
||||||
m_mbpsData.compRatio = float( bytes ) / decBytes;
|
m_mbpsData.compRatio = float( bytes ) / decBytes;
|
||||||
|
m_mbpsData.queue = m_serverQueryQueue.size();
|
||||||
t0 = t1;
|
t0 = t1;
|
||||||
bytes = 0;
|
bytes = 0;
|
||||||
decBytes = 0;
|
decBytes = 0;
|
||||||
|
|||||||
@ -186,11 +186,12 @@ private:
|
|||||||
|
|
||||||
struct MbpsBlock
|
struct MbpsBlock
|
||||||
{
|
{
|
||||||
MbpsBlock() : mbps( 64 ), compRatio( 1.0 ) {}
|
MbpsBlock() : mbps( 64 ), compRatio( 1.0 ), queue( 0 ) {}
|
||||||
|
|
||||||
TracyMutex lock;
|
TracyMutex lock;
|
||||||
std::vector<float> mbps;
|
std::vector<float> mbps;
|
||||||
float compRatio;
|
float compRatio;
|
||||||
|
size_t queue;
|
||||||
};
|
};
|
||||||
|
|
||||||
enum class NextCallstackType
|
enum class NextCallstackType
|
||||||
@ -317,6 +318,7 @@ public:
|
|||||||
TracyMutex& GetMbpsDataLock() { return m_mbpsData.lock; }
|
TracyMutex& GetMbpsDataLock() { return m_mbpsData.lock; }
|
||||||
const std::vector<float>& GetMbpsData() const { return m_mbpsData.mbps; }
|
const std::vector<float>& GetMbpsData() const { return m_mbpsData.mbps; }
|
||||||
float GetCompRatio() const { return m_mbpsData.compRatio; }
|
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 HasData() const { return m_hasData.load( std::memory_order_acquire ); }
|
||||||
bool IsConnected() const { return m_connected.load( std::memory_order_relaxed ); }
|
bool IsConnected() const { return m_connected.load( std::memory_order_relaxed ); }
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user