Lines Matching refs:pBtree
180 Btree *pBtree, /* Handle that must hold lock */ in hasSharedCacheTableLock() argument
185 Schema *pSchema = (Schema *)pBtree->pBt->pSchema; in hasSharedCacheTableLock()
193 if( (pBtree->sharable==0) in hasSharedCacheTableLock()
194 || (eLockType==READ_LOCK && (pBtree->db->flags & SQLITE_ReadUncommit)) in hasSharedCacheTableLock()
235 for(pLock=pBtree->pBt->pLock; pLock; pLock=pLock->pNext){ in hasSharedCacheTableLock()
236 if( pLock->pBtree==pBtree in hasSharedCacheTableLock()
268 static int hasReadConflicts(Btree *pBtree, Pgno iRoot){ in hasReadConflicts() argument
270 for(p=pBtree->pBt->pCursor; p; p=p->pNext){ in hasReadConflicts()
272 && p->pBtree!=pBtree in hasReadConflicts()
273 && 0==(p->pBtree->db->flags & SQLITE_ReadUncommit) in hasReadConflicts()
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()
330 sqlite3ConnectionBlocked(p->db, pIter->pBtree->db); in querySharedCacheTableLock()
382 if( pIter->iTable==iTable && pIter->pBtree==p ){ in setSharedCacheTableLock()
397 pLock->pBtree = p; in setSharedCacheTableLock()
434 assert( (pBt->btsFlags & BTS_EXCLUSIVE)==0 || pBt->pWriter==pLock->pBtree ); in clearAllSharedCacheTableLocks()
435 assert( pLock->pBtree->inTrans>=pLock->eLock ); in clearAllSharedCacheTableLocks()
436 if( pLock->pBtree==p ){ in clearAllSharedCacheTableLocks()
475 assert( pLock->eLock==READ_LOCK || pLock->pBtree==p ); in downgradeAllSharedCacheTableLocks()
507 return (p->pBtree->db==p->pBt->db); in cursorOwnsBtShared()
544 Btree *pBtree, /* The database file to check */ in invalidateIncrblobCursors() argument
550 assert( pBtree->hasIncrblobCur ); in invalidateIncrblobCursors()
551 assert( sqlite3BtreeHoldsMutex(pBtree) ); in invalidateIncrblobCursors()
552 pBtree->hasIncrblobCur = 0; in invalidateIncrblobCursors()
553 for(p=pBtree->pBt->pCursor; p; p=p->pNext){ in invalidateIncrblobCursors()
555 pBtree->hasIncrblobCur = 1; in invalidateIncrblobCursors()
2483 p->lock.pBtree = p; in sqlite3BtreeOpen()
2829 assert( pTmp->pBtree!=p ); in sqlite3BtreeClose()
3530 if( pIter->pBtree!=p ){ in sqlite3BtreeBeginTrans()
3531 pBlock = pIter->pBtree->db; in sqlite3BtreeBeginTrans()
3606 assert( p->lock.pBtree==p && p->lock.iTable==1 ); in sqlite3BtreeBeginTrans()
4303 int sqlite3BtreeTripAllCursors(Btree *pBtree, int errCode, int writeOnly){ in sqlite3BtreeTripAllCursors() argument
4308 if( pBtree ){ in sqlite3BtreeTripAllCursors()
4309 sqlite3BtreeEnter(pBtree); in sqlite3BtreeTripAllCursors()
4310 for(p=pBtree->pBt->pCursor; p; p=p->pNext){ in sqlite3BtreeTripAllCursors()
4315 (void)sqlite3BtreeTripAllCursors(pBtree, rc, 0); in sqlite3BtreeTripAllCursors()
4326 sqlite3BtreeLeave(pBtree); in sqlite3BtreeTripAllCursors()
4565 pCur->pBtree = p; in btreeCursor()
4644 Btree *pBtree = pCur->pBtree; in sqlite3BtreeCloseCursor() local
4645 if( pBtree ){ in sqlite3BtreeCloseCursor()
4647 sqlite3BtreeEnter(pBtree); in sqlite3BtreeCloseCursor()
4668 assert( pBtree->sharable==0 ); in sqlite3BtreeCloseCursor()
4669 sqlite3BtreeClose(pBtree); in sqlite3BtreeCloseCursor()
4671 sqlite3BtreeLeave(pBtree); in sqlite3BtreeCloseCursor()
4673 pCur->pBtree = 0; in sqlite3BtreeCloseCursor()
5051 assert( pCur->pBtree->db==pBt->db ); in accessPayload()
5207 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) ); in fetchPayload()
5480 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) ); in sqlite3BtreeFirst()
5502 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) ); in sqlite3BtreeLast()
5572 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) ); in sqlite3BtreeTableMoveto()
5609 pCur->pBtree->nSeek++; /* Performance measurement during testing */ in sqlite3BtreeTableMoveto()
5803 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) ); in sqlite3BtreeIndexMoveto()
5808 pCur->pBtree->nSeek++; /* Performance measurement during testing */ in sqlite3BtreeIndexMoveto()
5956 && (pIdxKey->errCode!=SQLITE_NOMEM || pCur->pBtree->db->mallocFailed) in sqlite3BtreeIndexMoveto()
6024 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) ); in sqlite3BtreeRowCountEst()
8999 Btree *p = pCur->pBtree; in sqlite3BtreeInsert()
9417 Btree *p = pCur->pBtree; in sqlite3BtreeDelete()
9877 return sqlite3BtreeClearTable(pCur->pBtree, pCur->pgnoRoot, 0); in sqlite3BtreeClearTableOfCursor()
10968 assert( sqlite3_mutex_held(pCsr->pBtree->db->mutex) ); in sqlite3BtreePutData()
11003 assert( hasSharedCacheTableLock(pCsr->pBtree, pCsr->pgnoRoot, 0, 2) ); in sqlite3BtreePutData()
11004 assert( !hasReadConflicts(pCsr->pBtree, pCsr->pgnoRoot) ); in sqlite3BtreePutData()
11015 pCur->pBtree->hasIncrblobCur = 1; in sqlite3BtreeIncrblobCursor()
11024 int sqlite3BtreeSetVersion(Btree *pBtree, int iVersion){ in sqlite3BtreeSetVersion() argument
11025 BtShared *pBt = pBtree->pBt; in sqlite3BtreeSetVersion()
11036 rc = sqlite3BtreeBeginTrans(pBtree, 0, 0); in sqlite3BtreeSetVersion()
11040 rc = sqlite3BtreeBeginTrans(pBtree, 2, 0); in sqlite3BtreeSetVersion()