github
/
aria2
mirror of https://github.com/aria2/aria2
1
0
Fork 0
Code Issues Releases Wiki Activity

Fix cached data is not flushed when downloaded data is less than 16KiB

pull/82/head
Tatsuhiro Tsujikawa 2013-04-23 23:00:11 +09:00
parent 9665a3491d
commit b05454657f
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/SegmentMan.cc
View File

@ -282,14 +282,8 @@ void SegmentMan::cancelSegmentInternal
A2_LOG_DEBUG(fmt("Canceling segment#%lu", A2_LOG_DEBUG(fmt("Canceling segment#%lu",
static_cast<unsigned long>(segment->getIndex()))); static_cast<unsigned long>(segment->getIndex())));
const SharedHandle<Piece>& piece = segment->getPiece(); const SharedHandle<Piece>& piece = segment->getPiece();
piece->setUsedBySegment(false);
pieceStorage_->cancelPiece(piece, cuid);
segmentWrittenLengthMemo_[segment->getIndex()] = segment->getWrittenLength();
A2_LOG_DEBUG(fmt("Memorized segment index=%lu, writtenLength=%d",
static_cast<unsigned long>(segment->getIndex()),
segment->getWrittenLength()));
// TODO In PieceStorage::cancelPiece(), WrDiskCacheEntry may be // TODO In PieceStorage::cancelPiece(), WrDiskCacheEntry may be
// released. // released. Flush first.
if(piece->getWrDiskCacheEntry()) { if(piece->getWrDiskCacheEntry()) {
// Flush cached data here, because the cached data may be overlapped // Flush cached data here, because the cached data may be overlapped
// if BT peers are involved. // if BT peers are involved.
@ -300,6 +294,12 @@ void SegmentMan::cancelSegmentInternal
// TODO Exception may cause some segments (pieces) are not // TODO Exception may cause some segments (pieces) are not
// canceled. // canceled.
} }
piece->setUsedBySegment(false);
pieceStorage_->cancelPiece(piece, cuid);
segmentWrittenLengthMemo_[segment->getIndex()] = segment->getWrittenLength();
A2_LOG_DEBUG(fmt("Memorized segment index=%lu, writtenLength=%d",
static_cast<unsigned long>(segment->getIndex()),
segment->getWrittenLength()));
} }
void SegmentMan::cancelSegment(cuid_t cuid) { void SegmentMan::cancelSegment(cuid_t cuid) {