Home
last modified time | relevance | path

Searched refs:eLock (Results 1 – 23 of 23) sorted by relevance

/sqlite-3.40.0/ext/async/
H A Dsqlite3async.c487 int eLock; member
632 p->lock.eLock = 0; in asyncClose()
868 if( p->lock.eLock<eLock ){ in asyncLock()
874 (eLock==SQLITE_LOCK_EXCLUSIVE && pIter->eLock>=SQLITE_LOCK_SHARED) || in asyncLock()
875 (eLock==SQLITE_LOCK_PENDING && pIter->eLock>=SQLITE_LOCK_RESERVED) || in asyncLock()
876 (eLock==SQLITE_LOCK_RESERVED && pIter->eLock>=SQLITE_LOCK_RESERVED) || in asyncLock()
877 (eLock==SQLITE_LOCK_SHARED && pIter->eLock>=SQLITE_LOCK_PENDING) in asyncLock()
883 p->lock.eLock = eLock; in asyncLock()
904 pLock->eLock = MIN(pLock->eLock, eLock); in asyncUnlock()
1461 int eLock = p->nByte; in asyncWriterThread() local
[all …]
/sqlite-3.40.0/src/
H A Dtest_journal.c118 int eLock; /* Current lock held on the file */ member
300 && ((pMain->eLock>=SQLITE_LOCK_RESERVED) || noLock) in locateDatabaseHandle()
638 static int jtLock(sqlite3_file *pFile, int eLock){ in jtLock() argument
641 rc = sqlite3OsLock(p->pReal, eLock); in jtLock()
642 if( rc==SQLITE_OK && eLock>p->eLock ){ in jtLock()
643 p->eLock = eLock; in jtLock()
651 static int jtUnlock(sqlite3_file *pFile, int eLock){ in jtUnlock() argument
654 rc = sqlite3OsUnlock(p->pReal, eLock); in jtUnlock()
655 if( rc==SQLITE_OK && eLock<p->eLock ){ in jtUnlock()
656 p->eLock = eLock; in jtUnlock()
[all …]
H A Dpager.c1138 assert( !pPager->exclusiveMode || pPager->eLock==eLock ); in pagerUnlockDb()
1139 assert( eLock==NO_LOCK || eLock==SHARED_LOCK ); in pagerUnlockDb()
1142 assert( pPager->eLock>=eLock ); in pagerUnlockDb()
1145 pPager->eLock = (u8)eLock; in pagerUnlockDb()
1166 assert( eLock==SHARED_LOCK || eLock==RESERVED_LOCK || eLock==EXCLUSIVE_LOCK ); in pagerLockDb()
1167 if( pPager->eLock<eLock || pPager->eLock==UNKNOWN_LOCK ){ in pagerLockDb()
1169 if( rc==SQLITE_OK && (pPager->eLock!=UNKNOWN_LOCK||eLock==EXCLUSIVE_LOCK) ){ in pagerLockDb()
1170 pPager->eLock = (u8)eLock; in pagerLockDb()
5221 assert( pPager->eLock==NO_LOCK || pPager->eLock==UNKNOWN_LOCK ); in sqlite3PagerSharedLock()
7480 assert( pPager->eLock==SHARED_LOCK || pPager->eLock==EXCLUSIVE_LOCK ); in pagerExclusiveLock()
[all …]
H A Dmemdb.c88 int eLock; /* Most recent lock against this file */ member
367 static int memdbLock(sqlite3_file *pFile, int eLock){ in memdbLock() argument
371 if( eLock==pThis->eLock ) return SQLITE_OK; in memdbLock()
373 if( eLock>SQLITE_LOCK_SHARED ){ in memdbLock()
376 }else if( pThis->eLock<=SQLITE_LOCK_SHARED ){ in memdbLock()
383 }else if( eLock==SQLITE_LOCK_SHARED ){ in memdbLock()
384 if( pThis->eLock > SQLITE_LOCK_SHARED ){ in memdbLock()
393 assert( eLock==SQLITE_LOCK_NONE ); in memdbLock()
394 if( pThis->eLock>SQLITE_LOCK_SHARED ){ in memdbLock()
401 if( rc==SQLITE_OK ) pThis->eLock = eLock; in memdbLock()
H A Dtest_vfstrace.c398 static const char *lockName(int eLock){ in lockName() argument
402 if( eLock<0 || eLock>=sizeof(azLockNames)/sizeof(azLockNames[0]) ){ in lockName()
405 return azLockNames[eLock]; in lockName()
412 static int vfstraceLock(sqlite3_file *pFile, int eLock){ in vfstraceLock() argument
417 lockName(eLock)); in vfstraceLock()
418 rc = p->pReal->pMethods->xLock(p->pReal, eLock); in vfstraceLock()
426 static int vfstraceUnlock(sqlite3_file *pFile, int eLock){ in vfstraceUnlock() argument
431 lockName(eLock)); in vfstraceUnlock()
432 rc = p->pReal->pMethods->xUnlock(p->pReal, eLock); in vfstraceUnlock()
H A Dos_kv.c735 static int kvvfsLock(sqlite3_file *pProtoFile, int eLock){ in kvvfsLock() argument
738 SQLITE_KV_LOG(("xLock(%s,%d)\n", pFile->zClass, eLock)); in kvvfsLock()
740 if( eLock!=SQLITE_LOCK_NONE ){ in kvvfsLock()
749 static int kvvfsUnlock(sqlite3_file *pProtoFile, int eLock){ in kvvfsUnlock() argument
752 SQLITE_KV_LOG(("xUnlock(%s,%d)\n", pFile->zClass, eLock)); in kvvfsUnlock()
753 if( eLock==SQLITE_LOCK_NONE ){ in kvvfsUnlock()
H A Dtest_devsym.c146 static int devsymLock(sqlite3_file *pFile, int eLock){ in devsymLock() argument
148 return sqlite3OsLock(p->pReal, eLock); in devsymLock()
154 static int devsymUnlock(sqlite3_file *pFile, int eLock){ in devsymUnlock() argument
156 return sqlite3OsUnlock(p->pReal, eLock); in devsymUnlock()
H A Dtest_osinst.c353 static int vfslogLock(sqlite3_file *pFile, int eLock){ in vfslogLock() argument
358 rc = p->pReal->pMethods->xLock(p->pReal, eLock); in vfslogLock()
360 vfslog_call(p->pVfslog, OS_LOCK, p->iFileId, t, rc, eLock, 0); in vfslogLock()
367 static int vfslogUnlock(sqlite3_file *pFile, int eLock){ in vfslogUnlock() argument
372 rc = p->pReal->pMethods->xUnlock(p->pReal, eLock); in vfslogUnlock()
374 vfslog_call(p->pVfslog, OS_UNLOCK, p->iFileId, t, rc, eLock, 0); in vfslogUnlock()
H A Dtest_onefile.c332 static int tmpLock(sqlite3_file *pFile, int eLock){ in tmpLock() argument
339 static int tmpUnlock(sqlite3_file *pFile, int eLock){ in tmpUnlock() argument
540 static int fsLock(sqlite3_file *pFile, int eLock){ in fsLock() argument
547 static int fsUnlock(sqlite3_file *pFile, int eLock){ in fsUnlock() argument
H A Dtest6.c514 static int cfLock(sqlite3_file *pFile, int eLock){ in cfLock() argument
515 return sqlite3OsLock(((CrashFile *)pFile)->pRealFile, eLock); in cfLock()
517 static int cfUnlock(sqlite3_file *pFile, int eLock){ in cfUnlock() argument
518 return sqlite3OsUnlock(((CrashFile *)pFile)->pRealFile, eLock); in cfUnlock()
H A Dtest_vfs.c479 static int tvfsLock(sqlite3_file *pFile, int eLock){ in tvfsLock() argument
484 sqlite3_snprintf(sizeof(zLock),zLock,"%d",eLock); in tvfsLock()
488 return sqlite3OsLock(pFd->pReal, eLock); in tvfsLock()
494 static int tvfsUnlock(sqlite3_file *pFile, int eLock){ in tvfsUnlock() argument
499 sqlite3_snprintf(sizeof(zLock),zLock,"%d",eLock); in tvfsUnlock()
506 return sqlite3OsUnlock(pFd->pReal, eLock); in tvfsUnlock()
H A Dtest_demovfs.c360 static int demoLock(sqlite3_file *pFile, int eLock){ in demoLock() argument
363 static int demoUnlock(sqlite3_file *pFile, int eLock){ in demoUnlock() argument
H A Dbtree.c238 && pLock->eLock>=eLockType in hasSharedCacheTableLock()
293 assert( eLock==READ_LOCK || eLock==WRITE_LOCK ); in querySharedCacheTableLock()
327 assert( pIter->eLock==READ_LOCK || pIter->eLock==WRITE_LOCK ); in querySharedCacheTableLock()
328 assert( eLock==READ_LOCK || pIter->pBtree==p || pIter->eLock==READ_LOCK); in querySharedCacheTableLock()
329 if( pIter->pBtree!=p && pIter->iTable==iTab && pIter->eLock!=eLock ){ in querySharedCacheTableLock()
331 if( eLock==WRITE_LOCK ){ in querySharedCacheTableLock()
366 assert( eLock==READ_LOCK || eLock==WRITE_LOCK ); in setSharedCacheTableLock()
407 if( eLock>pLock->eLock ){ in setSharedCacheTableLock()
408 pLock->eLock = eLock; in setSharedCacheTableLock()
476 pLock->eLock = READ_LOCK; in downgradeAllSharedCacheTableLocks()
[all …]
H A DbtreeInt.h316 u8 eLock; /* READ_LOCK or WRITE_LOCK */ member
/sqlite-3.40.0/ext/misc/
H A Dvfslog.c508 static int vlogLock(sqlite3_file *pFile, int eLock){ in vlogLock() argument
513 rc = p->pReal->pMethods->xLock(p->pReal, eLock); in vlogLock()
515 vlogLogPrint(p->pLog, tStart, tElapse, "LOCK", eLock, -1, 0, rc); in vlogLock()
522 static int vlogUnlock(sqlite3_file *pFile, int eLock){ in vlogUnlock() argument
527 vlogLogPrint(p->pLog, tStart, 0, "UNLOCK", eLock, -1, 0, 0); in vlogUnlock()
528 rc = p->pReal->pMethods->xUnlock(p->pReal, eLock); in vlogUnlock()
H A Dappendvfs.c328 static int apndLock(sqlite3_file *pFile, int eLock){ in apndLock() argument
330 return pFile->pMethods->xLock(pFile, eLock); in apndLock()
336 static int apndUnlock(sqlite3_file *pFile, int eLock){ in apndUnlock() argument
338 return pFile->pMethods->xUnlock(pFile, eLock); in apndUnlock()
H A Dvfsstat.c321 static int vstatLock(sqlite3_file *pFile, int eLock){ in vstatLock() argument
324 rc = p->pReal->pMethods->xLock(p->pReal, eLock); in vstatLock()
332 static int vstatUnlock(sqlite3_file *pFile, int eLock){ in vstatUnlock() argument
335 rc = p->pReal->pMethods->xUnlock(p->pReal, eLock); in vstatUnlock()
H A Dcksumvfs.c527 static int cksmLock(sqlite3_file *pFile, int eLock){ in cksmLock() argument
529 return pFile->pMethods->xLock(pFile, eLock); in cksmLock()
535 static int cksmUnlock(sqlite3_file *pFile, int eLock){ in cksmUnlock() argument
537 return pFile->pMethods->xUnlock(pFile, eLock); in cksmUnlock()
H A Dmemvfs.c229 static int memLock(sqlite3_file *pFile, int eLock){ in memLock() argument
236 static int memUnlock(sqlite3_file *pFile, int eLock){ in memUnlock() argument
/sqlite-3.40.0/ext/recover/
H A Dsqlite3recover.c2449 static int recoverVfsLock(sqlite3_file *pFd, int eLock){ in recoverVfsLock() argument
2451 pFd->pMethods->xLock(pFd, eLock) in recoverVfsLock()
2454 static int recoverVfsUnlock(sqlite3_file *pFd, int eLock){ in recoverVfsUnlock() argument
2456 pFd->pMethods->xUnlock(pFd, eLock) in recoverVfsUnlock()
/sqlite-3.40.0/ext/lsm1/
H A Dlsm_file.c425 int lsmEnvLock(lsm_env *pEnv, lsm_file *pFile, int iLock, int eLock){ in lsmEnvLock() argument
427 return pEnv->xLock(pFile, iLock, eLock); in lsmEnvLock()
435 int eLock in lsmEnvTestLock() argument
437 return pEnv->xTestLock(pFile, iLock, nLock, eLock); in lsmEnvTestLock()
H A DlsmInt.h777 int lsmEnvLock(lsm_env *pEnv, lsm_file *pFile, int iLock, int eLock);
/sqlite-3.40.0/ext/rbu/
H A Dsqlite3rbu.c4791 static int rbuVfsLock(sqlite3_file *pFile, int eLock){ in rbuVfsLock() argument
4797 if( eLock==SQLITE_LOCK_EXCLUSIVE in rbuVfsLock()
4804 rc = p->pReal->pMethods->xLock(p->pReal, eLock); in rbuVfsLock()
4813 static int rbuVfsUnlock(sqlite3_file *pFile, int eLock){ in rbuVfsUnlock() argument
4815 return p->pReal->pMethods->xUnlock(p->pReal, eLock); in rbuVfsUnlock()