Home
last modified time | relevance | path

Searched refs:pWorker (Results 1 – 7 of 7) sorted by relevance

/sqlite-3.40.0/ext/lsm1/lsm-test/
H A Dlsmtest_tdb3.c1203 while( (pWorker = p->pWorker) ){ in worker_main()
1213 rc = lsm_checkpoint(pWorker, 0); in worker_main()
1220 waitOnCheckpointer(p->pDb, pWorker); in worker_main()
1224 rc = lsm_work(pWorker, 0, 256, &nWrite); in worker_main()
1229 }while( nWrite && p->pWorker ); in worker_main()
1241 if( p->pWorker && p->bDoWork==0 ){ in worker_main()
1254 if( p->pWorker ){ in mt_stop_worker()
1256 lsm_db *pWorker; in mt_stop_worker() local
1260 pWorker = p->pWorker; in mt_stop_worker()
1261 p->pWorker = 0; in mt_stop_worker()
[all …]
/sqlite-3.40.0/ext/lsm1/
H A Dlsm_shared.c184 assert( pDb->pWorker ); in dbTruncate()
185 ctx.nBlock = pDb->pWorker->nBlock; in dbTruncate()
217 assert( pDb->pWorker==0 ); in dbTruncateFile()
241 pDb->pWorker = 0; in dbTruncateFile()
775 Snapshot *p = pDb->pWorker; in lsmBlockAllocate()
875 Snapshot *p = pDb->pWorker; in lsmBlockFree()
919 assert( pDb->pWorker==0 ); in lsmCheckpointWrite()
1069 if( pDb->pWorker ){ in lsmFinishWork()
1089 pDb->pWorker = 0; in lsmFinishWork()
1145 assert( pDb->pWorker==0 ); in lsmBeginReadTrans()
[all …]
H A Dlsm_sorted.c2009 Snapshot *pWorker = pCsr->pDb->pWorker; in multiCursorGetKey() local
2556 Snapshot *pWorker = pCsr->pDb->pWorker; in multiCursorGetVal() local
2557 if( pWorker in multiCursorGetVal()
2602 assert( pDb->pWorker ); in lsmSortedWalkFreelist()
2607 pSnap = pDb->pWorker; in lsmSortedWalkFreelist()
2658 assert( pDb->pWorker ); in lsmSortedLoadFreelist()
4549 assert( pDb->pWorker ); in mergeWorkerInit()
4939 Snapshot *pWorker = pDb->pWorker; in sortedWork() local
4941 assert( pWorker ); in sortedWork()
5196 pWorker = pDb->pWorker; in doLsmSingleWork()
[all …]
H A Dlsm_ckpt.c392 LsmPgno *aiAppend = db->pWorker->aiAppend; in ckptExportAppendlist()
409 Snapshot *pSnap = pDb->pWorker; /* Worker snapshot */ in ckptExportSnapshot()
635 pParent = lsmDbSnapshotLevel(pDb->pWorker); in lsmCheckpointLoadLevels()
668 for(p=lsmDbSnapshotLevel(pDb->pWorker); p; p=p->pNext) nAll++; in lsmCheckpointLevels()
900 assert( db->pClient==0 && db->pWorker==0 ); in lsmInfoCompressionId()
949 rc = lsmCheckpointDeserialize(pDb, 1, pShm->aSnap1, &pDb->pWorker); in lsmCheckpointLoadWorker()
950 if( pDb->pWorker ) pDb->pWorker->pDatabase = pDb->pDatabase; in lsmCheckpointLoadWorker()
953 rc = lsmCheckCompressionId(pDb, pDb->pWorker->iCmpId); in lsmCheckpointLoadWorker()
1058 assert( pDb->pWorker ); in lsmDatabaseFull()
1060 for(p=pDb->pWorker->pLevel; p; p=p->pNext){ in lsmDatabaseFull()
[all …]
H A Dlsm_file.c1867 Snapshot *pSnapshot = pDb->pWorker; in lsmFsGobble()
2393 Snapshot *p = pFS->pDb->pWorker; in lsmFsMoveBlock()
2990 pWorker = pDb->pWorker; in lsmInfoArrayStructure()
2991 if( !pWorker ){ in lsmInfoArrayStructure()
2994 pWorker = pDb->pWorker; in lsmInfoArrayStructure()
3082 pWorker = pDb->pWorker; in lsmInfoArrayPages()
3083 if( !pWorker ){ in lsmInfoArrayPages()
3086 pWorker = pDb->pWorker; in lsmInfoArrayPages()
3091 pSeg = findSegment(pWorker, iFirst); in lsmInfoArrayPages()
3257 Snapshot *pWorker = pDb->pWorker; in lsmFsIntegrityCheck() local
[all …]
H A Dlsm_main.c444 if( !pDb->pWorker ){ in infoGetWorker()
449 if( pp ) *pp = pDb->pWorker; in infoGetWorker()
468 Snapshot *pWorker; /* Worker snapshot */ in lsmStructList() local
472 rc = infoGetWorker(pDb, &pWorker, &bUnlock); in lsmStructList()
476 pTopLevel = lsmDbSnapshotLevel(pWorker); in lsmStructList()
502 Snapshot *pWorker; /* Worker snapshot */ in lsmInfoFreelist() local
508 rc = infoGetWorker(pDb, &pWorker, &bUnlock); in lsmInfoFreelist()
H A DlsmInt.h379 Snapshot *pWorker; /* Worker snapshot (or NULL) */ member