contrib/sqlite3/sqlite3.c

38599 static int kvvfsLock(sqlite3_file *pProtoFile, int eLock){  in kvvfsLock()  argument
38602   SQLITE_KV_LOG(("xLock(%s,%d)\n", pFile->zClass, eLock));  in kvvfsLock()
38604   if( eLock!=SQLITE_LOCK_NONE ){  in kvvfsLock()
38613 static int kvvfsUnlock(sqlite3_file *pProtoFile, int eLock){  in kvvfsUnlock()  argument
38616   SQLITE_KV_LOG(("xUnlock(%s,%d)\n", pFile->zClass, eLock));  in kvvfsUnlock()
38617   if( eLock==SQLITE_LOCK_NONE ){  in kvvfsUnlock()
53902   int eLock;                      /* Most recent lock against this file */  member
54182 static int memdbLock(sqlite3_file *pFile, int eLock){
54186   if( eLock<=pThis->eLock ) return SQLITE_OK;
54190   assert( pThis->eLock<=SQLITE_LOCK_SHARED || p->nWrLock==1 );
54191   assert( pThis->eLock==SQLITE_LOCK_NONE || p->nRdLock>=1 );
54193   if( eLock>SQLITE_LOCK_SHARED && (p->mFlags & SQLITE_DESERIALIZE_READONLY) ){
54196     switch( eLock ){
54198         assert( pThis->eLock==SQLITE_LOCK_NONE );
54209         assert( pThis->eLock>=SQLITE_LOCK_SHARED );
54210         if( ALWAYS(pThis->eLock==SQLITE_LOCK_SHARED) ){
54221         assert(  eLock==SQLITE_LOCK_EXCLUSIVE );
54222         assert( pThis->eLock>=SQLITE_LOCK_SHARED );
54225         }else if( pThis->eLock==SQLITE_LOCK_SHARED ){
54232   if( rc==SQLITE_OK ) pThis->eLock = eLock;
54240 static int memdbUnlock(sqlite3_file *pFile, int eLock){
54243   if( eLock>=pThis->eLock ) return SQLITE_OK;
54246   assert( eLock==SQLITE_LOCK_SHARED || eLock==SQLITE_LOCK_NONE );
54247   if( eLock==SQLITE_LOCK_SHARED ){
54248     if( ALWAYS(pThis->eLock>SQLITE_LOCK_SHARED) ){
54252     if( pThis->eLock>SQLITE_LOCK_SHARED ){
54258   pThis->eLock = eLock;
58703   u8 eLock;                   /* Current lock held on database file */  member
58920   assert( p->tempFile==0 || p->eLock==EXCLUSIVE_LOCK );
58950   assert( pPager->changeCountDone==0 || pPager->eLock>=RESERVED_LOCK );
58951   assert( p->eLock!=PENDING_LOCK );
58962       assert( p->eLock!=UNKNOWN_LOCK );
58963       assert( p->eLock>=SHARED_LOCK );
58967       assert( p->eLock!=UNKNOWN_LOCK );
58970         assert( p->eLock>=RESERVED_LOCK );
58979       assert( p->eLock!=UNKNOWN_LOCK );
58987         assert( p->eLock>=RESERVED_LOCK );
58998       assert( p->eLock==EXCLUSIVE_LOCK );
59001       assert( p->eLock>=EXCLUSIVE_LOCK );
59011       assert( p->eLock==EXCLUSIVE_LOCK );
59069       , p->eLock==NO_LOCK         ? "NO_LOCK" :
59070         p->eLock==RESERVED_LOCK   ? "RESERVED" :
59071         p->eLock==EXCLUSIVE_LOCK  ? "EXCLUSIVE" :
59072         p->eLock==SHARED_LOCK     ? "SHARED" :
59073         p->eLock==UNKNOWN_LOCK    ? "UNKNOWN" : "?error?"
59189 static int pagerUnlockDb(Pager *pPager, int eLock){
59192   assert( !pPager->exclusiveMode || pPager->eLock==eLock );
59193   assert( eLock==NO_LOCK || eLock==SHARED_LOCK );
59194   assert( eLock!=NO_LOCK || pagerUseWal(pPager)==0 );
59196     assert( pPager->eLock>=eLock );
59197     rc = pPager->noLock ? SQLITE_OK : sqlite3OsUnlock(pPager->fd, eLock);
59198     if( pPager->eLock!=UNKNOWN_LOCK ){
59199       pPager->eLock = (u8)eLock;
59201     IOTRACE(("UNLOCK %p %d\n", pPager, eLock))
59217 static int pagerLockDb(Pager *pPager, int eLock){
59220   assert( eLock==SHARED_LOCK || eLock==RESERVED_LOCK || eLock==EXCLUSIVE_LOCK );
59221   if( pPager->eLock<eLock || pPager->eLock==UNKNOWN_LOCK ){
59222     rc = pPager->noLock ? SQLITE_OK : sqlite3OsLock(pPager->fd, eLock);
59223     if( rc==SQLITE_OK && (pPager->eLock!=UNKNOWN_LOCK||eLock==EXCLUSIVE_LOCK) ){
59224       pPager->eLock = (u8)eLock;
59225       IOTRACE(("LOCK %p %d\n", pPager, eLock))
59949       pPager->eLock = UNKNOWN_LOCK;
60116   if( pPager->eState<PAGER_WRITER_LOCKED && pPager->eLock<RESERVED_LOCK ){
60207     assert( pPager->eLock==EXCLUSIVE_LOCK );
60266     u8 eLock = pPager->eLock;  local
60269     pPager->eLock = EXCLUSIVE_LOCK;
60272     pPager->eLock = eLock;
60374        || (pPager->eState==PAGER_OPEN && pPager->eLock==EXCLUSIVE_LOCK)
60723     assert( pPager->eLock==EXCLUSIVE_LOCK );
61345   assert( pPager->eLock>=SHARED_LOCK );
61398   assert( pPager->eLock>=SHARED_LOCK );
61997   assert( (pPager->eLock>=locktype)
61998        || (pPager->eLock==NO_LOCK && locktype==SHARED_LOCK)
61999        || (pPager->eLock==RESERVED_LOCK && locktype==EXCLUSIVE_LOCK)
62476   assert( pPager->eLock==EXCLUSIVE_LOCK );
63049     pPager->eLock = EXCLUSIVE_LOCK;    /* Pretend we are in EXCLUSIVE mode */
63311     assert( pPager->tempFile==0 || pPager->eLock==EXCLUSIVE_LOCK );
63315       assert( pPager->eLock==NO_LOCK || pPager->eLock==UNKNOWN_LOCK );
63322     if( pPager->eLock<=SHARED_LOCK ){
63426       assert( (pPager->eLock==SHARED_LOCK)
63427            || (pPager->exclusiveMode && pPager->eLock>SHARED_LOCK)
65457       if( pPager->eLock>=RESERVED_LOCK ){
65604   assert( pPager->eLock>=SHARED_LOCK );
65605   eOrigLock = pPager->eLock;
65626   assert( pPager->eLock==SHARED_LOCK || pPager->eLock==EXCLUSIVE_LOCK );
70832   u8 eLock;             /* READ_LOCK or WRITE_LOCK */  member
71735            pLock->eLock==READ_LOCK ? "R" : "W");
71738       printf(",%u%s", pLock->iTable, pLock->eLock==READ_LOCK ? "R" : "W");
71831      && (pLock->iTable==iTab || (pLock->eLock==WRITE_LOCK && pLock->iTable==1))
71832      && pLock->eLock>=eLockType
71882 static int querySharedCacheTableLock(Btree *p, Pgno iTab, u8 eLock){
71887   assert( eLock==READ_LOCK || eLock==WRITE_LOCK );
71889   assert( !(p->db->flags&SQLITE_ReadUncommit)||eLock==WRITE_LOCK||iTab==1 );
71895   assert( eLock==READ_LOCK || (p==pBt->pWriter && p->inTrans==TRANS_WRITE) );
71896   assert( eLock==READ_LOCK || pBt->inTransaction==TRANS_WRITE );
71921     assert( pIter->eLock==READ_LOCK || pIter->eLock==WRITE_LOCK );
71922     assert( eLock==READ_LOCK || pIter->pBtree==p || pIter->eLock==READ_LOCK);
71923     if( pIter->pBtree!=p && pIter->iTable==iTab && pIter->eLock!=eLock ){
71925       if( eLock==WRITE_LOCK ){
71954 static int setSharedCacheTableLock(Btree *p, Pgno iTable, u8 eLock){
71959   SHARED_LOCK_TRACE(pBt,"setLock", iTable, eLock);
71962   assert( eLock==READ_LOCK || eLock==WRITE_LOCK );
71969   assert( 0==(p->db->flags&SQLITE_ReadUncommit) || eLock==WRITE_LOCK );
71974   assert( SQLITE_OK==querySharedCacheTableLock(p, iTable, eLock) );
72003   if( eLock>pLock->eLock ){
72004     pLock->eLock = eLock;
72033     assert( pLock->pBtree->inTrans>=pLock->eLock );
72076       assert( pLock->eLock==READ_LOCK || pLock->pBtree==p );
72077       pLock->eLock = READ_LOCK;
75273         p->lock.eLock = READ_LOCK;
226112 static int rbuVfsLock(sqlite3_file *pFile, int eLock){
226118   if( eLock==SQLITE_LOCK_EXCLUSIVE
226125     rc = p->pReal->pMethods->xLock(p->pReal, eLock);
226134 static int rbuVfsUnlock(sqlite3_file *pFile, int eLock){
226136   return p->pReal->pMethods->xUnlock(p->pReal, eLock);