Lines Matching refs:pFd
174 sqlite3_file *pFd; /* File handle */ member
355 sqlite3_file *pFd; /* File handle we are reading from */ member
421 sqlite3_file *pFd; /* File handle to write to */ member
472 if( pReadr->aMap ) sqlite3OsUnfetch(pReadr->pFd, 0, pReadr->aMap); in vdbePmaReaderClear()
519 rc = sqlite3OsRead(p->pFd, p->aBuffer, nRead, p->iReadOff); in vdbePmaReadBlob()
616 sqlite3_file *pFd = pFile->pFd; in vdbeSorterMapFile() local
617 if( pFd->pMethods->iVersion>=3 ){ in vdbeSorterMapFile()
618 rc = sqlite3OsFetch(pFd, 0, (int)pFile->iEof, (void**)pp); in vdbeSorterMapFile()
642 sqlite3OsUnfetch(pReadr->pFd, 0, pReadr->aMap); in vdbePmaReaderSeek()
647 pReadr->pFd = pFile->pFd; in vdbePmaReaderSeek()
664 pReadr->pFd, &pReadr->aBuffer[iBuf], nRead, pReadr->iReadOff in vdbePmaReaderSeek()
1060 if( pTask->file.pFd ){ in vdbeSortSubtaskCleanup()
1061 sqlite3OsCloseFree(pTask->file.pFd); in vdbeSortSubtaskCleanup()
1063 if( pTask->file2.pFd ){ in vdbeSortSubtaskCleanup()
1064 sqlite3OsCloseFree(pTask->file2.pFd); in vdbeSortSubtaskCleanup()
1219 if( pIncr->aFile[0].pFd ) sqlite3OsCloseFree(pIncr->aFile[0].pFd); in vdbeIncrFree()
1220 if( pIncr->aFile[1].pFd ) sqlite3OsCloseFree(pIncr->aFile[1].pFd); in vdbeIncrFree()
1286 static void vdbeSorterExtendFile(sqlite3 *db, sqlite3_file *pFd, i64 nByte){ in vdbeSorterExtendFile() argument
1287 if( nByte<=(i64)(db->nMaxSorterMmap) && pFd->pMethods->iVersion>=3 ){ in vdbeSorterExtendFile()
1290 sqlite3OsFileControlHint(pFd, SQLITE_FCNTL_CHUNK_SIZE, &chunksize); in vdbeSorterExtendFile()
1291 sqlite3OsFileControlHint(pFd, SQLITE_FCNTL_SIZE_HINT, &nByte); in vdbeSorterExtendFile()
1292 sqlite3OsFetch(pFd, 0, (int)nByte, &p); in vdbeSorterExtendFile()
1293 if( p ) sqlite3OsUnfetch(pFd, 0, p); in vdbeSorterExtendFile()
1454 sqlite3_file *pFd, /* File handle to write to */ in vdbePmaWriterInit() argument
1467 p->pFd = pFd; in vdbePmaWriterInit()
1486 p->eFWErr = sqlite3OsWrite(p->pFd, in vdbePmaWriteBlob()
1511 p->eFWErr = sqlite3OsWrite(p->pFd, in vdbePmaWriterFinish()
1564 if( pTask->file.pFd==0 ){ in vdbeSorterListToPMA()
1565 rc = vdbeSorterOpenTempFile(db, 0, &pTask->file.pFd); in vdbeSorterListToPMA()
1566 assert( rc!=SQLITE_OK || pTask->file.pFd ); in vdbeSorterListToPMA()
1573 vdbeSorterExtendFile(db, pTask->file.pFd, pTask->file.iEof+pList->szPMA+9); in vdbeSorterListToPMA()
1585 vdbePmaWriterInit(pTask->file.pFd, &writer, pTask->pSorter->pgsz, in vdbeSorterListToPMA()
1638 if( pReadr1->pFd==0 ){ in vdbeMergeEngineStep()
1640 }else if( pReadr2->pFd==0 ){ in vdbeMergeEngineStep()
1668 if( pReadr1->pFd ) bCached = 0; in vdbeMergeEngineStep()
1673 *pbEof = (pMerger->aReadr[pMerger->aTree[1]].pFd==0); in vdbeMergeEngineStep()
1891 vdbePmaWriterInit(pOut->pFd, &writer, pTask->pSorter->pgsz, iStart); in vdbeIncrPopulate()
1900 if( pReader->pFd==0 ) break; in vdbeIncrPopulate()
2055 if( p1->pFd==0 ){ in vdbeMergeEngineCompare()
2057 }else if( p2->pFd==0 ){ in vdbeMergeEngineCompare()
2208 rc = vdbeSorterOpenTempFile(db, mxSz, &pIncr->aFile[0].pFd); in vdbePmaReaderIncrMergeInit()
2210 rc = vdbeSorterOpenTempFile(db, mxSz, &pIncr->aFile[1].pFd); in vdbePmaReaderIncrMergeInit()
2215 if( pTask->file2.pFd==0 ){ in vdbePmaReaderIncrMergeInit()
2217 rc = vdbeSorterOpenTempFile(db, pTask->file2.iEof, &pTask->file2.pFd); in vdbePmaReaderIncrMergeInit()
2221 pIncr->aFile[1].pFd = pTask->file2.pFd; in vdbePmaReaderIncrMergeInit()
2648 if( rc==SQLITE_OK && pSorter->pReader->pFd==0 ) rc = SQLITE_DONE; in sqlite3VdbeSorterNext()