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

Use LZ4 to compress network data.

Browse Source 
This greatly reduces required network bandwidth, which in effect speeds
up queue processing.

Time to process a single event queue item:

      | Raw data | With LZ4 |
------+----------+----------+
Deque |  6.86 ns |   6.7 ns |
Pack  |  4.03 ns |   4.0 ns |
LZ4   |  ---     |  21.6 ns |
Send  | 214.5 ns |   5.2 ns |
------+----------+----------+
Total | 225.4 ns | 37.58 ns |
This commit is contained in:
Bartosz Taudul 2017-09-12 01:49:31 +02:00
parent 5c2cb6098d
commit 1ea61c2f2c
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
client/TracyProfiler.cpp
View File

@ -1,7 +1,9 @@
#include <assert.h>
#include <chrono>
#include <limits>
#include <memory>
#include "../common/tracy_lz4.hpp"
#include "../common/TracySocket.hpp"
#include "TracyProfiler.hpp"
#include "TracySystem.hpp"
@ -74,6 +76,9 @@ void Profiler::Worker()
{
enum { TargetFrameSize = 64000 };
enum { BulkSize = TargetFrameSize / QueueItemSize };
enum { LZ4Size = LZ4_COMPRESSBOUND( TargetFrameSize ) };
static_assert( LZ4Size <= std::numeric_limits<uint16_t>::max(), "LZ4Size greater than uint16_t" );
moodycamel::ConsumerToken token( m_queue );
ListenSocket listen;
@ -107,7 +112,10 @@ void Profiler::Worker()
memcpy( ptr, item+i, dsz );
ptr += dsz;
}
if( sock->Send( buf, ptr - buf ) == -1 ) break;
char lz4[LZ4Size + sizeof( uint16_t )];
const uint16_t lz4sz = LZ4_compress_default( buf, lz4+2, ptr - buf, LZ4Size );
memcpy( lz4, &lz4sz, sizeof( uint16_t ) );
if( sock->Send( lz4, lz4sz ) == -1 ) break;
}
else
{