Home
last modified time | relevance | path

Searched refs:pCsr (Results 1 – 25 of 53) sorted by relevance

123

/sqlite-3.40.0/ext/recover/
H A Ddbdata.c509 if( pCsr->bOnePage==0 && pCsr->iPgno>pCsr->szDb ) return SQLITE_OK; in dbdataNext()
510 rc = dbdataLoadPage(pCsr, pCsr->iPgno, &pCsr->aPage, &pCsr->nPage); in dbdataNext()
522 pCsr->iCell = pCsr->nCell; in dbdataNext()
525 if( pCsr->iCell>=pCsr->nCell ){ in dbdataNext()
555 pCsr->iCell = pCsr->nCell; in dbdataNext()
559 if( pCsr->iCell>=pCsr->nCell ){ in dbdataNext()
648 pCsr->pPtr = &pCsr->pRec[pCsr->nHdr]; in dbdataNext()
656 if( pCsr->pHdrPtr>&pCsr->pRec[pCsr->nRec] ){ in dbdataNext()
673 if( pCsr->iField<0 || pCsr->pHdrPtr<&pCsr->pRec[pCsr->nHdr] ){ in dbdataNext()
867 }else if( &pCsr->pRec[pCsr->nRec] >= pCsr->pPtr ){ in dbdataColumn()
[all …]
/sqlite-3.40.0/ext/fts5/
H A Dfts5_main.c684 for(pCsr=pTab->pGlobal->pCsr; pCsr; pCsr=pCsr->pNext){ in fts5NewTransaction()
707 pCsr->aColumnSize = (int*)&pCsr[1]; in fts5OpenMethod()
708 pCsr->pNext = pGlobal->pCsr; in fts5OpenMethod()
709 pGlobal->pCsr = pCsr; in fts5OpenMethod()
776 memset(&pCsr->ePlan, 0, sizeof(Fts5Cursor) - ((u8*)&pCsr->ePlan - (u8*)pCsr)); in fts5FreeCursorComponents()
845 for(pCsr=pTab->pGlobal->pCsr; pCsr; pCsr=pCsr->pNext){ in fts5TripCursors()
1068 pCsr->iSpecial = pCsr->iCsrId; in fts5SpecialMatch()
1237 memset(&pCsr->ePlan, 0, sizeof(Fts5Cursor) - ((u8*)&pCsr->ePlan-(u8*)pCsr)); in fts5FilterMethod()
2352 for(pCsr=pGlobal->pCsr; pCsr; pCsr=pCsr->pNext){ in fts5CursorFromCsrid()
2373 if( pCsr==0 || pCsr->ePlan==0 ){ in fts5ApiCallback()
[all …]
H A Dfts5_vocab.c381 if( pCsr ){ in fts5VocabOpenMethod()
384 pCsr->aCnt = (i64*)&pCsr[1]; in fts5VocabOpenMethod()
385 pCsr->aDoc = &pCsr->aCnt[pFts5->pConfig->nCol]; in fts5VocabOpenMethod()
481 pCsr->rowid++; in fts5VocabNextMethod()
488 for(pCsr->iCol++; pCsr->iCol<nCol; pCsr->iCol++){ in fts5VocabNextMethod()
489 if( pCsr->aDoc[pCsr->iCol] ) break; in fts5VocabNextMethod()
590 for(/* noop */; pCsr->iCol<nCol && pCsr->aDoc[pCsr->iCol]==0; pCsr->iCol++); in fts5VocabNextMethod()
642 pCsr->zLeTerm = sqlite3_malloc(pCsr->nLeTerm+1); in fts5VocabFilterMethod()
646 memcpy(pCsr->zLeTerm, zCopy, pCsr->nLeTerm+1); in fts5VocabFilterMethod()
702 iVal = pCsr->aDoc[pCsr->iCol]; in fts5VocabColumnMethod()
[all …]
H A Dfts5_test_tok.c279 if( pCsr==0 ){ in fts5tokOpenMethod()
299 pCsr->zInput = 0; in fts5tokResetCursor()
300 pCsr->aRow = 0; in fts5tokResetCursor()
301 pCsr->nRow = 0; in fts5tokResetCursor()
320 pCsr->iRowid++; in fts5tokNextMethod()
335 if( (pCsr->nRow & (pCsr->nRow-1))==0 ){ in fts5tokCb()
336 int nNew = pCsr->nRow ? pCsr->nRow*2 : 32; in fts5tokCb()
344 pRow = &pCsr->aRow[pCsr->nRow]; in fts5tokCb()
354 pCsr->nRow++; in fts5tokCb()
398 return (pCsr->iRowid>pCsr->nRow); in fts5tokEofMethod()
[all …]
/sqlite-3.40.0/src/
H A Ddbstat.c292 if( pCsr==0 ){ in statOpen()
336 pCsr->iPage = 0; in statResetCsr()
338 pCsr->zPath = 0; in statResetCsr()
526 pCsr->iOffset = (i64)pCsr->szPage * (pCsr->iPageno - 1); in statSizeAndOffset()
607 StatPage *p = &pCsr->aPage[pCsr->iPage]; in statNext()
608 if( !pCsr->isAgg ) statResetCounts(pCsr); in statNext()
644 if( pCsr->isAgg && pCsr->iPage<0 ){ in statNext()
652 if( pCsr->iPage>=ArraySize(pCsr->aPage) ){ in statNext()
656 assert( p==&pCsr->aPage[pCsr->iPage-1] ); in statNext()
679 StatPage *p = &pCsr->aPage[pCsr->iPage]; in statNext()
[all …]
H A Ddbpage.c170 if( pCsr==0 ){ in dbpageOpen()
187 if( pCsr->pPage1 ) sqlite3PagerUnrefPageOne(pCsr->pPage1); in dbpageClose()
198 pCsr->pgno++; in dbpageNext()
204 return pCsr->pgno > pCsr->mxPgno; in dbpageEof()
229 pCsr->pgno = 1; in dbpageFilter()
239 pCsr->iDb = 0; in dbpageFilter()
249 if( pCsr->pgno<1 || pCsr->pgno>pCsr->mxPgno ){ in dbpageFilter()
253 pCsr->mxPgno = pCsr->pgno; in dbpageFilter()
258 if( pCsr->pPage1 ) sqlite3PagerUnrefPageOne(pCsr->pPage1); in dbpageFilter()
259 rc = sqlite3PagerGet(pCsr->pPager, 1, &pCsr->pPage1, 0); in dbpageFilter()
[all …]
H A Dtest_fs.c238 if( pCsr->pDir ){ in fsdirNext()
239 pCsr->pEntry = readdir(pCsr->pDir); in fsdirNext()
244 pCsr->iRowid++; in fsdirNext()
267 pCsr->iRowid = 0; in fsdirFilter()
269 if( pCsr->pDir ){ in fsdirFilter()
271 pCsr->pDir = 0; in fsdirFilter()
280 pCsr->pDir = opendir(pCsr->zDir); in fsdirFilter()
429 if( pCsr->fd>=0 ){ in fstreeCloseFd()
430 close(pCsr->fd); in fstreeCloseFd()
431 pCsr->fd = -1; in fstreeCloseFd()
[all …]
H A Dtest_osinst.c943 *ppCursor = &pCsr->base; in vlogOpen()
972 pCsr->zTransient = 0; in vlogNext()
977 rc = p->pFd->pMethods->xRead(p->pFd, pCsr->aBuf, nRead, pCsr->iOffset); in vlogNext()
997 pCsr->azFile = (char **)sqlite3_realloc(pCsr->azFile, nNew); in vlogNext()
998 nNew -= sizeof(pCsr->azFile[0])*pCsr->nFile; in vlogNext()
999 memset(&pCsr->azFile[pCsr->nFile], 0, nNew); in vlogNext()
1011 pCsr->iRowid += 1; in vlogNext()
1012 pCsr->iOffset += nRead; in vlogNext()
1028 pCsr->iRowid = 0; in vlogFilter()
1029 pCsr->iOffset = 20; in vlogFilter()
[all …]
/sqlite-3.40.0/ext/lsm1/
H A Dlsm_sorted.c652 &dummy, &pCsr->eType, &pCsr->pKey, &pCsr->nKey, &pCsr->blob in btreeCursorLoadKey()
787 pCsr->iPg = pCsr->nDepth-1; in btreeCursorFirst()
966 &dummy, &pCsr->eType, &pCsr->pKey, &pCsr->nKey, &pCsr->blob in btreeCursorRestore()
2437 db->pCsr = pCsr; in multiCursorNew()
2446 for(pCsr=pDb->pCsr; pCsr; pCsr=pCsr->pNext){ in lsmSortedRemap()
2502 pDb->pCsr = pCsr; in lsmMCursorNew()
2963 for(pCsr=pDb->pCsr; rc==LSM_OK && pCsr; pCsr=pCsr->pNext){ in lsmSaveCursors()
2973 for(pCsr=pDb->pCsr; rc==LSM_OK && pCsr; pCsr=pCsr->pNext){ in lsmRestoreCursors()
4229 pCsr = pMW->pCsr; in mergeWorkerStep()
4582 pMW->pCsr = pCsr; in mergeWorkerInit()
[all …]
H A Dlsm_tree.c579 u32 iPtr = pCsr->apTreeNode[pCsr->iNode]->aiKeyPtr[pCsr->aiCell[pCsr->iNode]]; in csrGetKey()
595 if( pCsr && pCsr->pSave==0 ){ in lsmTreeCursorSave()
598 pCsr->pSave = csrGetKey(pCsr, &pCsr->blob, &rc); in lsmTreeCursorSave()
841 p = pCsr->apTreeNode[pCsr->iNode]; in treeUpdatePtr()
1052 pCsr->aiCell[pCsr->iNode] in treeInsertLeaf()
1936 tblobFree(pCsr->pDb, &pCsr->blob); in lsmTreeCursorDestroy()
1937 lsmFree(pCsr->pDb->pEnv, pCsr); in lsmTreeCursorDestroy()
2156 iCell = pCsr->aiCell[pCsr->iNode]; in lsmTreeCursorPrev()
2241 if( pCsr && pCsr->iNode>=0 ){ in lsmTreeCursorFlags()
2244 pCsr->apTreeNode[pCsr->iNode]->aiKeyPtr[pCsr->aiCell[pCsr->iNode]] in lsmTreeCursorFlags()
[all …]
/sqlite-3.40.0/ext/fts3/
H A Dfts3_aux.c273 pCsr->iRowid++; in fts3auxNextMethod()
275 for(pCsr->iCol++; pCsr->iCol<pCsr->nStat; pCsr->iCol++){ in fts3auxNextMethod()
276 if( pCsr->aStat[pCsr->iCol].nDoc>0 ) return SQLITE_OK; in fts3auxNextMethod()
289 int n = (pCsr->nStop<pCsr->csr.nTerm) ? pCsr->nStop : pCsr->csr.nTerm; in fts3auxNextMethod()
290 int mc = memcmp(pCsr->zStop, pCsr->csr.zTerm, n); in fts3auxNextMethod()
291 if( mc<0 || (mc==0 && pCsr->csr.nTerm>pCsr->nStop) ){ in fts3auxNextMethod()
355 pCsr->iCol = 0; in fts3auxNextMethod()
414 memset(&pCsr->csr, 0, ((u8*)&pCsr[1]) - (u8*)&pCsr->csr); in fts3auxFilterMethod()
425 pCsr->filter.nTerm = (int)strlen(pCsr->filter.zTerm); in fts3auxFilterMethod()
432 pCsr->nStop = (int)strlen(pCsr->zStop); in fts3auxFilterMethod()
[all …]
H A Dfts3_tokenize_vtab.c268 if( pCsr==0 ){ in fts3tokOpenMethod()
282 if( pCsr->pCsr ){ in fts3tokResetCursor()
284 pTab->pMod->xClose(pCsr->pCsr); in fts3tokResetCursor()
285 pCsr->pCsr = 0; in fts3tokResetCursor()
292 pCsr->iEnd = 0; in fts3tokResetCursor()
293 pCsr->iPos = 0; in fts3tokResetCursor()
317 rc = pTab->pMod->xNext(pCsr->pCsr, in fts3tokNextMethod()
318 &pCsr->zToken, &pCsr->nToken, in fts3tokNextMethod()
319 &pCsr->iStart, &pCsr->iEnd, &pCsr->iPos in fts3tokNextMethod()
356 rc = pTab->pMod->xOpen(pTab->pTok, pCsr->zInput, nByte, &pCsr->pCsr); in fts3tokFilterMethod()
[all …]
H A Dfts3_term.c203 pCsr->iRowid++; in fts3termNextMethod()
207 || pCsr->pNext>=&pCsr->csr.aDoclist[pCsr->csr.nDoclist-1] in fts3termNextMethod()
218 pCsr->pNext = pCsr->csr.aDoclist; in fts3termNextMethod()
221 pCsr->pNext += sqlite3Fts3GetVarint(pCsr->pNext, &pCsr->iDocid); in fts3termNextMethod()
224 pCsr->pNext += sqlite3Fts3GetVarint(pCsr->pNext, &v); in fts3termNextMethod()
226 pCsr->pNext += sqlite3Fts3GetVarint(pCsr->pNext, &v); in fts3termNextMethod()
228 pCsr->pNext += sqlite3Fts3GetVarint(pCsr->pNext, &v); in fts3termNextMethod()
234 pCsr->pNext += sqlite3Fts3GetVarint(pCsr->pNext, &v); in fts3termNextMethod()
237 pCsr->pNext += sqlite3Fts3GetVarint(pCsr->pNext, &v); in fts3termNextMethod()
270 memset(&pCsr->csr, 0, ((u8*)&pCsr[1]) - (u8*)&pCsr->csr); in fts3termFilterMethod()
[all …]
H A Dfts3_icu.c101 IcuCursor *pCsr; in icuOpen() local
125 if( !pCsr ){ in icuOpen()
129 pCsr->aChar = (UChar *)&pCsr[1]; in icuOpen()
130 pCsr->aOffset = (int *)&pCsr->aChar[(nChar+3)&~3]; in icuOpen()
139 sqlite3_free(pCsr); in icuOpen()
151 pCsr->pIter = ubrk_open(UBRK_WORD, p->zLocale, pCsr->aChar, iOut, &status); in icuOpen()
153 sqlite3_free(pCsr); in icuOpen()
156 pCsr->nChar = iOut; in icuOpen()
170 sqlite3_free(pCsr); in icuClose()
202 U16_NEXT(pCsr->aChar, iWhite, pCsr->nChar, c); in icuNext()
[all …]
H A Dfts3_unicode.c277 unicode_cursor *pCsr; in unicodeOpen() local
280 if( pCsr==0 ){ in unicodeOpen()
287 pCsr->nInput = 0; in unicodeOpen()
295 *pp = &pCsr->base; in unicodeOpen()
307 sqlite3_free(pCsr); in unicodeClose()
327 const unsigned char *z = &pCsr->aInput[pCsr->iOff]; in unicodeNext()
330 const unsigned char *zTerm = &pCsr->aInput[pCsr->nInput]; in unicodeNext()
342 zOut = pCsr->zToken; in unicodeNext()
347 if( (zOut-pCsr->zToken)>=(pCsr->nAlloc-4) ){ in unicodeNext()
348 char *zNew = sqlite3_realloc64(pCsr->zToken, pCsr->nAlloc+64); in unicodeNext()
[all …]
H A Dfts3.c1750 if( !pCsr ){ in fts3OpenMethod()
1847 sqlite3_bind_int64(pCsr->pStmt, 1, pCsr->iPrevId); in fts3CursorSeek()
2955 pCsr->apSegment[pCsr->nSegment++] = pNew; in fts3SegReaderCursorAppend()
3256 pCsr->iPrevId = sqlite3_column_int64(pCsr->pStmt, 0); in fts3NextMethod()
3373 pCsr->pNextId = pCsr->aDoclist; in fts3FilterMethod()
3386 p->zReadExprlist, pCsr->iMinDocid, pCsr->iMaxDocid, in fts3FilterMethod()
3764 assert( pCsr ); in fts3OffsetsFunc()
5171 fts3EvalStartReaders(pCsr, pCsr->pExpr, &rc); in fts3EvalStart()
5640 bMiss = (0==fts3EvalTestExpr(pCsr, pCsr->pExpr, &rc)); in sqlite3Fts3EvalTestDeferred()
5676 (pCsr->bDesc==0 && pCsr->iPrevId>pCsr->iMaxDocid) in fts3EvalNext()
[all …]
H A Dfts3_snippet.c326 sCtx.pCsr = pCsr; in fts3ExprLoadDoclists()
474 char *pCsr; in fts3SnippetFindPositions() local
478 rc = sqlite3Fts3EvalPhrasePoslist(p->pCsr, pExpr, p->iCol, &pCsr); in fts3SnippetFindPositions()
480 if( pCsr ){ in fts3SnippetFindPositions()
554 sIter.pCsr = pCsr; in fts3BestSnippet()
973 char *pCsr; in fts3ExprLocalHitsCb() local
975 if( pCsr ){ in fts3ExprLocalHitsCb()
1372 if( pCsr->pMIBuffer && strcmp(pCsr->pMIBuffer->zMatchinfo, zArg) ){ in fts3GetMatchinfo()
1387 pCsr->nPhrase = fts3ExprPhraseCount(pCsr->pExpr); in fts3GetMatchinfo()
1550 Fts3Cursor *pCsr; member
[all …]
H A Dfts3_test.c394 if( pCsr==0 ){ in testTokenizerOpen()
398 pCsr->aInput = pInput; in testTokenizerOpen()
402 pCsr->nInput = nBytes; in testTokenizerOpen()
413 sqlite3_free(pCsr); in testTokenizerClose()
439 p = &pCsr->aInput[pCsr->iInput]; in testTokenizerNext()
440 pEnd = &pCsr->aInput[pCsr->nInput]; in testTokenizerNext()
460 if( pCsr->aBuffer==0 ){ in testTokenizerNext()
470 pCsr->iToken++; in testTokenizerNext()
471 pCsr->iInput = (int)(p - pCsr->aInput); in testTokenizerNext()
490 pCsr->iLangid = iLangid; in testTokenizerLanguage()
[all …]
H A Dfts3_write.c1563 Fts3Cursor *pCsr, in sqlite3Fts3MsrOvfl() argument
2766 for(i=0; pCsr->bRestart==0 && i<pCsr->nSegment; i++){ in fts3SegReaderStart()
2870 aNew = sqlite3_realloc64(pCsr->aBuffer, pCsr->nBuffer); in fts3GrowSegReaderBuffer()
2963 pCsr->aDoclist = pCsr->aBuffer; in sqlite3Fts3SegReaderStep()
3045 pCsr->aDoclist = pCsr->aBuffer; in sqlite3Fts3SegReaderStep()
3060 if( pCsr ){ in sqlite3Fts3SegReaderFinish()
3647 memset(pCsr, 0, sizeof(*pCsr)); in fts3IncrmergeCsr()
5241 pCsr += sqlite3Fts3GetVarint(pCsr, &iDocid); in fts3ChecksumIndex()
5244 pCsr += sqlite3Fts3GetVarintU(pCsr, &iVal); in fts3ChecksumIndex()
5250 pCsr += sqlite3Fts3GetVarint(pCsr, &iCol); in fts3ChecksumIndex()
[all …]
/sqlite-3.40.0/ext/fts2/
H A Dfts2_icu.c103 IcuCursor *pCsr; in icuOpen() local
124 if( !pCsr ){ in icuOpen()
128 pCsr->aChar = (UChar *)&pCsr[1]; in icuOpen()
129 pCsr->aOffset = (int *)&pCsr->aChar[(nChar+3)&~3]; in icuOpen()
138 sqlite3_free(pCsr); in icuOpen()
150 pCsr->pIter = ubrk_open(UBRK_WORD, p->zLocale, pCsr->aChar, iOut, &status); in icuOpen()
152 sqlite3_free(pCsr); in icuOpen()
155 pCsr->nChar = iOut; in icuOpen()
169 sqlite3_free(pCsr); in icuClose()
201 U8_NEXT(pCsr->aChar, iWhite, pCsr->nChar, c); in icuNext()
[all …]
/sqlite-3.40.0/ext/misc/
H A Dbtreeinfo.c183 BinfoCursor *pCsr; in binfoOpen() local
186 if( pCsr==0 ){ in binfoOpen()
204 sqlite3_free(pCsr); in binfoClose()
213 pCsr->rc = sqlite3_step(pCsr->pStmt); in binfoNext()
214 pCsr->hasRowid = -1; in binfoNext()
249 pCsr->zSchema); in binfoFilter()
251 pCsr->pStmt = 0; in binfoFilter()
252 pCsr->hasRowid = -1; in binfoFilter()
286 pCsr->depth = 1; in binfoCompute()
320 pCsr->depth++; in binfoCompute()
[all …]
H A Dzipfile.c441 pCsr = sqlite3_malloc(sizeof(*pCsr)); in zipfileOpen()
446 memset(pCsr, 0, sizeof(*pCsr)); in zipfileOpen()
903 i64 iEof = pCsr->eocd.iOffset + pCsr->eocd.nSize; in zipfileNext()
920 pCsr->pCurrent = pCsr->pCurrent->pNext; in zipfileNext()
1293 pCsr->iNextOff = pCsr->eocd.iOffset; in zipfileFilter()
1300 pCsr->pCurrent = pCsr->pFreeEntry ? pCsr->pFreeEntry : pTab->pFirstEntry; in zipfileFilter()
1715 for(pCsr=pTab->pCsrList; pCsr; pCsr=pCsr->pCsrNext){ in zipfileUpdate()
1716 if( pCsr->pCurrent && (pCsr->pCurrent==pOld || pCsr->pCurrent==pOld2) ){ in zipfileUpdate()
1717 pCsr->pCurrent = pCsr->pCurrent->pNext; in zipfileUpdate()
1837 for(pCsr=pTab->pCsrList; pCsr; pCsr=pCsr->pCsrNext){ in zipfileFindCursor()
[all …]
H A Dunionvtab.c728 if( pCsr->pStmt ){ in unionFinalizeCsrStmt()
732 pCsr->pStmt = 0; in unionFinalizeCsrStmt()
1034 UnionCsr *pCsr; in unionOpen() local
1038 *ppCursor = &pCsr->base; in unionOpen()
1047 unionFinalizeCsrStmt(pCsr); in unionClose()
1048 sqlite3_free(pCsr); in unionClose()
1059 assert( pCsr->pStmt ); in doUnionNext()
1064 pCsr->iTab++; in doUnionNext()
1127 return pCsr->pStmt==0; in unionEof()
1227 pCsr->iTab = i; in unionFilter()
[all …]
/sqlite-3.40.0/ext/lsm1/lsm-test/
H A Dlsmtest7.c21 lsm_cursor *pCsr; in do_test_api1_lsm() local
29 ret = lsm_csr_next(pCsr); in do_test_api1_lsm()
31 ret = lsm_csr_prev(pCsr); in do_test_api1_lsm()
36 ret = lsm_csr_next(pCsr); in do_test_api1_lsm()
38 ret = lsm_csr_prev(pCsr); in do_test_api1_lsm()
43 ret = lsm_csr_next(pCsr); in do_test_api1_lsm()
45 ret = lsm_csr_prev(pCsr); in do_test_api1_lsm()
50 ret = lsm_csr_next(pCsr); in do_test_api1_lsm()
52 ret = lsm_csr_prev(pCsr); in do_test_api1_lsm()
73 ret = lsm_csr_next(pCsr); in do_test_api1_lsm()
[all …]
/sqlite-3.40.0/ext/repair/
H A Dcheckindex.c201 sqlite3_free(pCsr); in cidxClose()
213 pCsr->pStmt = 0; in cidxNext()
219 pCsr->iRowid++; in cidxNext()
534 CidxCursor *pCsr, in cidxDecodeAfter() argument
798 pCsr->zIdxName = 0; in cidxFilter()
800 pCsr->zAfterKey = 0; in cidxFilter()
802 pCsr->pStmt = 0; in cidxFilter()
817 pCsr->pStmt = cidxPrepare(&rc, pCsr, "%z", zSql); in cidxFilter()
821 if( pCsr->pStmt ){ in cidxFilter()
825 pCsr->iRowid = 1; in cidxFilter()
[all …]

123