contrib/sqlite3/sqlite3.c

38177 ** Apply posix advisory locks for all bytes from ofst through ofst+n-1.
38185   int ofst,              /* First byte of the locking range */
38208     f.l_start = ofst;
38224   mask = ofst>31 ? 0xffff : (1<<(ofst+n)) - (1<<ofst);
38227       OSTRACE(("unlock %d ok", ofst));
38231       OSTRACE(("read-lock %d ok", ofst));
38236       OSTRACE(("write-lock %d ok", ofst));
38242       OSTRACE(("unlock %d failed", ofst));
38247       OSTRACE(("write-lock %d failed", ofst));
38723   int ofst,                  /* First lock to acquire or release */
38736   assert( ofst>=0 && ofst+n<=SQLITE_SHM_NLOCK );
38749   **   1. Checkpointer lock (ofst==1).
38750   **   2. Write lock (ofst==0).
38751   **   3. Read locks (ofst>=3 && ofst<SQLITE_SHM_NLOCK).
38761          (ofst!=2)                                   /* not RECOVER */
38762       && (ofst!=1 || (p->exclMask|p->sharedMask)==0)
38763       && (ofst!=0 || (p->exclMask|p->sharedMask)<3)
38764       && (ofst<3  || (p->exclMask|p->sharedMask)<(1<<ofst))
38768   mask = (1<<(ofst+n)) - (1<<ofst);
38769   assert( n>1 || mask==(1<<ofst) );
38777       for(ii=ofst; ii<ofst+n; ii++){
38784         rc = unixShmSystemLock(pDbFd, F_UNLCK, ofst+UNIX_SHM_BASE, n);
38786           memset(&aLock[ofst], 0, sizeof(int)*n);
38788       }else if( ALWAYS(p->sharedMask & (1<<ofst)) ){
38789         assert( n==1 && aLock[ofst]>1 );
38790         aLock[ofst]--;
38801     assert( (p->exclMask & (1<<ofst))==0 );
38803       if( aLock[ofst]<0 ){
38805       }else if( aLock[ofst]==0 ){
38806         rc = unixShmSystemLock(pDbFd, F_RDLCK, ofst+UNIX_SHM_BASE, n);
38812         aLock[ofst]++;
38819     for(ii=ofst; ii<ofst+n; ii++){
38830       rc = unixShmSystemLock(pDbFd, F_WRLCK, ofst+UNIX_SHM_BASE, n);
38834         for(ii=ofst; ii<ofst+n; ii++){
45889 ** Apply advisory locks for all n bytes beginning at ofst.
45897   int ofst,             /* Offset to first byte to be locked/unlocked */
45906            pFile->hFile.h, lockType, ofst, nByte));
45910     rc = winUnlockFile(&pFile->hFile.h, ofst, 0, nByte, 0);
45915     rc = winLockFile(&pFile->hFile.h, dwFlags, ofst, 0, nByte, 0);
46174   int ofst,                  /* First lock to acquire or release */
46185   assert( ofst>=0 && ofst+n<=SQLITE_SHM_NLOCK );
46193   mask = (u16)((1U<<(ofst+n)) - (1U<<ofst));
46194   assert( n>1 || mask==(1<<ofst) );
46208       rc = winShmSystemLock(pShmNode, WINSHM_UNLCK, ofst+WIN_SHM_BASE, n);
46236         rc = winShmSystemLock(pShmNode, WINSHM_RDLCK, ofst+WIN_SHM_BASE, n);
46261       rc = winShmSystemLock(pShmNode, WINSHM_WRLCK, ofst+WIN_SHM_BASE, n);
54517     i64 ofst = (pgno-1)*(i64)pPager->pageSize;
54527     rc = sqlite3OsWrite(pPager->fd, (u8 *)aData, pPager->pageSize, ofst);
199568     unsigned int cnt, ofst;
199573         ofst = rbuDeltaGetInt(&zDelta, &lenDelta);
199584         if( (int)(ofst+cnt) > lenSrc ){
199588         memcpy(zOut, &zSrc[ofst], cnt);
203810 static int rbuVfsShmLock(sqlite3_file *pFile, int ofst, int n, int flags){
203828     if( ofst==WAL_LOCK_CKPT && n==1 ) rc = SQLITE_BUSY;
203835       rc = p->pReal->pMethods->xShmLock(p->pReal, ofst, n, flags);
203837         pRbu->mLock |= ((1<<n) - 1) << ofst;