frodovdr/vdr-plugin-softhddevice
1
0
Fork 0
mirror of https://projects.vdr-developer.org/git/vdr-plugin-softhddevice.git synced 2023-10-10 19:16:51 +02:00
Code Issues Releases Wiki Activity

Better Poll(), flush video buffers after replay.

Browse Source
This commit is contained in:
Johns 2012-03-10 17:05:41 +01:00
parent f59425ac57
commit 47d2896468
1 changed files with 42 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
softhddev.c
View File

@ -1135,6 +1135,7 @@ static int VideoPacketRead; ///< read pointer
static atomic_t VideoPacketsFilled; ///< how many of the buffer is used static atomic_t VideoPacketsFilled; ///< how many of the buffer is used
static volatile char VideoClearBuffers; ///< clear video buffers static volatile char VideoClearBuffers; ///< clear video buffers
static volatile char VideoClearClose; ///< clear video buffers upto close
static volatile char SkipVideo; ///< skip video static volatile char SkipVideo; ///< skip video
static volatile char VideoTrickSpeed; ///< current trick speed static volatile char VideoTrickSpeed; ///< current trick speed
static volatile char VideoTrickCounter; ///< current trick speed counter static volatile char VideoTrickCounter; ///< current trick speed counter
@ -1358,22 +1359,23 @@ int VideoDecode(void)
if (!filled) { if (!filled) {
return -1; return -1;
} }
#if 0 if (VideoClearClose) {
int f; int f;
// FIXME: flush buffers, if close is in the queue // flush buffers, if close is in the queue
for (f = 0; f < filled; ++f) { for (f = 0; f < filled; ++f) {
avpkt = &VideoPacketRb[(VideoPacketRead + f) % VIDEO_PACKET_MAX]; avpkt = &VideoPacketRb[(VideoPacketRead + f) % VIDEO_PACKET_MAX];
if ((int)(size_t) avpkt->priv == CODEC_ID_NONE) { if ((int)(size_t) avpkt->priv == CODEC_ID_NONE) {
printf("video: close\n");
if (f) { if (f) {
Debug(3, "video: cleared upto close\n");
atomic_sub(f, &VideoPacketsFilled); atomic_sub(f, &VideoPacketsFilled);
VideoPacketRead = (VideoPacketRead + f) % VIDEO_PACKET_MAX; VideoPacketRead = (VideoPacketRead + f) % VIDEO_PACKET_MAX;
VideoClearClose = 0;
} }
break; break;
} }
} }
#endif }
avpkt = &VideoPacketRb[VideoPacketRead]; avpkt = &VideoPacketRb[VideoPacketRead];
// //
@ -1619,6 +1621,10 @@ int PlayVideo(const uint8_t * data, int size)
Error(_("[softhddev] invalid PES video packet\n")); Error(_("[softhddev] invalid PES video packet\n"));
return size; return size;
} }
// 0xBE, filler, padding stream
if (data[3] == PES_PADDING_STREAM) { // from DVD plugin
return size;
}
n = data[8]; // header size n = data[8]; // header size
if (size < 9 + n + 4) { // wrong size if (size < 9 + n + 4) { // wrong size
@ -1861,9 +1867,11 @@ void Clear(void)
//NewAudioStream = 1; //NewAudioStream = 1;
// FIXME: audio avcodec_flush_buffers, video is done by VideoClearBuffers // FIXME: audio avcodec_flush_buffers, video is done by VideoClearBuffers
// wait for empty buffers
for (i = 0; VideoClearBuffers && i < 20; ++i) { for (i = 0; VideoClearBuffers && i < 20; ++i) {
usleep(1 * 1000); usleep(1 * 1000);
} }
Debug(3, "[softhddev]%s: buffers %d\n", __FUNCTION__, VideoGetBuffers());
} }
/** /**
@ -1991,20 +1999,34 @@ void StillPicture(const uint8_t * data, int size)
/** /**
** Poll if device is ready. Called by replay. ** Poll if device is ready. Called by replay.
** **
** This function is useless, the return value is ignored and
** all buffers are overrun by vdr.
**
** The dvd plugin is using this correct.
**
** @param timeout timeout to become ready in ms ** @param timeout timeout to become ready in ms
*/ */
int Poll(int timeout) int Poll(int timeout)
{ {
// poll is only called during replay, flush buffers after replay
VideoClearClose = 1;
for (;;) {
int empty;
int t;
// buffers are too full // buffers are too full
if (atomic_read(&VideoPacketsFilled) >= VIDEO_PACKET_MAX * 2 / 3 empty = atomic_read(&VideoPacketsFilled) < VIDEO_PACKET_MAX * 1 / 4
|| AudioFreeBytes() < AUDIO_MIN_BUFFER_FREE * 2) { || AudioUsedBytes() < AUDIO_MIN_BUFFER_FREE * 2;
if (timeout) { // let display thread work if (empty || !timeout) {
usleep(timeout * 1000); return empty;
} }
return atomic_read(&VideoPacketsFilled) < VIDEO_PACKET_MAX * 2 / 3 t = 15;
&& AudioFreeBytes() > AUDIO_MIN_BUFFER_FREE; if (timeout < t) {
t = timeout;
}
usleep(t * 1000); // let display thread work
timeout -= t;
} }
return 1;
} }
/** /**