From 1ea61c2f2c977cc80d5df54e721dea7a2ae6896f Mon Sep 17 00:00:00 2001
From: Bartosz Taudul <wolf.pld@gmail.com>
Date: Tue, 12 Sep 2017 01:49:31 +0200
Subject: [PATCH] Use LZ4 to compress network data.

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 |
---
 client/TracyProfiler.cpp | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/client/TracyProfiler.cpp b/client/TracyProfiler.cpp
index 17e21106..5b24ac99 100755
--- a/client/TracyProfiler.cpp
+++ b/client/TracyProfiler.cpp
@@ -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
             {