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

Send event data over network.

Browse Source
This commit is contained in:
Bartosz Taudul 2017-09-11 22:51:47 +02:00
parent dbd25e2653
commit 8747da8e2c
1 changed files with 28 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
client/TracyProfiler.cpp
View File

@ -1,6 +1,8 @@
#include <assert.h>
#include <chrono>
#include <memory>
#include "../common/TracySocket.hpp"
#include "TracyProfiler.hpp"
#include "TracySystem.hpp"
@ -69,19 +71,37 @@ void Profiler::Worker()
enum { BulkSize = 1024 };
moodycamel::ConsumerToken token( m_queue );
ListenSocket listen;
listen.Listen( "8086", 8 );
for(;;)
{
if( m_shutdown.load( std::memory_order_relaxed ) ) return;
QueueItem item[BulkSize];
const auto sz = m_queue.try_dequeue_bulk( token, item, BulkSize );
if( sz > 0 )
{
}
else
std::unique_ptr<Socket> sock;
for(;;)
{
if( m_shutdown.load( std::memory_order_relaxed ) ) return;
sock = listen.Accept();
if( sock ) break;
std::this_thread::sleep_for( std::chrono::milliseconds( 10 ) );
}
sock->Send( &m_timeBegin, sizeof( m_timeBegin ) );
for(;;)
{
if( m_shutdown.load( std::memory_order_relaxed ) ) return;
QueueItem item[BulkSize];
const auto sz = m_queue.try_dequeue_bulk( token, item, BulkSize );
if( sz > 0 )
{
if( sock->Send( item, sz * sizeof( QueueItem ) ) == -1 ) break;
}
else
{
std::this_thread::sleep_for( std::chrono::milliseconds( 10 ) );
}
}
}
}