Home
last modified time | relevance | path

Searched refs:pDb (Results 1 – 25 of 59) sorted by relevance

123

/sqlite-3.40.0/ext/lsm1/
H A Dlsm_main.c43 assert( (pDb->pCsr!=0||pDb->nTransOpen>0)==(pDb->iReader>=0||pDb->bRoTrans) ); in assert_db_state()
45 assert( (pDb->iReader<0 && pDb->bRoTrans==0) || pDb->pClient!=0 ); in assert_db_state()
115 if( pDb->nTransOpen==0 && pDb->pCsr==0 ){ in dbReleaseClientSnapshot()
217 if( pDb->pCsr || pDb->nTransOpen ){ in lsm_close()
221 lsmFreeSnapshot(pDb->pEnv, pDb->pClient); in lsm_close()
233 if( pDb->factory.xFree ) pDb->factory.xFree(pDb->factory.pCtx); in lsm_close()
234 if( pDb->compress.xFree ) pDb->compress.xFree(pDb->compress.pCtx); in lsm_close()
237 lsmFree(pDb->pEnv, pDb->aTrans); in lsm_close()
238 lsmFree(pDb->pEnv, pDb->apShm); in lsm_close()
239 lsmFree(pDb->pEnv, pDb); in lsm_close()
[all …]
H A Dlsm_shared.c240 lsmFreeSnapshot(pDb->pEnv, pDb->pWorker); in dbTruncateFile()
357 pDb->pShmhdr = (ShmHeader *)pDb->apShm[0]; in doDbConnect()
691 ctx[0].pDb = pDb; in lsmWalkFreelist()
703 ctx[1].pDb = pDb; in lsmWalkFreelist()
1083 rc = dbSetReadLock(pDb, pDb->pWorker->iId, pDb->treehdr.iUsedShmid); in lsmFinishWork()
1122 pDb->factory.xFactory(pDb->factory.pCtx, pDb, iReq); in lsmCheckCompressionId()
1187 rc = lsmCheckpointDeserialize(pDb, 0, pDb->aSnapshot,&pDb->pClient); in lsmBeginReadTrans()
1332 lsmFree(pDb->pEnv, pDb->apShm[i]); in lsmFinishReadTrans()
1334 lsmFree(pDb->pEnv, pDb->apShm); in lsmFinishReadTrans()
1427 rc = dbSetReadLock(pDb, pDb->pClient->iId, pDb->treehdr.iUsedShmid); in lsmFinishWriteTrans()
[all …]
H A Dlsm_tree.c563 pCsr->pDb = pDb; in treeCursorInit()
578 lsm_db *pDb = pCsr->pDb; in csrGetKey() local
656 pFirst = treeShmChunk(pDb, pDb->treehdr.iFirst); in treeShmalloc()
1085 pDb->treehdr.oldcksum0 = pDb->treehdr.log.cksum0; in lsmTreeMakeOld()
1101 pDb->treehdr.iUsedShmid = pDb->treehdr.iOldShmid; in lsmTreeDiscardOld()
1978 lsm_db *pDb = pCsr->pDb; in lsmTreeCursorSeek() local
2068 lsm_db *pDb = pCsr->pDb; in lsmTreeCursorNext() local
2134 lsm_db *pDb = pCsr->pDb; in lsmTreeCursorPrev() local
2202 lsm_db *pDb = pCsr->pDb; in lsmTreeCursorEnd() local
2347 pChunk = treeShmChunk(pDb, pDb->treehdr.iFirst); in lsmTreeRollback()
[all …]
H A Dlsm_ckpt.c360 lsm_db *pDb, in ckptExportLog() argument
552 lsm_db *pDb, in ckptLoadLevels() argument
912 aShm = (iSnap==1) ? pDb->pShmhdr->aSnap1 : pDb->pShmhdr->aSnap2; in lsmCheckpointLoadOk()
918 && pDb->pClient->iId==lsmCheckpointId(pDb->aSnapshot, 0) in lsmCheckpointClientCacheOk()
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()
963 lsm_db *pDb, in lsmCheckpointDeserialize() argument
1213 &pDb->aSnapshot[nCkpt-2], &pDb->aSnapshot[nCkpt-1] in lsmCheckpointZeroLogoffset()
1216 memcpy(pDb->pShmhdr->aSnap1, pDb->aSnapshot, nCkpt*sizeof(u32)); in lsmCheckpointZeroLogoffset()
[all …]
H A Dlsm_sorted.c2286 lsm_db *pDb = pCsr->pDb; in lsmMCursorClose() local
2507 bOld = (lsmTreeHasOld(pDb) && pDb->treehdr.iOldLog!=pDb->pClient->iLogOff); in lsmMCursorNew()
4313 pDb->xWork(pDb, pDb->pWorkCtx); in sortedInvokeWorkHook()
4353 pCsr->pDb = pDb; in sortedNewToplevel()
4388 mergeworker.pDb = pDb; in sortedNewToplevel()
4554 pMW->pDb = pDb; in mergeWorkerInit()
5424 rc = doLsmWork(pDb, pDb->nMerge, nRemaining, 0); in lsmSortedAutoWork()
5429 lsmFreeSnapshot(pDb->pEnv, pDb->pClient); in lsmSortedAutoWork()
5435 rc = lsmCheckpointDeserialize(pDb, 0, pDb->aSnapshot, &pDb->pClient); in lsmSortedAutoWork()
5455 rc = sortedWork(pDb, 256, pDb->nMerge, 1, 0); in lsmFlushTreeToDisk()
[all …]
H A Dlsm_log.c403 lsmLogClose(pDb); in lsmLogBegin()
489 p = pDb->pLogWriter; in lsmLogEnd()
511 lsm_db *pDb, in jumpIfRequired() argument
677 pLog = pDb->pLogWriter; in lsmLogWrite()
748 pLog = pDb->pLogWriter; in lsmLogTell()
771 pLog = pDb->pLogWriter; in lsmLogSeek()
803 if( pDb->pCsr==0 && pDb->nTransOpen==0 ){ in lsmInfoLogStructure()
951 p->pFS = pDb->pFS; in logReaderInit()
988 rc = lsmTreeInit(pDb); in lsmLogRecover()
1140 if( pDb->bRoTrans ){ in lsmLogRecover()
[all …]
H A DlsmInt.h616 int lsmDatabaseFull(lsm_db *pDb);
631 void lsmTreeMakeOld(lsm_db *pDb);
632 void lsmTreeDiscardOld(lsm_db *pDb);
633 int lsmTreeHasOld(lsm_db *pDb);
807 int lsmFlushTreeToDisk(lsm_db *pDb);
809 void lsmSortedRemap(lsm_db *pDb);
836 int lsmSaveCursors(lsm_db *pDb);
837 int lsmRestoreCursors(lsm_db *pDb);
868 int lsmLogBegin(lsm_db *pDb);
924 int lsmFreelistDelta(lsm_db *pDb);
[all …]
/sqlite-3.40.0/ext/lsm1/lsm-test/
H A Dlsmtest_tdb3.c174 pRet->pDb = pDb; in testEnvOpen()
197 LsmDb *pDb = p->pDb; in testEnvWrite() local
257 LsmDb *pDb = p->pDb; in testEnvSync() local
579 rc = waitOnCheckpointer(pDb, pDb->db); in test_lsm_write()
736 if( pDb->pCsr==0 ) rc = lsm_csr_open(pDb->db, &pDb->pCsr); in test_lsm_begin()
969 pDb->zName = (char *)&pDb[1]; in testLsmOpen()
984 pDb->env.pVfsCtx = (void *)pDb; in testLsmOpen()
1003 rc = lsm_new(&pDb->env, &pDb->db); in testLsmOpen()
1292 if( pDb->xWork ) pDb->xWork(db, pDb->pWorkCtx); in mt_client_work_hook()
1302 if( pDb->xWork ) pDb->xWork(db, pDb->pWorkCtx); in mt_worker_work_hook()
[all …]
H A Dlsmtest_tdb.c58 free(pDb); in test_leveldb_close()
79 leveldb_delete(pDb->db, pDb->pWriteOpt, pKey, nKey, &zErr); in test_leveldb_delete()
96 pDb->pVal = leveldb_get(pDb->db, pDb->pReadOpt, pKey, nKey, &nVal, &zErr); in test_leveldb_fetch()
118 iter = leveldb_create_iterator(pDb->db, pDb->pReadOpt); in test_leveldb_scan()
656 SqlDb *pDb; in sql_open() local
789 if( pDb ){ in tdb_close()
790 return pDb->pMethods->xClose(pDb); in tdb_close()
800 return pDb->pMethods->xDelete(pDb, pKey, nKey); in tdb_delete()
827 return pDb->pMethods->xBegin(pDb, iLevel); in tdb_begin()
830 return pDb->pMethods->xCommit(pDb, iLevel); in tdb_commit()
[all …]
H A Dlsmtest6.c85 lsm_db *pDb, in testOomFetch() argument
124 lsm_db *pDb, in testOomWrite() argument
143 lsm_db *pDb, in testOomFetchStr() argument
155 lsm_db *pDb, in testOomFetchData() argument
168 lsm_db *pDb, in testOomWriteStr() argument
180 lsm_db *pDb, in testOomWriteData() argument
193 lsm_db *pDb, in testOomScan() argument
385 lsm_db *pDb; in setup_populate_db() local
421 lsm_db *pDb; in setup_populate_db2() local
450 lsm_db *pDb; in simple_oom_1() local
[all …]
H A Dlsmtest1.c276 TestDb *pDb; in doDataTest1() local
300 testReopen(&pDb, &rc); in doDataTest1()
325 testReopen(&pDb, &rc); in doDataTest1()
337 tdb_close(pDb); in doDataTest1()
385 TestDb *pDb, in testCompareDb() argument
431 TestDb *pDb; in doDataTest2() local
443 if( tdb_lsm(pDb) ){ in doDataTest2()
480 testClose(&pDb); in doDataTest2()
560 TestDb *pDb; in doDataTest3() local
604 testReopen(&pDb, &rc); in doDataTest3()
[all …]
H A Dlsmtest3.c39 TestDb *pDb; in testCksumArrayNew() local
70 tdb_close(pDb); in testCksumArrayNew()
111 testDelete(pDb, pKey, nKey, pRc); in testDeleteDatasource()
156 TestDb *pDb; in rollback_test_1() local
167 pDb = 0; in rollback_test_1()
169 if( pDb && tdb_transaction_support(pDb)==0 ){ in rollback_test_1()
185 tdb_begin(pDb, iTrans); in rollback_test_1()
194 tdb_rollback(pDb, iTrans); in rollback_test_1()
201 tdb_rollback(pDb, 0); in rollback_test_1()
206 tdb_commit(pDb, 0); in rollback_test_1()
[all …]
H A Dlsmtest8.c27 TestDb *pDb, in doSetupStep() argument
37 lsm_db *db = tdb_lsm(pDb); in doSetupStep()
53 TestDb *pDb, in doSetupStepArray() argument
165 TestDb *pDb = 0; in doLiveRecovery() local
190 db = tdb_lsm(pDb); in doLiveRecovery()
202 testClose(&pDb); in doLiveRecovery()
213 TestDb *pDb = 0; in doWriterCrash1() local
230 testCommit(pDb, 0, &rc); in doWriterCrash1()
231 testClose(&pDb); in doWriterCrash1()
242 TestDb *pDb = 0; in doWriterCrash2() local
[all …]
H A Dlsmtest_tdb.h41 int tdb_close(TestDb *pDb);
99 int tdb_begin(TestDb *pDb, int iLevel);
100 int tdb_commit(TestDb *pDb, int iLevel);
101 int tdb_rollback(TestDb *pDb, int iLevel);
106 int tdb_transaction_support(TestDb *pDb);
112 const char *tdb_library_name(TestDb *pDb);
137 lsm_db *tdb_lsm(TestDb *pDb);
143 int tdb_lsm_multithread(TestDb *pDb);
159 void tdb_lsm_application_crash(TestDb *pDb);
161 void tdb_lsm_system_crash(TestDb *pDb);
[all …]
H A Dlsmtest2.c188 TestDb *pDb; in testSetupSavedLsmdb() local
192 testClose(&pDb); in testSetupSavedLsmdb()
216 TestDb *pDb; in testCompareCksumLsmdb() local
220 testClose(&pDb); in testCompareCksumLsmdb()
254 TestDb *pDb;
258 testClose(&pDb);
305 TestDb *pDb; in crash_test1() local
345 tdb_close(pDb); in crash_test1()
371 TestDb *pDb; in crash_test2() local
401 tdb_close(pDb); in crash_test2()
[all …]
H A Dlsmtest_main.c140 TestDb *pDb, in testFetchCompare() argument
168 TestDb *pDb; member
280 res1.pDb = pDb1; in testScanCompare()
284 res2.pDb = pDb2; in testScanCompare()
312 TestDb *pDb = 0; in testOpen() local
321 return pDb; in testOpen()
621 TestDb *pDb; in do_speed_test2() local
758 testClose(&pDb); in do_speed_test2()
920 tdb_close(pDb); in do_speed_tests()
1401 TestDb *pDb = 0; in do_insert() local
[all …]
H A Dlsmtest_func.c14 lsm_db *pDb; in do_work() local
41 rc = lsm_new(0, &pDb); in do_work()
45 rc = lsm_open(pDb, zDb); in do_work()
61 rc = lsm_checkpoint(pDb, 0); in do_work()
64 lsm_close(pDb); in do_work()
77 lsm_db *pDb; in do_show() local
130 rc = lsm_new(0, &pDb); in do_show()
131 tdb_lsm_configure(pDb, zConfig); in do_show()
135 rc = lsm_open(pDb, zDb); in do_show()
165 lsm_config(pDb, eOpt, &iRes); in do_show()
[all …]
H A Dlsmtest5.c187 if( tdb_transaction_support(pDb) ) testBegin(pDb, 1, pRc); in dbReadOperation()
201 if( tdb_transaction_support(pDb) ) testCommit(pDb, 0, pRc); in dbReadOperation()
221 rc = tdb_begin(pDb, 2); in dbWriteOperation()
226 testWriteStr(pDb, zKey, zValue, pRc); in dbWriteOperation()
234 testWriteStr(pDb, zKey, zCksum, pRc); in dbWriteOperation()
236 if( tdb_transaction_support(pDb) ) testCommit(pDb, 0, pRc); in dbWriteOperation()
527 pDb = testOpen(p->zSystem, 0, &rc); in mt1Main()
558 testClose(&pDb); in mt1Main()
594 TestDb *pDb; in do_test_mt1() local
600 pDb = testOpen(zSystem, 1, pRc); in do_test_mt1()
[all …]
H A Dlsmtest_tdb2.cc49 int test_kc_close(TestDb *pDb){ in test_kc_close() argument
50 KcDb *pKcDb = (KcDb *)pDb; in test_kc_close()
61 KcDb *pKcDb = (KcDb *)pDb; in test_kc_write()
69 KcDb *pKcDb = (KcDb *)pDb; in test_kc_delete()
77 TestDb *pDb, in test_kc_delete_range() argument
82 KcDb *pKcDb = (KcDb *)pDb; in test_kc_delete_range()
121 TestDb *pDb, in test_kc_fetch() argument
127 KcDb *pKcDb = (KcDb *)pDb; in test_kc_fetch()
155 KcDb *pKcDb = (KcDb *)pDb; in test_kc_scan()
251 MdbDb *pMdb = (MdbDb *)pDb; in test_mdb_close()
[all …]
H A Dlsmtest4.c46 TestDb *pDb; /* First database connection (writer) */ in do_mc_test() local
53 TestDb *pDb; /* Connection handle */ in do_mc_test() member
61 pDb = testOpen(zSystem, 1, pRc); in do_mc_test()
66 aReader[iReader].pDb = testOpen(zSystem, 0, pRc); in do_mc_test()
75 testWriteDatasourceRange(pDb, pData, iFirst, pTest->nWriteStep, pRc); in do_mc_test()
79 testDbContents(pDb, pData, nDomain, 0, iLast, iLast, 1, pRc); in do_mc_test()
83 if( iBegin<iStep ) tdb_commit(aReader[iBegin].pDb, 0); in do_mc_test()
84 tdb_begin(aReader[iBegin].pDb, 1); in do_mc_test()
91 aReader[iReader].pDb, pData, nDomain, 0, iLast, iLast, 1, pRc in do_mc_test()
101 testClose(&aReader[iReader].pDb); in do_mc_test()
[all …]
H A Dlsmtest9.c41 TestDb *pDb; in doDataTest4() local
54 pDb = testOpen(zSystem, 1, &rc); in doDataTest4()
57 db = tdb_lsm(pDb); in doDataTest4()
58 bMultiThreaded = tdb_lsm_multithread(pDb); in doDataTest4()
62 testWriteDatasourceRange(pDb, pData, iData, nRecOn3*3, &rc); in doDataTest4()
67 testDeleteDatasourceRange(pDb, pData, iData, nRecOn3*2, &rc); in doDataTest4()
87 testWriteDatasourceRange(pDb, pData, iData+nRecOn3, nRecOn3*2, &rc); in doDataTest4()
89 testCompareDb(pData, nRecOn3*3, iData, pControl, pDb, &rc); in doDataTest4()
93 testReopen(&pDb, &rc); in doDataTest4()
94 if( rc==0 ) db = tdb_lsm(pDb); in doDataTest4()
[all …]
/sqlite-3.40.0/src/
H A Dtclsqlite.c431 p->pDb = pDb; in createIncrblobChannel()
485 pNew->pDb = pDb; in findSqlFunc()
526 pDb->nRef++; in addDatabaseRef()
535 pDb->nRef--; in delDatabaseRef()
543 assert( pFunc->pDb==pDb ); in delDatabaseRef()
627 rc = Tcl_Eval(pDb->interp, pDb->zProgress); in DbProgressHandler()
762 rc = Tcl_Eval(pDb->interp, pDb->zCommit); in DbCommitHandler()
1526 while( pDb->nStmt>pDb->maxStmt ){ in dbReleaseStmt()
1595 p->pDb = pDb; in dbEvalInit()
1680 SqliteDb *pDb = p->pDb; in dbEvalStep() local
[all …]
/sqlite-3.40.0/test/
H A Dtt3_stress.c193 sql_script_printf(pErr, pDb, in stress2_workload1()
208 sql_script(pErr, pDb, "SELECT * FROM t0 WHERE z = 'big'"); in stress2_workload4()
212 sql_script(pErr, pDb, in stress2_workload5()
218 sql_script(pErr, pDb, in stress2_workload6()
224 sql_script_printf(pErr, pDb, in stress2_workload7()
231 sql_script_printf(pErr, pDb, in stress2_workload8()
239 sql_script_printf(pErr, pDb, in stress2_workload9()
244 sql_script_printf(pErr, pDb, in stress2_workload10()
250 sql_script(pErr, pDb, "VACUUM"); in stress2_workload11()
254 sql_script(pErr, pDb, "PRAGMA integrity_check"); in stress2_workload14()
[all …]
H A Dthreadtest3.c506 Sqlite *pDb, in sqlite_error() argument
557 sqlite3_close(pDb->db); in opendb_x()
558 pDb->db = 0; in opendb_x()
585 sqlite3_free(pDb->aText); in closedb_x()
641 pRet->pNext = pDb->pCache; in getSqlStatement()
642 pDb->pCache = pRet; in getSqlStatement()
687 va_start(ap, pDb); in execsql_i64_x()
714 if( iSlot>=pDb->nText ){ in execsql_text_x()
716 pDb->aText = (char **)sqlite3_realloc(pDb->aText, nByte); in execsql_text_x()
717 memset(&pDb->aText[pDb->nText], 0, sizeof(char*)*(iSlot+1-pDb->nText)); in execsql_text_x()
[all …]
/sqlite-3.40.0/ext/wasm/api/
H A Dsqlite3-api-glue.js116 util.sqlite3_wasm_db_error = function(pDb,errCode,msg){ argument
141 const __dbArgcMismatch = (pDb,f,n)=>{ argument
173 return __dbArgcMismatch(pDb,"sqlite3_exec",f.length);
175 return __exec(pDb, sql, callback, pVoid, pErrMsg);
202 rc = __exec(pDb, sql, pFunc, pVoid, pErrMsg);
204 rc = util.sqlite3_wasm_db_error(pDb, capi.SQLITE_ERROR,
391 pDb, funcName, nArg, eTextRep, pApp, argument
420 pDb, funcName, nArg, eTextRep, pApp, argument
431 pDb, funcName, nArg, eTextRep, pApp, argument
561 pDb, capi.SQLITE_MISUSE,
[all …]

123