Lines Matching refs:pLock

388   AsyncLock *pLock;            /* Linked list of all AsyncLock structures */  member
524 AsyncLock *pLock; /* AsyncLock object for this file system entry */ member
813 static int getFileLock(AsyncLock *pLock){ in getFileLock() argument
818 if( pLock->pFile ){ in getFileLock()
819 for(pIter=pLock->pList; pIter; pIter=pIter->pNext){ in getFileLock()
827 if( eRequired>pLock->eLock ){ in getFileLock()
828 rc = pLock->pFile->pMethods->xLock(pLock->pFile, eRequired); in getFileLock()
830 pLock->eLock = eRequired; in getFileLock()
833 else if( eRequired<pLock->eLock && eRequired<=SQLITE_LOCK_SHARED ){ in getFileLock()
834 rc = pLock->pFile->pMethods->xUnlock(pLock->pFile, eRequired); in getFileLock()
836 pLock->eLock = eRequired; in getFileLock()
850 AsyncLock *p = async.pLock; in findLock()
869 AsyncLock *pLock = p->pLock; in asyncLock() local
871 assert(pLock && pLock->pList); in asyncLock()
872 for(pIter=pLock->pList; pIter; pIter=pIter->pNext){ in asyncLock()
888 rc = getFileLock(pLock); in asyncLock()
901 AsyncFileLock *pLock = &p->lock; in asyncUnlock() local
904 pLock->eLock = MIN(pLock->eLock, eLock); in asyncUnlock()
922 for(pIter=p->pLock->pList; pIter; pIter=pIter->pNext){ in asyncCheckReservedLock()
969 AsyncLock *pLock = pData->pLock; in unlinkAsyncFile() local
970 for(ppIter=&pLock->pList; *ppIter; ppIter=&((*ppIter)->pNext)){ in unlinkAsyncFile()
976 if( !pLock->pList ){ in unlinkAsyncFile()
978 if( pLock->pFile ){ in unlinkAsyncFile()
979 pLock->pFile->pMethods->xClose(pLock->pFile); in unlinkAsyncFile()
981 for(pp=&async.pLock; *pp!=pLock; pp=&((*pp)->pNext)); in unlinkAsyncFile()
982 *pp = pLock->pNext; in unlinkAsyncFile()
983 sqlite3_free(pLock); in unlinkAsyncFile()
985 rc = getFileLock(pLock); in unlinkAsyncFile()
1043 AsyncLock *pLock = 0; in asyncOpen() local
1097 pLock = findLock(pData->zName, pData->nName); in asyncOpen()
1098 if( !pLock ){ in asyncOpen()
1100 pLock = (AsyncLock *)sqlite3_malloc(nByte); in asyncOpen()
1101 if( pLock ){ in asyncOpen()
1102 memset(pLock, 0, nByte); in asyncOpen()
1104 pLock->pFile = (sqlite3_file *)&pLock[1]; in asyncOpen()
1105 rc = pVfs->xOpen(pVfs, pData->zName, pLock->pFile, flags, 0); in asyncOpen()
1107 sqlite3_free(pLock); in asyncOpen()
1108 pLock = 0; in asyncOpen()
1111 if( pLock ){ in asyncOpen()
1112 pLock->nFile = pData->nName; in asyncOpen()
1113 pLock->zFile = &((char *)(&pLock[1]))[pVfs->szOsFile]; in asyncOpen()
1114 memcpy(pLock->zFile, pData->zName, pLock->nFile); in asyncOpen()
1115 pLock->pNext = async.pLock; in asyncOpen()
1116 async.pLock = pLock; in asyncOpen()
1132 pData->lock.pNext = pLock->pList; in asyncOpen()
1133 pLock->pList = &pData->lock; in asyncOpen()
1134 pData->zName = pLock->zFile; in asyncOpen()
1149 pData->pLock = pLock; in asyncOpen()
1504 rc = getFileLock(pData->pLock); in asyncWriterThread()
1574 if( 0==async.pLock ){ in asyncWriterThread()