Lines Matching refs:pRbu
225799 SQLITE_API int sqlite3rbu_step(sqlite3rbu *pRbu);
225811 SQLITE_API int sqlite3rbu_savestate(sqlite3rbu *pRbu);
225831 SQLITE_API int sqlite3rbu_close(sqlite3rbu *pRbu, char **pzErrmsg);
225838 SQLITE_API sqlite3_int64 sqlite3rbu_progress(sqlite3rbu *pRbu);
225880 SQLITE_API void sqlite3rbu_bp_progress(sqlite3rbu *pRbu, int *pnOne, int*pnTwo);
225918 SQLITE_API int sqlite3rbu_state(sqlite3rbu *pRbu);
225942 sqlite3rbu *pRbu,
226371 sqlite3rbu *pRbu; /* Owner RBU object */ member
226387 sqlite3rbu *pRbu; /* Pointer to rbu object (rbu target only) */ member
229033 static int rbuCaptureWalRead(sqlite3rbu *pRbu, i64 iOff, int iAmt){ argument
229037 if( pRbu->mLock!=mReq ){
229038 pRbu->rc = SQLITE_BUSY;
229042 pRbu->pgsz = iAmt;
229043 if( pRbu->nFrame==pRbu->nFrameAlloc ){
229044 int nNew = (pRbu->nFrameAlloc ? pRbu->nFrameAlloc : 64) * 2;
229046 aNew = (RbuFrame*)sqlite3_realloc64(pRbu->aFrame, nNew * sizeof(RbuFrame));
229048 pRbu->aFrame = aNew;
229049 pRbu->nFrameAlloc = nNew;
229053 if( pRbu->iMaxFrame<iFrame ) pRbu->iMaxFrame = iFrame;
229054 pRbu->aFrame[pRbu->nFrame].iWalFrame = iFrame;
229055 pRbu->aFrame[pRbu->nFrame].iDbPage = 0;
229056 pRbu->nFrame++;
229065 static int rbuCaptureDbWrite(sqlite3rbu *pRbu, i64 iOff){ argument
229066 pRbu->aFrame[pRbu->nFrame-1].iDbPage = (u32)(iOff / pRbu->pgsz) + 1;
229820 ((rbu_vfs*)pVfs)->pRbu = p;
230140 SQLITE_API sqlite3 *sqlite3rbu_db(sqlite3rbu *pRbu, int bRbu){ argument
230142 if( pRbu ){
230143 db = (bRbu ? pRbu->dbRbu : pRbu->dbMain);
230235 SQLITE_API sqlite3_int64 sqlite3rbu_progress(sqlite3rbu *pRbu){ argument
230236 return pRbu->nProgress;
230376 sqlite3rbu *pRbu, argument
230381 pRbu->xRename = xRename;
230382 pRbu->pRenameArg = pArg;
230384 pRbu->xRename = xDefaultRename;
230385 pRbu->pRenameArg = 0;
230450 if( p->pRbu ){
230454 if( (1<<i) & p->pRbu->mLock ){
230458 p->pRbu->mLock = 0;
230465 sqlite3rbu *pRbu = pFd->pRbu; local
230467 pRbu->szTemp += nDiff;
230469 assert( pRbu->szTemp>=0 );
230470 if( pRbu->szTempLimit && pRbu->szTemp>pRbu->szTempLimit ) return SQLITE_FULL;
230487 if( p->pRbu==0 ){
230561 else if( (p->openFlags & SQLITE_OPEN_DELETEONCLOSE) && p->pRbu ){
230609 sqlite3rbu *pRbu = p->pRbu; local
230612 if( pRbu && pRbu->eStage==RBU_STAGE_CAPTURE ){
230614 rc = rbuCaptureWalRead(p->pRbu, iOfst, iAmt);
230616 if( pRbu && pRbu->eStage==RBU_STAGE_OAL
230618 && iOfst>=pRbu->iOalSz
230629 if( pRbu && rbuIsVacuum(pRbu)
230632 && pRbu->rc==SQLITE_OK
230634 sqlite3_file *pFd = (sqlite3_file*)pRbu->pRbuFd;
230643 rbuPutU32(&aBuf[24], pRbu->pRbuFd->iCookie+1); /* Change counter */
230675 sqlite3rbu *pRbu = p->pRbu; local
230678 if( pRbu && pRbu->eStage==RBU_STAGE_CAPTURE ){
230680 rc = rbuCaptureDbWrite(p->pRbu, iOfst);
230682 if( pRbu ){
230683 if( pRbu->eStage==RBU_STAGE_OAL
230685 && iOfst>=pRbu->iOalSz
230687 pRbu->iOalSz = iAmt + iOfst;
230713 if( (p->openFlags & SQLITE_OPEN_DELETEONCLOSE) && p->pRbu ){
230725 if( p->pRbu && p->pRbu->eStage==RBU_STAGE_CAPTURE ){
230747 && p->pRbu && rbuIsVacuum(p->pRbu)
230760 sqlite3rbu *pRbu = p->pRbu; local
230765 && (p->bNolock || (pRbu && pRbu->eStage!=RBU_STAGE_DONE))
230805 sqlite3rbu *pRbu = (sqlite3rbu*)pArg; local
230819 pRbu->zErrmsg = sqlite3_mprintf("rbu/zipvfs setup error");
230821 pRbu->pTargetFd = p;
230822 p->pRbu = pRbu;
230824 if( p->pWalFd ) p->pWalFd->pRbu = pRbu;
230831 sqlite3rbu *pRbu = (sqlite3rbu*)pArg; local
230832 pRbu->nRbu++;
230833 pRbu->pRbuFd = p;
230870 sqlite3rbu *pRbu = p->pRbu; local
230878 if( pRbu && (
230879 pRbu->eStage==RBU_STAGE_OAL
230880 || pRbu->eStage==RBU_STAGE_MOVE
230881 || pRbu->eStage==RBU_STAGE_DONE
230889 if( pRbu && pRbu->eStage==RBU_STAGE_CAPTURE ){
230895 pRbu->mLock |= ((1<<n) - 1) << ofst;
230915 int eStage = (p->pRbu ? p->pRbu->eStage : 0);
230975 int eStage = (p->pRbu ? p->pRbu->eStage : 0);
231060 if( pDb->pRbu && pDb->pRbu->eStage==RBU_STAGE_OAL ){
231063 if( rbuIsVacuum(pDb->pRbu) ){
231064 zOpen = sqlite3_db_filename(pDb->pRbu->dbRbu, "main");
231069 pFd->pRbu = pDb->pRbu;
231075 pFd->pRbu = pRbuVfs->pRbu;
231150 if( pDb && pDb->pRbu->eStage==RBU_STAGE_OAL ){
231151 assert( pDb->pRbu );
231352 SQLITE_API sqlite3_int64 sqlite3rbu_temp_size_limit(sqlite3rbu *pRbu, sqlite3_int64 n){ argument
231354 pRbu->szTempLimit = n;
231356 return pRbu->szTempLimit;
231359 SQLITE_API sqlite3_int64 sqlite3rbu_temp_size(sqlite3rbu *pRbu){ argument
231360 return pRbu->szTemp;