Link/tracy
1
0
Fork 0
mirror of https://github.com/wolfpld/tracy.git synced 2025-03-20 07:40:02 +08:00
Code Issues Projects Wiki Activity

Extract callstack sample processing implementation.

Browse Source
This commit is contained in:
Bartosz Taudul 2021-06-15 01:59:49 +02:00
parent 6d03b18d1c
commit 0fdd5ab01b
No known key found for this signature in database
GPG Key ID: B7FE2008B7575DF3
2 changed files with 30 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
server/TracyWorker.cpp
View File

@ -5861,32 +5861,24 @@ void Worker::ProcessCallstack()
m_pendingCallstackId = 0; m_pendingCallstackId = 0;
} }
void Worker::ProcessCallstackSample( const QueueCallstackSample& ev ) void Worker::ProcessCallstackSampleImpl( const SampleData& sd, ThreadData& td, int64_t t, uint32_t callstack )
{ {
assert( m_pendingCallstackId != 0 ); assert( sd.time.Val() == t );
assert( sd.callstack.Val() == callstack );
m_data.samplesCnt++; m_data.samplesCnt++;
const auto refTime = m_refTimeCtx + ev.time; if( td.samples.empty() )
m_refTimeCtx = refTime;
const auto t = TscTime( refTime - m_data.baseTime );
SampleData sd;
sd.time.SetVal( t );
sd.callstack.SetVal( m_pendingCallstackId );
auto td = NoticeThread( ev.thread );
if( td->samples.empty() )
{ {
td->samples.push_back( sd ); td.samples.push_back( sd );
} }
else else
{ {
assert( td->samples.back().time.Val() < t ); assert( td->samples.back().time.Val() < t );
td->samples.push_back_non_empty( sd ); td.samples.push_back_non_empty( sd );
} }
#ifndef TRACY_NO_STATISTICS #ifndef TRACY_NO_STATISTICS
const auto& cs = GetCallstack( m_pendingCallstackId ); const auto& cs = GetCallstack( callstack );
{ {
const auto& ip = cs[0]; const auto& ip = cs[0];
auto frame = GetCallstackFrame( ip ); auto frame = GetCallstackFrame( ip );
@ -5964,19 +5956,36 @@ void Worker::ProcessCallstackSample( const QueueCallstackSample& ev )
} }
} }
const auto framesKnown = UpdateSampleStatistics( m_pendingCallstackId, 1, true ); const auto framesKnown = UpdateSampleStatistics( callstack, 1, true );
assert( td->samples.size() > td->ghostIdx ); assert( td.samples.size() > td.ghostIdx );
if( framesKnown && td->ghostIdx + 1 == td->samples.size() ) if( framesKnown && td.ghostIdx + 1 == td.samples.size() )
{ {
td->ghostIdx++; td.ghostIdx++;
m_data.ghostCnt += AddGhostZone( cs, &td->ghostZones, t ); m_data.ghostCnt += AddGhostZone( cs, &td.ghostZones, t );
} }
else else
{ {
m_data.ghostZonesPostponed = true; m_data.ghostZonesPostponed = true;
} }
#endif #endif
}
void Worker::ProcessCallstackSample( const QueueCallstackSample& ev )
{
assert( m_pendingCallstackId != 0 );
const auto callstack = m_pendingCallstackId;
m_pendingCallstackId = 0; m_pendingCallstackId = 0;
const auto refTime = m_refTimeCtx + ev.time;
m_refTimeCtx = refTime;
const auto t = TscTime( refTime - m_data.baseTime );
SampleData sd;
sd.time.SetVal( t );
sd.callstack.SetVal( callstack );
auto td = NoticeThread( ev.thread );
ProcessCallstackSampleImpl( sd, *td, t, callstack );
} }
void Worker::ProcessCallstackFrameSize( const QueueCallstackFrameSize& ev ) void Worker::ProcessCallstackFrameSize( const QueueCallstackFrameSize& ev )

1
server/TracyWorker.hpp
View File

@ -702,6 +702,7 @@ private:
tracy_force_inline void ProcessGpuZoneBeginImplCommon( GpuEvent* zone, const QueueGpuZoneBeginLean& ev, bool serial ); tracy_force_inline void ProcessGpuZoneBeginImplCommon( GpuEvent* zone, const QueueGpuZoneBeginLean& ev, bool serial );
tracy_force_inline MemEvent* ProcessMemAllocImpl( uint64_t memname, MemData& memdata, const QueueMemAlloc& ev ); tracy_force_inline MemEvent* ProcessMemAllocImpl( uint64_t memname, MemData& memdata, const QueueMemAlloc& ev );
tracy_force_inline MemEvent* ProcessMemFreeImpl( uint64_t memname, MemData& memdata, const QueueMemFree& ev ); tracy_force_inline MemEvent* ProcessMemFreeImpl( uint64_t memname, MemData& memdata, const QueueMemFree& ev );
tracy_force_inline void ProcessCallstackSampleImpl( const SampleData& sd, ThreadData& td, int64_t t, uint32_t callstack );
void ZoneStackFailure( uint64_t thread, const ZoneEvent* ev ); void ZoneStackFailure( uint64_t thread, const ZoneEvent* ev );
void ZoneDoubleEndFailure( uint64_t thread, const ZoneEvent* ev ); void ZoneDoubleEndFailure( uint64_t thread, const ZoneEvent* ev );