Lines Matching refs:eLock
38114 static int kvvfsLock(sqlite3_file *pProtoFile, int eLock){
38117 SQLITE_KV_LOG(("xLock(%s,%d)\n", pFile->zClass, eLock));
38119 if( eLock!=SQLITE_LOCK_NONE ){
38128 static int kvvfsUnlock(sqlite3_file *pProtoFile, int eLock){
38131 SQLITE_KV_LOG(("xUnlock(%s,%d)\n", pFile->zClass, eLock));
38132 if( eLock==SQLITE_LOCK_NONE ){
52953 int eLock; /* Most recent lock against this file */
53233 static int memdbLock(sqlite3_file *pFile, int eLock){
53237 if( eLock<=pThis->eLock ) return SQLITE_OK;
53241 assert( pThis->eLock<=SQLITE_LOCK_SHARED || p->nWrLock==1 );
53242 assert( pThis->eLock==SQLITE_LOCK_NONE || p->nRdLock>=1 );
53244 if( eLock>SQLITE_LOCK_SHARED && (p->mFlags & SQLITE_DESERIALIZE_READONLY) ){
53247 switch( eLock ){
53249 assert( pThis->eLock==SQLITE_LOCK_NONE );
53260 assert( pThis->eLock>=SQLITE_LOCK_SHARED );
53261 if( ALWAYS(pThis->eLock==SQLITE_LOCK_SHARED) ){
53272 assert( eLock==SQLITE_LOCK_EXCLUSIVE );
53273 assert( pThis->eLock>=SQLITE_LOCK_SHARED );
53276 }else if( pThis->eLock==SQLITE_LOCK_SHARED ){
53283 if( rc==SQLITE_OK ) pThis->eLock = eLock;
53291 static int memdbUnlock(sqlite3_file *pFile, int eLock){
53294 if( eLock>=pThis->eLock ) return SQLITE_OK;
53297 assert( eLock==SQLITE_LOCK_SHARED || eLock==SQLITE_LOCK_NONE );
53298 if( eLock==SQLITE_LOCK_SHARED ){
53299 if( ALWAYS(pThis->eLock>SQLITE_LOCK_SHARED) ){
53303 if( pThis->eLock>SQLITE_LOCK_SHARED ){
53309 pThis->eLock = eLock;
57753 u8 eLock; /* Current lock held on database file */
57973 assert( p->tempFile==0 || p->eLock==EXCLUSIVE_LOCK );
58003 assert( pPager->changeCountDone==0 || pPager->eLock>=RESERVED_LOCK );
58004 assert( p->eLock!=PENDING_LOCK );
58015 assert( p->eLock!=UNKNOWN_LOCK );
58016 assert( p->eLock>=SHARED_LOCK );
58020 assert( p->eLock!=UNKNOWN_LOCK );
58023 assert( p->eLock>=RESERVED_LOCK );
58032 assert( p->eLock!=UNKNOWN_LOCK );
58040 assert( p->eLock>=RESERVED_LOCK );
58051 assert( p->eLock==EXCLUSIVE_LOCK );
58054 assert( p->eLock>=EXCLUSIVE_LOCK );
58064 assert( p->eLock==EXCLUSIVE_LOCK );
58122 , p->eLock==NO_LOCK ? "NO_LOCK" :
58123 p->eLock==RESERVED_LOCK ? "RESERVED" :
58124 p->eLock==EXCLUSIVE_LOCK ? "EXCLUSIVE" :
58125 p->eLock==SHARED_LOCK ? "SHARED" :
58126 p->eLock==UNKNOWN_LOCK ? "UNKNOWN" : "?error?"
58242 static int pagerUnlockDb(Pager *pPager, int eLock){
58245 assert( !pPager->exclusiveMode || pPager->eLock==eLock );
58246 assert( eLock==NO_LOCK || eLock==SHARED_LOCK );
58247 assert( eLock!=NO_LOCK || pagerUseWal(pPager)==0 );
58249 assert( pPager->eLock>=eLock );
58250 rc = pPager->noLock ? SQLITE_OK : sqlite3OsUnlock(pPager->fd, eLock);
58251 if( pPager->eLock!=UNKNOWN_LOCK ){
58252 pPager->eLock = (u8)eLock;
58254 IOTRACE(("UNLOCK %p %d\n", pPager, eLock))
58270 static int pagerLockDb(Pager *pPager, int eLock){
58273 assert( eLock==SHARED_LOCK || eLock==RESERVED_LOCK || eLock==EXCLUSIVE_LOCK );
58274 if( pPager->eLock<eLock || pPager->eLock==UNKNOWN_LOCK ){
58275 rc = pPager->noLock ? SQLITE_OK : sqlite3OsLock(pPager->fd, eLock);
58276 if( rc==SQLITE_OK && (pPager->eLock!=UNKNOWN_LOCK||eLock==EXCLUSIVE_LOCK) ){
58277 pPager->eLock = (u8)eLock;
58278 IOTRACE(("LOCK %p %d\n", pPager, eLock))
58993 pPager->eLock = UNKNOWN_LOCK;
59160 if( pPager->eState<PAGER_WRITER_LOCKED && pPager->eLock<RESERVED_LOCK ){
59251 assert( pPager->eLock==EXCLUSIVE_LOCK );
59310 u8 eLock = pPager->eLock;
59313 pPager->eLock = EXCLUSIVE_LOCK;
59316 pPager->eLock = eLock;
59418 || (pPager->eState==PAGER_OPEN && pPager->eLock==EXCLUSIVE_LOCK)
59764 assert( pPager->eLock==EXCLUSIVE_LOCK );
60386 assert( pPager->eLock>=SHARED_LOCK );
60439 assert( pPager->eLock>=SHARED_LOCK );
61038 assert( (pPager->eLock>=locktype)
61039 || (pPager->eLock==NO_LOCK && locktype==SHARED_LOCK)
61040 || (pPager->eLock==RESERVED_LOCK && locktype==EXCLUSIVE_LOCK)
61516 assert( pPager->eLock==EXCLUSIVE_LOCK );
62088 pPager->eLock = EXCLUSIVE_LOCK; /* Pretend we are in EXCLUSIVE mode */
62350 assert( pPager->tempFile==0 || pPager->eLock==EXCLUSIVE_LOCK );
62354 assert( pPager->eLock==NO_LOCK || pPager->eLock==UNKNOWN_LOCK );
62361 if( pPager->eLock<=SHARED_LOCK ){
62465 assert( (pPager->eLock==SHARED_LOCK)
62466 || (pPager->exclusiveMode && pPager->eLock>SHARED_LOCK)
64496 if( pPager->eLock>=RESERVED_LOCK ){
64643 assert( pPager->eLock>=SHARED_LOCK );
64644 eOrigLock = pPager->eLock;
64665 assert( pPager->eLock==SHARED_LOCK || pPager->eLock==EXCLUSIVE_LOCK );
69828 u8 eLock; /* READ_LOCK or WRITE_LOCK */
70725 pLock->eLock==READ_LOCK ? "R" : "W");
70728 printf(",%u%s", pLock->iTable, pLock->eLock==READ_LOCK ? "R" : "W");
70821 && (pLock->iTable==iTab || (pLock->eLock==WRITE_LOCK && pLock->iTable==1))
70822 && pLock->eLock>=eLockType
70872 static int querySharedCacheTableLock(Btree *p, Pgno iTab, u8 eLock){
70877 assert( eLock==READ_LOCK || eLock==WRITE_LOCK );
70879 assert( !(p->db->flags&SQLITE_ReadUncommit)||eLock==WRITE_LOCK||iTab==1 );
70885 assert( eLock==READ_LOCK || (p==pBt->pWriter && p->inTrans==TRANS_WRITE) );
70886 assert( eLock==READ_LOCK || pBt->inTransaction==TRANS_WRITE );
70911 assert( pIter->eLock==READ_LOCK || pIter->eLock==WRITE_LOCK );
70912 assert( eLock==READ_LOCK || pIter->pBtree==p || pIter->eLock==READ_LOCK);
70913 if( pIter->pBtree!=p && pIter->iTable==iTab && pIter->eLock!=eLock ){
70915 if( eLock==WRITE_LOCK ){
70944 static int setSharedCacheTableLock(Btree *p, Pgno iTable, u8 eLock){
70949 SHARED_LOCK_TRACE(pBt,"setLock", iTable, eLock);
70952 assert( eLock==READ_LOCK || eLock==WRITE_LOCK );
70959 assert( 0==(p->db->flags&SQLITE_ReadUncommit) || eLock==WRITE_LOCK );
70964 assert( SQLITE_OK==querySharedCacheTableLock(p, iTable, eLock) );
70993 if( eLock>pLock->eLock ){
70994 pLock->eLock = eLock;
71023 assert( pLock->pBtree->inTrans>=pLock->eLock );
71066 assert( pLock->eLock==READ_LOCK || pLock->pBtree==p );
71067 pLock->eLock = READ_LOCK;
74250 p->lock.eLock = READ_LOCK;
222931 static int rbuVfsLock(sqlite3_file *pFile, int eLock){
222937 if( eLock==SQLITE_LOCK_EXCLUSIVE
222944 rc = p->pReal->pMethods->xLock(p->pReal, eLock);
222953 static int rbuVfsUnlock(sqlite3_file *pFile, int eLock){
222955 return p->pReal->pMethods->xUnlock(p->pReal, eLock);