diff options
| -rw-r--r-- | libmpdemux/demux_rtp.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/libmpdemux/demux_rtp.cpp b/libmpdemux/demux_rtp.cpp index f6b7b38829..5d2698394f 100644 --- a/libmpdemux/demux_rtp.cpp +++ b/libmpdemux/demux_rtp.cpp @@ -504,8 +504,9 @@ static demux_packet_t* getBuffer(demuxer_t* demuxer, demux_stream_t* ds, // Block ourselves until data becomes available: TaskScheduler& scheduler = bufferQueue->readSource()->envir().taskScheduler(); - int delay = bufferQueue->prevPacketPTS * 1.05 > - rtpState->mediaSession->playEndTime() ? 1000000 : 10000000; + int delay = 10000000; + if (bufferQueue->prevPacketPTS * 1.05 > rtpState->mediaSession->playEndTime()) + delay /= 10; task = scheduler.scheduleDelayedTask(delay, onSourceClosure, bufferQueue); scheduler.doEventLoop(&bufferQueue->blockingFlag); scheduler.unscheduleDelayedTask(task); |