MpegTSBaseClass *klass = GST_MPEGTS_BASE_GET_CLASS (base);
/* Call implementation */
- if (G_UNLIKELY (klass->flush == NULL))
- GST_WARNING_OBJECT (base, "Class doesn't have a 'flush' implementation !");
- else
+ if (klass->flush)
klass->flush (base, hard);
}
base->queried_latency = TRUE;
}
-static inline GstFlowReturn
-mpegts_base_push (MpegTSBase * base, MpegTSPacketizerPacket * packet,
- MpegTSPacketizerSection * section)
-{
- MpegTSBaseClass *klass = GST_MPEGTS_BASE_GET_CLASS (base);
-
- /* Call implementation */
- if (G_UNLIKELY (klass->push == NULL)) {
- GST_ERROR_OBJECT (base, "Class doesn't have a 'push' implementation !");
- return GST_FLOW_ERROR;
- }
-
- return klass->push (base, packet, section);
-}
-
static GstFlowReturn
mpegts_base_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
{
}
}
/* we need to push section packet downstream */
- res = mpegts_base_push (base, &packet, §ion);
+ res = klass->push (base, &packet, §ion);
} else if (MPEGTS_BIT_IS_SET (base->is_pes, packet.pid)) {
/* push the packet downstream */
- res = mpegts_base_push (base, &packet, NULL);
+ res = klass->push (base, &packet, NULL);
}
next: