Home
last modified time | relevance | path

Searched refs:lsm_db (Results 1 – 21 of 21) sorted by relevance

/sqlite-3.40.0/ext/lsm1/
H A DlsmInt.h336 struct lsm_db { struct
628 int lsmTreeInit(lsm_db *);
629 int lsmTreeRepair(lsm_db *);
635 int lsmTreeSize(lsm_db *);
696 void lsmFsCloseLog(lsm_db *);
868 int lsmLogBegin(lsm_db *pDb);
870 int lsmLogCommit(lsm_db *);
874 void lsmLogClose(lsm_db *);
876 int lsmLogRecover(lsm_db *);
893 int lsmBeginFlush(lsm_db *);
[all …]
H A Dlsm.h28 typedef struct lsm_db lsm_db; /* Database connection handle */ typedef
124 int lsm_new(lsm_env*, lsm_db **ppDb);
125 int lsm_close(lsm_db *pDb);
139 lsm_env *lsm_get_env(lsm_db *pDb);
153 int lsm_config(lsm_db *, int, ...);
341 int lsm_info(lsm_db *, int, ...);
504 int lsm_begin(lsm_db *pDb, int iLevel);
505 int lsm_commit(lsm_db *pDb, int iLevel);
529 int lsm_delete_range(lsm_db *,
540 int lsm_flush(lsm_db *pDb);
[all …]
H A Dlsm_main.c36 static void assert_db_state(lsm_db *pDb){ in assert_db_state()
73 int lsm_new(lsm_env *pEnv, lsm_db **ppDb){ in lsm_new()
74 lsm_db *pDb; in lsm_new()
81 *ppDb = pDb = (lsm_db *)lsmMallocZero(pEnv, sizeof(lsm_db)); in lsm_new()
105 lsm_env *lsm_get_env(lsm_db *pDb){ in lsm_get_env()
213 int lsm_close(lsm_db *pDb){ in lsm_close()
658 lsm_db *pDb, in doWriteOp()
839 lsm_db *pDb, in lsm_config_log()
848 lsm_db *pDb, in lsm_config_work_hook()
849 void (*xWork)(lsm_db *, void *), in lsm_config_work_hook() argument
[all …]
H A Dlsm_shared.c562 lsm_db **ppDb; in lsmDbDatabaseRelease()
622 lsm_db *pDb;
977 int lsmBeginWork(lsm_db *pDb){ in lsmBeginWork()
1262 int lsmBeginRoTrans(lsm_db *db){ in lsmBeginRoTrans()
1623 int lsmDbMultiProc(lsm_db *pDb){ in lsmDbMultiProc()
1735 lsm_db *db, in lsmShmTestLock()
1741 lsm_db *pIter; in lsmShmTestLock()
1779 lsm_db *db, in lsmShmLock()
1784 lsm_db *pIter; in lsmShmLock()
1945 lsm_db *p; in print_all_db_locks()
[all …]
H A Dlsm_tree.c325 lsm_db *db, in assertIsWorkingChild()
486 lsm_db *pDb, in dump_node_contents()
578 lsm_db *pDb = pCsr->pDb; in csrGetKey()
730 lsm_db *pDb, in newTreeKey()
788 lsm_db *pDb, in copyTreeNode()
805 lsm_db *pDb, in copyTreeLeaf()
1797 lsm_db *db, in lsmTreeDelete()
1978 lsm_db *pDb = pCsr->pDb; in lsmTreeCursorSeek()
2068 lsm_db *pDb = pCsr->pDb; in lsmTreeCursorNext()
2134 lsm_db *pDb = pCsr->pDb; in lsmTreeCursorPrev()
[all …]
H A Dlsm_ckpt.c360 lsm_db *pDb, in ckptExportLog()
552 lsm_db *pDb, in ckptLoadLevels()
776 static void ckptLoadEmpty(lsm_db *pDb){ in ckptLoadEmpty()
810 int lsmCheckpointRecover(lsm_db *pDb){ in lsmCheckpointRecover()
844 int lsmCheckpointStore(lsm_db *pDb, int iMeta){ in lsmCheckpointStore()
916 int lsmCheckpointClientCacheOk(lsm_db *pDb){ in lsmCheckpointClientCacheOk()
924 int lsmCheckpointLoadWorker(lsm_db *pDb){ in lsmCheckpointLoadWorker()
963 lsm_db *pDb, in lsmCheckpointDeserialize()
1053 int lsmDatabaseFull(lsm_db *pDb){ in lsmDatabaseFull()
1201 void lsmCheckpointZeroLogoffset(lsm_db *pDb){ in lsmCheckpointZeroLogoffset()
[all …]
H A Dlsm_log.c310 static int logReclaimSpace(lsm_db *pDb){ in logReclaimSpace()
364 int lsmLogBegin(lsm_db *pDb){ in lsmLogBegin()
486 void lsmLogEnd(lsm_db *pDb, int bCommit){ in lsmLogEnd()
511 lsm_db *pDb, in jumpIfRequired()
574 static int logCksumAndFlush(lsm_db *pDb){ in logCksumAndFlush()
597 static int logFlush(lsm_db *pDb, int eType){ in logFlush()
660 lsm_db *pDb, /* Database handle */ in lsmLogWrite()
729 int lsmLogCommit(lsm_db *pDb){ in lsmLogCommit()
793 int lsmInfoLogStructure(lsm_db *pDb, char **pzVal){ in lsmInfoLogStructure()
974 int lsmLogRecover(lsm_db *pDb){ in lsmLogRecover()
[all …]
H A Dlsm_sorted.c979 lsm_db *pDb, in btreeCursorNew()
2286 lsm_db *pDb = pCsr->pDb; in lsmMCursorClose()
2339 lsm_db *db = pCsr->pDb; in multiCursorAddTree()
2444 void lsmSortedRemap(lsm_db *pDb){ in lsmSortedRemap()
2959 int lsmSaveCursors(lsm_db *pDb){ in lsmSaveCursors()
2969 int lsmRestoreCursors(lsm_db *pDb){ in lsmRestoreCursors()
4870 lsm_db *pDb, in mergeInsertFreelistSegments()
5175 lsm_db *pDb, in doLsmSingleWork()
5358 int lsm_flush(lsm_db *db){ in lsm_flush()
5450 int lsmFlushTreeToDisk(lsm_db *pDb){ in lsmFlushTreeToDisk()
[all …]
H A Dlsm_file.c212 lsm_db *pDb; /* Database handle that owns this object */
578 int lsmFsOpenLog(lsm_db *db, int *pbOpen){ in lsmFsOpenLog()
597 void lsmFsCloseLog(lsm_db *db){ in lsmFsCloseLog()
619 lsm_db *pDb, /* Database connection to open fd for */ in lsmFsOpen()
684 int lsmFsConfigure(lsm_db *db){ in lsmFsConfigure()
822 int lsmFsFileid(lsm_db *pDb, void **ppId, int *pnId){ in lsmFsFileid()
1662 int lsmFsReadSyncedId(lsm_db *db, int iMeta, i64 *piVal){ in lsmFsReadSyncedId()
1860 lsm_db *pDb, in lsmFsGobble()
2976 lsm_db *pDb, in lsmInfoArrayStructure()
3072 int lsmInfoArrayPages(lsm_db *pDb, LsmPgno iFirst, char **pzOut){ in lsmInfoArrayPages()
[all …]
H A Dlsm_vtab.c109 lsm_db *pDb; /* Open connection to the LSM table */
/sqlite-3.40.0/ext/lsm1/lsm-test/
H A Dlsmtest6.c71 lsm_db **ppDb, in testOomOpen()
85 lsm_db *pDb, in testOomFetch()
124 lsm_db *pDb, in testOomWrite()
143 lsm_db *pDb, in testOomFetchStr()
155 lsm_db *pDb, in testOomFetchData()
168 lsm_db *pDb, in testOomWriteStr()
180 lsm_db *pDb, in testOomWriteData()
193 lsm_db *pDb, in testOomScan()
385 lsm_db *pDb; in setup_populate_db()
421 lsm_db *pDb; in setup_populate_db2()
[all …]
H A Dlsmtest7.c19 static void do_test_api1_lsm(lsm_db *pDb, int *pRc){ in do_test_api1_lsm()
128 static lsm_db *newLsmConnection( in newLsmConnection()
134 lsm_db *db = 0; in newLsmConnection()
148 static void testPagesize(lsm_db *db, int nPgsz, int nBlksz, int *pRc){ in testPagesize()
169 lsm_db *db1 = 0; in do_test_api2()
170 lsm_db *db2 = 0; in do_test_api2()
H A Dlsmtest_tdb3.c42 lsm_db *pWorker; /* Worker database handle */
100 lsm_db *db; /* LSM database handle */
119 void (*xWork)(lsm_db *, void *);
470 static int testConfigureCompression(lsm_db *pDb){ in testConfigureCompression()
518 static int waitOnCheckpointer(LsmDb *pDb, lsm_db *db){ in waitOnCheckpointer()
779 static void xWorkHook(lsm_db *db, void *pArg){ in xWorkHook()
794 lsm_db *db, in test_lsm_config_str()
1089 lsm_db *tdb_lsm(TestDb *pDb){ in tdb_lsm()
1105 lsm_db *db = tdb_lsm(pDb); in tdb_lsm_enable_log()
1156 void (*xWork)(lsm_db *, void *), in tdb_lsm_config_work_hook() argument
[all …]
H A Dlsmtest_tdb.h137 lsm_db *tdb_lsm(TestDb *pDb);
166 void tdb_lsm_config_work_hook(TestDb *pDb, void (*)(lsm_db *, void *), void *);
H A Dlsmtest_func.c14 lsm_db *pDb; in do_work()
77 lsm_db *pDb; in do_show()
H A Dlsmtest8.c37 lsm_db *db = tdb_lsm(pDb); in doSetupStep()
174 lsm_db *db; in doLiveRecovery()
H A Dlsmtest_main.c510 static lsm_db *configure_lsm_db(TestDb *pDb){ in configure_lsm_db()
511 lsm_db *pLsm; in configure_lsm_db()
884 lsm_db *pLsm; in do_speed_tests()
1289 static void do_insert_work_hook(lsm_db *db, void *p){ in do_insert_work_hook()
H A Dlsmtest9.c40 lsm_db *db = 0; in doDataTest4()
H A Dlsmtest.h130 int tdb_lsm_configure(lsm_db *, const char *);
H A Dlsmtest2.c340 lsm_db *db = tdb_lsm(pDb); in crash_test1()
H A Dlsmtest5.c491 static void xMt1Work(lsm_db *pDb, void *pCtx){ in xMt1Work()