Lines Matching refs:pIn
84 void *pIn; /* First argument to xInput */ member
2814 int (*xInput)(void *pIn, void *pData, int *pnData), in sessionChangesetStart() argument
2815 void *pIn, in sessionChangesetStart()
2837 pRet->in.pIn = pIn; in sessionChangesetStart()
2872 int (*xInput)(void *pIn, void *pData, int *pnData), in sqlite3changeset_start_strm() argument
2873 void *pIn in sqlite3changeset_start_strm()
2875 return sessionChangesetStart(pp, xInput, pIn, 0, 0, 0, 0); in sqlite3changeset_start_strm()
2879 int (*xInput)(void *pIn, void *pData, int *pnData), in sqlite3changeset_start_v2_strm() argument
2880 void *pIn, in sqlite3changeset_start_v2_strm()
2884 return sessionChangesetStart(pp, xInput, pIn, 0, 0, bInvert, 0); in sqlite3changeset_start_v2_strm()
2891 static void sessionDiscardData(SessionInput *pIn){ in sessionDiscardData() argument
2892 if( pIn->xInput && pIn->iNext>=sessions_strm_chunk_size ){ in sessionDiscardData()
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()
2899 pIn->iNext = 0; in sessionDiscardData()
2900 pIn->nData = pIn->buf.nBuf; in sessionDiscardData()
2911 static int sessionInputBuffer(SessionInput *pIn, int nByte){ in sessionInputBuffer() argument
2913 if( pIn->xInput ){ in sessionInputBuffer()
2914 while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){ in sessionInputBuffer()
2917 if( pIn->bNoDiscard==0 ) sessionDiscardData(pIn); in sessionInputBuffer()
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()
2921 pIn->bEof = 1; 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()
3007 SessionInput *pIn, /* Input data */ in sessionReadRecord() argument
3021 rc = sessionInputBuffer(pIn, 9); in sessionReadRecord()
3023 if( pIn->iNext>=pIn->nData ){ in sessionReadRecord()
3026 eType = pIn->aData[pIn->iNext++]; in sessionReadRecord()
3037 u8 *aVal = &pIn->aData[pIn->iNext]; in sessionReadRecord()
3040 pIn->iNext += sessionVarintGet(aVal, &nByte); in sessionReadRecord()
3041 rc = sessionInputBuffer(pIn, nByte); in sessionReadRecord()
3043 if( nByte<0 || nByte>pIn->nData-pIn->iNext ){ in sessionReadRecord()
3047 rc = sessionValueSetStr(apOut[i],&pIn->aData[pIn->iNext],nByte,enc); in sessionReadRecord()
3048 pIn->iNext += nByte; in sessionReadRecord()
3061 pIn->iNext += 8; in sessionReadRecord()
3082 static int sessionChangesetBufferTblhdr(SessionInput *pIn, int *pnByte){ in sessionChangesetBufferTblhdr() argument
3087 rc = sessionInputBuffer(pIn, 9); in sessionChangesetBufferTblhdr()
3089 nRead += sessionVarintGet(&pIn->aData[pIn->iNext + nRead], &nCol); in sessionChangesetBufferTblhdr()
3100 rc = sessionInputBuffer(pIn, nRead+nCol+100); in sessionChangesetBufferTblhdr()
3106 while( (pIn->iNext + nRead)<pIn->nData && pIn->aData[pIn->iNext + nRead] ){ in sessionChangesetBufferTblhdr()
3109 if( (pIn->iNext + nRead)<pIn->nData ) break; in sessionChangesetBufferTblhdr()
3110 rc = sessionInputBuffer(pIn, nRead + 100); in sessionChangesetBufferTblhdr()
3126 SessionInput *pIn, /* Input data */ in sessionChangesetBufferRecord() argument
3135 rc = sessionInputBuffer(pIn, nByte + 10); in sessionChangesetBufferRecord()
3137 eType = pIn->aData[pIn->iNext + nByte++]; in sessionChangesetBufferRecord()
3140 nByte += sessionVarintGet(&pIn->aData[pIn->iNext+nByte], &n); in sessionChangesetBufferRecord()
3142 rc = sessionInputBuffer(pIn, nByte); in sessionChangesetBufferRecord()
3723 int (*xInput)(void *pIn, void *pData, int *pnData), in sqlite3changeset_invert_strm() argument
3724 void *pIn, in sqlite3changeset_invert_strm()
3734 sInput.pIn = pIn; in sqlite3changeset_invert_strm()
4886 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */ in sqlite3changeset_apply_v2_strm() argument
4887 void *pIn, /* First arg for xInput */ in sqlite3changeset_apply_v2_strm()
4903 int rc = sessionChangesetStart(&pIter, xInput, pIn, 0, 0, bInverse, 1); in sqlite3changeset_apply_v2_strm()
4913 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */ in sqlite3changeset_apply_strm() argument
4914 void *pIn, /* First arg for xInput */ in sqlite3changeset_apply_strm()
4927 db, xInput, pIn, xFilter, xConflict, pCtx, 0, 0, 0 in sqlite3changeset_apply_strm()
4973 u8 *pIn = aRec; in sessionChangeMerge() local
4976 int nIn = sessionSerialLen(pIn); in sessionChangeMerge()
4977 if( *pIn==0 ){ in sessionChangeMerge()
4982 memcpy(pOut, pIn, nIn); in sessionChangeMerge()
4985 pIn += nIn; in sessionChangeMerge()
5347 int (*xInput)(void *pIn, void *pData, int *pnData), in sqlite3changegroup_add_strm() argument
5348 void *pIn in sqlite3changegroup_add_strm()
5353 rc = sqlite3changeset_start_strm(&pIter, xInput, pIn); in sqlite3changegroup_add_strm()
5415 int (*xInputA)(void *pIn, void *pData, int *pnData), in sqlite3changeset_concat_strm() argument
5417 int (*xInputB)(void *pIn, void *pData, int *pnData), in sqlite3changeset_concat_strm() argument
5738 int nIn, const void *pIn, in sqlite3rebaser_rebase() argument
5742 int rc = sqlite3changeset_start(&pIter, nIn, (void*)pIn); in sqlite3rebaser_rebase()
5757 int (*xInput)(void *pIn, void *pData, int *pnData), in sqlite3rebaser_rebase_strm() argument
5758 void *pIn, in sqlite3rebaser_rebase_strm()
5763 int rc = sqlite3changeset_start_strm(&pIter, xInput, pIn); in sqlite3rebaser_rebase_strm()