Lines Matching refs:pWrite

538 static void addAsyncWrite(AsyncWrite *pWrite){  in addAsyncWrite()  argument
540 if( pWrite->op!=ASYNC_UNLOCK ){ in addAsyncWrite()
545 assert( !pWrite->pNext ); in addAsyncWrite()
548 async.pQueueLast->pNext = pWrite; in addAsyncWrite()
550 async.pQueueFirst = pWrite; in addAsyncWrite()
552 async.pQueueLast = pWrite; in addAsyncWrite()
553 ASYNC_TRACE(("PUSH %p (%s %s %d)\n", pWrite, azOpcodeName[pWrite->op], in addAsyncWrite()
554 pWrite->pFileData ? pWrite->pFileData->zName : "-", pWrite->iOffset)); in addAsyncWrite()
556 if( pWrite->op==ASYNC_CLOSE ){ in addAsyncWrite()
565 if( pWrite->op!=ASYNC_UNLOCK ){ in addAsyncWrite()
699 AsyncWrite *pWrite; in asyncRead() local
702 for(pWrite=async.pQueueFirst; pWrite; pWrite = pWrite->pNext){ in asyncRead()
703 if( pWrite->op==ASYNC_WRITE && ( in asyncRead()
704 (pWrite->pFileData==p) || in asyncRead()
705 (zName && pWrite->pFileData->zName==zName) in asyncRead()
708 sqlite3_int64 nByte64 = (sqlite3_int64)pWrite->nByte; in asyncRead()
715 sqlite3_int64 iBeginOut = (pWrite->iOffset-iOffset); in asyncRead()
720 filesize = MAX(filesize, pWrite->iOffset+nByte64); in asyncRead()
724 memcpy(&((char *)zOut)[iBeginOut], &pWrite->zBuf[iBeginIn], (size_t)nCopy); in asyncRead()
783 AsyncWrite *pWrite; in asyncFileSize() local
784 for(pWrite=async.pQueueFirst; pWrite; pWrite = pWrite->pNext){ in asyncFileSize()
785 if( pWrite->op==ASYNC_DELETE in asyncFileSize()
787 && strcmp(p->zName, pWrite->zBuf)==0 in asyncFileSize()
790 }else if( pWrite->pFileData && ( in asyncFileSize()
791 (pWrite->pFileData==p) in asyncFileSize()
792 || (p->zName && pWrite->pFileData->zName==p->zName) in asyncFileSize()
794 switch( pWrite->op ){ in asyncFileSize()
796 s = MAX(pWrite->iOffset + (sqlite3_int64)(pWrite->nByte), s); in asyncFileSize()
799 s = MIN(s, pWrite->iOffset); in asyncFileSize()