| /sqlite-3.40.0/ext/lsm1/ |
| H A D | lsm_file.c | 984 pPg->pLruNext->pLruPrev = pPg->pLruPrev; in fsPageRemoveFromLru() 989 pPg->pLruPrev->pLruNext = pPg->pLruNext; in fsPageRemoveFromLru() 1004 pPg->pLruPrev->pLruNext = pPg; in fsPageAddToLru() 1029 lsmFree(pPg->pFS->pEnv, pPg->aData); in fsPageBufferFree() 1030 lsmFree(pPg->pFS->pEnv, pPg); in fsPageBufferFree() 2573 (const char *)pPg->aData, pPg->nData in fsCompressIntoBuffer() 2684 if( pPg && (pPg->flags & PAGE_DIRTY) ){ in lsmFsPagePersist() 2690 assert( pPg->pSeg && pPg->iPg==0 && pPg->nCompress==0 ); in lsmFsPagePersist() 2740 assert( pPg->pHashNext==0 || pPg->pHashNext->iPg!=pPg->iPg ); in lsmFsPagePersist() 2744 memmove(&pPg->aData[4], pPg->aData, pPg->nData); in lsmFsPagePersist() [all …]
|
| H A D | lsm_sorted.c | 406 Page *pPg, in sortedReadData() argument 593 Page *pPg, in pageGetBtreeKey() argument 684 pPg->iCell++; in btreeCursorNext() 752 Page *pPg = 0; in btreeCursorFirst() local 1580 Page *pPg = pPtr->pPg; in segmentPtrFwdPointer() local 1835 pPg = 0; in seekInBtree() 1863 Page *pPg; in seekInSegment() local 3978 if( pPg ){ in mergeWorkerWrite() 5608 Page *pPg, in infoCellDump() argument 5834 Page *pPg; in sortedDumpSegment() local [all …]
|
| H A D | lsm_ckpt.c | 700 static i64 ckptLoadId(MetaPage *pPg){ in ckptLoadId() argument 702 if( pPg ){ in ckptLoadId() 704 u8 *aData = lsmFsMetaPageData(pPg, &nData); in ckptLoadId() 748 aData = lsmFsMetaPageData(pPg, &nData); in ckptTryLoad() 845 MetaPage *pPg = 0; in lsmCheckpointStore() local 849 rc = lsmFsMetaPageGet(pDb->pFS, 1, iMeta, &pPg); in lsmCheckpointStore() 856 aData = lsmFsMetaPageData(pPg, &nData); in lsmCheckpointStore() 859 rc = lsmFsMetaPageRelease(pPg); in lsmCheckpointStore() 1113 MetaPage *pPg; in lsmCheckpointSynced() local 1124 aData = lsmFsMetaPageData(pPg, &nData); in lsmCheckpointSynced() [all …]
|
| H A D | lsm_shared.c | 935 MetaPage *pPg; /* Meta page */ in lsmCheckpointWrite() local 941 rc = lsmFsMetaPageGet(pDb->pFS, 0, pShm->iMetaPage, &pPg); in lsmCheckpointWrite() 943 aData = lsmFsMetaPageData(pPg, &nData); in lsmCheckpointWrite() 946 lsmFsMetaPageRelease(pPg); in lsmCheckpointWrite()
|
| H A D | lsmInt.h | 747 int lsmFsDbPageIsLast(Segment *pSeg, Page *pPg); 842 void lsmSortedExpandBtreePage(Page *pPg, int nOrig);
|
| /sqlite-3.40.0/src/ |
| H A D | pcache.c | 70 PgHdr *pPg; in pcachePageTrace() local 129 assert( pPg!=0 ); in sqlite3PcachePageSanity() 138 assert( pPg->pDirtyNext==0 || pPg->pDirtyNext->pDirtyPrev==pPg ); in sqlite3PcachePageSanity() 139 assert( pPg->pDirtyPrev==0 || pPg->pDirtyPrev->pDirtyNext==pPg ); in sqlite3PcachePageSanity() 140 assert( pPg->pDirtyPrev!=0 || pCache->pDirty==pPg ); in sqlite3PcachePageSanity() 437 PgHdr *pPg; in sqlite3PcacheFetchStress() local 451 pPg && (pPg->nRef || (pPg->flags&PGHDR_NEED_SYNC)); in sqlite3PcacheFetchStress() 452 pPg=pPg->pDirtyPrev in sqlite3PcacheFetchStress() 455 if( !pPg ){ in sqlite3PcacheFetchStress() 456 for(pPg=pCache->pDirtyTail; pPg && pPg->nRef; pPg=pPg->pDirtyPrev); in sqlite3PcacheFetchStress() [all …]
|
| H A D | pager.c | 1266 assert( (pPg->flags&PGHDR_DIRTY) || pPg->pageHash==pager_pagehash(pPg) ); in checkPage() 2353 pPg = 0; in pager_playback_one_page() 2416 if( pPg ){ in pager_playback_one_page() 3062 PgHdr *pPg; in pagerUndoCallback() local 3066 if( pPg ){ in pagerUndoCallback() 5489 PgHdr *pPg; in getPageNormal() local 5501 pPg = 0; in getPageNormal() 5512 assert( pPg->pPager==pPager || pPg->pPager==0 ); in getPageNormal() 5574 if( pPg ){ in getPageNormal() 5726 if( pPg ) sqlite3PagerUnrefNotNull(pPg); in sqlite3PagerUnref() [all …]
|
| H A D | dbstat.c | 482 DbPage *pPg = 0; in statDecodePage() local 483 rc = sqlite3PagerGet(sqlite3BtreePager(pBt), iPrev, &pPg, 0); in statDecodePage() 485 assert( pPg==0 ); in statDecodePage() 488 pCell->aOvfl[j] = sqlite3Get4byte(sqlite3PagerGetData(pPg)); in statDecodePage() 489 sqlite3PagerUnref(pPg); in statDecodePage() 538 StatPage *pPg /* Load page into this object */ in statGetPage() argument 544 if( pPg->aPg==0 ){ in statGetPage() 545 pPg->aPg = (u8*)sqlite3_malloc(pgsz + DBSTAT_PAGE_PADDING_BYTES); in statGetPage() 546 if( pPg->aPg==0 ){ in statGetPage() 549 memset(&pPg->aPg[pgsz], 0, DBSTAT_PAGE_PADDING_BYTES); in statGetPage() [all …]
|
| H A D | pcache1.c | 434 void *pPg; in pcache1AllocPage() local 452 pPg = pcache1Alloc(pCache->szAlloc); in pcache1AllocPage() 457 if( pPg==0 ) return 0; in pcache1AllocPage() 458 p = (PgHdr1 *)&((u8 *)pPg)[pCache->szPage]; in pcache1AllocPage() 459 p->page.pBuf = pPg; in pcache1AllocPage() 1080 sqlite3_pcache_page *pPg, in pcache1Unpin() argument 1084 PgHdr1 *pPage = (PgHdr1 *)pPg; in pcache1Unpin() 1115 sqlite3_pcache_page *pPg, in pcache1Rekey() argument 1120 PgHdr1 *pPage = (PgHdr1 *)pPg; in pcache1Rekey()
|
| H A D | btree.c | 6512 MemPage *pPg = 0; in allocateBtreePage() local 6518 releasePage(pPg); in allocateBtreePage() 7325 assert( sz==pPg->xCellSize(pPg, pCell) || CORRUPT_DB ); in rebuildPage() 7335 pPg->nCell = nCell; in rebuildPage() 7336 pPg->nOverflow = 0; in rebuildPage() 7442 u8 * const pStart = &aData[pPg->hdrOffset + 8 + pPg->childPtrSize]; in pageFreeArray() 7507 int iOldEnd = iOld + pPg->nCell + pPg->nOverflow; in editPage() 7520 memmove(pPg->aCellIdx, &pPg->aCellIdx[nShift*2], nCell*2); in editPage() 7538 pCellptr = pPg->aCellIdx; in editPage() 7572 pPg->nCell = nNew; in editPage() [all …]
|
| H A D | backup.c | 496 DbPage *pPg; in sqlite3_backup_step() local 497 rc = sqlite3PagerGet(pDestPager, iPg, &pPg, 0); in sqlite3_backup_step() 499 rc = sqlite3PagerWrite(pPg); in sqlite3_backup_step() 500 sqlite3PagerUnref(pPg); in sqlite3_backup_step()
|