Lines Matching defs:aFile
100149 ** A multi-threaded IncrMerger object uses two temporary files - aFile[0]
100150 ** and aFile[1]. Neither file is allowed to grow to more than mxSz bytes in
100152 ** pMerger to populate aFile[0]. It then sets variables within the
100154 ** a background thread to populate aFile[1] with the next mxSz bytes of
100157 ** When the PmaReader reaches the end of aFile[0], it blocks until the
100158 ** background thread has finished populating aFile[1]. It then exchanges
100159 ** the contents of the aFile[0] and aFile[1] variables within this structure,
100160 ** sets the PmaReader fields to read from the new aFile[0] and kicks off
100161 ** another background thread to populate the new aFile[1]. And so on, until
100179 SorterFile aFile[2]; /* aFile[0] for reading, [1] for writing */
100465 pIncr->pTask, pReadr, &pIncr->aFile[0], pIncr->iStartOff
100995 if( pIncr->aFile[0].pFd ) sqlite3OsCloseFree(pIncr->aFile[0].pFd);
100996 if( pIncr->aFile[1].pFd ) sqlite3OsCloseFree(pIncr->aFile[1].pFd);
101651 ** Read keys from pIncr->pMerger and populate pIncr->aFile[1]. The format
101652 ** of the data stored in aFile[1] is the same as that used by regular PMAs,
101659 SorterFile *pOut = &pIncr->aFile[1];
101694 ** The main routine for background threads that populate aFile[1] of
101705 ** Launch a background thread to populate aFile[1] of pIncr.
101716 ** finished reading the contents of aFile[0]. Its purpose is to "refill"
101717 ** aFile[0] such that the PmaReader should start rereading it from the
101721 ** keys from pIncr->pMerger and repopulating aFile[0].
101725 ** aFile[0] and aFile[1] in place. If the contents of pMerger have not
101727 ** to populate the new aFile[1].
101739 SorterFile f0 = pIncr->aFile[0];
101740 pIncr->aFile[0] = pIncr->aFile[1];
101741 pIncr->aFile[1] = f0;
101745 if( pIncr->aFile[0].iEof==pIncr->iStartOff ){
101755 pIncr->aFile[0] = pIncr->aFile[1];
101756 if( pIncr->aFile[0].iEof==pIncr->iStartOff ){
101879 ** already been populated, but that they have not yet populated aFile[0] and
101947 ** initialized as for INCRINIT_NORMAL and the aFile[1] buffer belonging to
101954 ** to block on thread (pTask->thread) before accessing aFile[1]. But, since
101984 rc = vdbeSorterOpenTempFile(db, mxSz, &pIncr->aFile[0].pFd);
101986 rc = vdbeSorterOpenTempFile(db, mxSz, &pIncr->aFile[1].pFd);
101997 pIncr->aFile[1].pFd = pTask->file2.pFd;
102006 /* Use the current thread to populate aFile[1], even though this