diff --git a/stream/tvi_vbi.c b/stream/tvi_vbi.c index 77d77de994..aa493a7eb7 100644 --- a/stream/tvi_vbi.c +++ b/stream/tvi_vbi.c @@ -149,6 +149,7 @@ typedef struct { unsigned int juliandate; unsigned int universaltime; unsigned char networkname[21]; + int cache_reset; } priv_vbi_t; static unsigned char fixParity[256]; @@ -622,6 +623,8 @@ static inline tt_page* get_from_cache(priv_vbi_t* priv, int pagenum,int subpagen static void clear_cache(priv_vbi_t* priv){ int i; tt_page* tp; + priv->cache_reset=1; + for(i=0;iptt_cache[i]){ tp=priv->ptt_cache[i]; @@ -1447,7 +1450,7 @@ static void vbi_decode(priv_vbi_t* priv,unsigned char*buf){ int d0,d1; int i=0; mp_msg(MSGT_TV,MSGL_DBG3,"vbi: vbi_decode\n"); - for(linep=buf; linepptsp->bufsize; linep+=priv->ptsp->samples_per_line,i++){ + for(linep=buf; !priv->cache_reset && linepptsp->bufsize; linep+=priv->ptsp->samples_per_line,i++){ #if 0 /* This routine is alternative implementation of raw VBI data decoding. @@ -1487,6 +1490,11 @@ static void vbi_decode(priv_vbi_t* priv,unsigned char*buf){ mp_msg(MSGT_TV,MSGL_DBG3,"unsupported packet:%d\n",pkt); } } + if (priv->cache_reset){ + pthread_mutex_lock(&(priv->buffer_mutex)); + priv->cache_reset=0; + pthread_mutex_unlock(&(priv->buffer_mutex)); + } }