Home
last modified time | relevance | path

Searched refs:pEnv (Results 1 – 19 of 19) sorted by relevance

/sqlite-3.40.0/ext/lsm1/
H A Dlsm_mem.c22 assert( pEnv ); in lsmMalloc()
23 return pEnv->xMalloc(pEnv, N); in lsmMalloc()
26 assert( pEnv ); in lsmFree()
27 pEnv->xFree(pEnv, p); in lsmFree()
30 assert( pEnv ); in lsmRealloc()
31 return pEnv->xRealloc(pEnv, p, N); in lsmRealloc()
38 return lsmMalloc(pEnv ? pEnv : lsm_default_env(), N); in lsm_malloc()
41 lsmFree(pEnv ? pEnv : lsm_default_env(), p); in lsm_free()
44 return lsmRealloc(pEnv ? pEnv : lsm_default_env(), p, N); in lsm_realloc()
49 assert( pEnv ); in lsmMallocZero()
[all …]
H A Dlsm_win32.c114 lsm_env *pEnv, in win32RetryIoerr() argument
193 lsm_env *pEnv, in win32Open() argument
244 lsm_env *pEnv, in lsmWin32OsOpen() argument
262 pWin32File->pEnv = pEnv; in lsmWin32OsOpen()
460 lsm_env *pEnv, in lsmWin32OsFullpath() argument
544 lsm_env *pEnv, in win32Delete() argument
840 lsm_env *pEnv; member
858 lsm_env *pEnv, in lsmWin32OsMutexStatic() argument
887 pMutex->pEnv = pEnv; in lsmWin32OsMutexNew()
964 lsm_env *pEnv, in lsmWin32OsMutexStatic() argument
[all …]
H A Dlsm_mutex.c20 int lsmMutexNew(lsm_env *pEnv, lsm_mutex **ppNew){ in lsmMutexNew() argument
21 return pEnv->xMutexNew(pEnv, ppNew); in lsmMutexNew()
28 return pEnv->xMutexStatic(pEnv, iMutex, ppStatic); in lsmMutexStatic()
34 void lsmMutexDel(lsm_env *pEnv, lsm_mutex *pMutex){ in lsmMutexDel() argument
35 if( pMutex ) pEnv->xMutexDel(pMutex); in lsmMutexDel()
42 pEnv->xMutexEnter(pMutex); in lsmMutexEnter()
53 int lsmMutexTry(lsm_env *pEnv, lsm_mutex *pMutex){ in lsmMutexTry() argument
54 return pEnv->xMutexTry(pMutex); in lsmMutexTry()
61 pEnv->xMutexLeave(pMutex); in lsmMutexLeave()
74 return pEnv->xMutexHeld ? pEnv->xMutexHeld(pMutex) : 1; in lsmMutexHeld()
[all …]
H A Dlsm_shared.c75 lsmMutexLeave(pEnv, p); in leaveGlobalMutex()
82 return lsmMutexHeld(pEnv, p); in holdingGlobalMutex()
101 lsm_env *pEnv = db->pEnv; in freelistAppend() local
161 lsmFree(pEnv, p); in freeDatabase()
441 lsm_env *pEnv = pDb->pEnv; in lsmDbDatabaseConnect() local
447 rc = enterGlobalMutex(pEnv); in lsmDbDatabaseConnect()
495 freeDatabase(pEnv, p); in lsmDbDatabaseConnect()
503 leaveGlobalMutex(pEnv); in lsmDbDatabaseConnect()
791 lsmFree(pDb->pEnv, zFree); in lsmBlockAllocate()
995 lsmFree(pEnv, p); in lsmFreeSnapshot()
[all …]
H A Dlsm_file.c372 return pEnv->xOpen(pEnv, zFile, flags, ppNew); in lsmEnvOpen()
376 lsm_env *pEnv, in lsmEnvRead() argument
386 lsm_env *pEnv, in lsmEnvWrite() argument
412 return IOERR_WRAPPER( pEnv->xUnlink(pEnv, zDel) ); in lsmEnvUnlink()
416 lsm_env *pEnv, in lsmEnvRemap() argument
431 lsm_env *pEnv, in lsmEnvTestLock() argument
459 pEnv->xSleep(pEnv, nUs); in lsmEnvSleep()
642 pFS->pEnv = pDb->pEnv; in lsmFsOpen()
687 lsm_env *pEnv = pFS->pEnv; in lsmFsConfigure() local
756 lsm_env *pEnv = pFS->pEnv; in lsmFsClose() local
[all …]
H A Dlsm_unix.c76 lsm_env *pEnv, in lsmPosixOsOpen() argument
92 p->pEnv = pEnv; in lsmPosixOsOpen()
95 lsm_free(pEnv, p); in lsmPosixOsOpen()
244 lsm_env *pEnv, in lsmPosixOsFullpath() argument
274 lsmFree(pEnv, zTmp); in lsmPosixOsFullpath()
537 lsm_env *pEnv; member
551 lsm_env *pEnv, in lsmPosixOsMutexStatic() argument
574 pMutex->pEnv = pEnv; in lsmPosixOsMutexNew()
654 lsm_env *pEnv, in lsmPosixOsMutexStatic() argument
665 if( p ) p->pEnv = pEnv; in lsmPosixOsMutexNew()
[all …]
H A Dlsm_main.c77 if( pEnv==0 ) pEnv = lsm_default_env(); in lsm_new()
78 assert( pEnv ); in lsm_new()
85 pDb->pEnv = pEnv; in lsm_new()
106 assert( pDb->pEnv ); in lsm_get_env()
107 return pDb->pEnv; in lsm_get_env()
121 lsm_env *pEnv, in getFullpathname() argument
132 rc = pEnv->xFullpath(pEnv, zRel, zAlloc, &nReq); in getFullpathname()
139 lsmFree(pEnv, zAlloc); in getFullpathname()
203 lsmFree(pDb->pEnv, zFull); in lsm_open()
239 lsmFree(pDb->pEnv, pDb); in lsm_close()
[all …]
H A Dlsm_str.c20 void lsmStringInit(LsmString *pStr, lsm_env *pEnv){ in lsmStringInit() argument
22 pStr->pEnv = pEnv; in lsmStringInit()
37 char *zNew = lsmRealloc(pStr->pEnv, pStr->z, nAlloc); in lsmStringExtend()
39 lsmFree(pStr->pEnv, pStr->z); in lsmStringExtend()
54 lsmFree(pStr->pEnv, pStr->z); in lsmStringClear()
55 lsmStringInit(pStr, pStr->pEnv); in lsmStringClear()
137 char *lsmMallocPrintf(lsm_env *pEnv, const char *zFormat, ...){ in lsmMallocPrintf() argument
140 lsmStringInit(&s, pEnv); in lsmMallocPrintf()
147 return (char *)lsmReallocOrFree(pEnv, s.z, s.n+1); in lsmMallocPrintf()
H A Dlsm_sorted.c110 lsm_env *pEnv; member
375 assert( pBlob->pEnv==pEnv || (pBlob->pEnv==0 && pBlob->pData==0) ); in sortedBlobGrow()
380 pBlob->pEnv = pEnv; in sortedBlobGrow()
1116 lsm_env *pEnv = pDb->pEnv; /* Environment handle */ in sortedSplitkey() local
1719 lsm_env *pEnv = pCsr->pDb->pEnv; in segmentPtrSeek() local
2238 lsm_env *pEnv = pCsr->pDb->pEnv; in mcursorFreeComponents() local
3021 lsm_env *pEnv = pCsr->pDb->pEnv; in treeCursorSeek() local
3480 lsm_env *pEnv = pMW->pDb->pEnv; in mergeWorkerLoadHierarchy() local
4307 lsmFree(pEnv, p); in sortedFreeLevel()
5497 lsmFree(pEnv, z1); in segToString()
[all …]
H A Dlsm_ckpt.c210 lsm_env *pEnv; member
419 ckpt.pEnv = pDb->pEnv; in ckptExportSnapshot()
528 pMerge = (Merge *)lsmMallocZero(pDb->pEnv, nByte); in ckptSetupMerge()
603 lsmSortedFreeLevel(pDb->pEnv, pRet); in ckptLoadLevels()
618 aIn = lsmMallocRc(pDb->pEnv, nVal, &rc); in lsmCheckpointLoadLevels()
632 lsmFree(pDb->pEnv, aIn); in lsmCheckpointLoadLevels()
675 ckpt.pEnv = pDb->pEnv; in lsmCheckpointLevels()
766 lsmFree(pDb->pEnv, aCkpt); in ckptTryLoad()
1034 lsmFreeSnapshot(pDb->pEnv, pNew); in lsmCheckpointDeserialize()
1094 lsmFree(pDb->pEnv, p); in lsmCheckpointSaveWorker()
[all …]
H A DlsmInt.h193 lsm_env *pEnv; /* Run-time environment */ member
339 lsm_env *pEnv; /* runtime environment */ member
673 void *lsmMallocZero(lsm_env *pEnv, size_t);
674 char *lsmMallocStrdup(lsm_env *pEnv, const char *);
776 int lsmEnvClose(lsm_env *pEnv, lsm_file *pFile);
777 int lsmEnvLock(lsm_env *pEnv, lsm_file *pFile, int iLock, int eLock);
778 int lsmEnvTestLock(lsm_env *pEnv, lsm_file *pFile, int iLock, int nLock, int);
811 void lsmSortedFreeLevel(lsm_env *pEnv, Level *);
957 int lsmFreelistAppend(lsm_env *pEnv, Freelist *p, int iBlk, i64 iId);
971 void lsmStringInit(LsmString*, lsm_env *pEnv);
H A Dlsm_log.c375 pNew = lsmMallocZeroRc(pDb->pEnv, sizeof(LogWriter), &rc); in lsmLogBegin()
377 lsmStringInit(&pNew->buf, pDb->pEnv); in lsmLogBegin()
810 zVal = lsmMallocPrintf(pDb->pEnv, in lsmInfoLogStructure()
955 if( bInitBuf ){ lsmStringInit(&p->buf, pDb->pEnv); } in logReaderInit()
995 lsmStringInit(&buf1, pDb->pEnv); in lsmLogRecover()
996 lsmStringInit(&buf2, pDb->pEnv); in lsmLogRecover()
1152 lsmFree(db->pEnv, db->pLogWriter->buf.z); in lsmLogClose()
1153 lsmFree(db->pEnv, db->pLogWriter); in lsmLogClose()
H A Dlsm_tree.c205 lsmFree(pDb->pEnv, p->a); in tblobGrow()
206 p->a = lsmMallocRc(pDb->pEnv, n, pRc); in tblobGrow()
212 lsmFree(pDb->pEnv, p->a); in tblobFree()
227 aNew = lsmRealloc(pEnv, p->aArray, nNew*sizeof(u32)); in intArrayAppend()
240 static void intArrayFree(lsm_env *pEnv, IntArray *p){ in intArrayFree() argument
503 lsmStringInit(&s, pDb->pEnv); in dump_node_contents()
531 lsmStringInit(&s, pDb->pEnv); in dump_node_contents()
1285 aSort = lsmMallocZeroRc(db->pEnv, nByte, &rc); in treeRepairList()
1325 lsmFree(db->pEnv, aSort); in treeRepairList()
1937 lsmFree(pCsr->pDb->pEnv, pCsr); in lsmTreeCursorDestroy()
[all …]
/sqlite-3.40.0/ext/lsm1/lsm-test/
H A Dlsmtest_mem.c309 lsm_env *pEnv; member
342 assert( pEnv->pMemCtx==0 ); in testMallocInstall()
351 pMutex->pEnv = pEnv; in testMallocInstall()
352 pEnv->xMutexStatic(pEnv, LSM_MUTEX_HEAP, &pMutex->pMutex); in testMallocInstall()
364 pEnv->xMalloc = tmLsmEnvMalloc; in testMallocInstall()
366 pEnv->xFree = tmLsmEnvFree; in testMallocInstall()
371 pEnv->pMemCtx = 0; in testMallocUninstall()
375 pEnv->xFree = p->xSaveFree; in testMallocUninstall()
382 lsm_env *pEnv, in testMallocCheck() argument
387 if( pEnv->pMemCtx==0 ){ in testMallocCheck()
[all …]
H A Dlsmtest_tdb4.c53 sqlite4_env *pEnv; /* SQLite environment (for malloc/free) */ member
73 sqlite4_env *pEnv, in btVfsFullpath() argument
80 return pBt->pVfs->xFullpath(pEnv, pBt->pVfs, z, pzOut); in btVfsFullpath()
84 sqlite4_env *pEnv, in btVfsOpen() argument
107 rc = pBt->pVfs->xOpen(pEnv, pVfs, zFile, flags, &p->pFile); in btVfsOpen()
292 static int btVfsUnlink(sqlite4_env *pEnv, bt_env *pVfs, const char *zFile){ in btVfsUnlink() argument
295 return pBt->pVfs->xUnlink(pEnv, pBt->pVfs, zFile); in btVfsUnlink()
704 sqlite4_env *pEnv = sqlite4_env_default(); in test_bt_open() local
713 rc = sqlite4BtNew(pEnv, 0, &pBt); in test_bt_open()
720 p->pEnv = pEnv; in test_bt_open()
[all …]
H A Dlsmtest.h152 void testMallocInstall(lsm_env *pEnv);
153 void testMallocUninstall(lsm_env *pEnv);
154 void testMallocCheck(lsm_env *pEnv, int *, int *, FILE *);
155 void testMallocOom(lsm_env *pEnv, int, int, void(*)(void*), void *);
156 void testMallocOomEnable(lsm_env *pEnv, int);
H A Dlsmtest_tdb3.c151 lsm_env *pEnv, /* Environment for current LsmDb */ in testEnvFullpath() argument
161 lsm_env *pEnv, /* Environment for current LsmDb */ in testEnvOpen() argument
167 LsmDb *pDb = (LsmDb *)pEnv->pVfsCtx; in testEnvOpen()
340 static int testEnvUnlink(lsm_env *pEnv, const char *zFile){ in testEnvUnlink() argument
342 unused_parameter(pEnv); in testEnvUnlink()
381 static int testEnvSleep(lsm_env *pEnv, int us){ in testEnvSleep() argument
387 lsm_env *pEnv = tdb_lsm_env(); in doSystemCrash() local
398 pEnv->xOpen(pEnv, zFile, 0, &pFile); in doSystemCrash()
412 pEnv->xWrite( in doSystemCrash()
421 pEnv->xClose(pFile); in doSystemCrash()
H A Dlsmtest6.c6 lsm_env *pEnv; member
18 p->pEnv = tdb_lsm_env(); in testOomStart()
30 testMallocOom(p->pEnv, p->iNext, 0, (void (*)(void*))xOomHook, (void *)p); in testOomContinue()
36 testMallocOomEnable(p->pEnv, bEnable); in testOomEnable()
H A Dlsmtest_main.c1351 lsm_env *pEnv; in do_replay() local
1366 pEnv = tdb_lsm_env(); in do_replay()
1367 rc = pEnv->xOpen(pEnv, zDb, 0, &pOut); in do_replay()
1376 rc = pEnv->xSync(pOut); in do_replay()
1387 rc = pEnv->xWrite(pOut, iOff+i, aBuf, sizeof(aBuf)); in do_replay()
1394 pEnv->xClose(pOut); in do_replay()