mirror/tracy
1
0
Fork 0
mirror of https://github.com/wolfpld/tracy.git synced 2024-11-10 10:41:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Collect throughput statistics.

Browse Source
This commit is contained in:
Bartosz Taudul 2017-09-15 02:29:48 +02:00
parent c1a90f2b0f
commit d7c09605d6
2 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
server/TracyView.cpp
View File

@ -21,6 +21,7 @@ static View* s_instance = nullptr;
View::View( const char* addr ) View::View( const char* addr )
: m_addr( addr ) : m_addr( addr )
, m_shutdown( false ) , m_shutdown( false )
, m_mbps( 64 )
{ {
assert( s_instance == nullptr ); assert( s_instance == nullptr );
s_instance = this; s_instance = this;
@ -59,6 +60,9 @@ void View::Worker()
if( !m_sock.Read( &m_timeBegin, sizeof( m_timeBegin ), &tv, ShouldExit ) ) goto close; if( !m_sock.Read( &m_timeBegin, sizeof( m_timeBegin ), &tv, ShouldExit ) ) goto close;
if( !m_sock.Read( &lz4, sizeof( lz4 ), &tv, ShouldExit ) ) goto close; if( !m_sock.Read( &lz4, sizeof( lz4 ), &tv, ShouldExit ) ) goto close;
auto t0 = std::chrono::high_resolution_clock::now();
uint64_t bytes = 0;
for(;;) for(;;)
{ {
if( m_shutdown.load( std::memory_order_relaxed ) ) return; if( m_shutdown.load( std::memory_order_relaxed ) ) return;
@ -70,6 +74,7 @@ void View::Worker()
lz4sz_t lz4sz; lz4sz_t lz4sz;
if( !m_sock.Read( &lz4sz, sizeof( lz4sz ), &tv, ShouldExit ) ) goto close; if( !m_sock.Read( &lz4sz, sizeof( lz4sz ), &tv, ShouldExit ) ) goto close;
if( !m_sock.Read( lz4buf, lz4sz, &tv, ShouldExit ) ) goto close; if( !m_sock.Read( lz4buf, lz4sz, &tv, ShouldExit ) ) goto close;
bytes += sizeof( lz4sz ) + lz4sz;
auto sz = LZ4_decompress_safe( lz4buf, buf, lz4sz, TargetFrameSize ); auto sz = LZ4_decompress_safe( lz4buf, buf, lz4sz, TargetFrameSize );
assert( sz >= 0 ); assert( sz >= 0 );
@ -91,8 +96,20 @@ void View::Worker()
{ {
if( !m_sock.Read( ((char*)&ev) + sizeof( QueueHeader ), payload, &tv, ShouldExit ) ) goto close; if( !m_sock.Read( ((char*)&ev) + sizeof( QueueHeader ), payload, &tv, ShouldExit ) ) goto close;
} }
bytes += sizeof( QueueHeader ) + payload; // ignores string transfer
DispatchProcess( ev ); DispatchProcess( ev );
} }
auto t1 = std::chrono::high_resolution_clock::now();
auto td = std::chrono::duration_cast<std::chrono::milliseconds>( t1 - t0 ).count();
enum { MbpsUpdateTime = 200 };
if( td > MbpsUpdateTime )
{
m_mbps.erase( m_mbps.begin() );
m_mbps.emplace_back( 8.f * MbpsUpdateTime * bytes / ( td * 1000 * 1000 ) );
t0 = t1;
bytes = 0;
}
} }
close: close:

1
server/TracyView.hpp
View File

@ -53,6 +53,7 @@ private:
// this block must be locked // this block must be locked
std::mutex m_lock; std::mutex m_lock;
std::vector<float> m_mbps;
std::vector<Event> m_data; std::vector<Event> m_data;
std::vector<uint64_t> m_timeline; std::vector<uint64_t> m_timeline;
std::unordered_map<uint64_t, std::string> m_strings; std::unordered_map<uint64_t, std::string> m_strings;