mirrors/tracy
1
0
Fork 0
mirror of https://github.com/wolfpld/tracy synced 2025-04-30 12:53:51 +00:00
Code Issues Releases Wiki Activity

Add support for determining FileRead EOF.

Browse Source
This commit is contained in:
Bartosz Taudul 2018-04-02 01:54:25 +02:00
parent 5824b47a66
commit 68acc30bdd
1 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
server/TracyFileRead.hpp
View File

@ -38,12 +38,24 @@ public:
} }
} }
bool IsEOF()
{
if( m_lastBlock != BufSize && m_offset == m_lastBlock ) return true;
if( m_offset == BufSize )
{
if( fseek( m_file, 1, SEEK_CUR ) != 0 ) return true;
fseek( m_file, -1, SEEK_CUR );
}
return false;
}
private: private:
FileRead( FILE* f ) FileRead( FILE* f )
: m_stream( LZ4_createStreamDecode() ) : m_stream( LZ4_createStreamDecode() )
, m_file( f ) , m_file( f )
, m_offset( BufSize ) , m_offset( BufSize )
, m_active( 1 ) , m_active( 1 )
, m_lastBlock( 0 )
{} {}
tracy_force_inline void ReadSmall( void* ptr, size_t size ) tracy_force_inline void ReadSmall( void* ptr, size_t size )
@ -65,7 +77,7 @@ private:
uint32_t sz; uint32_t sz;
fread( &sz, 1, sizeof( sz ), m_file ); fread( &sz, 1, sizeof( sz ), m_file );
fread( m_lz4buf, 1, sz, m_file ); fread( m_lz4buf, 1, sz, m_file );
LZ4_decompress_safe_continue( m_stream, m_lz4buf, m_buf[m_active], sz, BufSize ); m_lastBlock = LZ4_decompress_safe_continue( m_stream, m_lz4buf, m_buf[m_active], sz, BufSize );
} }
const auto sz = std::min( size, BufSize - m_offset ); const auto sz = std::min( size, BufSize - m_offset );
@ -84,6 +96,7 @@ private:
char m_buf[2][BufSize]; char m_buf[2][BufSize];
size_t m_offset; size_t m_offset;
uint8_t m_active; uint8_t m_active;
int m_lastBlock;
}; };
} }