From 2e4636e16ecf36fd6f96f16d545fa43336f054af Mon Sep 17 00:00:00 2001 From: Julien Desfossez Date: Mon, 5 Jun 2017 17:11:38 -0400 Subject: [PATCH] fs-sink: flush open packets on destroy MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Signed-off-by: Julien Desfossez Signed-off-by: Jérémie Galarneau --- plugins/ctf/fs-sink/write.c | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/plugins/ctf/fs-sink/write.c b/plugins/ctf/fs-sink/write.c index d8131d31..b945f519 100644 --- a/plugins/ctf/fs-sink/write.c +++ b/plugins/ctf/fs-sink/write.c @@ -58,6 +58,15 @@ gboolean empty_ht(gpointer key, gpointer value, gpointer user_data) return TRUE; } +gboolean empty_streams_ht(gpointer key, gpointer value, gpointer user_data) +{ + struct bt_ctf_stream *writer_stream = value; + + bt_ctf_stream_flush(writer_stream); + + return TRUE; +} + void destroy_stream_state_key(gpointer key) { g_free((enum fs_writer_stream_state *) key); @@ -503,7 +512,7 @@ void writer_close(struct writer_component *writer_component, /* Empty the stream HT. */ g_hash_table_foreach_remove(fs_writer->stream_map, - empty_ht, NULL); + empty_streams_ht, NULL); g_hash_table_destroy(fs_writer->stream_map); /* Empty the stream state HT. */ -- 2.34.1