void/AyuGramDesktop
2
0
Fork 0
mirror of https://github.com/AyuGram/AyuGramDesktop.git synced 2025-04-16 22:27:20 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Simplify frame presentation.

Browse source
This commit is contained in:
John Preston 2020-07-17 22:59:25 +04:00
parent da3bbba497
commit 16177eae2b
2 changed files with 30 additions and 30 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

54
Telegram/SourceFiles/media/streaming/media_streaming_video_track.cpp
View file

@ -52,6 +52,8 @@ public:
const FrameRequest &request);
void removeFrameRequest(const Instance *instance);
void rasterizeFrame(not_null<Frame*> frame);
private:
enum class FrameResult {
Done,
@ -354,36 +356,37 @@ QSize VideoTrackObject::chooseOriginalResize() const {
return chosen;
}
void VideoTrackObject::rasterizeFrame(not_null<Frame*> frame) {
Expects(frame->position != kFinishedPosition);
fillRequests(frame);
frame->alpha = (frame->decoded->format == AV_PIX_FMT_BGRA);
frame->original = ConvertFrame(
_stream,
frame->decoded.get(),
chooseOriginalResize(),
std::move(frame->original));
if (frame->original.isNull()) {
frame->prepared.clear();
fail(Error::InvalidData);
return;
}
VideoTrack::PrepareFrameByRequests(frame, _stream.rotation);
Ensures(VideoTrack::IsRasterized(frame));
}
void VideoTrackObject::presentFrameIfNeeded() {
if (_pausedTime != kTimeUnknown || _resumedTime == kTimeUnknown) {
return;
}
const auto rasterize = [&](not_null<Frame*> frame) {
Expects(frame->position != kFinishedPosition);
fillRequests(frame);
frame->alpha = (frame->decoded->format == AV_PIX_FMT_BGRA);
frame->original = ConvertFrame(
_stream,
frame->decoded.get(),
chooseOriginalResize(),
std::move(frame->original));
if (frame->original.isNull()) {
frame->prepared.clear();
fail(Error::InvalidData);
return;
}
VideoTrack::PrepareFrameByRequests(frame, _stream.rotation);
Ensures(VideoTrack::IsRasterized(frame));
};
const auto dropStaleFrames = !_options.waitForMarkAsShown;
const auto presented = _shared->presentFrame(
this,
trackTime(),
_options.speed,
dropStaleFrames,
rasterize);
dropStaleFrames);
addTimelineDelay(presented.addedWorldTimeDelay);
if (presented.displayPosition == kFinishedPosition) {
interrupt();
@ -693,12 +696,11 @@ bool VideoTrack::Shared::firstPresentHappened() const {
Unexpected("Counter value in VideoTrack::Shared::firstPresentHappened.");
}
template <typename RasterizeCallback>
auto VideoTrack::Shared::presentFrame(
not_null<VideoTrackObject*> object,
TimePoint time,
float64 playbackSpeed,
bool dropStaleFrames,
RasterizeCallback &&rasterize)
bool dropStaleFrames)
-> PresentFrame {
const auto present = [&](int counter, int index) -> PresentFrame {
const auto frame = getFrame(index);
@ -707,7 +709,7 @@ auto VideoTrack::Shared::presentFrame(
if (position == kFinishedPosition) {
return { kFinishedPosition, kTimeUnknown, addedWorldTimeDelay };
}
rasterize(frame);
object->rasterizeFrame(frame);
if (!IsRasterized(frame)) {
// Error happened during frame prepare.
return { kTimeUnknown, kTimeUnknown, addedWorldTimeDelay };

6
Telegram/SourceFiles/media/streaming/media_streaming_video_track.h
View file

@ -108,13 +108,11 @@ private:
crl::time trackTime,
bool dropStaleFrames);
// RasterizeCallback(not_null<Frame*>).
template <typename RasterizeCallback>
[[nodiscard]] PresentFrame presentFrame(
not_null<VideoTrackObject*> object,
TimePoint trackTime,
float64 playbackSpeed,
bool dropStaleFrames,
RasterizeCallback &&rasterize);
bool dropStaleFrames);
[[nodiscard]] bool firstPresentHappened() const;
// Called from the main thread.