Cbl 2026 05 06

.indent_cpp_list

@@ -14,6 +14,7 @@ subprojects/gst-plugins-bad/sys/d3d11
 subprojects/gst-plugins-bad/sys/d3d12
 subprojects/gst-plugins-bad/sys/dwrite
 subprojects/gst-plugins-bad/sys/hip
+^(subprojects/gst-plugins-bad/sys/decklink2/)+(\w)+([^/])+(cpp$)
 subprojects/gst-plugins-bad/sys/mediafoundation
 subprojects/gst-plugins-bad/sys/nvcodec
 ^(subprojects/gst-plugins-bad/sys/qsv/)+(\w)+([^/])+(cpp$)

subprojects/gst-libav/ext/libav/gstavdemux.c

@@ -648,7 +648,7 @@ gst_ffmpegdemux_perform_seek (GstFFMpegDemux * demux, GstEvent * event)
   /* and restart the task in case it got paused explicitely or by
    * the FLUSH_START event we pushed out. */
   gst_pad_start_task (demux->sinkpad, (GstTaskFunction) gst_ffmpegdemux_loop,
-      demux->sinkpad, NULL);
+      gst_object_ref (demux->sinkpad), gst_object_unref);
 
   /* and release the lock again so we can continue streaming */
   GST_PAD_STREAM_UNLOCK (demux->sinkpad);
@@ -1965,7 +1965,7 @@ gst_ffmpegdemux_sink_activate_pull (GstPad * sinkpad, GstObject * parent,
   if (active) {
     demux->seekable = TRUE;
     res = gst_pad_start_task (sinkpad, (GstTaskFunction) gst_ffmpegdemux_loop,
-        demux, NULL);
+        gst_object_ref (demux), gst_object_unref);
   } else {
     res = gst_pad_stop_task (sinkpad);
     demux->seekable = FALSE;

subprojects/gst-libav/ext/libav/gstavviddec.c

@@ -2136,9 +2136,10 @@ gst_ffmpegviddec_video_frame (GstFFMpegVidDec * ffmpegdec,
       GstVideoInfo *info = &ffmpegdec->output_state->info;
       if (vmeta->width != GST_VIDEO_INFO_WIDTH (info) ||
           vmeta->height != GST_VIDEO_INFO_HEIGHT (info)) {
-        g_error ("video meta uses %dx%d instead of %dx%d",
+        GST_ERROR_OBJECT (ffmpegdec, "video meta uses %dx%d instead of %dx%d",
             vmeta->width, vmeta->height, GST_VIDEO_INFO_WIDTH (info),
             GST_VIDEO_INFO_HEIGHT (info));
+        GST_VIDEO_CODEC_FRAME_SET_DECODE_ONLY (output_frame);
       }
     }
   }

subprojects/gst-plugins-bad/ext/dtls/gstdtlsenc.c

@@ -477,8 +477,8 @@ src_activate_mode (GstPad * pad, GstObject * parent, GstPadMode mode,
     self->src_ret = GST_FLOW_OK;
     self->send_initial_events = TRUE;
     success =
-        gst_pad_start_task (pad, (GstTaskFunction) src_task_loop, self->src,
-        NULL);
+        gst_pad_start_task (pad, (GstTaskFunction) src_task_loop,
+        gst_object_ref (self->src), gst_object_unref);
     if (!success) {
       GST_WARNING_OBJECT (self, "failed to activate pad task");
     }

subprojects/gst-plugins-bad/ext/gme/gstgme.c

@@ -258,7 +258,7 @@ gst_gme_dec_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
         gme->seeking = TRUE;
 
         gst_pad_start_task (gme->srcpad, (GstTaskFunction) gst_gme_play,
-            gme->srcpad, NULL);
+            gst_object_ref (gme->srcpad), gst_object_unref);
 
         GST_PAD_STREAM_UNLOCK (gme->srcpad);
         result = TRUE;
@@ -461,8 +461,8 @@ gme_setup (GstGmeDec * gme)
   gst_segment_init (&seg, GST_FORMAT_TIME);
   gst_pad_push_event (gme->srcpad, gst_event_new_segment (&seg));
 
-  gst_pad_start_task (gme->srcpad, (GstTaskFunction) gst_gme_play, gme->srcpad,
-      NULL);
+  gst_pad_start_task (gme->srcpad, (GstTaskFunction) gst_gme_play,
+      gst_object_ref (gme->srcpad), gst_object_unref);
 
   gme->initialized = TRUE;
   gme->seeking = FALSE;

subprojects/gst-plugins-bad/ext/modplug/gstmodplug.cc

@@ -392,7 +392,7 @@ gst_modplug_do_seek (GstModPlug * modplug, GstEvent * event)
       gst_util_uint64_scale_int (cur, modplug->frequency, GST_SECOND);
 
   gst_pad_start_task (modplug->sinkpad,
-      (GstTaskFunction) gst_modplug_loop, modplug, NULL);
+      (GstTaskFunction) gst_modplug_loop, gst_object_ref (modplug), gst_object_unref);
 
   GST_PAD_STREAM_UNLOCK (modplug->sinkpad);
 
