Lines Matching refs:nByte
373 int nByte; /* Size of serialized value in bytes */ in sessionSerializeValue() local
383 nByte = 1; in sessionSerializeValue()
403 nByte = 9; in sessionSerializeValue()
426 nByte = 1 + nVarint + n; in sessionSerializeValue()
431 nByte = 1; in sessionSerializeValue()
435 if( pnWrite ) *pnWrite += nByte; in sessionSerializeValue()
444 static void *sessionMalloc64(sqlite3_session *pSession, i64 nByte){ in sessionMalloc64() argument
445 void *pRet = sqlite3_malloc64(nByte); in sessionMalloc64()
1005 sqlite3_int64 nByte; in sessionTableInfo() local
1055 nByte = nThis + 1; in sessionTableInfo()
1057 nByte += sqlite3_column_bytes(pStmt, 1); in sessionTableInfo()
1063 nByte += nDbCol * (sizeof(const char *) + sizeof(u8) + 1); in sessionTableInfo()
1064 pAlloc = sessionMalloc64(pSession, nByte); in sessionTableInfo()
1252 int nByte; in sessionUpdateMaxSize() local
1253 nOld = sessionVarintGet(pCsr, &nByte); in sessionUpdateMaxSize()
1255 nOld += nByte; in sessionUpdateMaxSize()
1258 && nByte==sqlite3_value_bytes(p) in sessionUpdateMaxSize()
1259 && (nByte==0 || 0==memcmp(pCsr, sqlite3_value_blob(p), nByte)) in sessionUpdateMaxSize()
1263 pCsr += nByte; in sessionUpdateMaxSize()
1364 sqlite3_int64 nByte; /* Number of bytes to allocate */ in sessionPreupdateOneChange() local
1371 nByte = sizeof(SessionChange); in sessionPreupdateOneChange()
1384 rc = sessionSerializeValue(0, p, &nByte); in sessionPreupdateOneChange()
1389 pC = (SessionChange *)sessionMalloc64(pSession, nByte); in sessionPreupdateOneChange()
1402 nByte = 0; in sessionPreupdateOneChange()
1410 sessionSerializeValue(&pC->aRecord[nByte], p, &nByte); in sessionPreupdateOneChange()
1417 pC->nRecord = nByte; in sessionPreupdateOneChange()
1966 int nByte = sizeof(SessionTable) + nName + 1; in sqlite3session_attach() local
1967 pTab = (SessionTable*)sessionMalloc64(pSession, nByte); in sqlite3session_attach()
1997 static int sessionBufferGrow(SessionBuffer *p, i64 nByte, int *pRc){ in sessionBufferGrow() argument
1999 i64 nReq = p->nBuf + nByte; in sessionBufferGrow()
2043 sqlite3_int64 nByte = 0; in sessionAppendValue() local
2044 rc = sessionSerializeValue(0, pVal, &nByte); in sessionAppendValue()
2045 sessionBufferGrow(p, nByte, &rc); in sessionAppendValue()
2048 p->nBuf += nByte; in sessionAppendValue()
2195 int nByte; in sessionAppendCol() local
2201 nByte = sqlite3_column_bytes(pStmt, iCol); in sessionAppendCol()
2202 if( z || (eType==SQLITE_BLOB && nByte==0) ){ in sessionAppendCol()
2203 sessionAppendVarint(p, nByte, pRc); in sessionAppendCol()
2204 sessionAppendBlob(p, z, nByte, pRc); in sessionAppendCol()
2822 int nByte; /* Number of bytes to allocate for iterator */ in sessionChangesetStart() local
2830 nByte = sizeof(sqlite3_changeset_iter); in sessionChangesetStart()
2831 pRet = (sqlite3_changeset_iter *)sqlite3_malloc(nByte); in sessionChangesetStart()
2911 static int sessionInputBuffer(SessionInput *pIn, int nByte){ in sessionInputBuffer() argument
2914 while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){ in sessionInputBuffer()
2948 int nByte; in sessionSkipRecord() local
2949 aRec += sessionVarintGet((u8*)aRec, &nByte); in sessionSkipRecord()
2950 aRec += nByte; in sessionSkipRecord()
3039 int nByte; in sessionReadRecord() local
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()
3131 int nByte = 0; in sessionChangesetBufferRecord() local
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()
3141 nByte += n; in sessionChangesetBufferRecord()
3142 rc = sessionInputBuffer(pIn, nByte); in sessionChangesetBufferRecord()
3144 nByte += 8; in sessionChangesetBufferRecord()
3148 *pnByte = nByte; in sessionChangesetBufferRecord()
3176 int nByte; in sessionChangesetReadTblhdr() local
3182 nByte = p->nCol * sizeof(sqlite3_value*) * 2 + nCopy; in sessionChangesetReadTblhdr()
3184 sessionBufferGrow(&p->tblhdr, nByte, &rc); in sessionChangesetReadTblhdr()
3584 int nByte; in sessionChangesetInvert() local
3587 if( (rc = sessionChangesetBufferTblhdr(pInput, &nByte)) ){ in sessionChangesetInvert()
3594 sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc); in sessionChangesetInvert()
3597 pInput->iNext += nByte; in sessionChangesetInvert()
3606 int nByte; in sessionChangesetInvert() local
3611 rc = sessionChangesetBufferRecord(pInput, nCol, &nByte); in sessionChangesetInvert()
3614 sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc); in sessionChangesetInvert()
3615 pInput->iNext += nByte; in sessionChangesetInvert()
3838 int nByte = sizeof(SessionUpdate) * nU32*sizeof(u32); in sessionUpdateFind() local
3840 pUp = (SessionUpdate*)sqlite3_malloc(nByte); in sessionUpdateFind()
4591 size_t nByte = 2*pApply->nCol*sizeof(sqlite3_value*); in sessionRetryConstraints() local
4597 sessionBufferGrow(&pIter2->tblhdr, nByte, &rc); in sessionRetryConstraints()
4599 if( rc==SQLITE_OK ) memset(pIter2->apValue, 0, nByte); in sessionRetryConstraints()
4993 sqlite3_int64 nByte = nRec + pExist->nRecord + sizeof(SessionChange); in sessionChangeMerge() local
4994 pNew = (SessionChange*)sqlite3_malloc64(nByte); in sessionChangeMerge()
5003 memset(pNew, 0, nByte); in sessionChangeMerge()
5054 sqlite3_int64 nByte; in sessionChangeMerge() local
5060 nByte = sizeof(SessionChange) + pExist->nRecord + nRec; in sessionChangeMerge()
5061 pNew = (SessionChange *)sqlite3_malloc64(nByte); in sessionChangeMerge()