* Copyright 2019 Philippe Proulx <pproulx@efficios.com>
*/
+#include <glib.h>
+#include <stdio.h>
+
+#include <babeltrace2/babeltrace.h>
+
#define BT_COMP_LOG_SELF_COMP (stream->trace->fs_sink->self_comp)
#define BT_LOG_OUTPUT_LEVEL (stream->log_level)
#define BT_LOG_TAG "PLUGIN/SINK.CTF.FS/STREAM"
#include "logging/comp-logging.h"
-#include <babeltrace2/babeltrace.h>
-#include <stdio.h>
-#include <stdbool.h>
-#include <glib.h>
#include "common/assert.h"
-#include "ctfser/ctfser.h"
#include "compat/endian.h"
+#include "ctfser/ctfser.h"
-#include "fs-sink.hpp"
-#include "fs-sink-trace.hpp"
#include "fs-sink-stream.hpp"
+#include "fs-sink-trace.hpp"
+#include "fs-sink.hpp"
#include "translate-trace-ir-to-ctf-ir.hpp"
-BT_HIDDEN
void fs_sink_stream_destroy(struct fs_sink_stream *stream)
{
if (!stream) {
stream->file_name = make_unique_stream_file_name(stream->trace, base_name);
}
-BT_HIDDEN
struct fs_sink_stream *fs_sink_stream_create(struct fs_sink_trace *trace,
const bt_stream *ir_stream)
{
return ret;
}
-static inline int write_string_field(struct fs_sink_stream *stream,
- struct fs_sink_ctf_field_class_string *fc,
- const bt_field *field)
+static inline int write_string_field(struct fs_sink_stream *stream, const bt_field *field)
{
return bt_ctfser_write_string(&stream->ctfser, bt_field_string_get_value(field));
}
ret = write_float_field(stream, fs_sink_ctf_field_class_as_float(fc), field);
break;
case FS_SINK_CTF_FIELD_CLASS_TYPE_STRING:
- ret = write_string_field(stream, fs_sink_ctf_field_class_as_string(fc), field);
+ ret = write_string_field(stream, field);
break;
case FS_SINK_CTF_FIELD_CLASS_TYPE_STRUCT:
ret = write_struct_field(stream, fs_sink_ctf_field_class_as_struct(fc), field, true);
return ret;
}
-BT_HIDDEN
int fs_sink_stream_write_event(struct fs_sink_stream *stream, const bt_clock_snapshot *cs,
const bt_event *event, struct fs_sink_ctf_event_class *ec)
{
return ret;
}
-BT_HIDDEN
int fs_sink_stream_open_packet(struct fs_sink_stream *stream, const bt_clock_snapshot *cs,
const bt_packet *packet)
{
return ret;
}
-BT_HIDDEN
int fs_sink_stream_close_packet(struct fs_sink_stream *stream, const bt_clock_snapshot *cs)
{
int ret;