Lines Matching refs:nBuf
65 int nBuf; /* Size of buffer aBuf */ member
1999 i64 nReq = p->nBuf + nByte; in sessionBufferGrow()
2047 rc = sessionSerializeValue(&p->aBuf[p->nBuf], pVal, 0); in sessionAppendValue()
2048 p->nBuf += nByte; in sessionAppendValue()
2064 p->aBuf[p->nBuf++] = v; in sessionAppendByte()
2077 p->nBuf += sessionVarintPut(&p->aBuf[p->nBuf], v); in sessionAppendVarint()
2095 memcpy(&p->aBuf[p->nBuf], aBlob, nBlob); in sessionAppendBlob()
2096 p->nBuf += nBlob; in sessionAppendBlob()
2115 memcpy(&p->aBuf[p->nBuf], zStr, nStr); in sessionAppendStr()
2116 p->nBuf += nStr; in sessionAppendStr()
2154 char *zOut = (char *)&p->aBuf[p->nBuf]; in sessionAppendIdent()
2162 p->nBuf = (int)((u8 *)zOut - p->aBuf); in sessionAppendIdent()
2244 int nRewind = pBuf->nBuf; /* Set to zero if any values are modified */ in sessionAppendUpdate()
2320 pBuf->nBuf = nRewind; in sessionAppendUpdate()
2322 sessionAppendBlob(pBuf, buf2.aBuf, buf2.nBuf, &rc); in sessionAppendUpdate()
2428 nSql = buf.nBuf; in sessionSelectStmt()
2579 int nRewind = buf.nBuf; /* Initial size of write buffer */ in sessionGenerateChangeset()
2597 nNoop = buf.nBuf; in sessionGenerateChangeset()
2627 && buf.nBuf>nNoop in sessionGenerateChangeset()
2628 && buf.nBuf>sessions_strm_chunk_size in sessionGenerateChangeset()
2630 rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); in sessionGenerateChangeset()
2632 buf.nBuf = 0; in sessionGenerateChangeset()
2639 if( buf.nBuf==nNoop ){ in sessionGenerateChangeset()
2640 buf.nBuf = nRewind; in sessionGenerateChangeset()
2648 *pnChangeset = buf.nBuf; in sessionGenerateChangeset()
2651 }else if( buf.nBuf>0 ){ in sessionGenerateChangeset()
2652 rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); in sessionGenerateChangeset()
2893 int nMove = pIn->buf.nBuf - pIn->iNext; in sessionDiscardData()
2898 pIn->buf.nBuf -= pIn->iNext; in sessionDiscardData()
2900 pIn->nData = pIn->buf.nBuf; in sessionDiscardData()
2919 rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew); in sessionInputBuffer()
2923 pIn->buf.nBuf += nNew; in sessionInputBuffer()
2928 pIn->nData = pIn->buf.nBuf; in sessionInputBuffer()
3183 p->tblhdr.nBuf = 0; in sessionChangesetReadTblhdr()
3591 sPK.nBuf = 0; in sessionChangesetInvert()
3676 if( xOutput && sOut.nBuf>=sessions_strm_chunk_size ){ in sessionChangesetInvert()
3677 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionChangesetInvert()
3678 sOut.nBuf = 0; in sessionChangesetInvert()
3685 *pnInverted = sOut.nBuf; in sessionChangesetInvert()
3688 }else if( sOut.nBuf>0 && ALWAYS(xOutput!=0) ){ in sessionChangesetInvert()
3689 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionChangesetInvert()
3890 rc = sqlite3_prepare_v2(p->db, zSql, buf.nBuf, &pUp->pStmt, 0); in sessionUpdateFind()
3992 rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pDelete, 0); in sessionDeleteRow()
4054 rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pInsert, 0); in sessionInsertRow()
4582 while( pApply->constraints.nBuf ){ in sessionRetryConstraints()
4588 &pIter2, 0, 0, cons.nBuf, cons.aBuf, pApply->bInvertConstraints, 1 in sessionRetryConstraints()
4608 assert( pApply->bDeferConstraints || pApply->constraints.nBuf==0 ); in sessionRetryConstraints()
4612 if( pApply->constraints.nBuf>=cons.nBuf ){ in sessionRetryConstraints()
4805 assert( sApply.bRebase || sApply.rebase.nBuf==0 ); in sessionChangesetApply()
4808 *pnRebase = sApply.rebase.nBuf; in sessionChangesetApply()
5276 if( rc==SQLITE_OK && xOutput && buf.nBuf>=sessions_strm_chunk_size ){ in sessionChangegroupOutput()
5277 rc = xOutput(pOut, buf.aBuf, buf.nBuf); in sessionChangegroupOutput()
5278 buf.nBuf = 0; in sessionChangegroupOutput()
5286 if( buf.nBuf>0 ) rc = xOutput(pOut, buf.aBuf, buf.nBuf); in sessionChangegroupOutput()
5289 if( pnOut ) *pnOut = buf.nBuf; in sessionChangegroupOutput()
5463 u8 *pOut = &pBuf->aBuf[pBuf->nBuf]; in sessionAppendRecordMerge()
5478 pBuf->nBuf = pOut-pBuf->aBuf; in sessionAppendRecordMerge()
5479 assert( pBuf->nBuf<=pBuf->nAlloc ); in sessionAppendRecordMerge()
5512 u8 *pOut = &pBuf->aBuf[pBuf->nBuf]; in sessionAppendPartialUpdate()
5550 pBuf->nBuf = (pOut - pBuf->aBuf); in sessionAppendPartialUpdate()
5672 if( rc==SQLITE_OK && xOutput && sOut.nBuf>sessions_strm_chunk_size ){ in sessionRebase()
5673 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionRebase()
5674 sOut.nBuf = 0; in sessionRebase()
5686 if( sOut.nBuf>0 ){ in sessionRebase()
5687 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionRebase()
5691 *pnOut = sOut.nBuf; in sessionRebase()