diff options
Diffstat (limited to 'xine_input_vdr.c')
| -rw-r--r-- | xine_input_vdr.c | 22 |
1 files changed, 20 insertions, 2 deletions
diff --git a/xine_input_vdr.c b/xine_input_vdr.c index 460faeeb..25b92191 100644 --- a/xine_input_vdr.c +++ b/xine_input_vdr.c @@ -4,7 +4,7 @@ * See the main source file 'xineliboutput.c' for copyright information and * how to reach the author. * - * $Id: xine_input_vdr.c,v 1.271 2009-07-17 12:44:59 phintuka Exp $ + * $Id: xine_input_vdr.c,v 1.272 2009-07-17 13:00:42 phintuka Exp $ * */ @@ -3924,7 +3924,17 @@ static void udp_process_queue(vdr_input_plugin_t *this) } /* - * flush continous part of queue to demuxer queue + * flush all packets when idle padding found + */ + + if (udp->is_padding && udp->queued > 0) + while (!udp->queue[udp->next_seq]) { + INCSEQ(udp->next_seq); + udp->missed_frames++; + } + + /* + * return next packet if available */ while (udp->queued > 0 && udp->queue[udp->next_seq]) { @@ -3938,8 +3948,16 @@ static void udp_process_queue(vdr_input_plugin_t *this) udp->queue[udp->next_seq] = NULL; udp->queued --; INCSEQ(udp->next_seq); + if (udp->resend_requested) udp->resend_requested --; + + /* flush all packets when idle padding found */ + if (udp->is_padding && udp->queued > 0) + while (!udp->queue[udp->next_seq]) { + INCSEQ(udp->next_seq); + udp->missed_frames++; + } } } |