Lines Matching refs:pBtree

102 ** Check to see if pBtree holds the required locks to read or write to the 
106 ** Btree connection pBtree:
108 ** assert( hasSharedCacheTableLock(pBtree, iRoot, 0, WRITE_LOCK) );
122 Btree *pBtree, /* Handle that must hold lock */
127 Schema *pSchema = (Schema *)pBtree->pBt->pSchema;
135 if( (pBtree->sharable==0)
136 || (eLockType==READ_LOCK && (pBtree->db->flags & SQLITE_ReadUncommitted))
169 for(pLock=pBtree->pBt->pLock; pLock; pLock=pLock->pNext){
170 if( pLock->pBtree==pBtree
187 ** Return true if it would be illegal for pBtree to write into the
191 ** It is illegal for pBtree to write if some other Btree object that
200 ** assert( !hasReadConflicts(pBtree, iRoot) );
202 static int hasReadConflicts(Btree *pBtree, Pgno iRoot){
204 for(p=pBtree->pBt->pCursor; p; p=p->pNext){
206 && p->pBtree!=pBtree
207 && 0==(p->pBtree->db->flags & SQLITE_ReadUncommitted)
262 assert( eLock==READ_LOCK || pIter->pBtree==p || pIter->eLock==READ_LOCK);
263 if( pIter->pBtree!=p && pIter->iTable==iTab && pIter->eLock!=eLock ){
264 sqlite3ConnectionBlocked(p->db, pIter->pBtree->db);
316 if( pIter->iTable==iTable && pIter->pBtree==p ){
331 pLock->pBtree = p;
368 assert( pBt->isExclusive==0 || pBt->pWriter==pLock->pBtree );
369 assert( pLock->pBtree->inTrans>=pLock->eLock );
370 if( pLock->pBtree==p ){
411 assert( pLock->eLock==READ_LOCK || pLock->pBtree==p );
469 Btree *pBtree, /* The database file to check */
474 BtShared *pBt = pBtree->pBt;
475 assert( sqlite3BtreeHoldsMutex(pBtree) );
1745 p->lock.pBtree = p;
2022 if( pTmp->pBtree==p ){
2558 if( pIter->pBtree!=p ){
2559 pBlock = pIter->pBtree->db;
2610 assert( p->lock.pBtree==p && p->lock.iTable==1 );
3241 ** code to errCode for every cursor on BtShared that pBtree
3246 ** the cache with pBtree.
3256 void sqlite3BtreeTripAllCursors(Btree *pBtree, int errCode){
3258 sqlite3BtreeEnter(pBtree);
3259 for(p=pBtree->pBt->pCursor; p; p=p->pNext){
3269 sqlite3BtreeLeave(pBtree);
3471 pCur->pBtree = p;
3556 Btree *pBtree = pCur->pBtree;
3557 if( pBtree ){
3560 sqlite3BtreeEnter(pBtree);
3576 sqlite3BtreeLeave(pBtree);
4075 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) );
4084 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) );
4196 Btree *p = pCur->pBtree;
4322 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) );
4345 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) );
4415 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) );
6653 Btree *p = pCur->pBtree;
6783 Btree *p = pCur->pBtree;
7166 sqlite3ConnectionBlocked(p->db, pBt->pCursor->pBtree->db);
8061 assert( sqlite3_mutex_held(pCsr->pBtree->db->mutex) );
8084 assert( hasSharedCacheTableLock(pCsr->pBtree, pCsr->pgnoRoot, 0, 2) );
8085 assert( !hasReadConflicts(pCsr->pBtree, pCsr->pgnoRoot) );
8103 assert( sqlite3_mutex_held(pCur->pBtree->db->mutex) );
8114 int sqlite3BtreeSetVersion(Btree *pBtree, int iVersion){
8115 BtShared *pBt = pBtree->pBt;
8118 assert( pBtree->inTrans==TRANS_NONE );
8126 rc = sqlite3BtreeBeginTrans(pBtree, 0);
8130 rc = sqlite3BtreeBeginTrans(pBtree, 2);