Home
last modified time | relevance | path

Searched refs:diskAdaptor (Results 1 – 17 of 17) sorted by relevance

/dports/www/aria2/aria2-1.36.0/src/
H A DBtFileAllocationEntry.cc66 auto diskAdaptor = ps->getDiskAdaptor(); in prepareForNextAction() local
72 diskAdaptor->size() <= option->getAsLLInt(PREF_MAX_MMAP_LIMIT)) { in prepareForNextAction()
73 diskAdaptor->enableMmap(); in prepareForNextAction()
96 if (!diskAdaptor->isReadOnlyEnabled()) { in prepareForNextAction()
103 diskAdaptor->closeFile(); in prepareForNextAction()
104 diskAdaptor->enableReadOnly(); in prepareForNextAction()
105 diskAdaptor->openFile(); in prepareForNextAction()
H A DBtCheckIntegrityEntry.cc64 const auto& diskAdaptor = ps->getDiskAdaptor(); in onDownloadIncomplete() local
65 if (diskAdaptor->isReadOnlyEnabled()) { in onDownloadIncomplete()
67 diskAdaptor->closeFile(); in onDownloadIncomplete()
68 diskAdaptor->disableReadOnly(); in onDownloadIncomplete()
69 diskAdaptor->openFile(); in onDownloadIncomplete()
H A DMetalinkPostDownloadHandler.cc97 auto diskAdaptor = requestGroup->getPieceStorage()->getDiskAdaptor(); in getNextRequestGroups() local
99 diskAdaptor->openExistingFile(); in getNextRequestGroups()
104 Metalink2RequestGroup().generate(newRgs, diskAdaptor, in getNextRequestGroups()
126 diskAdaptor->closeFile(); in getNextRequestGroups()
129 diskAdaptor->closeFile(); in getNextRequestGroups()
H A DStreamFileAllocationEntry.cc67 auto diskAdaptor = ps->getDiskAdaptor(); in prepareForNextAction() local
75 diskAdaptor->size() <= option->getAsLLInt(PREF_MAX_MMAP_LIMIT)) { in prepareForNextAction()
76 diskAdaptor->enableMmap(); in prepareForNextAction()
H A DOpenedFileCounter.cc80 auto diskAdaptor = ps->getDiskAdaptor(); in ensureMaxOpenFileLimit() local
82 if (!diskAdaptor) { in ensureMaxOpenFileLimit()
86 left -= diskAdaptor->tryCloseFile(left); in ensureMaxOpenFileLimit()
H A DBtDependency.cc98 std::shared_ptr<DiskAdaptor> diskAdaptor = in resolve() local
100 diskAdaptor->openExistingFile(); in resolve()
101 std::string content = util::toString(diskAdaptor); in resolve()
H A DWrDiskCacheEntry.cc48 const std::shared_ptr<DiskAdaptor>& diskAdaptor) in WrDiskCacheEntry() argument
54 diskAdaptor_(diskAdaptor) in WrDiskCacheEntry()
H A DDownloadCommand.cc146 const std::shared_ptr<DiskAdaptor>& diskAdaptor = in executeInternal() local
183 streamFilter_->transform(diskAdaptor, segment, in executeInternal()
191 streamFilter_->transform(diskAdaptor, segment, in executeInternal()
263 segment->getSegmentLength(), diskAdaptor); in executeInternal()
H A DMultiFileAllocationIterator.cc50 MultiDiskAdaptor* diskAdaptor) in MultiFileAllocationIterator() argument
51 : diskAdaptor_{diskAdaptor}, in MultiFileAllocationIterator()
H A DMultiFileAllocationIterator.h57 MultiFileAllocationIterator(MultiDiskAdaptor* diskAdaptor);
H A DWrDiskCacheEntry.h68 WrDiskCacheEntry(const std::shared_ptr<DiskAdaptor>& diskAdaptor);
H A DPiece.cc301 const std::shared_ptr<DiskAdaptor>& diskAdaptor) in initWrCache() argument
307 wrCache_ = make_unique<WrDiskCacheEntry>(diskAdaptor); in initWrCache()
H A DPiece.h178 const std::shared_ptr<DiskAdaptor>& diskAdaptor);
/dports/www/aria2/aria2-1.36.0/test/
H A DMultiFileAllocationIteratorTest.cc68 MultiDiskAdaptor diskAdaptor; in testMakeDiskWriterEntries() local
69 diskAdaptor.setFileEntries(std::begin(fs), std::end(fs)); in testMakeDiskWriterEntries()
70 diskAdaptor.setPieceLength(1_k); in testMakeDiskWriterEntries()
71 diskAdaptor.openFile(); in testMakeDiskWriterEntries()
73 auto allocitr = diskAdaptor.fileAllocationIterator(); in testMakeDiskWriterEntries()
155 MultiDiskAdaptor diskAdaptor; in testAllocate() local
156 diskAdaptor.setPieceLength(1); in testAllocate()
182 diskAdaptor.setFileEntries(std::begin(fs), std::end(fs)); in testAllocate()
189 diskAdaptor.initAndOpenFile(); in testAllocate()
190 auto allocitr = diskAdaptor.fileAllocationIterator(); in testAllocate()
H A DUTMetadataDataExtensionMessageTest.cc68 auto diskAdaptor = std::make_shared<DirectDiskAdaptor>(); in testDoReceivedAction() local
73 diskAdaptor->setDiskWriter(std::move(dw)); in testDoReceivedAction()
76 pieceStorage->setDiskAdaptor(diskAdaptor); in testDoReceivedAction()
H A DBtDependencyTest.cc183 auto diskAdaptor = std::make_shared<DirectDiskAdaptor>(); in testResolve_metadata() local
191 diskAdaptor->setDiskWriter(std::move(diskWriter)); in testResolve_metadata()
194 pieceStorage->setDiskAdaptor(diskAdaptor); in testResolve_metadata()
H A DMockPieceStorage.h24 std::shared_ptr<DiskAdaptor> diskAdaptor; variable
226 return diskAdaptor; in getDiskAdaptor()
235 this->diskAdaptor = adaptor; in setDiskAdaptor()