stv0g/tvheadend
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Need to init ptsq + some cosmetics

Browse source
This commit is contained in:
Andreas Öman 2010-06-21 19:23:13 +00:00
parent 839244f637
commit 1ccfa89afe
1 changed files with 6 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
src/plumbing/tsfix.c
View file

@ -61,17 +61,6 @@ typedef struct tsfix {
} tsfix_t;
/**
*
*/
static void
tsfix_destroy_stream(tfstream_t *tfs)
{
LIST_REMOVE(tfs, tfs_link);
free(tfs);
}
/**
*
*/
@ -79,9 +68,11 @@ static void
tsfix_destroy_streams(tsfix_t *tf)
{
tfstream_t *tfs;
while((tfs = LIST_FIRST(&tf->tf_streams)) != NULL)
tsfix_destroy_stream(tfs);
pktref_clear_queue(&tf->tf_ptsq);
while((tfs = LIST_FIRST(&tf->tf_streams)) != NULL) {
LIST_REMOVE(tfs, tfs_link);
free(tfs);
}
}
@ -290,9 +281,6 @@ recover_pts(tsfix_t *tf, tfstream_t *tfs, th_pkt_t *pkt)
/**
* Compute PTS (if not known)
*
* We do this by placing packets on a queue and wait for next I/P
* frame to appear
*/
static void
compute_pts(tsfix_t *tf, tfstream_t *tfs, th_pkt_t *pkt)
@ -321,7 +309,6 @@ tsfix_input_packet(tsfix_t *tf, streaming_message_t *sm)
{
th_pkt_t *pkt = pkt_copy(sm->sm_data);
tfstream_t *tfs = tfs_find(tf, pkt);
streaming_msg_free(sm);
if(tfs == NULL) {
@ -398,6 +385,8 @@ tsfix_create(streaming_target_t *output)
{
tsfix_t *tf = calloc(1, sizeof(tsfix_t));
TAILQ_INIT(&tf->tf_ptsq);
tf->tf_output = output;
streaming_target_init(&tf->tf_input, tsfix_input, tf, 0);
return &tf->tf_input;