Lines Matching refs:aBuf
64 u8 *aBuf; /* Pointer to changeset buffer */ member
308 static int sessionVarintPut(u8 *aBuf, int iVal){ in sessionVarintPut() argument
309 return putVarint32(aBuf, iVal); in sessionVarintPut()
323 static int sessionVarintGet(u8 *aBuf, int *piVal){ in sessionVarintGet() argument
324 return getVarint32(aBuf, *piVal); in sessionVarintGet()
344 static void sessionPutI64(u8 *aBuf, sqlite3_int64 i){ in sessionPutI64() argument
345 aBuf[0] = (i>>56) & 0xFF; in sessionPutI64()
346 aBuf[1] = (i>>48) & 0xFF; in sessionPutI64()
347 aBuf[2] = (i>>40) & 0xFF; in sessionPutI64()
348 aBuf[3] = (i>>32) & 0xFF; in sessionPutI64()
349 aBuf[4] = (i>>24) & 0xFF; in sessionPutI64()
350 aBuf[5] = (i>>16) & 0xFF; in sessionPutI64()
351 aBuf[6] = (i>> 8) & 0xFF; in sessionPutI64()
352 aBuf[7] = (i>> 0) & 0xFF; in sessionPutI64()
369 u8 *aBuf, /* If non-NULL, write serialized value here */ in sessionSerializeValue() argument
379 if( aBuf ) aBuf[0] = eType; in sessionSerializeValue()
388 if( aBuf ){ in sessionSerializeValue()
401 sessionPutI64(&aBuf[1], i); in sessionSerializeValue()
421 if( aBuf ){ in sessionSerializeValue()
422 sessionVarintPut(&aBuf[1], n); in sessionSerializeValue()
423 if( n>0 ) memcpy(&aBuf[nVarint + 1], z, n); in sessionSerializeValue()
432 if( aBuf ) aBuf[0] = '\0'; in sessionSerializeValue()
2021 aNew = (u8 *)sqlite3_realloc64(p->aBuf, nNew); in sessionBufferGrow()
2025 p->aBuf = aNew; in sessionBufferGrow()
2047 rc = sessionSerializeValue(&p->aBuf[p->nBuf], pVal, 0); 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()
2115 memcpy(&p->aBuf[p->nBuf], zStr, nStr); in sessionAppendStr()
2133 char aBuf[24]; in sessionAppendInteger() local
2134 sqlite3_snprintf(sizeof(aBuf)-1, aBuf, "%d", iVal); in sessionAppendInteger()
2135 sessionAppendStr(p, aBuf, pRc); in sessionAppendInteger()
2154 char *zOut = (char *)&p->aBuf[p->nBuf]; in sessionAppendIdent()
2162 p->nBuf = (int)((u8 *)zOut - p->aBuf); in sessionAppendIdent()
2183 u8 aBuf[8]; in sessionAppendCol() local
2190 sessionPutI64(aBuf, i); in sessionAppendCol()
2191 sessionAppendBlob(p, aBuf, 8, pRc); in sessionAppendCol()
2322 sessionAppendBlob(pBuf, buf2.aBuf, buf2.nBuf, &rc); in sessionAppendUpdate()
2324 sqlite3_free(buf2.aBuf); in sessionAppendUpdate()
2427 zSql = (char*)buf.aBuf; in sessionSelectStmt()
2630 rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); in sessionGenerateChangeset()
2649 *ppChangeset = buf.aBuf; in sessionGenerateChangeset()
2650 buf.aBuf = 0; in sessionGenerateChangeset()
2652 rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); in sessionGenerateChangeset()
2656 sqlite3_free(buf.aBuf); in sessionGenerateChangeset()
2896 memmove(pIn->buf.aBuf, &pIn->buf.aBuf[pIn->iNext], nMove); in sessionDiscardData()
2919 rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew); in sessionInputBuffer()
2927 pIn->aData = pIn->buf.aBuf; in sessionInputBuffer()
3192 memset(p->tblhdr.aBuf, 0, iPK); in sessionChangesetReadTblhdr()
3193 memcpy(&p->tblhdr.aBuf[iPK], &p->in.aData[p->in.iNext], nCopy); in sessionChangesetReadTblhdr()
3197 p->apValue = (sqlite3_value**)p->tblhdr.aBuf; in sessionChangesetReadTblhdr()
3537 sqlite3_free(p->tblhdr.aBuf); in sqlite3changeset_finalize()
3538 sqlite3_free(p->in.buf.aBuf); in sqlite3changeset_finalize()
3600 abPK = sPK.aBuf; in sessionChangesetInvert()
3677 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionChangesetInvert()
3686 *ppInverted = sOut.aBuf; in sessionChangesetInvert()
3687 sOut.aBuf = 0; in sessionChangesetInvert()
3689 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionChangesetInvert()
3693 sqlite3_free(sOut.aBuf); in sessionChangesetInvert()
3695 sqlite3_free(sPK.aBuf); in sessionChangesetInvert()
3737 sqlite3_free(sInput.buf.aBuf); in sqlite3changeset_invert_strm()
3889 char *zSql = (char*)buf.aBuf; in sessionUpdateFind()
3900 sqlite3_free(buf.aBuf); in sessionUpdateFind()
3992 rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pDelete, 0); in sessionDeleteRow()
3994 sqlite3_free(buf.aBuf); in sessionDeleteRow()
4054 rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pInsert, 0); in sessionInsertRow()
4056 sqlite3_free(buf.aBuf); in sessionInsertRow()
4588 &pIter2, 0, 0, cons.nBuf, cons.aBuf, pApply->bInvertConstraints, 1 in sessionRetryConstraints()
4598 pIter2->apValue = (sqlite3_value**)pIter2->tblhdr.aBuf; in sessionRetryConstraints()
4610 sqlite3_free(cons.aBuf); in sessionRetryConstraints()
4807 *ppRebase = (void*)sApply.rebase.aBuf; in sessionChangesetApply()
4809 sApply.rebase.aBuf = 0; in sessionChangesetApply()
4816 sqlite3_free((char*)sApply.constraints.aBuf); in sessionChangesetApply()
4817 sqlite3_free((char*)sApply.rebase.aBuf); in sessionChangesetApply()
5277 rc = xOutput(pOut, buf.aBuf, buf.nBuf); in sessionChangegroupOutput()
5286 if( buf.nBuf>0 ) rc = xOutput(pOut, buf.aBuf, buf.nBuf); in sessionChangegroupOutput()
5288 *ppOut = buf.aBuf; in sessionChangegroupOutput()
5290 buf.aBuf = 0; in sessionChangegroupOutput()
5293 sqlite3_free(buf.aBuf); in sessionChangegroupOutput()
5463 u8 *pOut = &pBuf->aBuf[pBuf->nBuf]; in sessionAppendRecordMerge()
5478 pBuf->nBuf = pOut-pBuf->aBuf; in sessionAppendRecordMerge()
5512 u8 *pOut = &pBuf->aBuf[pBuf->nBuf]; in sessionAppendPartialUpdate()
5550 pBuf->nBuf = (pOut - pBuf->aBuf); in sessionAppendPartialUpdate()
5673 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionRebase()
5680 sqlite3_free(sOut.aBuf); in sessionRebase()
5687 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionRebase()
5690 *ppOut = (void*)sOut.aBuf; in sessionRebase()
5692 sOut.aBuf = 0; in sessionRebase()
5695 sqlite3_free(sOut.aBuf); in sessionRebase()