RepoMirrors/tdesktop
1
0
Fork 0
mirror of https://github.com/telegramdesktop/tdesktop synced 2025-04-01 23:00:58 +00:00
Code Issues Projects Releases Wiki Activity

Revert pausing in processQueuedPackets.

Browse Source
This commit is contained in:
John Preston 2020-06-29 16:41:42 +04:00
parent 73b0153a66
commit a33c9479a5
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
Telegram/SourceFiles/media/streaming/media_streaming_file.cpp
View File

@ -59,7 +59,15 @@ int File::Context::read(bytes::span buffer) {
if (result == Reader::FillState::Success) { if (result == Reader::FillState::Success) {
break; break;
} else if (result == Reader::FillState::WaitingRemote) { } else if (result == Reader::FillState::WaitingRemote) {
processQueuedPackets(SleepPolicy::Allowed); // Perhaps for the correct sleeping in case of enough packets
// being read already we require SleepPolicy::Allowed here.
// Otherwise if we wait for the remote frequently and
// _queuedPackets never get to kMaxQueuedPackets and we don't call
// processQueuedPackets(SleepPolicy::Allowed) ever.
//
// But right now we can't simply pass SleepPolicy::Allowed here,
// it freezes because of two _semaphore.acquire one after another.
processQueuedPackets(SleepPolicy::Disallowed);
_delegate->fileWaitingForData(); _delegate->fileWaitingForData();
} }
_semaphore.acquire(); _semaphore.acquire();