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

multifilesink: write stream-headers when switching to the next file in max-size mode

Browse Source
This commit is contained in:
Tim-Philipp Müller 2011-09-23 18:43:35 +01:00
parent bced3c218a
commit 82ac47f33f
1 changed files with 30 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
gst/multifile/gstmultifilesink.c
View File

@ -475,6 +475,34 @@ gst_multi_file_sink_post_message (GstMultiFileSink * multifilesink,
offset, offset_end, running_time, stream_time, filename); offset, offset_end, running_time, stream_time, filename);
} }
static gboolean
gst_multi_file_sink_write_stream_headers (GstMultiFileSink * sink)
{
int i;
if (sink->streamheaders == NULL)
return TRUE;
/* we want to write these at the beginning */
g_assert (sink->cur_file_size == 0);
for (i = 0; i < sink->n_streamheaders; i++) {
GstBuffer *hdr;
int ret;
hdr = sink->streamheaders[i];
ret = fwrite (GST_BUFFER_DATA (hdr), GST_BUFFER_SIZE (hdr), 1, sink->file);
if (ret != 1)
return FALSE;
sink->cur_file_size += GST_BUFFER_SIZE (hdr);
}
return TRUE;
}
static GstFlowReturn static GstFlowReturn
gst_multi_file_sink_render (GstBaseSink * sink, GstBuffer * buffer) gst_multi_file_sink_render (GstBaseSink * sink, GstBuffer * buffer)
{ {
@ -542,20 +570,10 @@ gst_multi_file_sink_render (GstBaseSink * sink, GstBuffer * buffer)
} }
if (multifilesink->file == NULL) { if (multifilesink->file == NULL) {
int i;
if (!gst_multi_file_sink_open_next_file (multifilesink)) if (!gst_multi_file_sink_open_next_file (multifilesink))
goto stdio_write_error; goto stdio_write_error;
if (multifilesink->streamheaders) { gst_multi_file_sink_write_stream_headers (multifilesink);
for (i = 0; i < multifilesink->n_streamheaders; i++) {
ret = fwrite (GST_BUFFER_DATA (multifilesink->streamheaders[i]),
GST_BUFFER_SIZE (multifilesink->streamheaders[i]), 1,
multifilesink->file);
if (ret != 1)
goto stdio_write_error;
}
}
} }
ret = fwrite (GST_BUFFER_DATA (buffer), GST_BUFFER_SIZE (buffer), 1, ret = fwrite (GST_BUFFER_DATA (buffer), GST_BUFFER_SIZE (buffer), 1,
@ -595,7 +613,7 @@ gst_multi_file_sink_render (GstBaseSink * sink, GstBuffer * buffer)
if (!gst_multi_file_sink_open_next_file (multifilesink)) if (!gst_multi_file_sink_open_next_file (multifilesink))
goto stdio_write_error; goto stdio_write_error;
/* FIXME: write stream headers if present */ gst_multi_file_sink_write_stream_headers (multifilesink);
} }
ret = fwrite (GST_BUFFER_DATA (buffer), GST_BUFFER_SIZE (buffer), 1, ret = fwrite (GST_BUFFER_DATA (buffer), GST_BUFFER_SIZE (buffer), 1,