Lines Matching refs:a1

654   u8 *a1 = aLeft;                 /* Cursor to iterate through aLeft */  in sessionChangeEqual()  local
660 int n1 = sessionSerialLen(a1); in sessionChangeEqual()
663 if( n1!=n2 || memcmp(a1, a2, n1) ){ in sessionChangeEqual()
666 a1 += n1; in sessionChangeEqual()
669 if( bLeftPkOnly==0 ) a1 += sessionSerialLen(a1); in sessionChangeEqual()
696 u8 *a1 = aLeft; /* Cursor used to iterate through aLeft */ in sessionMergeRecord() local
702 int n1 = sessionSerialLen(a1); in sessionMergeRecord()
708 memcpy(aOut, a1, n1); in sessionMergeRecord()
711 a1 += n1; in sessionMergeRecord()
741 u8 *a1 = *paOne; in sessionMergeValue() local
746 assert( a1 ); in sessionMergeValue()
756 n1 = sessionSerialLen(a1); in sessionMergeValue()
759 pRet = a1; in sessionMergeValue()
761 *paOne = &a1[n1]; in sessionMergeValue()
4999 u8 *a1 = pExist->aRecord; in sessionChangeMerge() local
5009 int n1 = sessionSerialLen(a1); in sessionChangeMerge()
5011 if( *a1==0xFF || (pTab->abPK[i]==0 && bIndirect) ){ in sessionChangeMerge()
5014 memcpy(pOut, a1, n1); in sessionChangeMerge()
5020 a1 += n1; in sessionChangeMerge()
5071 u8 *a1 = aRec; in sessionChangeMerge() local
5074 if( bPatchset==0 ) sessionSkipRecord(&a1, pTab->nCol); in sessionChangeMerge()
5075 sessionMergeRecord(&aCsr, pTab->nCol, aExist, a1); in sessionChangeMerge()
5089 u8 *a1 = aExist; in sessionChangeMerge() local
5093 sessionSkipRecord(&a1, pTab->nCol); in sessionChangeMerge()
5097 if( 0==sessionMergeUpdate(&aCsr, pTab, bPatchset, aRec, aExist,a1,a2) ){ in sessionChangeMerge()
5456 u8 *a1, int n1, /* Record 1 */ in sessionAppendRecordMerge() argument
5465 int nn1 = sessionSerialLen(a1); in sessionAppendRecordMerge()
5467 if( *a1==0 || *a1==0xFF ){ in sessionAppendRecordMerge()
5471 memcpy(pOut, a1, nn1); in sessionAppendRecordMerge()
5474 a1 += nn1; in sessionAppendRecordMerge()
5514 u8 *a1 = aRec; in sessionAppendPartialUpdate() local
5520 int n1 = sessionSerialLen(a1); in sessionAppendPartialUpdate()
5523 if( !pIter->abPK[i] && a1[0] ) bData = 1; in sessionAppendPartialUpdate()
5524 memcpy(pOut, a1, n1); in sessionAppendPartialUpdate()
5533 a1 += n1; in sessionAppendPartialUpdate()
5539 int n1 = sessionSerialLen(a1); in sessionAppendPartialUpdate()
5542 memcpy(pOut, a1, n1); in sessionAppendPartialUpdate()
5547 a1 += n1; in sessionAppendPartialUpdate()