Lines Matching refs:pThrottle
1560 …phSourceStats & tStat, CSphIndexProgress & tProgress, ThrottleState_t * pThrottle, volatile bool *…
1561 …, CSphString & sError, CSphIndexProgress & tProgress, ThrottleState_t * pThrottle, volatile bool *…
1731 …void * pBuf, int64_t iCount, const char * sName, CSphString & sError, ThrottleState_t * pThrottle ) in sphWriteThrottled() argument
1733 assert ( pThrottle ); in sphWriteThrottled()
1741 if ( pThrottle->m_iMaxIOSize>=4096 ) in sphWriteThrottled()
1742 iChunkSize = Min ( iChunkSize, pThrottle->m_iMaxIOSize ); in sphWriteThrottled()
1751 sphThrottleSleep ( pThrottle ); in sphWriteThrottled()
1789 static size_t sphReadThrottled ( int iFD, void * pBuf, size_t iCount, ThrottleState_t * pThrottle ) in sphReadThrottled() argument
1791 assert ( pThrottle ); in sphReadThrottled()
1792 if ( pThrottle->m_iMaxIOSize && int(iCount) > pThrottle->m_iMaxIOSize ) in sphReadThrottled()
1794 size_t nChunks = iCount / pThrottle->m_iMaxIOSize; in sphReadThrottled()
1795 size_t nBytesLeft = iCount % pThrottle->m_iMaxIOSize; in sphReadThrottled()
1802 …ead = sphReadThrottled ( iFD, (char *)pBuf + i*pThrottle->m_iMaxIOSize, pThrottle->m_iMaxIOSize, p… in sphReadThrottled()
1804 if ( iRead!=(size_t)pThrottle->m_iMaxIOSize ) in sphReadThrottled()
1810 …ead = sphReadThrottled ( iFD, (char *)pBuf + nChunks*pThrottle->m_iMaxIOSize, nBytesLeft, pThrottl… in sphReadThrottled()
1819 sphThrottleSleep ( pThrottle ); in sphReadThrottled()
13996 …char * sSrc, const char * sDst, CSphString & sErrStr, ThrottleState_t * pThrottle, volatile bool *… in CopyFile() argument
14024 size_t iRead = sphReadThrottled ( tSrcFile.GetFD(), dData.Begin(), iSize, pThrottle ); in CopyFile()
14031 …if ( !sphWriteThrottled ( tDstFile.GetFD(), dData.Begin(), iSize, "CopyFile", sErrStr, pThrottle )… in CopyFile()
14176 CSphString & sError, bool bWordDict, ThrottleState_t * pThrottle, bool bHasSkips ) in Setup() argument
14180 Setup ( &m_tMyReader, iMaxPos, eHitless, bWordDict, pThrottle, bHasSkips ); in Setup()
14184 …fset_t iMaxPos, ESphHitless eHitless, bool bWordDict, ThrottleState_t * pThrottle, bool bHasSkips ) in Setup() argument
14187 m_pReader->SetThrottle ( pThrottle ); in Setup()
14430 int iDynamic, int iInline, const CSphRowitem * pMin, ThrottleState_t * pThrottle ) in ConfigureQword() argument
14435 tQword.m_rdHitlist.SetThrottle ( pThrottle ); in ConfigureQword()
14439 tQword.m_rdDoclist.SetThrottle ( pThrottle ); in ConfigureQword()
14455 …CSphIndexProgress & tProgress, ThrottleState_t * pThrottle, volatile bool * pGlobalStop, volatile … in MergeWords() argument
14469 …pDstIndex->m_tSettings.m_eHitless, sError, bWordDict, pThrottle, pDstIndex->m_tWordlist.m_bHaveSki… in MergeWords()
14472 …pSrcIndex->m_tSettings.m_eHitless, sError, bWordDict, pThrottle, pSrcIndex->m_tWordlist.m_bHaveSki… in MergeWords()
14506 pDstIndex->m_dMinRow.Begin(), pThrottle ); in MergeWords()
14509 pSrcIndex->m_dMinRow.Begin(), pThrottle ); in MergeWords()
14711 , CSphString & sError, CSphIndexProgress & tProgress, ThrottleState_t * pThrottle, in DoMerge() argument
14750 tSPMWriter.SetThrottle ( pThrottle ); in DoMerge()
14751 tSPSWriter.SetThrottle ( pThrottle ); in DoMerge()
14790 wrRows.SetThrottle ( pThrottle ); in DoMerge()
14933 if ( !CopyFile ( sSrc.cstr(), sDst.cstr(), sError, pThrottle, pGlobalStop, pLocalStop ) ) in DoMerge()
14975 tHitBuilder.SetThrottle ( pThrottle ); in DoMerge()
14985 pDict->DictBegin ( tTmpDict, tDict, iHitBufferSize, pThrottle ); in DoMerge()
14995 tProgress, pThrottle, pGlobalStop, pLocalStop ) ) in DoMerge()
15005 tProgress, pThrottle, pGlobalStop, pLocalStop ) ) in DoMerge()
15034 …etFD(), &dKillList[0], dKillList.GetLength()*sizeof(SphDocID_t), "kill_list", sError, pThrottle ) ) in DoMerge()
15058 tBuildHeader.m_pThrottle = pThrottle; in DoMerge()
15070 CSphString & sError, CSphIndexProgress & tProgress, ThrottleState_t * pThrottle, in sphMerge() argument
15076 …erge ( pDstIndex, pSrcIndex, false, NULL, dKillList, sError, tProgress, pThrottle, pGlobalStop, pL… in sphMerge()
21135 …in ( CSphAutofile & tTempDict, CSphAutofile & tDict, int iDictLimit, ThrottleState_t * pThrottle );
22668 …skDictTraits::DictBegin ( CSphAutofile & , CSphAutofile & tDict, int, ThrottleState_t * pThrottle ) in DictBegin() argument
22672 m_wrDict.SetThrottle ( pThrottle ); in DictBegin()
23436 …in ( CSphAutofile & tTempDict, CSphAutofile & tDict, int iDictLimit, ThrottleState_t * pThrottle );
23439 …ictEnd ( DictHeader_t * pHeader, int iMemLimit, CSphString & sError, ThrottleState_t * pThrottle );
23737 …gin ( CSphAutofile & tTempDict, CSphAutofile & tDict, int iDictLimit, ThrottleState_t * pThrottle ) in DictBegin() argument
23742 m_wrTmpDict.SetThrottle ( pThrottle ); in DictBegin()
23746 m_wrDict.SetThrottle ( pThrottle ); in DictBegin()
23753 …DictEnd ( DictHeader_t * pHeader, int iMemLimit, CSphString & sError, ThrottleState_t * pThrottle ) in DictEnd() argument
23799 dBins[i]->SetThrottle ( pThrottle ); in DictEnd()