@@ -586,7 +586,7 @@ gst_modplug_sinkpad_activate_mode (GstPad * pad, GstObject * parent,
     case GST_PAD_MODE_PULL:
       if (active) {
         res = gst_pad_start_task (pad, (GstTaskFunction) gst_modplug_loop,
-            modplug, NULL);
+            gst_object_ref (modplug), gst_object_unref);
       } else {
         res = gst_pad_stop_task (pad);
       }

subprojects/gst-plugins-bad/ext/mpeg2enc/gstmpeg2enc.cc

@@ -717,7 +717,7 @@ gst_mpeg2enc_handle_frame (GstVideoEncoder * video_encoder,
   if (!enc->started) {
     GST_DEBUG_OBJECT (video_encoder, "handle_frame: START task");
     gst_pad_start_task (video_encoder->srcpad,
-        (GstTaskFunction) gst_mpeg2enc_loop, enc, NULL);
+        (GstTaskFunction) gst_mpeg2enc_loop, gst_object_ref (enc), gst_object_unref);
     enc->started = TRUE;
   }
 

subprojects/gst-plugins-bad/ext/mplex/gstmplex.cc

@@ -533,8 +533,8 @@ gst_mplex_start_task (GstMplex * mplex)
   if (G_UNLIKELY (mplex->srcresult == GST_FLOW_CUSTOM_SUCCESS)
       && mplex->job->video_tracks == mplex->num_vpads
       && mplex->job->audio_tracks == mplex->num_apads) {
-    gst_pad_start_task (mplex->srcpad, (GstTaskFunction) gst_mplex_loop, mplex,
-        NULL);
+    gst_pad_start_task (mplex->srcpad, (GstTaskFunction) gst_mplex_loop, gst_object_ref (mplex),
+        gst_object_unref);
     mplex->srcresult = GST_FLOW_OK;
   }
 }

subprojects/gst-plugins-bad/ext/musepack/gstmusepackdec.c

@@ -233,7 +233,8 @@ gst_musepackdec_handle_seek_event (GstMusepackDec * dec, GstEvent * event)
   GST_DEBUG_OBJECT (dec, "seek successful");
 
   gst_pad_start_task (dec->sinkpad,
-      (GstTaskFunction) gst_musepackdec_loop, dec->sinkpad, NULL);
+      (GstTaskFunction) gst_musepackdec_loop, gst_object_ref (dec->sinkpad),
+      gst_object_unref);
 
   GST_PAD_STREAM_UNLOCK (dec->sinkpad);
 
@@ -473,7 +474,8 @@ gst_musepackdec_sink_activate_mode (GstPad * sinkpad, GstObject * parent,
     case GST_PAD_MODE_PULL:
       if (active) {
         result = gst_pad_start_task (sinkpad,
-            (GstTaskFunction) gst_musepackdec_loop, sinkpad, NULL);
+            (GstTaskFunction) gst_musepackdec_loop, gst_object_ref (sinkpad),
+            gst_object_unref);
       } else {
         result = gst_pad_stop_task (sinkpad);
       }

subprojects/gst-plugins-bad/ext/openjpeg/gstopenjpegdec.c

