Add server query queue.

This commit is contained in:
Bartosz Taudul 2019-04-01 19:17:18 +02:00
parent c07c6d11b7
commit 57dff0abc9
2 changed files with 5 additions and 0 deletions

View File

@ -1728,6 +1728,7 @@ void Worker::Exec()
} }
} }
m_serverQuerySpaceLeft = m_sock.GetSendBufSize() / ServerQueryPacketSize;
m_hasData.store( true, std::memory_order_release ); m_hasData.store( true, std::memory_order_release );
LZ4_setStreamDecode( m_stream, nullptr, 0 ); LZ4_setStreamDecode( m_stream, nullptr, 0 );

View File

@ -12,6 +12,7 @@
#include "../common/TracyForceInline.hpp" #include "../common/TracyForceInline.hpp"
#include "../common/TracyMutex.hpp" #include "../common/TracyMutex.hpp"
#include "../common/TracyQueue.hpp" #include "../common/TracyQueue.hpp"
#include "../common/TracyProtocol.hpp"
#include "../common/TracySocket.hpp" #include "../common/TracySocket.hpp"
#include "tracy_flat_hash_map.hpp" #include "tracy_flat_hash_map.hpp"
#include "TracyEvent.hpp" #include "TracyEvent.hpp"
@ -513,6 +514,9 @@ private:
FailureData m_failureData; FailureData m_failureData;
PlotData* m_sysTimePlot = nullptr; PlotData* m_sysTimePlot = nullptr;
Vector<ServerQueryPacket> m_serverQueryQueue;
size_t m_serverQuerySpaceLeft;
}; };
} }