Lines Matching refs:pData
516 AsyncFileData *pData; member
628 AsyncFileData *p = ((AsyncFile *)pFile)->pData; in asyncClose()
651 AsyncFileData *p = ((AsyncFile *)pFile)->pData; in asyncWrite()
668 AsyncFileData *p = ((AsyncFile *)pFile)->pData; in asyncRead()
744 AsyncFileData *p = ((AsyncFile *)pFile)->pData; in asyncTruncate()
753 AsyncFileData *p = ((AsyncFile *)pFile)->pData; in asyncSync()
765 AsyncFileData *p = ((AsyncFile *)pFile)->pData; in asyncFileSize()
864 AsyncFileData *p = ((AsyncFile *)pFile)->pData; in asyncLock()
899 AsyncFileData *p = ((AsyncFile *)pFile)->pData; in asyncUnlock()
919 AsyncFileData *p = ((AsyncFile *)pFile)->pData; in asyncCheckReservedLock()
942 *(int*)pArg = ((AsyncFile*)id)->pData->lock.eLock; in asyncFileControl()
964 static int unlinkAsyncFile(AsyncFileData *pData){ in unlinkAsyncFile() argument
968 if( pData->zName ){ in unlinkAsyncFile()
969 AsyncLock *pLock = pData->pLock; in unlinkAsyncFile()
971 if( (*ppIter)==&pData->lock ){ in unlinkAsyncFile()
972 *ppIter = pData->lock.pNext; in unlinkAsyncFile()
1042 AsyncFileData *pData; in asyncOpen() local
1065 pData = (AsyncFileData*)z; in asyncOpen()
1066 z += sizeof(pData[0]); in asyncOpen()
1067 pData->pBaseRead = (sqlite3_file*)z; in asyncOpen()
1069 pData->pBaseWrite = (sqlite3_file*)z; in asyncOpen()
1070 pData->closeOp.pFileData = pData; in asyncOpen()
1071 pData->closeOp.op = ASYNC_CLOSE; in asyncOpen()
1075 pData->zName = z; in asyncOpen()
1076 pData->nName = nName; in asyncOpen()
1077 memcpy(pData->zName, zName, nName); in asyncOpen()
1082 rc = pVfs->xOpen(pVfs, pData->zName, pData->pBaseRead, flags, &flagsout); in asyncOpen()
1087 rc = pVfs->xOpen(pVfs, pData->zName, pData->pBaseWrite, flags, 0); in asyncOpen()
1097 pLock = findLock(pData->zName, pData->nName); in asyncOpen()
1099 int nByte = pVfs->szOsFile + sizeof(AsyncLock) + pData->nName + 1; in asyncOpen()
1105 rc = pVfs->xOpen(pVfs, pData->zName, pLock->pFile, flags, 0); in asyncOpen()
1112 pLock->nFile = pData->nName; in asyncOpen()
1114 memcpy(pLock->zFile, pData->zName, pLock->nFile); in asyncOpen()
1126 p->pData = pData; in asyncOpen()
1132 pData->lock.pNext = pLock->pList; in asyncOpen()
1133 pLock->pList = &pData->lock; in asyncOpen()
1134 pData->zName = pLock->zFile; in asyncOpen()
1137 if( pData->pBaseRead->pMethods ){ in asyncOpen()
1138 pData->pBaseRead->pMethods->xClose(pData->pBaseRead); in asyncOpen()
1140 if( pData->pBaseWrite->pMethods ){ in asyncOpen()
1141 pData->pBaseWrite->pMethods->xClose(pData->pBaseWrite); in asyncOpen()
1143 sqlite3_free(pData); in asyncOpen()
1149 pData->pLock = pLock; in asyncOpen()
1153 rc = addNewAsyncWrite(pData, ASYNC_OPENEXCLUSIVE, (sqlite3_int64)flags,0,0); in asyncOpen()
1158 unlinkAsyncFile(pData); in asyncOpen()
1160 sqlite3_free(pData); in asyncOpen()
1430 AsyncFileData *pData = p->pFileData; in asyncWriterThread() local
1432 if( pData->pBaseWrite->pMethods ){ in asyncWriterThread()
1433 pData->pBaseWrite->pMethods->xClose(pData->pBaseWrite); in asyncWriterThread()
1435 if( pData->pBaseRead->pMethods ){ in asyncWriterThread()
1436 pData->pBaseRead->pMethods->xClose(pData->pBaseRead); in asyncWriterThread()
1444 rc = unlinkAsyncFile(pData); in asyncWriterThread()
1453 sqlite3_free(pData); in asyncWriterThread()
1460 AsyncFileData *pData = p->pFileData; in asyncWriterThread() local
1496 if( pIter->pFileData==pData && pIter->op==ASYNC_UNLOCK ) break; in asyncWriterThread()
1500 pData->lock.eAsyncLock = MIN( in asyncWriterThread()
1501 pData->lock.eAsyncLock, MAX(pData->lock.eLock, eLock) in asyncWriterThread()
1503 assert(pData->lock.eAsyncLock>=pData->lock.eLock); in asyncWriterThread()
1504 rc = getFileLock(pData->pLock); in asyncWriterThread()
1518 AsyncFileData *pData = p->pFileData; in asyncWriterThread() local
1520 assert(pData->pBaseRead->pMethods==0 && pData->pBaseWrite->pMethods==0); in asyncWriterThread()
1521 rc = pVfs->xOpen(pVfs, pData->zName, pData->pBaseRead, flags, 0); in asyncWriterThread()