| /sqlite-3.40.0/ext/lsm1/ |
| H A D | lsm_log.c | 336 i64 iOff = 0; in logReclaimSpace() local 342 if( iOff>=p->iStart && iOff<=p->iEnd ) break; in logReclaimSpace() 566 pLog->iOff = iJump; in jumpIfRequired() 587 pLog->iOff += pLog->buf.n; in logCksumAndFlush() 755 pMark->iOff = pLog->iOff + pLog->buf.n; in lsmLogTell() 773 assert( pMark->iOff<=pLog->iOff+pLog->buf.n ); in lsmLogSeek() 774 if( (pMark->iOff & 0xFFFFFFF8)>=pLog->iOff ){ in lsmLogSeek() 775 pLog->buf.n = (int)(pMark->iOff - pLog->iOff); in lsmLogSeek() 781 pLog->iOff = pMark->iOff - pMark->nBuf; in lsmLogSeek() 1079 int iOff = 0; in lsmLogRecover() local [all …]
|
| H A D | lsm_file.c | 378 lsm_i64 iOff, in lsmEnvRead() argument 388 lsm_i64 iOff, in lsmEnvWrite() argument 1145 pFix->aData += iOff; in fsGrowMapping() 1377 i64 iOff, in fsSubtractOffset() argument 1388 if( (iOff-iSub)>=iStart ){ in fsSubtractOffset() 1389 *piRes = (iOff-iSub); in fsSubtractOffset() 1411 i64 iOff, in fsAddOffset() argument 1422 if( (iOff+iAdd)<=iEob ){ in fsAddOffset() 1423 *piRes = (iOff+iAdd); in fsAddOffset() 1479 i64 iOff = pPg->iPg; in fsReadPagedata() local [all …]
|
| H A D | lsm_sorted.c | 407 int iOff, in sortedReadData() argument 1030 int iOff, in segmentPtrReadData() argument 1070 iOff++; in segmentPtrLoadCell() 1071 iOff += GETVARINT64(&aData[iOff], pPtr->iPgPtr); in segmentPtrLoadCell() 1072 iOff += GETVARINT32(&aData[iOff], pPtr->nKey); in segmentPtrLoadCell() 1074 iOff += GETVARINT32(&aData[iOff], pPtr->nVal); in segmentPtrLoadCell() 3361 int iOff; in mergeWorkerPageOffset() local 3373 iOff += lsmVarintGet32(&aData[iOff], &nKey); in mergeWorkerPageOffset() 3374 iOff += lsmVarintGet32(&aData[iOff], &nKey); in mergeWorkerPageOffset() 3680 iOff += lsmVarintPut32(&aData[iOff], nKey); in mergeWorkerBtreeWrite() [all …]
|
| H A D | lsm_win32.c | 276 lsm_i64 iOff, /* Offset to write to */ in lsmWin32OsWrite() argument 287 overlapped.Offset = (LONG)(iOff & 0XFFFFFFFF); in lsmWin32OsWrite() 288 overlapped.OffsetHigh = (LONG)((iOff>>32) & 0x7FFFFFFF); in lsmWin32OsWrite() 299 iOff += nWrite; in lsmWin32OsWrite() 300 overlapped.Offset = (LONG)(iOff & 0xFFFFFFFF); in lsmWin32OsWrite() 301 overlapped.OffsetHigh = (LONG)((iOff>>32) & 0x7FFFFFFF); in lsmWin32OsWrite() 334 lsm_i64 iOff, /* Offset to read from */ in lsmWin32OsRead() argument 344 overlapped.Offset = (LONG)(iOff & 0XFFFFFFFF); in lsmWin32OsRead() 345 overlapped.OffsetHigh = (LONG)((iOff>>32) & 0X7FFFFFFF); in lsmWin32OsRead()
|
| /sqlite-3.40.0/ext/fts5/ |
| H A D | fts5_index.c | 1344 for(iOff=pLvl->iOff; iOff<pData->nn; iOff++){ in fts5DlidxLvlNext() 1353 pLvl->iOff = iOff; in fts5DlidxLvlNext() 1437 int iOff = pLvl->iOff; in fts5DlidxLvlPrev() local 1453 iLimit = (iOff>9 ? iOff-9 : 0); in fts5DlidxLvlPrev() 1454 for(iOff--; iOff>iLimit; iOff--){ in fts5DlidxLvlPrev() 1479 pLvl->iOff = iOff - nZero; in fts5DlidxLvlPrev() 1708 iOff += fts5GetVarint32(&a[iOff], nNew); in fts5SegIterLoadTerm() 2749 if( iOff<4 || iOff>=n ){ in fts5SegIterGotoPage() 6450 iOff += fts5GetVarint32(&a[iOff], iVal); in fts5DecodePoslist() 6479 iOff += fts5DecodePoslist(pRc, pBuf, &a[iOff], MIN(n-iOff, nPos)); in fts5DecodeDoclist() [all …]
|
| H A D | fts5_aux.c | 172 fts5HighlightAppend(&rc, p, &p->zIn[p->iOff], iStartOff - p->iOff); in fts5HighlightCb() 174 p->iOff = iStartOff; in fts5HighlightCb() 181 fts5HighlightAppend(&rc, p, &p->zIn[p->iOff], iEndOff - p->iOff); in fts5HighlightCb() 183 p->iOff = iEndOff; in fts5HighlightCb() 190 fts5HighlightAppend(&rc, p, &p->zIn[p->iOff], iEndOff - p->iOff); in fts5HighlightCb() 191 p->iOff = iEndOff; in fts5HighlightCb() 234 fts5HighlightAppend(&rc, &ctx, &ctx.zIn[ctx.iOff], ctx.nIn - ctx.iOff); in fts5HighlightFunction() 333 int iOff = 0; in fts5SnippetScore() local 343 if( rc==SQLITE_OK && ic==iCol && iOff>=iPos && iOff<iEnd ){ in fts5SnippetScore() 346 if( iFirst<0 ) iFirst = iOff; in fts5SnippetScore() [all …]
|
| H A D | fts5_test_mi.c | 134 int iCol, iOff; in fts5MatchinfoXCb() local 138 for(pApi->xPhraseFirst(pFts, 0, &iter, &iCol, &iOff); in fts5MatchinfoXCb() 140 pApi->xPhraseNext(pFts, &iter, &iCol, &iOff) in fts5MatchinfoXCb() 244 int iOff, iCol; in fts5MatchinfoLocalCb() local 245 for(pApi->xPhraseFirst(pFts, iPhrase, &iter, &iCol, &iOff); in fts5MatchinfoLocalCb() 246 iOff>=0; in fts5MatchinfoLocalCb() 247 pApi->xPhraseNext(pFts, &iter, &iCol, &iOff) in fts5MatchinfoLocalCb() 272 int iPhrase, iOff, iCol = 0; in fts5MatchinfoLocalCb() local 278 rc = pApi->xInst(pFts, i, &iPhrase, &iCol, &iOff); in fts5MatchinfoLocalCb() 280 iNextOff = iOff+pApi->xPhraseSize(pFts, 0); in fts5MatchinfoLocalCb()
|
| H A D | fts5_buffer.c | 177 i64 iOff = *piOff; in sqlite3Fts5PoslistNext64() local 186 iOff = ((i64)iVal) << 32; in sqlite3Fts5PoslistNext64() 187 assert( iOff>=0 ); in sqlite3Fts5PoslistNext64() 194 *piOff = iOff + ((iVal-2) & 0x7FFFFFFF); in sqlite3Fts5PoslistNext64() 196 *piOff = (iOff & (i64)0x7FFFFFFF<<32)+((iOff + (iVal-2)) & 0x7FFFFFFF); in sqlite3Fts5PoslistNext64() 199 assert_nc( *piOff>=iOff ); in sqlite3Fts5PoslistNext64()
|
| H A D | fts5_storage.c | 307 int iOff; in sqlite3Fts5StorageOpen() local 309 iOff = (int)strlen(zDefn); in sqlite3Fts5StorageOpen() 311 sqlite3_snprintf(nDefn-iOff, &zDefn[iOff], ", c%d", i); in sqlite3Fts5StorageOpen() 312 iOff += (int)strlen(&zDefn[iOff]); in sqlite3Fts5StorageOpen() 1042 int iOff = 0; in fts5StorageDecodeSizeArray() local 1044 if( iOff>=nBlob ) return 1; in fts5StorageDecodeSizeArray() 1045 iOff += fts5GetVarint32(&aBlob[iOff], aCol[i]); in fts5StorageDecodeSizeArray() 1047 return (iOff!=nBlob); in fts5StorageDecodeSizeArray()
|
| /sqlite-3.40.0/ext/recover/ |
| H A D | dbdata.c | 521 if( pCsr->aPage[iOff]!=0x02 && pCsr->aPage[iOff]!=0x05 ){ in dbdataNext() 544 switch( pCsr->aPage[iOff] ){ in dbdataNext() 564 if( iOff>pCsr->nPage ){ in dbdataNext() 567 iOff = get_uint16(&pCsr->aPage[iOff]); in dbdataNext() 571 iOff += nPointer; in dbdataNext() 577 iOff += dbdataGetVarintU32(&pCsr->aPage[iOff], &nPayload); in dbdataNext() 582 iOff += dbdataGetVarint(&pCsr->aPage[iOff], &pCsr->iIntkey); in dbdataNext() 619 iOff += nLocal; in dbdataNext() 841 iOff += 8; in dbdataColumn() 845 iOff = get_uint16(&pCsr->aPage[iOff]); in dbdataColumn() [all …]
|
| H A D | sqlite3recover.c | 2119 int iOff = recoverGetU16(&a[iCellOff + 2*ii]); in recoverIsValidPage() local 2120 if( iOff<iContent || iOff>n ){ in recoverIsValidPage() 2143 if( iOff+nByte>n ){ in recoverIsValidPage() 2146 for(iByte=iOff; iByte<(iOff+nByte); iByte++){ in recoverIsValidPage() 2271 int iOff; in recoverVfsDetectPagesize() local 2272 for(iOff=0; iOff<nMax; iOff+=pgsz2){ in recoverVfsDetectPagesize() 2302 rc = pFd->pMethods->xRead(pFd, aBuf, nByte, iOff); in recoverVfsRead() 2306 if( rc==SQLITE_OK && iOff==0 && nByte>=108 ){ in recoverVfsRead() 2402 rc = pFd->pMethods->xRead(pFd, aBuf, nByte, iOff); in recoverVfsRead() 2431 pFd->pMethods->xWrite(pFd, aBuf, nByte, iOff) in recoverVfsWrite() [all …]
|
| /sqlite-3.40.0/src/ |
| H A D | test_journal.c | 411 i64 iOff = (i64)(pMain->nPagesize) * (i64)ii; in openTransaction() local 412 if( iOff==PENDING_BYTE ) continue; in openTransaction() 437 sqlite3_int64 iOff = 0; in readJournalFile() local 450 while( rc==SQLITE_OK && iOff<iSize ){ in readJournalFile() 455 rc = sqlite3OsRead(pReal, zBuf, 28, iOff); in readJournalFile() 461 iOff += nSector; in readJournalFile() 468 if( iSize>=(iOff+nSector) ){ in readJournalFile() 469 rc = sqlite3OsRead(pReal, zBuf, 28, iOff); in readJournalFile() 480 rc = sqlite3OsRead(pReal, zBuf, 4, iOff); in readJournalFile() 493 iOff += (8 + pMain->nPagesize); in readJournalFile() [all …]
|
| H A D | dbstat.c | 395 int iOff; in statDecodePage() local 420 iOff = get2byte(&aHdr[1]); in statDecodePage() 421 while( iOff ){ in statDecodePage() 424 nUnused += get2byte(&aData[iOff+2]); in statDecodePage() 425 iNext = get2byte(&aData[iOff]); in statDecodePage() 427 iOff = iNext; in statDecodePage() 446 iOff = get2byte(&aData[nHdr+i*2]); in statDecodePage() 447 if( iOff<nHdr || iOff>=szPage ) goto statPageIsCorrupt; in statDecodePage() 450 iOff += 4; in statDecodePage() 457 iOff += getVarint32(&aData[iOff], nPayload); in statDecodePage() [all …]
|
| H A D | memjournal.c | 103 sqlite3_int64 iOff = 0; in memjrnlRead() local 105 ALWAYS(pChunk) && (iOff+p->nChunkSize)<=iOfst; in memjrnlRead() 108 iOff += p->nChunkSize; in memjrnlRead() 154 i64 iOff = 0; in memjrnlCreateFile() local 157 if( iOff + nChunk > copy.endpoint.iOffset ){ in memjrnlCreateFile() 158 nChunk = copy.endpoint.iOffset - iOff; in memjrnlCreateFile() 160 rc = sqlite3OsWrite(pReal, (u8*)pIter->zChunk, nChunk, iOff); in memjrnlCreateFile() 162 iOff += nChunk; in memjrnlCreateFile() 269 i64 iOff = p->nChunkSize; in memjrnlTruncate() local 270 for(pIter=p->pFirst; ALWAYS(pIter) && iOff<size; pIter=pIter->pNext){ in memjrnlTruncate() [all …]
|
| H A D | backup.c | 238 i64 iOff; in backupOnePage() local 257 for(iOff=iEnd-(i64)nSrcPgsz; rc==SQLITE_OK && iOff<iEnd; iOff+=nDestPgsz){ in backupOnePage() 259 Pgno iDest = (Pgno)(iOff/nDestPgsz)+1; in backupOnePage() 264 const u8 *zIn = &zSrcData[iOff%nSrcPgsz]; in backupOnePage() 266 u8 *zOut = &zDestData[iOff%nDestPgsz]; in backupOnePage() 277 if( iOff==0 && bUpdate==0 ){ in backupOnePage() 477 i64 iOff; in sqlite3_backup_step() local 511 iOff=PENDING_BYTE+pgszSrc; in sqlite3_backup_step() 512 rc==SQLITE_OK && iOff<iEnd; in sqlite3_backup_step() 513 iOff+=pgszSrc in sqlite3_backup_step() [all …]
|
| H A D | os.c | 193 int sqlite3OsFetch(sqlite3_file *id, i64 iOff, int iAmt, void **pp){ in sqlite3OsFetch() argument 195 return id->pMethods->xFetch(id, iOff, iAmt, pp); in sqlite3OsFetch() 197 int sqlite3OsUnfetch(sqlite3_file *id, i64 iOff, void *p){ in sqlite3OsUnfetch() argument 198 return id->pMethods->xUnfetch(id, iOff, p); in sqlite3OsUnfetch() 202 int sqlite3OsFetch(sqlite3_file *id, i64 iOff, int iAmt, void **pp){ in sqlite3OsFetch() argument 206 int sqlite3OsUnfetch(sqlite3_file *id, i64 iOff, void *p){ in sqlite3OsUnfetch() argument
|
| H A D | test6.c | 177 static int writeDbFile(CrashFile *p, u8 *z, i64 iAmt, i64 iOff){ in writeDbFile() argument 181 rc = sqlite3OsWrite(p->pRealFile, &z[iSkip], (int)(iAmt-iSkip), iOff+iSkip); in writeDbFile() 647 i64 iOff; in cfOpen() local 650 for(iOff=0; iOff<pWrapper->iSize; iOff += 512){ in cfOpen() 651 int nRead = (int)(pWrapper->iSize - iOff); in cfOpen() 653 rc = sqlite3OsRead(pReal, &pWrapper->zData[iOff], nRead, iOff); in cfOpen()
|
| /sqlite-3.40.0/ext/session/ |
| H A D | session_speed_test.c | 40 int iOff; /* Offset of output variable */ member 138 *(int*)(&pOut[pOpt->iOff]) = 1; in parse_command_line() 146 *(int*)(&pOut[pOpt->iOff]) = get_integer_option(pOpt, argv[iArg]); in parse_command_line() 149 *(const char**)(&pOut[pOpt->iOff]) = argv[iArg]; in parse_command_line() 152 *(int*)(&pOut[pOpt->iOff]) = get_boolean_option(pOpt, argv[iArg]); in parse_command_line() 174 if( pOpt->eType!=CMDLINE_BARE || *(int*)(&pOut[pOpt->iOff]) ){ in parse_command_line() 179 fprintf(stdout, "%d ", *(int*)(&pOut[pOpt->iOff])); in parse_command_line() 182 fprintf(stdout, "%d ", *(int*)(&pOut[pOpt->iOff])); in parse_command_line() 185 fprintf(stdout, "%s ", *(const char**)(&pOut[pOpt->iOff])); in parse_command_line()
|
| /sqlite-3.40.0/ext/lsm1/lsm-test/ |
| H A D | lsmtest_main.c | 521 i64 iOff; member 538 i64 iOff, 545 if( prev.nData && nData && iOff==prev.iOff+prev.nData ){ 553 prev.iOff = iOff; 1305 i64 iOff; member 1322 i64 iOff, in do_insert_write_hook() argument 1334 && iOff==(pHook->iOff+pHook->nData) in do_insert_write_hook() 1340 pHook->iOff = iOff; in do_insert_write_hook() 1379 int iOff; in do_replay() local 1382 nMatch = sscanf(zLine, "write db %d %d", &iOff, &nData); in do_replay() [all …]
|
| H A D | lsmtest_tdb4.c | 125 static int btVfsRead(bt_file *pFile, sqlite4_int64 iOff, void *pBuf, int nBuf){ in btVfsRead() argument 128 return p->pVfs->xRead(p->pFile, iOff, pBuf, nBuf); in btVfsRead() 183 static int btSaveSectors(BtFile *p, sqlite4_int64 iOff, int nBuf){ in btSaveSectors() argument 194 iLast = (iOff+nBuf-1) / p->nSectorSize; in btSaveSectors() 195 iFirst = iOff / p->nSectorSize; in btSaveSectors() 222 static int btVfsWrite(bt_file *pFile, sqlite4_int64 iOff, void *pBuf, int nBuf){ in btVfsWrite() argument 226 btSaveSectors(p, iOff, nBuf); in btVfsWrite() 228 return p->pVfs->xWrite(p->pFile, iOff, pBuf, nBuf); in btVfsWrite() 231 static int btVfsTruncate(bt_file *pFile, sqlite4_int64 iOff){ in btVfsTruncate() argument 234 return p->pVfs->xTruncate(p->pFile, iOff); in btVfsTruncate()
|
| H A D | lsmtest_io.c | 144 i64 iOff = 0; in doOneCmd() local 153 iOff = getNextSize(z, &z, &rc); in doOneCmd() 158 lseek(pCtx->fd, (off_t)iOff, SEEK_SET); in doOneCmd()
|
| H A D | lsmtest_tdb3.c | 187 static int testEnvRead(lsm_file *pFile, lsm_i64 iOff, void *pData, int nData){ in testEnvRead() argument 191 return pRealEnv->xRead(p->pReal, iOff, pData, nData); in testEnvRead() 194 static int testEnvWrite(lsm_file *pFile, lsm_i64 iOff, void *pData, int nData){ in testEnvWrite() argument 207 iFirst = (int)(iOff / pDb->szSector); in testEnvWrite() 208 iLast = (int)((iOff + nData - 1) / pDb->szSector); in testEnvWrite() 241 rc = pRealEnv->xWrite(p->pReal, iOff, pData, nData); in testEnvWrite() 245 pDb->xWriteHook(pDb->pWriteCtx, p->bLog, iOff, nData, nUs); in testEnvWrite() 249 return pRealEnv->xWrite(p->pReal, iOff, pData, nData); in testEnvWrite() 297 static int testEnvTruncate(lsm_file *pFile, lsm_i64 iOff){ in testEnvTruncate() argument 301 return pRealEnv->xTruncate(p->pReal, iOff); in testEnvTruncate()
|
| /sqlite-3.40.0/ext/repair/ |
| H A D | checkfreelist.c | 260 int iOff = 0; in readint_function() local 270 iOff = sqlite3_value_int(apArg[1]); in readint_function() 276 if( nBlob>=(iOff+4) ){ in readint_function() 277 iRet = get4byte(&zBlob[iOff]); in readint_function()
|
| /sqlite-3.40.0/ext/misc/ |
| H A D | zipfile.c | 525 i64 iOff, /* Offset to read from */ in zipfileReadData() argument 529 fseek(pFile, (long)iOff, SEEK_SET); in zipfileReadData() 805 i64 iOff, /* Offset of CDS record */ in zipfileGetEntry() argument 816 aRead = (u8*)&aBlob[iOff]; in zipfileGetEntry() 842 pFile, aRead, nExtra+nFile, iOff+ZIPFILE_CDS_FIXED_SZ, pzErr in zipfileGetEntry() 845 aRead = (u8*)&aBlob[iOff + ZIPFILE_CDS_FIXED_SZ]; in zipfileGetEntry() 1148 i64 iOff; /* Offset to read from */ in zipfileReadEOCD() local 1156 iOff = szFile - nRead; in zipfileReadEOCD() 1226 i64 iOff; in zipfileLoadDirectory() local 1229 iOff = eocd.iOffset; in zipfileLoadDirectory() [all …]
|
| H A D | scrub.c | 105 sqlite3_int64 iOff; in scrubBackupRead() local 112 iOff = (pgno-1)*(sqlite3_int64)p->szPage; in scrubBackupRead() 113 rc = p->pSrc->pMethods->xRead(p->pSrc, pOut, p->szPage, iOff); in scrubBackupRead() 126 sqlite3_int64 iOff; in scrubBackupWrite() local 128 iOff = (pgno-1)*(sqlite3_int64)p->szPage; in scrubBackupWrite() 129 rc = p->pDest->pMethods->xWrite(p->pDest, pData, p->szPage, iOff); in scrubBackupWrite()
|