Lines Matching refs:pApply
4518 SessionApplyCtx *pApply, /* Apply context */ in sessionApplyOneWithRetry() argument
4526 rc = sessionApplyOneOp(pIter, pApply, xConflict, pCtx, &bReplace, &bRetry); in sessionApplyOneWithRetry()
4537 rc = sessionApplyOneOp(pIter, pApply, xConflict, pCtx, 0, 0); in sessionApplyOneWithRetry()
4550 sqlite3changeset_new, pApply->nCol, pApply->abPK, pApply->pDelete); in sessionApplyOneWithRetry()
4551 sqlite3_bind_int(pApply->pDelete, pApply->nCol+1, 1); in sessionApplyOneWithRetry()
4554 sqlite3_step(pApply->pDelete); in sessionApplyOneWithRetry()
4555 rc = sqlite3_reset(pApply->pDelete); in sessionApplyOneWithRetry()
4558 rc = sessionApplyOneOp(pIter, pApply, xConflict, pCtx, 0, 0); in sessionApplyOneWithRetry()
4576 SessionApplyCtx *pApply, in sessionRetryConstraints() argument
4582 while( pApply->constraints.nBuf ){ in sessionRetryConstraints()
4584 SessionBuffer cons = pApply->constraints; in sessionRetryConstraints()
4585 memset(&pApply->constraints, 0, sizeof(SessionBuffer)); in sessionRetryConstraints()
4588 &pIter2, 0, 0, cons.nBuf, cons.aBuf, pApply->bInvertConstraints, 1 in sessionRetryConstraints()
4591 size_t nByte = 2*pApply->nCol*sizeof(sqlite3_value*); in sessionRetryConstraints()
4595 pIter2->nCol = pApply->nCol; in sessionRetryConstraints()
4596 pIter2->abPK = pApply->abPK; in sessionRetryConstraints()
4602 rc = sessionApplyOneWithRetry(db, pIter2, pApply, xConflict, pCtx); in sessionRetryConstraints()
4608 assert( pApply->bDeferConstraints || pApply->constraints.nBuf==0 ); in sessionRetryConstraints()
4612 if( pApply->constraints.nBuf>=cons.nBuf ){ in sessionRetryConstraints()
4614 pApply->bDeferConstraints = 0; in sessionRetryConstraints()