diff --git a/lib/upipe-modules/upipe_row_join.c b/lib/upipe-modules/upipe_row_join.c index 937fa58c3..987bd18f8 100644 --- a/lib/upipe-modules/upipe_row_join.c +++ b/lib/upipe-modules/upipe_row_join.c @@ -153,6 +153,7 @@ static int upipe_row_join_control(struct upipe *upipe, int command, static void upipe_row_join_free(struct upipe *upipe) { + upipe_throw_dead(upipe); upipe_row_join_clean_ubuf_mgr(upipe); upipe_row_join_clean_urefcount(upipe); upipe_row_join_clean_output(upipe); @@ -178,6 +179,7 @@ static struct upipe *upipe_row_join_alloc(struct upipe_mgr *mgr, upipe_row_join_init_ubuf_mgr(upipe); upipe_row_join_init_urefcount(upipe); + upipe_throw_ready(upipe); return upipe; } diff --git a/lib/upipe-modules/upipe_rtp_pcm_pack.c b/lib/upipe-modules/upipe_rtp_pcm_pack.c index dfcc54d4d..e7ed59007 100644 --- a/lib/upipe-modules/upipe_rtp_pcm_pack.c +++ b/lib/upipe-modules/upipe_rtp_pcm_pack.c @@ -295,6 +295,7 @@ static struct upipe *upipe_rtp_pcm_pack_alloc(struct upipe_mgr *mgr, upipe_rtp_pcm_pack->output_time = 0; upipe_rtp_pcm_pack->output_samples = 0; + upipe_throw_ready(upipe); return upipe; } diff --git a/lib/upipe-modules/upipe_separate_fields.c b/lib/upipe-modules/upipe_separate_fields.c index f0ecaa9a6..70e0071fe 100644 --- a/lib/upipe-modules/upipe_separate_fields.c +++ b/lib/upipe-modules/upipe_separate_fields.c @@ -131,6 +131,7 @@ static int upipe_separate_fields_control(struct upipe *upipe, int command, static void upipe_separate_fields_free(struct upipe *upipe) { + upipe_throw_dead(upipe); upipe_separate_fields_clean_urefcount(upipe); upipe_separate_fields_clean_output(upipe); upipe_separate_fields_free_void(upipe); @@ -148,6 +149,7 @@ static struct upipe *upipe_separate_fields_alloc(struct upipe_mgr *mgr, upipe_separate_fields_init_urefcount(upipe); upipe_separate_fields_init_output(upipe); + upipe_throw_ready(upipe); return upipe; }