Lines Matching refs:bPatchset
94 int bPatchset; /* True if this is a patchset */ member
773 int bPatchset, /* True if records are patchset records */ in sessionMergeUpdate() argument
787 if( bPatchset==0 ){ in sessionMergeUpdate()
826 if( bPatchset==0 in sessionMergeUpdate()
928 int bPatchset, in sessionGrowHash() argument
951 int bPkOnly = (p->op==SQLITE_DELETE && bPatchset); in sessionGrowHash()
2236 int bPatchset, /* True for "patchset", 0 for "changeset" */ in sessionAppendUpdate() argument
2300 if( bPatchset==0 ){ in sessionAppendUpdate()
2310 if( bChanged || (bPatchset && abPK[i]) ){ in sessionAppendUpdate()
2336 int bPatchset, /* True for "patchset", 0 for "changeset" */ in sessionAppendDelete() argument
2346 if( bPatchset==0 ){ in sessionAppendDelete()
2519 int bPatchset, /* Use the patchset format if true */ in sessionAppendTableHdr() argument
2524 sessionAppendByte(pBuf, (bPatchset ? 'P' : 'T'), pRc); in sessionAppendTableHdr()
2542 int bPatchset, /* True for patchset, false for changeset */ in sessionGenerateChangeset() argument
2589 sessionAppendTableHdr(&buf, bPatchset, pTab, &rc); in sessionGenerateChangeset()
2614 rc = sessionAppendUpdate(&buf, bPatchset, pSel, p, abPK); in sessionGenerateChangeset()
2617 rc = sessionAppendDelete(&buf, bPatchset, p, nCol, abPK); in sessionGenerateChangeset()
3260 p->bPatchset = (op=='P'); in sessionChangesetNextOne()
3268 if( p->zTab==0 || (p->bPatchset && p->bInvert) ){ in sessionChangesetNextOne()
3283 if( p->bPatchset==0 && op==SQLITE_UPDATE ){ in sessionChangesetNextOne()
3285 }else if( p->bPatchset && op==SQLITE_DELETE ){ in sessionChangesetNextOne()
3300 if( p->op!=SQLITE_INSERT && (p->bPatchset==0 || p->op==SQLITE_DELETE) ){ in sessionChangesetNextOne()
3301 u8 *abPK = p->bPatchset ? p->abPK : 0; in sessionChangesetNextOne()
3312 if( (p->bPatchset || p->bInvert) && p->op==SQLITE_UPDATE ){ in sessionChangesetNextOne()
3318 assert( p->bPatchset==0 || p->apValue[i]==0 ); in sessionChangesetNextOne()
3781 int bPatchset, in sessionUpdateFind() argument
3809 if( bPatchset ) p->aUpdateMask[nCol/32] |= (1<<(nCol%32)); in sessionUpdateFind()
3870 if( p->abPK[ii] || (bPatchset==0 && sessionChangesetOld(pIter, ii)) ){ in sessionUpdateFind()
4414 u8 *abPK = (pIter->bPatchset ? p->abPK : 0); in sessionApplyOneOp()
4436 int bPatchset = (pbRetry==0 || pIter->bPatchset); in sessionApplyOneOp() local
4438 rc = sessionUpdateFind(pIter, p, bPatchset, &pUp); in sessionApplyOneOp()
4444 if( p->abPK[i] || (bPatchset==0 && pOld) ){ in sessionApplyOneOp()
4574 int bPatchset, in sessionRetryConstraints() argument
4593 pIter2->bPatchset = bPatchset; in sessionRetryConstraints()
4649 int bPatchset; in sessionChangesetApply() local
4675 db, pIter->bPatchset, zTab, &sApply, xConflict, pCtx in sessionChangesetApply()
4769 bPatchset = pIter->bPatchset; in sessionChangesetApply()
4777 rc = sessionRetryConstraints(db, bPatchset, zTab, &sApply, xConflict, pCtx); in sessionChangesetApply()
4806 if( rc==SQLITE_OK && bPatchset==0 && sApply.bRebase ){ in sessionChangesetApply()
4948 int bPatchset, /* True for patchsets */ in sessionChangeMerge() argument
5074 if( bPatchset==0 ) sessionSkipRecord(&a1, pTab->nCol); in sessionChangeMerge()
5079 if( bPatchset ){ in sessionChangeMerge()
5083 if( 0==sessionMergeUpdate(&aCsr, pTab, bPatchset, aExist, 0,aRec,0) ){ in sessionChangeMerge()
5092 if( bPatchset==0 ){ in sessionChangeMerge()
5097 if( 0==sessionMergeUpdate(&aCsr, pTab, bPatchset, aRec, aExist,a1,a2) ){ in sessionChangeMerge()
5104 if( bPatchset ){ in sessionChangeMerge()
5148 pGrp->bPatch = pIter->bPatchset; in sessionChangesetToHash()
5149 }else if( pIter->bPatchset!=pGrp->bPatch ){ in sessionChangesetToHash()
5191 if( sessionGrowHash(0, pIter->bPatchset, pTab) ){ in sessionChangesetToHash()
5196 pTab, (pIter->bPatchset && op==SQLITE_DELETE), aRec, pTab->nChange in sessionChangesetToHash()
5205 if( pIter->bPatchset ){ in sessionChangesetToHash()
5218 pIter->bPatchset, pExist, op, bIndirect, aRec, nRec, &pChange in sessionChangesetToHash()
5597 if( pIter->bPatchset ){ in sessionRebase()
5602 sessionAppendByte(&sOut, pIter->bPatchset ? 'P' : 'T', &rc); in sessionRebase()