Lines Matching refs:pCsr
167 DbpageCursor *pCsr; in dbpageOpen() local
169 pCsr = (DbpageCursor *)sqlite3_malloc64(sizeof(DbpageCursor)); in dbpageOpen()
170 if( pCsr==0 ){ in dbpageOpen()
173 memset(pCsr, 0, sizeof(DbpageCursor)); in dbpageOpen()
174 pCsr->base.pVtab = pVTab; in dbpageOpen()
175 pCsr->pgno = -1; in dbpageOpen()
178 *ppCursor = (sqlite3_vtab_cursor *)pCsr; in dbpageOpen()
186 DbpageCursor *pCsr = (DbpageCursor *)pCursor; in dbpageClose() local
187 if( pCsr->pPage1 ) sqlite3PagerUnrefPageOne(pCsr->pPage1); in dbpageClose()
188 sqlite3_free(pCsr); in dbpageClose()
197 DbpageCursor *pCsr = (DbpageCursor *)pCursor; in dbpageNext() local
198 pCsr->pgno++; in dbpageNext()
203 DbpageCursor *pCsr = (DbpageCursor *)pCursor; in dbpageEof() local
204 return pCsr->pgno > pCsr->mxPgno; in dbpageEof()
222 DbpageCursor *pCsr = (DbpageCursor *)pCursor; in dbpageFilter() local
229 pCsr->pgno = 1; in dbpageFilter()
230 pCsr->mxPgno = 0; in dbpageFilter()
236 pCsr->iDb = sqlite3FindDbName(db, zSchema); in dbpageFilter()
237 if( pCsr->iDb<0 ) return SQLITE_OK; in dbpageFilter()
239 pCsr->iDb = 0; in dbpageFilter()
241 pBt = db->aDb[pCsr->iDb].pBt; in dbpageFilter()
243 pCsr->pPager = sqlite3BtreePager(pBt); in dbpageFilter()
244 pCsr->szPage = sqlite3BtreeGetPageSize(pBt); in dbpageFilter()
245 pCsr->mxPgno = sqlite3BtreeLastPage(pBt); in dbpageFilter()
248 pCsr->pgno = sqlite3_value_int(argv[idxNum>>1]); in dbpageFilter()
249 if( pCsr->pgno<1 || pCsr->pgno>pCsr->mxPgno ){ in dbpageFilter()
250 pCsr->pgno = 1; in dbpageFilter()
251 pCsr->mxPgno = 0; in dbpageFilter()
253 pCsr->mxPgno = pCsr->pgno; in dbpageFilter()
256 assert( pCsr->pgno==1 ); in dbpageFilter()
258 if( pCsr->pPage1 ) sqlite3PagerUnrefPageOne(pCsr->pPage1); in dbpageFilter()
259 rc = sqlite3PagerGet(pCsr->pPager, 1, &pCsr->pPage1, 0); in dbpageFilter()
268 DbpageCursor *pCsr = (DbpageCursor *)pCursor; in dbpageColumn() local
272 sqlite3_result_int(ctx, pCsr->pgno); in dbpageColumn()
277 if( pCsr->pgno==((PENDING_BYTE/pCsr->szPage)+1) ){ in dbpageColumn()
280 sqlite3_result_zeroblob(ctx, pCsr->szPage); in dbpageColumn()
282 rc = sqlite3PagerGet(pCsr->pPager, pCsr->pgno, (DbPage**)&pDbPage, 0); in dbpageColumn()
284 sqlite3_result_blob(ctx, sqlite3PagerGetData(pDbPage), pCsr->szPage, in dbpageColumn()
293 sqlite3_result_text(ctx, db->aDb[pCsr->iDb].zDbSName, -1, SQLITE_STATIC); in dbpageColumn()
301 DbpageCursor *pCsr = (DbpageCursor *)pCursor; in dbpageRowid() local
302 *pRowid = pCsr->pgno; in dbpageRowid()