Lines Matching refs:u8
64 u8 *aBuf; /* Pointer to changeset buffer */
79 u8 *aData; /* Pointer to buffer containing changeset */
103 u8 *abPK; /* Primary key array */
126 u8 *abPK; /* Array of primary key flags */
296 u8 op; /* One of UPDATE, DELETE, INSERT */
297 u8 bIndirect; /* True if this change is "indirect" */
300 u8 *aRecord; /* Buffer containing old.* record */
308 static int sessionVarintPut(u8 *aBuf, int iVal){ in sessionVarintPut()
323 static int sessionVarintGet(u8 *aBuf, int *piVal){ in sessionVarintGet()
334 static sqlite3_int64 sessionGetI64(u8 *aRec){ in sessionGetI64()
344 static void sessionPutI64(u8 *aBuf, sqlite3_int64 i){ in sessionPutI64()
369 u8 *aBuf, /* If non-NULL, write serialized value here */ in sessionSerializeValue()
407 u8 *z; in sessionSerializeValue()
413 z = (u8 *)sqlite3_value_text(pValue); in sessionSerializeValue()
415 z = (u8 *)sqlite3_value_blob(pValue); in sessionSerializeValue()
490 static unsigned int sessionHashAppendBlob(unsigned int h, int n, const u8 *z){ in sessionHashAppendBlob()
553 const u8 *z; in sessionPreupdateHash()
556 z = (const u8 *)sqlite3_value_text(pVal); in sessionPreupdateHash()
558 z = (const u8 *)sqlite3_value_blob(pVal); in sessionPreupdateHash()
580 static int sessionSerialLen(u8 *a){ in sessionSerialLen()
601 u8 *aRecord, /* Change record */ in sessionChangeHash()
606 u8 *a = aRecord; /* Used to iterate through change record */ in sessionChangeHash()
650 u8 *aLeft, /* Change record */ in sessionChangeEqual()
652 u8 *aRight /* Change record */ in sessionChangeEqual()
654 u8 *a1 = aLeft; /* Cursor to iterate through aLeft */ in sessionChangeEqual()
655 u8 *a2 = aRight; /* Cursor to iterate through aRight */ in sessionChangeEqual()
691 u8 **paOut, in sessionMergeRecord()
693 u8 *aLeft, in sessionMergeRecord()
694 u8 *aRight in sessionMergeRecord()
696 u8 *a1 = aLeft; /* Cursor used to iterate through aLeft */ in sessionMergeRecord()
697 u8 *a2 = aRight; /* Cursor used to iterate through aRight */ in sessionMergeRecord()
698 u8 *aOut = *paOut; /* Output cursor */ in sessionMergeRecord()
736 static u8 *sessionMergeValue( in sessionMergeValue()
737 u8 **paOne, /* IN/OUT: Left-hand buffer pointer */ in sessionMergeValue()
738 u8 **paTwo, /* IN/OUT: Right-hand buffer pointer */ in sessionMergeValue()
741 u8 *a1 = *paOne; in sessionMergeValue()
742 u8 *a2 = *paTwo; in sessionMergeValue()
743 u8 *pRet = 0; in sessionMergeValue()
771 u8 **paOut, /* IN/OUT: Pointer to output buffer */ in sessionMergeUpdate()
774 u8 *aOldRecord1, /* old.* record for first change */ in sessionMergeUpdate()
775 u8 *aOldRecord2, /* old.* record for second change */ in sessionMergeUpdate()
776 u8 *aNewRecord1, /* new.* record for first change */ in sessionMergeUpdate()
777 u8 *aNewRecord2 /* new.* record for second change */ in sessionMergeUpdate()
779 u8 *aOld1 = aOldRecord1; in sessionMergeUpdate()
780 u8 *aOld2 = aOldRecord2; in sessionMergeUpdate()
781 u8 *aNew1 = aNewRecord1; in sessionMergeUpdate()
782 u8 *aNew2 = aNewRecord2; in sessionMergeUpdate()
784 u8 *aOut = *paOut; in sessionMergeUpdate()
795 u8 *aOld; in sessionMergeUpdate()
797 u8 *aNew; in sessionMergeUpdate()
820 u8 *aOld; in sessionMergeUpdate()
822 u8 *aNew; in sessionMergeUpdate()
854 u8 *a = pChange->aRecord; /* Cursor used to scan change record */ in sessionPreupdateEqual()
898 const u8 *z; in sessionPreupdateEqual()
1000 u8 **pabPK /* OUT: Array of booleans - true for PK col */ in sessionTableInfo()
1009 u8 *pAlloc = 0; in sessionTableInfo()
1011 u8 *abPK = 0; in sessionTableInfo()
1063 nByte += nDbCol * (sizeof(const char *) + sizeof(u8) + 1); in sessionTableInfo()
1071 pAlloc = (u8 *)&azCol[nDbCol]; in sessionTableInfo()
1072 abPK = (u8 *)pAlloc; in sessionTableInfo()
1127 u8 *abPK; in sessionInitTable()
1217 u8 *pCsr = pC->aRecord; in sessionUpdateMaxSize()
1395 pC->aRecord = (u8 *)&pC[1]; in sessionPreupdateOneChange()
1600 const char **azCol, u8 *abPK in sessionExprComparePK()
1623 const char **azCol, u8 *abPK in sessionExprCompareOther()
1770 u8 *abPK; in sqlite3session_diff()
2001 u8 *aNew; in sessionBufferGrow()
2021 aNew = (u8 *)sqlite3_realloc64(p->aBuf, nNew); in sessionBufferGrow()
2062 static void sessionAppendByte(SessionBuffer *p, u8 v, int *pRc){ in sessionAppendByte()
2090 const u8 *aBlob, in sessionAppendBlob()
2162 p->nBuf = (int)((u8 *)zOut - p->aBuf); in sessionAppendIdent()
2180 sessionAppendByte(p, (u8)eType, pRc); in sessionAppendCol()
2183 u8 aBuf[8]; in sessionAppendCol()
2194 u8 *z; in sessionAppendCol()
2197 z = (u8 *)sqlite3_column_blob(pStmt, iCol); in sessionAppendCol()
2199 z = (u8 *)sqlite3_column_text(pStmt, iCol); in sessionAppendCol()
2239 u8 *abPK /* Boolean array - true for PK columns */ in sessionAppendUpdate()
2246 u8 *pCsr = p->aRecord; /* Used to iterate through old.* values */ in sessionAppendUpdate()
2339 u8 *abPK /* Boolean array - true for PK columns */ in sessionAppendDelete()
2350 u8 *a = p->aRecord; in sessionAppendDelete()
2352 u8 *pStart = a; in sessionAppendDelete()
2395 u8 *abPK, /* PRIMARY KEY array */ in sessionSelectStmt()
2449 u8 *abPK, /* PRIMARY KEY array */ in sessionSelectBind()
2454 u8 *a = pChange->aRecord; in sessionSelectBind()
2527 sessionAppendBlob(pBuf, (u8 *)pTab->zName, (int)strlen(pTab->zName)+1, pRc); in sessionAppendTableHdr()
2575 u8 *abPK = 0; /* Primary key array */ in sessionGenerateChangeset()
2834 pRet->in.aData = (u8 *)pChangeset; in sessionChangesetStart()
2940 u8 **ppRec, /* IN/OUT: Record pointer */ in sessionSkipRecord()
2943 u8 *aRec = *ppRec; in sessionSkipRecord()
2949 aRec += sessionVarintGet((u8*)aRec, &nByte); in sessionSkipRecord()
2967 u8 *aData, /* Buffer containing string or blob data */ in sessionValueSetStr()
2969 u8 enc /* String encoding (0 for blobs) */ in sessionValueSetStr()
2975 u8 *aCopy = sqlite3_malloc64((sqlite3_int64)nData+1); in sessionValueSetStr()
3009 u8 *abPK, /* Array of primary key flags, or NULL */ in sessionReadRecord()
3037 u8 *aVal = &pIn->aData[pIn->iNext]; in sessionReadRecord()
3046 u8 enc = (eType==SQLITE_TEXT ? SQLITE_UTF8 : 0); in sessionReadRecord()
3202 p->abPK = (u8*)&p->apValue[p->nCol*2]; in sessionChangesetReadTblhdr()
3220 u8 **paRec, /* If non-NULL, store record pointer here */ in sessionChangesetNextOne()
3226 u8 op; in sessionChangesetNextOne()
3301 u8 *abPK = p->bPatchset ? p->abPK : 0; in sessionChangesetNextOne()
3353 u8 **paRec, /* If non-NULL, store record pointer here */ in sessionChangesetNext()
3554 u8 *abPK = 0; /* PK array for current table */ in sessionChangesetInvert()
3568 u8 eType; in sessionChangesetInvert()
3714 sInput.aData = (u8*)pChangeset; in sqlite3changeset_invert()
3757 u8 *abPK; /* Boolean array - true if column is in PK */
3765 u8 bRebaseStarted; /* If table header is already in rebase */
3766 u8 bRebase; /* True to collect rebase information */
4130 u8 *abPK, /* If not NULL, bind only if true */ in sessionBindRow()
4178 u8 *abPK, /* Primary key flags array */ in sessionSeekToRow()
4225 sessionAppendBlob(&p->rebase, (u8*)zTab, (int)strlen(zTab)+1, &rc); in sessionRebaseAdd()
4321 u8 *aBlob = &pIter->in.aData[pIter->in.iCurrent]; in sessionConflictHandler()
4414 u8 *abPK = (pIter->bPatchset ? p->abPK : 0); in sessionApplyOneOp()
4672 u8 *abPK; in sessionChangesetApply()
4952 u8 *aRec, /* Second change record */ in sessionChangeMerge()
4967 pNew->aRecord = (u8*)&pNew[1]; in sessionChangeMerge()
4973 u8 *pIn = aRec; in sessionChangeMerge()
4974 u8 *pOut = pNew->aRecord; in sessionChangeMerge()
4999 u8 *a1 = pExist->aRecord; in sessionChangeMerge()
5000 u8 *a2 = aRec; in sessionChangeMerge()
5001 u8 *pOut; in sessionChangeMerge()
5006 pOut = pNew->aRecord = (u8*)&pNew[1]; in sessionChangeMerge()
5053 u8 *aExist = pExist->aRecord; in sessionChangeMerge()
5055 u8 *aCsr; in sessionChangeMerge()
5068 aCsr = pNew->aRecord = (u8 *)&pNew[1]; in sessionChangeMerge()
5071 u8 *a1 = aRec; in sessionChangeMerge()
5089 u8 *a1 = aExist; in sessionChangeMerge()
5090 u8 *a2 = aRec; in sessionChangeMerge()
5132 u8 *aRec; in sessionChangesetToHash()
5158 u8 *abPK; in sessionChangesetToHash()
5174 pTab->abPK = (u8*)&pTab[1]; in sessionChangesetToHash()
5456 u8 *a1, int n1, /* Record 1 */ in sessionAppendRecordMerge()
5457 u8 *a2, int n2, /* Record 2 */ in sessionAppendRecordMerge()
5463 u8 *pOut = &pBuf->aBuf[pBuf->nBuf]; in sessionAppendRecordMerge()
5505 u8 *aRec, int nRec, /* Local change */ in sessionAppendPartialUpdate()
5506 u8 *aChange, int nChange, /* Record to rebase against */ in sessionAppendPartialUpdate()
5512 u8 *pOut = &pBuf->aBuf[pBuf->nBuf]; in sessionAppendPartialUpdate()
5514 u8 *a1 = aRec; in sessionAppendPartialUpdate()
5515 u8 *a2 = aChange; in sessionAppendPartialUpdate()
5579 u8 *aRec = 0; in sessionRebase()
5605 sessionAppendBlob(&sOut,(u8*)pIter->zTab,(int)strlen(pIter->zTab)+1,&rc); in sessionRebase()
5637 u8 *pCsr = aRec; in sessionRebase()