@@ -1534,7 +1534,8 @@ gst_openjpeg_dec_decode_frame_multiple (GstVideoDecoder * decoder,
   if (!self->started) {
     GST_DEBUG_OBJECT (self, "Starting task");
     gst_pad_start_task (GST_VIDEO_DECODER_SRC_PAD (self),
-        (GstTaskFunction) gst_openjpeg_dec_loop, decoder, NULL);
+        (GstTaskFunction) gst_openjpeg_dec_loop, gst_object_ref (decoder),
+        gst_object_unref);
     self->started = TRUE;
   }
   /* Make sure to release the base class stream lock, otherwise

subprojects/gst-plugins-bad/ext/resindvd/gstmpegdemux.c

@@ -2136,7 +2136,7 @@ gst_flups_demux_sink_activate_pull (GstPad * sinkpad, GstObject * parent,
     GST_DEBUG ("pull mode activated");
     demux->random_access = TRUE;
     return gst_pad_start_task (sinkpad, (GstTaskFunction) gst_flups_demux_loop,
-        sinkpad, NULL);
+        gst_object_ref (sinkpad), gst_object_unref);
   } else {
     demux->random_access = FALSE;
     return gst_pad_stop_task (sinkpad);

subprojects/gst-plugins-bad/ext/sctp/gstsctpdec.c

@@ -406,7 +406,8 @@ flush_srcpad (const GValue * item, gpointer user_data)
   } else {
     gst_data_queue_set_flushing (sctpdec_pad->packet_queue, FALSE);
     gst_pad_start_task (GST_PAD (sctpdec_pad),
-        (GstTaskFunction) gst_sctp_data_srcpad_loop, sctpdec_pad, NULL);
+        (GstTaskFunction) gst_sctp_data_srcpad_loop,
+        gst_object_ref (sctpdec_pad), gst_object_unref);
   }
 }
 
@@ -552,8 +553,8 @@ gst_sctp_dec_src_event (GstPad * pad, GstSctpDec * self, GstEvent * event)
 
       /* Unflush and start task again */
       gst_data_queue_set_flushing (sctpdec_pad->packet_queue, FALSE);
-      gst_pad_start_task (pad, (GstTaskFunction) gst_sctp_data_srcpad_loop, pad,
-          NULL);
+      gst_pad_start_task (pad, (GstTaskFunction) gst_sctp_data_srcpad_loop,
+          gst_object_ref (pad), gst_object_unref);
 
       return gst_pad_event_default (pad, GST_OBJECT (self), event);
     }
@@ -634,7 +635,7 @@ get_pad_for_stream_id (GstSctpDec * self, guint16 stream_id)
   GST_OBJECT_UNLOCK (self);
 
   gst_pad_start_task (new_pad, (GstTaskFunction) gst_sctp_data_srcpad_loop,
-      new_pad, NULL);
+      gst_object_ref (new_pad), gst_object_unref);
 
   gst_object_ref (new_pad);
 

subprojects/gst-plugins-bad/ext/sctp/gstsctpenc.c

@@ -397,7 +397,8 @@ gst_sctp_enc_change_state (GstElement * element, GstStateChange transition)
     case GST_STATE_CHANGE_READY_TO_PAUSED:
       if (ret != GST_STATE_CHANGE_FAILURE)
         gst_pad_start_task (self->src_pad,
-            (GstTaskFunction) gst_sctp_enc_srcpad_loop, self->src_pad, NULL);
+            (GstTaskFunction) gst_sctp_enc_srcpad_loop,
+            gst_object_ref (self->src_pad), gst_object_unref);
       break;
     case GST_STATE_CHANGE_PLAYING_TO_PAUSED:
       break;
@@ -820,7 +821,8 @@ gst_sctp_enc_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
       self->src_ret = GST_FLOW_OK;
       GST_OBJECT_UNLOCK (self);
       gst_pad_start_task (self->src_pad,
-          (GstTaskFunction) gst_sctp_enc_srcpad_loop, self->src_pad, NULL);
+          (GstTaskFunction) gst_sctp_enc_srcpad_loop,
+          gst_object_ref (self->src_pad), gst_object_unref);
 
       ret = gst_pad_event_default (pad, parent, event);
       break;

subprojects/gst-plugins-bad/ext/sndfile/gstsfdec.c

@@ -260,7 +260,8 @@ gst_sf_dec_do_seek (GstSFDec * self, GstEvent * event)
   gst_pad_push_event (self->srcpad, gst_event_new_segment (&seg));
 
   gst_pad_start_task (self->sinkpad,
-      (GstTaskFunction) gst_sf_dec_loop, self, NULL);
+      (GstTaskFunction) gst_sf_dec_loop, gst_object_ref (self),
+      gst_object_unref);
 
   GST_PAD_STREAM_UNLOCK (self->sinkpad);
 
@@ -459,7 +460,7 @@ gst_sf_dec_sink_activate_mode (GstPad * sinkpad, GstObject * parent,
         /* if we have a scheduler we can start the task */
         GST_DEBUG_OBJECT (sinkpad, "start task");
         res = gst_pad_start_task (sinkpad, (GstTaskFunction) gst_sf_dec_loop,
-            sinkpad, NULL);
+            gst_object_ref (sinkpad), gst_object_unref);
       } else {
         res = gst_pad_stop_task (sinkpad);
       }

subprojects/gst-plugins-bad/ext/sndfile/gstsfsink.c

