Plug two memory leaks
This commit is contained in:
parent
3c0e1141ff
commit
2ed2283a25
2 changed files with 3 additions and 1 deletions
|
@ -472,6 +472,7 @@ dvr_thread(void *aux)
|
|||
switch(sm->sm_type) {
|
||||
case SMT_PACKET:
|
||||
pkt = sm->sm_data;
|
||||
sm->sm_data = NULL;
|
||||
if(dispatch_clock > de->de_start - (60 * de->de_start_extra)) {
|
||||
pkt = pkt_merge_global(pkt);
|
||||
dvr_thread_new_pkt(de, pkt);
|
||||
|
@ -559,7 +560,7 @@ dvr_thread(void *aux)
|
|||
break;
|
||||
}
|
||||
|
||||
free(sm);
|
||||
streaming_msg_free(sm);
|
||||
pthread_mutex_lock(&sq->sq_mutex);
|
||||
}
|
||||
pthread_mutex_unlock(&sq->sq_mutex);
|
||||
|
|
|
@ -209,6 +209,7 @@ normalize_ts(tsfix_t *tf, tfstream_t *tfs, th_pkt_t *pkt)
|
|||
|
||||
streaming_message_t *sm = streaming_msg_create_pkt(pkt);
|
||||
streaming_target_deliver2(tf->tf_output, sm);
|
||||
pkt_ref_dec(pkt);
|
||||
}
|
||||
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue