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

Fix caching of first slice in header.

This commit is contained in:
John Preston 2019-03-18 10:59:51 +04:00
parent 8f9bed0443
commit 6c382c647c
1 changed files with 22 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
Telegram/SourceFiles/media/streaming/media_streaming_reader.cpp
View File

@ -336,19 +336,32 @@ bool Reader::Slices::headerWontBeFilled() const {
} }
void Reader::Slices::applyHeaderCacheData() { void Reader::Slices::applyHeaderCacheData() {
if (_header.parts.empty() || _headerMode != HeaderMode::Unknown) { using namespace rpl::mappers;
const auto applyWhile = [&](auto &&predicate) {
for (const auto &[offset, part] : _header.parts) {
const auto index = offset / kInSlice;
if (!predicate(index)) {
break;
}
_data[index].addPart(
offset - index * kInSlice,
base::duplicate(part));
}
};
if (_header.parts.empty()) {
return;
} else if (_headerMode == HeaderMode::Good) {
// Always apply data to first block if it is cached in the header.
applyWhile(_1 == 0);
} else if (_headerMode != HeaderMode::Unknown) {
return; return;
} else if (isFullInHeader()) { } else if (isFullInHeader()) {
headerDone(true); headerDone(true);
return; } else {
applyWhile(_1 < int(_data.size()));
headerDone(true);
} }
for (const auto &[offset, part] : _header.parts) {
const auto index = offset / kInSlice;
_data[index].addPart(
offset - index * kInSlice,
base::duplicate(part));
}
headerDone(true);
} }
void Reader::Slices::processCacheResult( void Reader::Slices::processCacheResult(