78   int iNext;                      /* Offset in aData[] of next change */  member
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()
2914     while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){  in sessionInputBuffer()
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()
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()
3089     nRead += sessionVarintGet(&pIn->aData[pIn->iNext + nRead], &nCol);  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()
3137       eType = pIn->aData[pIn->iNext + nByte++];  in sessionChangesetBufferRecord()
3140         nByte += sessionVarintGet(&pIn->aData[pIn->iNext+nByte], &n);  in sessionChangesetBufferRecord()
3178     nVarint = sessionVarintGet(&p->in.aData[p->in.iNext], &p->nCol);  in sessionChangesetReadTblhdr()
3181       p->in.iNext += nVarint;  in sessionChangesetReadTblhdr()
3193     memcpy(&p->tblhdr.aBuf[iPK], &p->in.aData[p->in.iNext], nCopy);  in sessionChangesetReadTblhdr()
3194     p->in.iNext += nCopy;  in sessionChangesetReadTblhdr()
3250   if( p->in.iNext>=p->in.nData ){  in sessionChangesetNextOne()
3255   p->in.iCurrent = p->in.iNext;  in sessionChangesetNextOne()
3257   op = p->in.aData[p->in.iNext++];  in sessionChangesetNextOne()
3263     p->in.iCurrent = p->in.iNext;  in sessionChangesetNextOne()
3264     if( p->in.iNext>=p->in.nData ) return SQLITE_DONE;  in sessionChangesetNextOne()
3265     op = p->in.aData[p->in.iNext++];  in sessionChangesetNextOne()
3271     assert( p->in.iNext==1 || p->zTab );  in sessionChangesetNextOne()
3276   p->bIndirect = p->in.aData[p->in.iNext++];  in sessionChangesetNextOne()
3293     *paRec = &p->in.aData[p->in.iNext];  in sessionChangesetNextOne()
3294     p->in.iNext += *pnRec;  in sessionChangesetNextOne()
3572     if( pInput->iNext>=pInput->nData ) break;  in sessionChangesetInvert()
3573     eType = pInput->aData[pInput->iNext];  in sessionChangesetInvert()
3586         pInput->iNext++;  in sessionChangesetInvert()
3590         nVar = sessionVarintGet(&pInput->aData[pInput->iNext], &nCol);  in sessionChangesetInvert()
3592         sessionAppendBlob(&sPK, &pInput->aData[pInput->iNext+nVar], nCol, &rc);  in sessionChangesetInvert()
3594         sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc);  in sessionChangesetInvert()
3597         pInput->iNext += nByte;  in sessionChangesetInvert()
3607         int bIndirect = pInput->aData[pInput->iNext+1];  in sessionChangesetInvert()
3609         pInput->iNext += 2;  in sessionChangesetInvert()
3614         sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc);  in sessionChangesetInvert()
3615         pInput->iNext += nByte;  in sessionChangesetInvert()
3634         sessionAppendByte(&sOut, pInput->aData[pInput->iNext+1], &rc);  in sessionChangesetInvert()
3637         pInput->iNext += 2;  in sessionChangesetInvert()
4322       int nBlob = pIter->in.iNext - pIter->in.iCurrent;  in sessionConflictHandler()