Lines Matching refs:pDbFd
43413 static int unixLockSharedMemory(unixFile *pDbFd, unixShmNode *pShmNode){ in unixLockSharedMemory() argument
43453 int iSaveTimeout = pDbFd->iBusyTimeout; in unixLockSharedMemory()
43454 pDbFd->iBusyTimeout = 0; in unixLockSharedMemory()
43456 rc = unixShmSystemLock(pDbFd, F_WRLCK, UNIX_SHM_DMS, 1); in unixLockSharedMemory()
43458 pDbFd->iBusyTimeout = iSaveTimeout; in unixLockSharedMemory()
43475 rc = unixShmSystemLock(pDbFd, F_RDLCK, UNIX_SHM_DMS, 1); in unixLockSharedMemory()
43515 static int unixOpenSharedMemory(unixFile *pDbFd){ in unixOpenSharedMemory() argument
43527 assert( pDbFd->pShm==0 ); in unixOpenSharedMemory()
43532 assert( unixFileMutexNotheld(pDbFd) ); in unixOpenSharedMemory()
43534 pInode = pDbFd->pInode; in unixOpenSharedMemory()
43539 const char *zBasePath = pDbFd->zPath; in unixOpenSharedMemory()
43546 if( osFstat(pDbFd->h, &sStat) ){ in unixOpenSharedMemory()
43569 sqlite3FileSuffix3(pDbFd->zPath, zShm); in unixOpenSharedMemory()
43572 pDbFd->pInode->pShmNode = pShmNode; in unixOpenSharedMemory()
43573 pShmNode->pInode = pDbFd->pInode; in unixOpenSharedMemory()
43595 if( 0==sqlite3_uri_boolean(pDbFd->zPath, "readonly_shm", 0) ){ in unixOpenSharedMemory()
43615 rc = unixLockSharedMemory(pDbFd, pShmNode); in unixOpenSharedMemory()
43626 pDbFd->pShm = p; in unixOpenSharedMemory()
43644 unixShmPurge(pDbFd); /* This call frees pShmNode if required */ in unixOpenSharedMemory()
43676 unixFile *pDbFd = (unixFile*)fd; in unixShmMap() local
43684 if( pDbFd->pShm==0 ){ in unixShmMap()
43685 rc = unixOpenSharedMemory(pDbFd); in unixShmMap()
43689 p = pDbFd->pShm; in unixShmMap()
43693 rc = unixLockSharedMemory(pDbFd, pShmNode); in unixShmMap()
43698 assert( pShmNode->pInode==pDbFd->pInode ); in unixShmMap()
43699 assert( pShmNode->hShm>=0 || pDbFd->pInode->bProcessLock==1 ); in unixShmMap()
43700 assert( pShmNode->hShm<0 || pDbFd->pInode->bProcessLock==0 ); in unixShmMap()
43853 unixFile *pDbFd = (unixFile*)fd; /* Connection holding shared memory */ in unixShmLock() local
43860 p = pDbFd->pShm; in unixShmLock()
43866 assert( pShmNode==pDbFd->pInode->pShmNode ); in unixShmLock()
43867 assert( pShmNode->pInode==pDbFd->pInode ); in unixShmLock()
43875 assert( pShmNode->hShm>=0 || pDbFd->pInode->bProcessLock==1 ); in unixShmLock()
43876 assert( pShmNode->hShm<0 || pDbFd->pInode->bProcessLock==0 ); in unixShmLock()
43893 assert( (flags & SQLITE_SHM_UNLOCK) || pDbFd->iBusyTimeout==0 || ( in unixShmLock()
43971 rc = unixShmSystemLock(pDbFd, F_UNLCK, ofst+UNIX_SHM_BASE, n); in unixShmLock()
43985 rc = unixShmSystemLock(pDbFd, F_RDLCK, ofst+UNIX_SHM_BASE, n); in unixShmLock()
44013 rc = unixShmSystemLock(pDbFd, F_WRLCK, ofst+UNIX_SHM_BASE, n); in unixShmLock()
44073 unixFile *pDbFd; /* The underlying database file */ in unixShmUnmap() local
44075 pDbFd = (unixFile*)fd; in unixShmUnmap()
44076 p = pDbFd->pShm; in unixShmUnmap()
44080 assert( pShmNode==pDbFd->pInode->pShmNode ); in unixShmUnmap()
44081 assert( pShmNode->pInode==pDbFd->pInode ); in unixShmUnmap()
44091 pDbFd->pShm = 0; in unixShmUnmap()
44096 assert( unixFileMutexNotheld(pDbFd) ); in unixShmUnmap()
44104 unixShmPurge(pDbFd); in unixShmUnmap()
47427 # define winFileBusyTimeout(pDbFd) pDbFd->iBusyTimeout argument
47429 # define winFileBusyTimeout(pDbFd) 0 argument
51513 static int winOpenSharedMemory(winFile *pDbFd){
51520 assert( pDbFd->pShm==0 ); /* Not previously opened */
51526 nName = sqlite3Strlen30(pDbFd->zPath);
51535 sqlite3_snprintf(nName+15, pNew->zFilename, "%s-shm", pDbFd->zPath);
51536 sqlite3FileSuffix3(pDbFd->zPath, pNew->zFilename);
51541 p->bReadonly = sqlite3_uri_boolean(pDbFd->zPath, "readonly_shm", 0);
51591 pDbFd->pShm = p;
51611 winFile *pDbFd; /* Database holding shared-memory */ local
51615 pDbFd = (winFile*)fd;
51616 p = pDbFd->pShm;
51630 winShmPurge(pDbFd->pVfs, deleteFlag);
51636 pDbFd->pShm = 0;
51649 winFile *pDbFd = (winFile*)fd; /* Connection holding shared memory */ local
51650 winShm *p = pDbFd->pShm; /* The shared memory being locked */
51682 assert( (flags & SQLITE_SHM_UNLOCK) || pDbFd->iBusyTimeout==0 || (
51723 DWORD nMs = winFileBusyTimeout(pDbFd);
51786 winFile *pDbFd = (winFile*)fd; local
51787 winShm *pShm = pDbFd->pShm;
51794 rc = winOpenSharedMemory(pDbFd);
51796 pShm = pDbFd->pShm;
51805 rc = winLockSharedMemory(pShmNode, winFileBusyTimeout(pDbFd));
51824 rc = winLogError(rc, osGetLastError(), "winShmMap1", pDbFd->zPath);
51837 rc = winLogError(rc, osGetLastError(), "winShmMap2", pDbFd->zPath);
51891 "winShmMap3", pDbFd->zPath);
66391 sqlite3_file *pDbFd; /* File handle for the database file */ member
66662 rc = sqlite3OsShmMap(pWal->pDbFd, iPage, WALINDEX_PGSZ,
66798 sqlite3OsShmBarrier(pWal->pDbFd);
66960 rc = sqlite3OsShmLock(pWal->pDbFd, lockIdx, 1,
66972 (void)sqlite3OsShmLock(pWal->pDbFd, lockIdx, 1,
66982 rc = sqlite3OsShmLock(pWal->pDbFd, lockIdx, n,
66996 (void)sqlite3OsShmLock(pWal->pDbFd, lockIdx, n,
67500 sqlite3OsShmUnmap(pWal->pDbFd, isDelete);
67521 sqlite3_file *pDbFd, /* The open database file */
67532 assert( pDbFd );
67588 pRet->pDbFd = pDbFd;
67608 int iDC = sqlite3OsDeviceCharacteristics(pDbFd);
67900 pWal->pDbFd, SQLITE_FCNTL_LOCK_TIMEOUT, (void*)&nMs
67927 sqlite3OsFileControl(pWal->pDbFd, SQLITE_FCNTL_LOCK_TIMEOUT, (void*)&tmout);
68146 sqlite3OsFileControl(pWal->pDbFd, SQLITE_FCNTL_CKPT_START, 0);
68147 rc = sqlite3OsFileSize(pWal->pDbFd, &nSize);
68156 sqlite3OsFileControlHint(pWal->pDbFd, SQLITE_FCNTL_SIZE_HINT,&nReq);
68180 rc = sqlite3OsWrite(pWal->pDbFd, zBuf, szPage, iOffset);
68183 sqlite3OsFileControl(pWal->pDbFd, SQLITE_FCNTL_CKPT_DONE, 0);
68190 rc = sqlite3OsTruncate(pWal->pDbFd, szDb);
68192 rc = sqlite3OsSync(pWal->pDbFd, CKPT_SYNC_FLAGS(sync_flags));
68387 && SQLITE_OK==(rc = sqlite3OsLock(pWal->pDbFd, SQLITE_LOCK_EXCLUSIVE))
68398 pWal->pDbFd, SQLITE_FCNTL_PERSIST_WAL, &bPersist
68697 rc = sqlite3OsShmMap(pWal->pDbFd, 0, WALINDEX_PGSZ, 0, &pDummy);
69145 rc = sqlite3OsFileSize(pWal->pDbFd, &szDb);
69166 rc = sqlite3OsRead(pWal->pDbFd, pBuf2, szPage, iDbOff);
70234 if( isChanged && pWal->pDbFd->pMethods->iVersion>=3 ){
70235 sqlite3OsUnfetch(pWal->pDbFd, 0, 0);