static
gboolean empty_streams_ht(gpointer key, gpointer value, gpointer user_data)
{
+ int ret;
struct bt_ctf_stream *writer_stream = value;
- bt_ctf_stream_flush(writer_stream);
-
+ ret = bt_ctf_stream_flush(writer_stream);
+ if (ret) {
+ BT_LOGD_STR("Failed to flush stream while emptying hash table.");
+ }
return TRUE;
}
}
- snprintf(trace_path, PATH_MAX, "%s/%s",
+ snprintf(trace_path, PATH_MAX, "%s" G_DIR_SEPARATOR_S "%s",
writer_component->base_path->str,
trace_name);
/*
int i = 0;
do {
- snprintf(trace_path, PATH_MAX, "%s/%s-%d",
+ snprintf(trace_path, PATH_MAX, "%s" G_DIR_SEPARATOR_S "%s-%d",
writer_component->base_path->str,
trace_name, ++i);
} while (g_file_test(trace_path, G_FILE_TEST_EXISTS) && i < INT_MAX);
fs_writer->static_listener_id = -1;
} else {
ret = bt_ctf_trace_add_is_static_listener(trace,
- trace_is_static_listener, fs_writer);
+ trace_is_static_listener, NULL, fs_writer);
assert(ret >= 0);
fs_writer->static_listener_id = ret;
}