Lines Matching refs:buf
82 SessionBuffer buf; /* Current read buffer */ member
2411 SessionBuffer buf = {0, 0, 0}; in sessionSelectStmt() local
2413 sessionAppendStr(&buf, "SELECT * FROM ", &rc); in sessionSelectStmt()
2414 sessionAppendIdent(&buf, zDb, &rc); in sessionSelectStmt()
2415 sessionAppendStr(&buf, ".", &rc); in sessionSelectStmt()
2416 sessionAppendIdent(&buf, zTab, &rc); in sessionSelectStmt()
2417 sessionAppendStr(&buf, " WHERE ", &rc); in sessionSelectStmt()
2420 sessionAppendStr(&buf, zSep, &rc); in sessionSelectStmt()
2421 sessionAppendIdent(&buf, azCol[i], &rc); in sessionSelectStmt()
2422 sessionAppendStr(&buf, " IS ?", &rc); in sessionSelectStmt()
2423 sessionAppendInteger(&buf, i+1, &rc); in sessionSelectStmt()
2427 zSql = (char*)buf.aBuf; in sessionSelectStmt()
2428 nSql = buf.nBuf; in sessionSelectStmt()
2550 SessionBuffer buf = {0,0,0}; /* Buffer in which to accumlate changeset */ in sessionGenerateChangeset() local
2579 int nRewind = buf.nBuf; /* Initial size of write buffer */ in sessionGenerateChangeset()
2589 sessionAppendTableHdr(&buf, bPatchset, pTab, &rc); in sessionGenerateChangeset()
2597 nNoop = buf.nBuf; in sessionGenerateChangeset()
2607 sessionAppendByte(&buf, SQLITE_INSERT, &rc); in sessionGenerateChangeset()
2608 sessionAppendByte(&buf, p->bIndirect, &rc); in sessionGenerateChangeset()
2610 sessionAppendCol(&buf, pSel, iCol, &rc); in sessionGenerateChangeset()
2614 rc = sessionAppendUpdate(&buf, bPatchset, pSel, p, abPK); in sessionGenerateChangeset()
2617 rc = sessionAppendDelete(&buf, bPatchset, p, nCol, abPK); 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()
2649 *ppChangeset = buf.aBuf; in sessionGenerateChangeset()
2650 buf.aBuf = 0; in sessionGenerateChangeset()
2651 }else if( buf.nBuf>0 ){ in sessionGenerateChangeset()
2652 rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); in sessionGenerateChangeset()
2656 sqlite3_free(buf.aBuf); in sessionGenerateChangeset()
2893 int nMove = pIn->buf.nBuf - pIn->iNext; in sessionDiscardData()
2896 memmove(pIn->buf.aBuf, &pIn->buf.aBuf[pIn->iNext], nMove); in sessionDiscardData()
2898 pIn->buf.nBuf -= pIn->iNext; in sessionDiscardData()
2900 pIn->nData = pIn->buf.nBuf; in sessionDiscardData()
2918 if( SQLITE_OK==sessionBufferGrow(&pIn->buf, nNew, &rc) ){ in sessionInputBuffer()
2919 rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew); in sessionInputBuffer()
2923 pIn->buf.nBuf += nNew; in sessionInputBuffer()
2927 pIn->aData = pIn->buf.aBuf; in sessionInputBuffer()
2928 pIn->nData = pIn->buf.nBuf; in sessionInputBuffer()
3538 sqlite3_free(p->in.buf.aBuf); in sqlite3changeset_finalize()
3737 sqlite3_free(sInput.buf.aBuf); in sqlite3changeset_invert_strm()
3845 SessionBuffer buf; in sessionUpdateFind() local
3847 memset(&buf, 0, sizeof(buf)); in sessionUpdateFind()
3851 sessionAppendStr(&buf, "UPDATE main.", &rc); in sessionUpdateFind()
3852 sessionAppendIdent(&buf, pIter->zTab, &rc); in sessionUpdateFind()
3853 sessionAppendStr(&buf, " SET ", &rc); in sessionUpdateFind()
3858 sessionAppendStr(&buf, zSep, &rc); in sessionUpdateFind()
3859 sessionAppendIdent(&buf, p->azCol[ii], &rc); in sessionUpdateFind()
3860 sessionAppendStr(&buf, " = ?", &rc); in sessionUpdateFind()
3861 sessionAppendInteger(&buf, ii*2+1, &rc); in sessionUpdateFind()
3868 sessionAppendStr(&buf, " WHERE ", &rc); in sessionUpdateFind()
3871 sessionAppendStr(&buf, zSep, &rc); in sessionUpdateFind()
3874 sessionAppendStr(&buf, in sessionUpdateFind()
3880 sessionAppendIdent(&buf, p->azCol[ii], &rc); in sessionUpdateFind()
3881 sessionAppendStr(&buf, " IS ?", &rc); in sessionUpdateFind()
3882 sessionAppendInteger(&buf, ii*2+2, &rc); in sessionUpdateFind()
3889 char *zSql = (char*)buf.aBuf; in sessionUpdateFind()
3890 rc = sqlite3_prepare_v2(p->db, zSql, buf.nBuf, &pUp->pStmt, 0); in sessionUpdateFind()
3900 sqlite3_free(buf.aBuf); in sessionUpdateFind()
3955 SessionBuffer buf = {0, 0, 0}; in sessionDeleteRow() local
3958 sessionAppendStr(&buf, "DELETE FROM main.", &rc); in sessionDeleteRow()
3959 sessionAppendIdent(&buf, zTab, &rc); in sessionDeleteRow()
3960 sessionAppendStr(&buf, " WHERE ", &rc); in sessionDeleteRow()
3965 sessionAppendStr(&buf, zSep, &rc); in sessionDeleteRow()
3966 sessionAppendIdent(&buf, p->azCol[i], &rc); in sessionDeleteRow()
3967 sessionAppendStr(&buf, " = ?", &rc); in sessionDeleteRow()
3968 sessionAppendInteger(&buf, i+1, &rc); in sessionDeleteRow()
3974 sessionAppendStr(&buf, " AND (?", &rc); in sessionDeleteRow()
3975 sessionAppendInteger(&buf, p->nCol+1, &rc); in sessionDeleteRow()
3976 sessionAppendStr(&buf, " OR ", &rc); in sessionDeleteRow()
3981 sessionAppendStr(&buf, zSep, &rc); in sessionDeleteRow()
3982 sessionAppendIdent(&buf, p->azCol[i], &rc); in sessionDeleteRow()
3983 sessionAppendStr(&buf, " IS ?", &rc); in sessionDeleteRow()
3984 sessionAppendInteger(&buf, i+1, &rc); in sessionDeleteRow()
3988 sessionAppendStr(&buf, ")", &rc); in sessionDeleteRow()
3992 rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pDelete, 0); in sessionDeleteRow()
3994 sqlite3_free(buf.aBuf); in sessionDeleteRow()
4037 SessionBuffer buf = {0, 0, 0}; in sessionInsertRow() local
4039 sessionAppendStr(&buf, "INSERT INTO main.", &rc); in sessionInsertRow()
4040 sessionAppendIdent(&buf, zTab, &rc); in sessionInsertRow()
4041 sessionAppendStr(&buf, "(", &rc); in sessionInsertRow()
4043 if( i!=0 ) sessionAppendStr(&buf, ", ", &rc); in sessionInsertRow()
4044 sessionAppendIdent(&buf, p->azCol[i], &rc); in sessionInsertRow()
4047 sessionAppendStr(&buf, ") VALUES(?", &rc); in sessionInsertRow()
4049 sessionAppendStr(&buf, ", ?", &rc); in sessionInsertRow()
4051 sessionAppendStr(&buf, ")", &rc); in sessionInsertRow()
4054 rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pInsert, 0); in sessionInsertRow()
4056 sqlite3_free(buf.aBuf); in sessionInsertRow()
5258 SessionBuffer buf = {0, 0, 0}; in sessionChangegroupOutput() local
5269 sessionAppendTableHdr(&buf, pGrp->bPatch, pTab, &rc); in sessionChangegroupOutput()
5273 sessionAppendByte(&buf, p->op, &rc); in sessionChangegroupOutput()
5274 sessionAppendByte(&buf, p->bIndirect, &rc); in sessionChangegroupOutput()
5275 sessionAppendBlob(&buf, p->aRecord, p->nRecord, &rc); in sessionChangegroupOutput()
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()
5288 *ppOut = buf.aBuf; in sessionChangegroupOutput()
5289 if( pnOut ) *pnOut = buf.nBuf; in sessionChangegroupOutput()
5290 buf.aBuf = 0; in sessionChangegroupOutput()
5293 sqlite3_free(buf.aBuf); in sessionChangegroupOutput()