mirror of
https://github.com/privacore/open-source-search-engine.git
synced 2025-07-13 02:36:06 -04:00
Remove QUICKPOLL from Msg3
This commit is contained in:
4
Msg3.cpp
4
Msg3.cpp
@ -659,7 +659,6 @@ void Msg3::doneScanningWrapper(void *state) {
|
||||
// . but now that we may get a list remotely to fix data corruption,
|
||||
// this may indeed block
|
||||
bool Msg3::doneScanning ( ) {
|
||||
QUICKPOLL(m_niceness);
|
||||
// . did we have any error on any scan?
|
||||
// . if so, repeat ALL of the scans
|
||||
g_errno = m_errno;
|
||||
@ -850,7 +849,6 @@ bool Msg3::doneScanning ( ) {
|
||||
// . if we have only 1 list, it won't be merged into a final list,
|
||||
// that is, we'll just set m_list = &m_scan[i].m_list
|
||||
for ( int32_t i = 0 ; i < m_numFileNums ; i++ ) {
|
||||
QUICKPOLL(m_niceness);
|
||||
// count total bytes for logging
|
||||
count += m_scan[i].m_list.getListSize();
|
||||
if(!m_scan[i].m_inPageCache)
|
||||
@ -945,8 +943,6 @@ bool Msg3::doneScanning ( ) {
|
||||
0 ); // timestamp. 0 = now
|
||||
}
|
||||
|
||||
QUICKPOLL(m_niceness);
|
||||
|
||||
if (!m_scan[i].m_list.constrain(m_startKey, m_constrainKey, mrs, m_scan[i].m_hintOffset, m_scan[i].m_hintKey, m_rdbId, filename)) {
|
||||
log(LOG_WARN, "net: Had error while constraining list read from %s: %s/%s. vfd=%" PRId32" parts=%" PRId32". "
|
||||
"This is likely caused by corrupted data on disk.",
|
||||
|
Reference in New Issue
Block a user