Lines Matching refs:pBuf
8817 void *pBuf; /* The content of the page */ member
24003 SQLITE_PRIVATE int sqlite3OsRead(sqlite3_file *id, void *pBuf, int amt, i64 offset){
24005 return id->pMethods->xRead(id, pBuf, amt, offset);
24007 SQLITE_PRIVATE int sqlite3OsWrite(sqlite3_file *id, const void *pBuf, int amt, i64 offset){
24009 return id->pMethods->xWrite(id, pBuf, amt, offset);
25027 static void randomFill(char *pBuf, int nByte){
25029 x = SQLITE_PTR_TO_INT(pBuf);
25035 *(int*)pBuf = r;
25036 pBuf += 4;
25043 *(pBuf++) = r & 0xff;
28499 LookasideSlot *pBuf = (LookasideSlot*)p;
28503 pBuf->pNext = db->lookaside.pSmallFree;
28504 db->lookaside.pSmallFree = pBuf;
28509 LookasideSlot *pBuf = (LookasideSlot*)p;
28513 pBuf->pNext = db->lookaside.pFree;
28514 db->lookaside.pFree = pBuf;
28675 LookasideSlot *pBuf;
28689 if( (pBuf = db->lookaside.pSmallFree)!=0 ){
28690 db->lookaside.pSmallFree = pBuf->pNext;
28692 return (void*)pBuf;
28693 }else if( (pBuf = db->lookaside.pSmallInit)!=0 ){
28694 db->lookaside.pSmallInit = pBuf->pNext;
28696 return (void*)pBuf;
28700 if( (pBuf = db->lookaside.pFree)!=0 ){
28701 db->lookaside.pFree = pBuf->pNext;
28703 return (void*)pBuf;
28704 }else if( (pBuf = db->lookaside.pInit)!=0 ){
28705 db->lookaside.pInit = pBuf->pNext;
28707 return (void*)pBuf;
31102 SQLITE_API void sqlite3_randomness(int N, void *pBuf){
31104 unsigned char *zBuf = pBuf;
31132 if( N<=0 || pBuf==0 ){
37523 static int seekAndRead(unixFile *id, sqlite3_int64 offset, void *pBuf, int cnt){
37534 got = osPread(id->h, pBuf, cnt, offset);
37537 got = osPread64(id->h, pBuf, cnt, offset);
37546 got = osRead(id->h, pBuf, cnt);
37558 pBuf = (void*)(got + (char*)pBuf);
37574 void *pBuf,
37598 memcpy(pBuf, &((u8 *)(pFile->pMapRegion))[offset], amt);
37602 memcpy(pBuf, &((u8 *)(pFile->pMapRegion))[offset], nCopy);
37603 pBuf = &((u8 *)pBuf)[nCopy];
37610 got = seekAndRead(pFile, offset, pBuf, amt);
37636 memset(&((char*)pBuf)[got], 0, amt-got);
37651 const void *pBuf, /* Copy data from this buffer to the file */
37664 do{ rc = (int)osPwrite(fd, pBuf, nBuf, iOff); }while( rc<0 && errno==EINTR );
37666 do{ rc = (int)osPwrite64(fd, pBuf, nBuf, iOff);}while( rc<0 && errno==EINTR);
37675 rc = osWrite(fd, pBuf, nBuf);
37694 static int seekAndWrite(unixFile *id, i64 offset, const void *pBuf, int cnt){
37695 return seekAndWriteFd(id->h, offset, pBuf, cnt, &id->lastErrno);
37705 const void *pBuf,
37738 if( rc!=4 || memcmp(oldCntr, &((char*)pBuf)[24-offset], 4)!=0 ){
37750 memcpy(&((u8 *)(pFile->pMapRegion))[offset], pBuf, amt);
37754 memcpy(&((u8 *)(pFile->pMapRegion))[offset], pBuf, nCopy);
37755 pBuf = &((u8 *)pBuf)[nCopy];
37762 while( (wrote = seekAndWrite(pFile, offset, pBuf, amt))<amt && wrote>0 ){
37765 pBuf = &((char*)pBuf)[wrote];
45083 void *pBuf, /* Write content into this buffer */
45100 pFile->h, pBuf, amt, offset, pFile->locktype));
45107 memcpy(pBuf, &((u8 *)(pFile->pMapRegion))[offset], amt);
45113 memcpy(pBuf, &((u8 *)(pFile->pMapRegion))[offset], nCopy);
45114 pBuf = &((u8 *)pBuf)[nCopy];
45127 while( !osReadFile(pFile->h, pBuf, amt, &nRead, 0) ){
45132 while( !osReadFile(pFile->h, pBuf, amt, &nRead, &overlapped) &&
45146 memset(&((char*)pBuf)[nRead], 0, amt-nRead);
45163 const void *pBuf, /* The bytes to be written */
45178 pFile->h, pBuf, amt, offset, pFile->locktype));
45185 memcpy(&((u8 *)(pFile->pMapRegion))[offset], pBuf, amt);
45191 memcpy(&((u8 *)(pFile->pMapRegion))[offset], pBuf, nCopy);
45192 pBuf = &((u8 *)pBuf)[nCopy];
45208 u8 *aRem = (u8 *)pBuf; /* Data yet to be written */
49646 SQLITE_PRIVATE void sqlite3BitvecClear(Bitvec *p, u32 i, void *pBuf){
49662 u32 *aiValues = pBuf;
49905 a = (unsigned char *)pLower->pBuf;
50294 pPgHdr->pData = pPage->pBuf;
50487 memset(pPage1->pBuf, 0, pCache->szPage);
50972 SQLITE_PRIVATE void sqlite3PCacheBufferSetup(void *pBuf, int sz, int n){
50975 if( pBuf==0 ) sz = n = 0;
50981 pcache1.pStart = pBuf;
50985 p = (PgFreeslot*)pBuf;
50988 pBuf = (void*)&((char*)pBuf)[sz];
50990 pcache1.pEnd = pBuf;
51019 pX->page.pBuf = zBulk;
51168 p->page.pBuf = pPg;
51190 pcache1Free(p->page.pBuf);
51956 nFree += pcache1MemSize(p->page.pBuf);
70373 void *pBuf, /* Pointer to buffer */
70384 memcpy(pPayload, pBuf, nByte);
70387 memcpy(pBuf, pPayload, nByte);
70425 unsigned char *pBuf, /* Write the bytes into this buffer */
70434 unsigned char * const pBufStart = pBuf; /* Start of original out buffer */
70465 rc = copyPayload(&aPayload[offset], pBuf, a, eOp, pPage->pDbPage);
70467 pBuf += a;
70565 && &pBuf[-4]>=pBufStart /* (6) */
70569 u8 *aWrite = &pBuf[-4];
70587 rc = copyPayload(&aPayload[offset+4], pBuf, a, eOp, pDbPage);
70594 pBuf += a;
70625 SQLITE_PRIVATE int sqlite3BtreePayload(BtCursor *pCur, u32 offset, u32 amt, void *pBuf){
70629 return accessPayload(pCur, offset, amt, (unsigned char*)pBuf, 0);
70642 void *pBuf
70650 return rc ? rc : accessPayload(pCur, offset, amt, pBuf, 0);
70652 SQLITE_PRIVATE int sqlite3BtreePayloadChecked(BtCursor *pCur, u32 offset, u32 amt, void *pBuf){
70655 return accessPayload(pCur, offset, amt, pBuf, 0);
70657 return accessPayloadChecked(pCur, offset, amt, pBuf);
81446 void *pBuf, /* Pointer to a prior allocation */
81450 if( pBuf==0 ){
81454 pBuf = &p->pSpace[p->nFree];
81459 assert( EIGHT_BYTE_ALIGNMENT(pBuf) );
81460 return pBuf;
167338 static int setupLookaside(sqlite3 *db, void *pBuf, int sz, int cnt){
167364 }else if( pBuf==0 ){
167370 pStart = pBuf;
167415 db->lookaside.bMalloced = pBuf==0 ?1:0;
167518 void *pBuf = va_arg(ap, void*); /* IMP: R-26835-10964 */
167521 rc = setupLookaside(db, pBuf, sz, cnt);
172990 SQLITE_PRIVATE int sqlite3Fts3GetVarintU(const char *pBuf, sqlite_uint64 *v){
172991 const unsigned char *p = (const unsigned char*)pBuf;
173017 SQLITE_PRIVATE int sqlite3Fts3GetVarint(const char *pBuf, sqlite_int64 *v){
173018 return sqlite3Fts3GetVarintU(pBuf, (sqlite3_uint64*)v);
173028 const char *pBuf,
173032 const unsigned char *p = (const unsigned char*)pBuf;
188837 MatchinfoBuffer *pBuf = (MatchinfoBuffer*)((u8*)p - ((u32*)p)[-1]);
188839 assert( (u32*)p==&pBuf->aMatchinfo[1]
188840 || (u32*)p==&pBuf->aMatchinfo[pBuf->nElem+2]
188842 if( (u32*)p==&pBuf->aMatchinfo[1] ){
188843 pBuf->aRef[1] = 0;
188845 pBuf->aRef[2] = 0;
188848 if( pBuf->aRef[0]==0 && pBuf->aRef[1]==0 && pBuf->aRef[2]==0 ){
188849 sqlite3_free(pBuf);
206446 u8 *pBuf = (u8*)zBuf;
206447 p->iCookie = rbuGetU32(&pBuf[24]);
206448 p->iWriteVer = pBuf[19];
206489 u8 *pBuf = (u8*)zBuf;
206490 p->iCookie = rbuGetU32(&pBuf[24]);
206491 p->iWriteVer = pBuf[19];
210688 SessionBuffer *pBuf, /* Buffer to append to */
210697 int nRewind = pBuf->nBuf; /* Set to zero if any values are modified */
210702 sessionAppendByte(pBuf, SQLITE_UPDATE, &rc);
210703 sessionAppendByte(pBuf, p->bIndirect, &rc);
210755 sessionAppendBlob(pBuf, pCsr, nAdvance, &rc);
210757 sessionAppendByte(pBuf, 0, &rc);
210773 pBuf->nBuf = nRewind;
210775 sessionAppendBlob(pBuf, buf2.aBuf, buf2.nBuf, &rc);
210788 SessionBuffer *pBuf, /* Buffer to append to */
210796 sessionAppendByte(pBuf, SQLITE_DELETE, &rc);
210797 sessionAppendByte(pBuf, p->bIndirect, &rc);
210800 sessionAppendBlob(pBuf, p->aRecord, p->nRecord, &rc);
210827 sessionAppendBlob(pBuf, pStart, (int)(a-pStart), &rc);
210971 SessionBuffer *pBuf, /* Append header to this buffer */
210977 sessionAppendByte(pBuf, (bPatchset ? 'P' : 'T'), pRc);
210978 sessionAppendVarint(pBuf, pTab->nCol, pRc);
210979 sessionAppendBlob(pBuf, pTab->abPK, pTab->nCol, pRc);
210980 sessionAppendBlob(pBuf, (u8 *)pTab->zName, (int)strlen(pTab->zName)+1, pRc);
213907 SessionBuffer *pBuf, /* Buffer to append to */
213913 sessionBufferGrow(pBuf, n1+n2, pRc);
213916 u8 *pOut = &pBuf->aBuf[pBuf->nBuf];
213931 pBuf->nBuf = pOut-pBuf->aBuf;
213932 assert( pBuf->nBuf<=pBuf->nAlloc );
213956 SessionBuffer *pBuf, /* Append record here */
213962 sessionBufferGrow(pBuf, 2+nRec+nChange, pRc);
213965 u8 *pOut = &pBuf->aBuf[pBuf->nBuf];
214003 pBuf->nBuf = (pOut - pBuf->aBuf);
215141 #define fts5BufferGrow(pRc,pBuf,nn) ( \
215142 (u32)((pBuf)->n) + (u32)(nn) <= (u32)((pBuf)->nSpace) ? 0 : \
215143 sqlite3Fts5BufferSize((pRc),(pBuf),(nn)+(pBuf)->n) \
217933 static int sqlite3Fts5BufferSize(int *pRc, Fts5Buffer *pBuf, u32 nByte){
217934 if( (u32)pBuf->nSpace<nByte ){
217935 u64 nNew = pBuf->nSpace ? pBuf->nSpace : 64;
217940 pNew = sqlite3_realloc64(pBuf->p, nNew);
217945 pBuf->nSpace = (int)nNew;
217946 pBuf->p = pNew;
217957 static void sqlite3Fts5BufferAppendVarint(int *pRc, Fts5Buffer *pBuf, i64 iVal){
217958 if( fts5BufferGrow(pRc, pBuf, 9) ) return;
217959 pBuf->n += sqlite3Fts5PutVarint(&pBuf->p[pBuf->n], iVal);
217980 Fts5Buffer *pBuf,
217985 if( fts5BufferGrow(pRc, pBuf, nData) ) return;
217986 memcpy(&pBuf->p[pBuf->n], pData, nData);
217987 pBuf->n += nData;
217998 Fts5Buffer *pBuf,
218002 sqlite3Fts5BufferAppendBlob(pRc, pBuf, nStr+1, (const u8*)zStr);
218003 pBuf->n--;
218016 Fts5Buffer *pBuf,
218029 sqlite3Fts5BufferAppendString(pRc, pBuf, zTmp);
218053 static void sqlite3Fts5BufferFree(Fts5Buffer *pBuf){
218054 sqlite3_free(pBuf->p);
218055 memset(pBuf, 0, sizeof(Fts5Buffer));
218062 static void sqlite3Fts5BufferZero(Fts5Buffer *pBuf){
218063 pBuf->n = 0;
218073 Fts5Buffer *pBuf,
218077 pBuf->n = 0;
218078 sqlite3Fts5BufferAppendBlob(pRc, pBuf, nData, pData);
218149 Fts5Buffer *pBuf,
218156 pBuf->p[pBuf->n++] = 1;
218157 pBuf->n += sqlite3Fts5PutVarint(&pBuf->p[pBuf->n], (iPos>>32));
218160 pBuf->n += sqlite3Fts5PutVarint(&pBuf->p[pBuf->n], (iPos-*piPrev)+2);
218166 Fts5Buffer *pBuf,
218171 if( fts5BufferGrow(&rc, pBuf, 5+5+5) ) return rc;
218172 sqlite3Fts5PoslistSafeAppend(pBuf, &pWriter->iPrev, iPos);
219750 Fts5Buffer *pBuf, /* Use this buffer for space if required */
219789 fts5BufferZero(pBuf);
219804 rc = sqlite3Fts5PoslistWriterAppend(pBuf, &writer, iMin);
219808 *pa = pBuf->p;
219809 *pn = pBuf->n;
222165 Fts5Buffer *pBuf = &pExpr->apExprPhrase[i]->poslist;
222169 (pBuf->n==0 || pNode->iRowid!=pExpr->pRoot->iRowid || pNode->bEof)
222173 pBuf->n = 0;
222344 Fts5Buffer *pBuf = (Fts5Buffer*)&pTerm->pSynonym[1];
222346 pTerm, pNode->iRowid, pBuf, (u8**)ppCollist, pnCollist
224077 #define fts5BufferSafeAppendBlob(pBuf, pBlob, nBlob) { \
224078 assert( (pBuf)->nSpace>=((pBuf)->n+nBlob) ); \
224079 memcpy(&(pBuf)->p[(pBuf)->n], pBlob, nBlob); \
224080 (pBuf)->n += nBlob; \
224083 #define fts5BufferSafeAppendVarint(pBuf, iVal) { \
224084 (pBuf)->n += sqlite3Fts5PutVarint(&(pBuf)->p[(pBuf)->n], (iVal)); \
224085 assert( (pBuf)->nSpace>=(pBuf)->n ); \
225940 Fts5Buffer *pBuf; /* Append to this buffer */
225947 Fts5Buffer *pBuf; /* Append to this buffer */
225980 fts5BufferSafeAppendVarint(pCtx->pBuf, iVal + 2 - pCtx->iWrite);
226006 fts5BufferSafeAppendVarint(pCtx->pBuf, 1);
226018 fts5BufferSafeAppendBlob(pCtx->pBuf, &pChunk[iStart], i-iStart);
226030 fts5BufferSafeAppendBlob(pCtx->pBuf, &pChunk[iStart], i-iStart);
226093 Fts5Buffer *pBuf
226095 assert( pBuf!=0 );
226097 if( 0==fts5BufferGrow(&p->rc, pBuf, pSeg->nPos+FTS5_DATA_ZERO_PADDING) ){
226098 assert( pBuf->p!=0 );
226099 assert( pBuf->nSpace >= pBuf->n+pSeg->nPos+FTS5_DATA_ZERO_PADDING );
226100 memset(&pBuf->p[pBuf->n+pSeg->nPos], 0, FTS5_DATA_ZERO_PADDING);
226102 fts5ChunkIterate(p, pSeg, (void*)pBuf, fts5PoslistCallback);
226106 sCtx.pBuf = pBuf;
226114 sCtx.pBuf = pBuf;
226784 static i64 fts5DlidxExtractFirstRowid(Fts5Buffer *pBuf){
226788 iOff = 1 + fts5GetVarint(&pBuf->p[1], (u64*)&iRowid);
226789 fts5GetVarint(&pBuf->p[iOff], (u64*)&iRowid);
227507 Fts5Buffer *pBuf; /* Buffer in which to assemble leaf page */
227513 pBuf = &writer.writer.buf;
227518 assert( p->rc || pBuf->nSpace>=(pgsz + FTS5_DATA_PADDING) );
227537 if( pgsz>=(pBuf->n + pPgidx->n + nDoclist + 1) ){
227539 fts5BufferSafeAppendBlob(pBuf, pDoclist, nDoclist);
227553 fts5PutU16(&pBuf->p[0], (u16)pBuf->n); /* first rowid on page */
227554 pBuf->n += sqlite3Fts5PutVarint(&pBuf->p[pBuf->n], iRowid);
227559 pBuf->n += sqlite3Fts5PutVarint(&pBuf->p[pBuf->n], iDelta);
227561 assert( pBuf->n<=pBuf->nSpace );
227565 pBuf->p[pBuf->n++] = 0;
227568 pBuf->p[pBuf->n++] = 0;
227572 if( (pBuf->n + pPgidx->n)>=pgsz ){
227580 if( (pBuf->n + pPgidx->n + nCopy) <= pgsz ){
227583 fts5BufferSafeAppendBlob(pBuf, &pDoclist[iOff], nCopy);
227591 int nSpace = pgsz - pBuf->n - pPgidx->n;
227599 fts5BufferSafeAppendBlob(pBuf, &pPoslist[iPos], n);
227601 if( (pBuf->n + pPgidx->n)>=pgsz ){
227614 assert( pBuf->n<=pBuf->nSpace );
227776 Fts5Buffer *pBuf
227779 fts5BufferAppendVarint(&p->rc, pBuf, iDelta);
227786 Fts5Buffer *pBuf
227791 if( p->rc==SQLITE_OK && 0==fts5BufferGrow(&p->rc, pBuf, nByte) ){
227792 fts5BufferSafeAppendVarint(pBuf, iDelta);
227793 fts5BufferSafeAppendVarint(pBuf, nData*2);
227794 fts5BufferSafeAppendBlob(pBuf, pMulti->base.pData, nData);
227795 memset(&pBuf->p[pBuf->n], 0, FTS5_DATA_ZERO_PADDING);
227830 Fts5Buffer *pBuf,
227834 if( pBuf->n>0 ){
227835 pIter->aPoslist = pBuf->p;
227836 pIter->aEof = &pBuf->p[pBuf->n];
227849 Fts5Buffer *pBuf, /* Buffer to write to */
227853 assert( pBuf->n!=0 || (*piLastRowid)==0 );
227854 fts5BufferSafeAppendVarint(pBuf, iRowid - *piLastRowid);
227859 #define fts5MergeAppendDocid(pBuf, iLastRowid, iRowid) { \
227860 assert( (pBuf)->n!=0 || (iLastRowid)==0 ); \
227861 fts5BufferSafeAppendVarint((pBuf), (iRowid) - (iLastRowid)); \
227874 static void fts5NextRowid(Fts5Buffer *pBuf, int *piOff, i64 *piRowid){
227876 if( i>=pBuf->n ){
227880 *piOff = i + sqlite3Fts5GetVarint(&pBuf->p[i], &iVal);
229260 static void fts5DebugRowid(int *pRc, Fts5Buffer *pBuf, i64 iKey){
229266 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, "{averages} ");
229268 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, "{structure}");
229272 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, "{%ssegid=%d h=%d pgno=%d}",
229282 Fts5Buffer *pBuf,
229289 sqlite3Fts5BufferAppendPrintf(pRc, pBuf,
229294 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, " {id=%d leaves=%d..%d}",
229298 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, "}");
229313 Fts5Buffer *pBuf,
229325 fts5DebugStructure(pRc, pBuf, p);
229340 Fts5Buffer *pBuf,
229349 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, "%s%d", zSpace, (int)iVal);
229363 static int fts5DecodePoslist(int *pRc, Fts5Buffer *pBuf, const u8 *a, int n){
229368 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, " %d", iVal);
229383 static int fts5DecodeDoclist(int *pRc, Fts5Buffer *pBuf, const u8 *a, int n){
229389 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, " id=%lld", iDocid);
229395 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, " nPos=%d%s", nPos, bDel?"*":"");
229396 iOff += fts5DecodePoslist(pRc, pBuf, &a[iOff], MIN(n-iOff, nPos));
229401 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, " id=%lld", iDocid);
229425 Fts5Buffer *pBuf, /* Buffer to append text to */
229447 sqlite3Fts5BufferAppendPrintf(pRc, pBuf, " %lld%s", iRowid, zApp);
233131 Fts5Buffer *pBuf /* sz value */
233139 sqlite3_bind_blob(pReplace, 2, pBuf->p, pBuf->n, SQLITE_STATIC);