}
sbuf_append(&la->sbuf, buf, buf_size);
/* notify iptv layer that we have new data to read */
- if (write(la->pipe.wr, "", 1)) { };
+ if (write(la->pipe.wr, "", 1)) {};
}
fin:
pthread_mutex_unlock(&la->lock);
}
if (atomic_get(&la->running) == 0)
goto unref;
+ if ((pkt.dts != AV_NOPTS_VALUE && pkt.dts < 0) ||
+ (pkt.pts != AV_NOPTS_VALUE && pkt.pts < 0))
+ goto unref;
in_stream = la->ictx->streams[pkt.stream_index];
out_stream = la->octx->streams[pkt.stream_index];
/* copy packet */