@@ -455,7 +455,8 @@ gst_sf_sink_activate_pull (GstBaseSink * basesink, gboolean active)
   if (active) {
     /* start task */
     result = gst_pad_start_task (basesink->sinkpad,
-        (GstTaskFunction) gst_sf_sink_loop, basesink->sinkpad, NULL);
+        (GstTaskFunction) gst_sf_sink_loop, gst_object_ref (basesink->sinkpad),
+        gst_object_unref);
   } else {
     /* step 2, make sure streaming finishes */
     result = gst_pad_stop_task (basesink->sinkpad);

subprojects/gst-plugins-bad/gst-libs/gst/audio/gstnonstreamaudiodecoder.c

@@ -1486,8 +1486,8 @@ static gboolean
 gst_nonstream_audio_decoder_start_task (GstNonstreamAudioDecoder * dec)
 {
   if (!gst_pad_start_task (dec->srcpad,
-          (GstTaskFunction) gst_nonstream_audio_decoder_output_task, dec,
-          NULL)) {
+          (GstTaskFunction) gst_nonstream_audio_decoder_output_task,
+          gst_object_ref (dec), gst_object_unref)) {
     GST_ERROR_OBJECT (dec, "could not start decoder output task");
     return FALSE;
   } else

subprojects/gst-plugins-bad/gst-libs/gst/mse/gstmsesrc.c

@@ -834,7 +834,8 @@ resume_all_streams (GstMseSrc * self)
     GstPad *pad = GST_PAD (stream->pad);
     if (active) {
       clear_flushing (GST_MSE_SRC_PAD (pad));
-      gst_pad_start_task (pad, (GstTaskFunction) pad_task, pad, NULL);
+      gst_pad_start_task (pad, (GstTaskFunction) pad_task, gst_object_ref (pad),
+          gst_object_unref);
     }
   }
 }
@@ -1111,7 +1112,8 @@ pad_activate_mode (GstMseSrcPad * pad, GstObject * parent, GstPadMode mode,
   }
 
   if (active) {
-    gst_pad_start_task (GST_PAD (pad), (GstTaskFunction) pad_task, pad, NULL);
+    gst_pad_start_task (GST_PAD (pad), (GstTaskFunction) pad_task,
+        gst_object_ref (pad), gst_object_unref);
   } else {
     set_flushing_and_signal (pad);
     gst_media_source_track_flush (pad->track);

subprojects/gst-plugins-bad/gst/aiff/aiffparse.c

@@ -526,7 +526,7 @@ gst_aiff_parse_perform_seek (GstAiffParse * aiff, GstEvent * event,
     aiff->segment_running = TRUE;
     if (!aiff->streaming) {
       gst_pad_start_task (aiff->sinkpad, (GstTaskFunction) gst_aiff_parse_loop,
-          aiff->sinkpad, NULL);
+          gst_object_ref (aiff->sinkpad), gst_object_unref);
     }
 
     GST_PAD_STREAM_UNLOCK (aiff->sinkpad);
@@ -1821,7 +1821,7 @@ gst_aiff_parse_sink_activate_mode (GstPad * sinkpad, GstObject * parent,
         aiff->segment_running = TRUE;
         res =
             gst_pad_start_task (sinkpad, (GstTaskFunction) gst_aiff_parse_loop,
-            sinkpad, NULL);
+            gst_object_ref (sinkpad), gst_object_unref);
       } else {
         aiff->segment_running = FALSE;
         res = gst_pad_stop_task (sinkpad);

subprojects/gst-plugins-bad/gst/closedcaption/gstccconverter.c

@@ -1566,14 +1566,20 @@ can_generate_output (GstCCConverter * self)
 
   /* compute the relative frame count for each */
   if (!gst_util_fraction_multiply (self->in_fps_d, self->in_fps_n,
-          self->input_frames, 1, &input_frame_n, &input_frame_d))
-    /* we should never overflow */
-    g_assert_not_reached ();
+          self->input_frames, 1, &input_frame_n, &input_frame_d)) {
+    GST_ERROR_OBJECT (self,
+        "Couldn't get input rate, fps: %d/%d, input frames %d",
+        self->in_fps_n, self->in_fps_d, self->input_frames);
+    return FALSE;
+  }
 
   if (!gst_util_fraction_multiply (self->out_fps_d, self->out_fps_n,
-          self->output_frames, 1, &output_frame_n, &output_frame_d))
-    /* we should never overflow */
-    g_assert_not_reached ();
+          self->output_frames, 1, &output_frame_n, &output_frame_d)) {
+    GST_ERROR_OBJECT (self,
+        "Couldn't get output rate, fps: %d/%d, output frames %d",
+        self->out_fps_n, self->out_fps_d, self->output_frames);
+    return FALSE;
+  }
 
   output_time_cmp = gst_util_fraction_compare (input_frame_n, input_frame_d,
       output_frame_n, output_frame_d);