Mirrors/privacore-open-source-search-engine
1
0
Fork 1
mirror of https://github.com/privacore/open-source-search-engine.git synced 2025-07-10 02:06:08 -04:00
Code Issues Packages Projects Releases Wiki Activity

use Msg3::areAllScansCompleted() internally

Browse Source
This commit is contained in:
Ivan Skytte Jørgensen
2016-07-26 13:30:23 +02:00
parent bd6a976fb9
commit fbe6b7c0ec
1 changed files with 3 additions and 3 deletions

6
Msg3.cpp

@ -26,7 +26,7 @@ Msg3::~Msg3() {
void Msg3::reset() {
if ( m_numScansCompleted < m_numScansStarted ) { g_process.shutdownAbort(true); }
if ( !areAllScansCompleted() ) { g_process.shutdownAbort(true); }
m_hadCorruption = false;
// reset # of lists to 0
m_numScansCompleted = 0;
@ -685,7 +685,7 @@ bool Msg3::readList ( char rdbId ,
//if ( rand() % 100 <= 10 ) m_errno = EIO;
// if we blocked, return false
if ( m_numScansCompleted < m_numScansStarted ) return false;
if ( !areAllScansCompleted() ) return false;
// . if all scans completed without blocking then wrap it up & ret true
// . doneScanning may now block if it finds data corruption and must
// get the list remotely
@ -723,7 +723,7 @@ void Msg3::doneScanningWrapper(void *state) {
}
// return now if we're awaiting more scan completions
if ( THIS->m_numScansCompleted < THIS->m_numScansStarted ) {
if ( !THIS->areAllScansCompleted() ) {
return;
}