| /sqlite-3.40.0/ext/lsm1/ |
| H A D | lsm_file.c | 676 pDb->pFS = pFS; in lsmFsOpen()
775 if( pFS->fdDb ) lsmEnvClose(pFS->pEnv, pFS->fdDb ); in lsmFsClose()
1140 rc = lsmEnvRemap(pFS->pEnv, pFS->fdDb, iSz, &pFS->pMap, &pFS->nMap); in fsGrowMapping()
1159 rc = lsmEnvRemap(pFS->pEnv, pFS->fdDb, -1, &pFS->pMap, &pFS->nMap); in lsmFsUnmap()
1197 pFS->pCompress ? pFS->nBlocksize : (pFS->nBlocksize / pFS->nPagesize) in lsmFsRedirectPage()
1446 pFS->nBuffer = pFS->pCompress->xBound(pFS->pCompress->pCtx, pFS->nPagesize); in fsAllocateBuffer()
1579 p->pFS = pFS; in fsPageGet()
1598 p->pFS = pFS; in fsPageGet()
2120 pPg->pFS = pFS; in lsmFsSortedAppend()
2315 pPg->pFS = pFS; in lsmFsMetaPageGet()
[all …]
|
| H A D | lsmInt.h | 359 FileSystem *pFS; /* On-disk portion of database */ member
705 int lsmFsMoveBlock(FileSystem *pFS, Segment *pSeg, int iTo, int iFrom);
729 int lsmFsDbPageLast(FileSystem *pFS, Segment *pSeg, Page **ppPg);
756 int lsmFsWriteLog(FileSystem *pFS, i64 iOff, LsmString *pStr);
757 int lsmFsSyncLog(FileSystem *pFS);
758 int lsmFsReadLog(FileSystem *pFS, i64 iOff, int nRead, LsmString *pStr);
759 int lsmFsTruncateLog(FileSystem *pFS, i64 nByte);
760 int lsmFsTruncateDb(FileSystem *pFS, i64 nByte);
761 int lsmFsCloseAndDeleteLog(FileSystem *pFS);
763 LsmFile *lsmFsDeferClose(FileSystem *pFS);
[all …]
|
| H A D | lsm_sorted.c | 753 FileSystem *pFS = pCsr->pFS; in btreeCursorFirst() local
989 pCsr->pFS = pDb->pFS; in btreeCursorNew()
1014 FileSystem *pFS, in segmentPtrLoadPage() argument
1241 FileSystem *pFS, in segmentPtrEndPage() argument
1270 FileSystem *pFS = pCsr->pDb->pFS; in segmentPtrEnd() local
3479 FileSystem *pFS = pMW->pDb->pFS; in mergeWorkerLoadHierarchy() local
3771 FileSystem *pFS = pMW->pDb->pFS; in mergeWorkerAddPadding() local
3796 nPgsz = lsmFsPageSize(pFS); in keyszToSkip()
4852 *pnWrite = lsmFsBlockSize(pDb->pFS) / lsmFsPageSize(pDb->pFS); in sortedMoveBlock()
5339 lsmFsPurgeCache(pDb->pFS); in lsm_work()
[all …]
|
| H A D | lsm_main.c | 198 lsmFsSetPageSize(pDb->pFS, lsmCheckpointPgsz(pDb->aSnapshot)); in lsm_open()
199 lsmFsSetBlockSize(pDb->pFS, lsmCheckpointBlksz(pDb->aSnapshot)); in lsm_open()
228 lsmFsClose(pDb->pFS); in lsm_close()
290 *piVal = lsmFsPageSize(pDb->pFS); in lsm_config()
309 *piVal = lsmFsBlockSize(pDb->pFS) / 1024; in lsm_config()
569 *piVal = lsmFsNWrite(pDb->pFS); in lsm_info()
575 *piVal = lsmFsNRead(pDb->pFS); in lsm_info()
679 int pgsz = lsmFsPageSize(pDb->pFS); in doWriteOp()
927 rc = lsmFsSyncLog(pDb->pFS); in lsm_commit()
|
| H A D | lsm_log.c | 411 pNew->szSector = lsmFsSectorSize(pDb->pFS); in lsmLogBegin()
447 rc = lsmFsWriteLog(pDb->pFS, aReg[2].iEnd, &pNew->buf); in lsmLogBegin()
561 rc = lsmFsWriteLog(pDb->pFS, pLog->iOff, &pLog->buf); in jumpIfRequired()
586 rc = lsmFsWriteLog(pDb->pFS, pLog->iOff, &pLog->buf); in logCksumAndFlush()
650 rc = lsmFsSyncLog(pDb->pFS); in logFlush()
829 FileSystem *pFS; /* File system to read from */ member
870 rc = lsmFsReadLog(p->pFS, p->iOff, LOG_READ_SIZE, &p->buf); in logReaderBlob()
951 p->pFS = pDb->pFS; in logReaderInit()
|
| H A D | lsm_shared.c | 235 pDb->pFS, (i64)ctx.nBlock*lsmFsBlockSize(pDb->pFS) in dbTruncateFile()
309 lsmFsCloseAndDeleteLog(pDb->pFS); in doDbDisconnect()
315 lsmFsUnmap(pDb->pFS); in doDbDisconnect()
534 if( pDb->pFS ){ in dbDeferClose()
537 pLsmFile = lsmFsDeferClose(pDb->pFS); in dbDeferClose()
568 lsmFsUnmap(pDb->pFS); in lsmDbDatabaseRelease()
941 rc = lsmFsMetaPageGet(pDb->pFS, 0, pShm->iMetaPage, &pPg); in lsmCheckpointWrite()
954 rc = lsmFsSyncDb(pDb->pFS, nBlock); in lsmCheckpointWrite()
958 rc = lsmFsSyncDb(pDb->pFS, 0); in lsmCheckpointWrite()
1161 lsmFsPurgeCache(pDb->pFS); in lsmBeginReadTrans()
[all …]
|
| H A D | lsm_ckpt.c | 408 FileSystem *pFS = pDb->pFS; /* File system object */ in ckptExportSnapshot() local
468 ckptSetValue(&ckpt, CKPT_HDR_BLKSZ, lsmFsBlockSize(pFS), &rc); in ckptExportSnapshot()
470 ckptSetValue(&ckpt, CKPT_HDR_PGSZ, lsmFsPageSize(pFS), &rc); in ckptExportSnapshot()
818 rc = lsmFsMetaPageGet(pDb->pFS, 0, 1, &apPg[0]); in lsmCheckpointRecover()
819 if( rc==LSM_OK ) rc = lsmFsMetaPageGet(pDb->pFS, 0, 2, &apPg[1]); in lsmCheckpointRecover()
849 rc = lsmFsMetaPageGet(pDb->pFS, 1, iMeta, &pPg); in lsmCheckpointStore()
1118 rc = lsmFsMetaPageGet(pDb->pFS, 0, iMeta, &pPg); in lsmCheckpointSynced()
|