Preserve valid order of server query acknowledgements.

This commit is contained in:
Bartosz Taudul 2021-02-07 20:53:20 +01:00
parent 9b5cc3352a
commit 9cfc36f92e
2 changed files with 13 additions and 6 deletions

View File

@ -569,16 +569,20 @@ static uint64_t GetPid()
#endif
}
static void AckServerQuery()
void Profiler::AckServerQuery()
{
TracyLfqPrepare( QueueType::AckServerQueryNoop );
TracyLfqCommit;
QueueItem item;
MemWrite( &item.hdr.type, QueueType::AckServerQueryNoop );
NeedDataSize( QueueDataSize[(int)QueueType::AckServerQueryNoop] );
AppendDataUnsafe( &item, QueueDataSize[(int)QueueType::AckServerQueryNoop] );
}
static void AckSourceCodeNotAvailable()
void Profiler::AckSourceCodeNotAvailable()
{
TracyLfqPrepare( QueueType::AckSourceCodeNotAvailable );
TracyLfqCommit;
QueueItem item;
MemWrite( &item.hdr.type, QueueType::AckSourceCodeNotAvailable );
NeedDataSize( QueueDataSize[(int)QueueType::AckSourceCodeNotAvailable] );
AppendDataUnsafe( &item, QueueDataSize[(int)QueueType::AckSourceCodeNotAvailable] );
}
static BroadcastMessage& GetBroadcastMessage( const char* procname, size_t pnsz, int& len, int port )

View File

@ -693,6 +693,9 @@ private:
void HandleSymbolCodeQuery( uint64_t symbol, uint32_t size );
void HandleSourceCodeQuery();
void AckServerQuery();
void AckSourceCodeNotAvailable();
void CalibrateTimer();
void CalibrateDelay();
void ReportTopology();