mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-20 13:06:23 +00:00
Code Issues 1 Projects Releases Wiki Activity

filesink: Use SYNC_AFTER flag in seeking test

Browse source 
Otherwise it's not guaranteed that buffers are actually on disk after
pushing them, and reading the file via g_file_get_contents() might not
include them yet.
This commit is contained in:
Sebastian Dröge 2018-08-17 17:24:59 +03:00
parent 035045c981
commit 3ee4896bef
1 changed files with 15 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
tests/check/elements/filesink.c
View file

@ -31,6 +31,7 @@
#include <gst/check/gstcheck.h>
static GstPad *mysrcpad;
static gboolean sync_buffers = FALSE;
static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src",
GST_PAD_SRC,
@ -83,6 +84,8 @@ cleanup_filesink (GstElement * filesink)
GRand *rand = g_rand_new_with_seed (num_bytes); \
GstMapInfo info; \
guint i; \
if (sync_buffers) \
GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_SYNC_AFTER); \
fail_unless (gst_buffer_map (buf, &info, GST_MAP_WRITE)); \
for (i = 0; i < num_bytes; ++i) \
((guint8 *)info.data)[i] = (g_rand_int (rand) >> 24) & 0xff; \
@ -96,6 +99,8 @@ cleanup_filesink (GstElement * filesink)
G_STMT_START { \
GstBuffer *buf = gst_buffer_new(); \
guint i; \
if (sync_buffers) \
GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_SYNC_AFTER); \
for (i = 0; i < num_mem_blocks; ++i){ \
GstMapInfo info; \
GstMemory* mem_block = gst_allocator_alloc(NULL,num_bytes,NULL); \
@ -120,6 +125,8 @@ cleanup_filesink (GstElement * filesink)
for(i = 0; i < num_buffers; ++i){ \
GstBuffer *buf = gst_buffer_new(); \
guint j; \
if (sync_buffers) \
GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_SYNC_AFTER); \
for (j = 0; j < num_mem_blocks; ++j){ \
GstMapInfo info; \
GstMemory* mem_block = gst_allocator_alloc(NULL,num_bytes,NULL); \
@ -150,6 +157,8 @@ cleanup_filesink (GstElement * filesink)
GRand *rand = g_rand_new_with_seed (num_bytes); \
GstMapInfo info; \
guint j; \
if (sync_buffers) \
GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_SYNC_AFTER); \
fail_unless (gst_buffer_map (buf, &info, GST_MAP_WRITE)); \
for (j = 0; j < num_bytes; ++j) \
((guint8 *)info.data)[j] = (g_rand_int (rand) >> 24) & 0xff; \
@ -220,6 +229,8 @@ GST_START_TEST (test_seeking)
return;
filesink = setup_filesink ();
sync_buffers = TRUE;
GST_LOG ("using temp file '%s'", tmp_fn);
g_object_set (filesink, "location", tmp_fn, NULL);
@ -309,6 +320,8 @@ GST_START_TEST (test_seeking)
CHECK_WRITTEN_BYTES (8801, 9256, 18057);
sync_buffers = FALSE;
/* remove file */
g_remove (tmp_fn);
g_free (tmp_fn);
@ -327,6 +340,8 @@ GST_START_TEST (test_flush)
return;
filesink = setup_filesink ();
sync_buffers = FALSE;
GST_LOG ("using temp file '%s'", tmp_fn);
g_object_set (filesink, "location", tmp_fn, NULL);