FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

matroskamux: handle GstForceKeyUnit event

Browse Source 
... by starting a new cluster after forwarding event.

Fixes #644154.
This commit is contained in:
Andoni Morales Alastruey 2011-03-15 11:03:53 +01:00 committed by Mark Nauwelaerts
parent 8f1f6d1a57
commit 782fc78d57
2 changed files with 26 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
gst/matroska/matroska-mux.c
View File

@ -391,6 +391,8 @@ gst_matroska_mux_finalize (GObject * object)
{ {
GstMatroskaMux *mux = GST_MATROSKA_MUX (object); GstMatroskaMux *mux = GST_MATROSKA_MUX (object);
gst_event_replace (&mux->force_key_unit_event, NULL);
gst_object_unref (mux->collect); gst_object_unref (mux->collect);
gst_object_unref (mux->ebml_write); gst_object_unref (mux->ebml_write);
if (mux->writing_app) if (mux->writing_app)
@ -662,6 +664,17 @@ gst_matroska_mux_handle_sink_event (GstPad * pad, GstEvent * event)
gst_event_unref (event); gst_event_unref (event);
event = NULL; event = NULL;
break; break;
case GST_EVENT_CUSTOM_DOWNSTREAM:{
const GstStructure *structure;
structure = gst_event_get_structure (event);
if (gst_structure_has_name (structure, "GstForceKeyUnit")) {
gst_event_replace (&mux->force_key_unit_event, NULL);
mux->force_key_unit_event = event;
event = NULL;
}
break;
}
default: default:
break; break;
} }
@ -2692,13 +2705,20 @@ gst_matroska_mux_write_data (GstMatroskaMux * mux, GstMatroskaPad * collect_pad)
} }
if (mux->cluster) { if (mux->cluster) {
/* start a new cluster at every keyframe or when we may be reaching the /* start a new cluster at every keyframe, at every GstForceKeyUnit event,
* limit of the relative timestamp */ * or when we may be reaching the limit of the relative timestamp */
if (mux->cluster_time + if (mux->cluster_time +
mux->max_cluster_duration < GST_BUFFER_TIMESTAMP (buf) mux->max_cluster_duration < GST_BUFFER_TIMESTAMP (buf)
|| is_video_keyframe) { || is_video_keyframe || mux->force_key_unit_event) {
if (!mux->streamable) if (!mux->streamable)
gst_ebml_write_master_finish (ebml, mux->cluster); gst_ebml_write_master_finish (ebml, mux->cluster);
/* Forward the GstForceKeyUnit event after finishing the cluster */
if (mux->force_key_unit_event) {
gst_pad_push_event (mux->srcpad, mux->force_key_unit_event);
mux->force_key_unit_event = NULL;
}
mux->prev_cluster_size = ebml->pos - mux->cluster_pos; mux->prev_cluster_size = ebml->pos - mux->cluster_pos;
mux->cluster_pos = ebml->pos; mux->cluster_pos = ebml->pos;
gst_ebml_write_set_cache (ebml, 0x20); gst_ebml_write_set_cache (ebml, 0x20);

3
gst/matroska/matroska-mux.h
View File

@ -126,6 +126,9 @@ typedef struct _GstMatroskaMux {
cluster_pos, cluster_pos,
prev_cluster_size; prev_cluster_size;
/* GstForceKeyUnit event */
GstEvent *force_key_unit_event;
} GstMatroskaMux; } GstMatroskaMux;
typedef struct _GstMatroskaMuxClass { typedef struct _GstMatroskaMuxClass {