@@ -252,10 +252,10 @@ bool CScanFile::LockFreecInit()
252
252
this ->_threadFinishSpinlock .store (false , std::memory_order_relaxed);
253
253
this ->_threadOperationReadStartSpinlock .store (false , std::memory_order_relaxed);
254
254
this ->_threadOperationReadCompletedSpinlock .store (false , std::memory_order_relaxed);
255
- this ->_pThreadReadBuffer = nullptr ;
256
- this ->_threadReadBufferSize = 0 ;
255
+ this ->_pThreadReadBuffer = nullptr ;
256
+ this ->_threadReadBufferSize = 0 ;
257
257
this ->_threadActuallyReadBytes = 0 ;
258
- this ->_threadReadSucceeded = false ;
258
+ this ->_threadReadSucceeded = false ;
259
259
// no need to synchronize before worker thread is started
260
260
261
261
// This is a dirty hack for speedup inter-thread communication on hyperthreading CPUs
@@ -321,10 +321,10 @@ bool CScanFile::LockFreeReadStart(char* const buffer, const size_t bufferLength)
321
321
assert (this ->_threadOperationReadStartSpinlock .load (std::memory_order_relaxed) == false );
322
322
assert (this ->_threadOperationReadCompletedSpinlock .load (std::memory_order_relaxed) == false );
323
323
324
- this ->_pThreadReadBuffer = buffer;
325
- this ->_threadReadBufferSize = bufferLength;
324
+ this ->_pThreadReadBuffer = buffer;
325
+ this ->_threadReadBufferSize = bufferLength;
326
326
this ->_threadActuallyReadBytes = 0 ;
327
- this ->_threadReadSucceeded = false ;
327
+ this ->_threadReadSucceeded = false ;
328
328
329
329
this ->_threadOperationReadStartSpinlock .store (true , std::memory_order_release);
330
330
0 commit comments