#include "ctfcopytrace.h"
#include "clock-fields.h"
+BT_HIDDEN
struct bt_ctf_clock_class *ctf_copy_clock_class(FILE *err,
struct bt_ctf_clock_class *clock_class)
{
}
description = bt_ctf_clock_class_get_description(clock_class);
- if (!description) {
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto end_destroy;
- }
-
- int_ret = bt_ctf_clock_class_set_description(writer_clock_class,
- description);
- if (int_ret != 0) {
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto end_destroy;
+ if (description) {
+ int_ret = bt_ctf_clock_class_set_description(writer_clock_class,
+ description);
+ if (int_ret != 0) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
+ __LINE__);
+ goto end_destroy;
+ }
}
u64_ret = bt_ctf_clock_class_get_frequency(clock_class);
goto end_destroy;
}
- int_ret = bt_ctf_clock_class_get_is_absolute(clock_class);
+ int_ret = bt_ctf_clock_class_is_absolute(clock_class);
if (int_ret == -1) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
return writer_clock_class;
}
+BT_HIDDEN
enum bt_component_status ctf_copy_clock_classes(FILE *err,
struct bt_ctf_trace *writer_trace,
struct bt_ctf_stream_class *writer_stream_class,
for (i = 0; i < clock_class_count; i++) {
struct bt_ctf_clock_class *writer_clock_class;
struct bt_ctf_clock_class *clock_class =
- bt_ctf_trace_get_clock_class(trace, i);
+ bt_ctf_trace_get_clock_class_by_index(trace, i);
if (!clock_class) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
return ret;
}
+BT_HIDDEN
struct bt_ctf_event_class *ctf_copy_event_class(FILE *err,
struct bt_ctf_event_class *event_class)
{
struct bt_ctf_event_class *writer_event_class = NULL;
+ struct bt_ctf_field_type *context, *payload_type;
const char *name;
- int count, i;
+ int ret;
+ int64_t id;
+ enum bt_ctf_event_class_log_level log_level;
+ const char *emf_uri;
name = bt_ctf_event_class_get_name(event_class);
if (!name) {
goto end;
}
- count = bt_ctf_event_class_get_attribute_count(event_class);
- for (i = 0; i < count; i++) {
- const char *attr_name;
- struct bt_value *attr_value;
- int ret;
+ id = bt_ctf_event_class_get_id(event_class);
+ if (id < 0) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__,
+ __FILE__, __LINE__);
+ goto error;
+ }
- attr_name = bt_ctf_event_class_get_attribute_name(event_class, i);
- if (!attr_name) {
- fprintf(err, "[error] %s in %s:%d\n", __func__,
- __FILE__, __LINE__);
- goto error;
- }
- attr_value = bt_ctf_event_class_get_attribute_value(event_class, i);
- if (!attr_value) {
+ ret = bt_ctf_event_class_set_id(writer_event_class, id);
+ if (ret) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__,
+ __FILE__, __LINE__);
+ goto error;
+ }
+
+ log_level = bt_ctf_event_class_get_log_level(event_class);
+ if (log_level < 0) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__,
+ __FILE__, __LINE__);
+ goto error;
+ }
+
+ ret = bt_ctf_event_class_set_log_level(writer_event_class, log_level);
+ if (ret) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__,
+ __FILE__, __LINE__);
+ goto error;
+ }
+
+ emf_uri = bt_ctf_event_class_get_emf_uri(event_class);
+ if (emf_uri) {
+ ret = bt_ctf_event_class_set_emf_uri(writer_event_class,
+ emf_uri);
+ if (ret) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
goto error;
}
+ }
- ret = bt_ctf_event_class_set_attribute(writer_event_class,
- attr_name, attr_value);
- BT_PUT(attr_value);
+ payload_type = bt_ctf_event_class_get_payload_type(event_class);
+ if (payload_type) {
+ ret = bt_ctf_event_class_set_payload_type(writer_event_class,
+ payload_type);
if (ret < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
goto error;
}
+ BT_PUT(payload_type);
}
- count = bt_ctf_event_class_get_field_count(event_class);
- for (i = 0; i < count; i++) {
- const char *field_name;
- struct bt_ctf_field_type *field_type;
- int ret;
-
- ret = bt_ctf_event_class_get_field(event_class, &field_name,
- &field_type, i);
- if (ret < 0) {
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__, __LINE__);
- goto error;
- }
-
- ret = bt_ctf_event_class_add_field(writer_event_class, field_type,
- field_name);
- BT_PUT(field_type);
+ context = bt_ctf_event_class_get_context_type(event_class);
+ if (context) {
+ ret = bt_ctf_event_class_set_context_type(
+ writer_event_class, context);
+ BT_PUT(context);
if (ret < 0) {
- fprintf(err, "[error] Cannot add field %s\n", field_name);
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__, __LINE__);
+ fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
+ __LINE__);
goto error;
}
}
return writer_event_class;
}
+BT_HIDDEN
enum bt_component_status ctf_copy_event_classes(FILE *err,
struct bt_ctf_stream_class *stream_class,
struct bt_ctf_stream_class *writer_stream_class)
}
for (i = 0; i < count; i++) {
- struct bt_ctf_field_type *context;
int int_ret;
- event_class = bt_ctf_stream_class_get_event_class(
+ event_class = bt_ctf_stream_class_get_event_class_by_index(
stream_class, i);
if (!event_class) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
ret = BT_COMPONENT_STATUS_ERROR;
goto error;
}
- writer_event_class = ctf_copy_event_class(err, event_class);
- if (!writer_event_class) {
- fprintf(err, "[error] %s in %s:%d\n", __func__,
- __FILE__, __LINE__);
- ret = BT_COMPONENT_STATUS_ERROR;
- goto error;
+ if (i < bt_ctf_stream_class_get_event_class_count(writer_stream_class)) {
+ writer_event_class = bt_ctf_stream_class_get_event_class_by_index(
+ writer_stream_class, i);
+ if (writer_event_class) {
+ /*
+ * If the writer_event_class already exists,
+ * just skip it. It can be used to resync the
+ * event_classes after a trace has become
+ * static.
+ */
+ BT_PUT(writer_event_class);
+ BT_PUT(event_class);
+ continue;
+ }
}
- context = bt_ctf_event_class_get_context_type(event_class);
- if (!context) {
+ writer_event_class = ctf_copy_event_class(err, event_class);
+ if (!writer_event_class) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
ret = BT_COMPONENT_STATUS_ERROR;
goto error;
}
- ret = bt_ctf_event_class_set_context_type(writer_event_class, context);
- BT_PUT(context);
- if (ret < 0) {
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto error;
- }
int_ret = bt_ctf_stream_class_add_event_class(writer_stream_class,
writer_event_class);
return ret;
}
+BT_HIDDEN
struct bt_ctf_stream_class *ctf_copy_stream_class(FILE *err,
struct bt_ctf_stream_class *stream_class,
struct bt_ctf_trace *writer_trace,
name = NULL;
}
- writer_stream_class = bt_ctf_stream_class_create(name);
+ writer_stream_class = bt_ctf_stream_class_create_empty(name);
if (!writer_stream_class) {
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
}
type = bt_ctf_stream_class_get_packet_context_type(stream_class);
- if (!type) {
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto error;
- }
-
- ret_int = bt_ctf_stream_class_set_packet_context_type(
- writer_stream_class, type);
- if (ret_int < 0) {
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto error;
+ if (type) {
+ ret_int = bt_ctf_stream_class_set_packet_context_type(
+ writer_stream_class, type);
+ if (ret_int < 0) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__,
+ __FILE__, __LINE__);
+ goto error;
+ }
+ BT_PUT(type);
}
- BT_PUT(type);
type = bt_ctf_stream_class_get_event_header_type(stream_class);
if (!type) {
return writer_stream_class;
}
+BT_HIDDEN
enum bt_component_status ctf_copy_packet_context_field(FILE *err,
struct bt_ctf_field *field, const char *field_name,
struct bt_ctf_field *writer_packet_context,
}
BT_PUT(field_type);
- writer_field = bt_ctf_field_structure_get_field(writer_packet_context,
- field_name);
+ writer_field = bt_ctf_field_structure_get_field_by_name(
+ writer_packet_context, field_name);
if (!writer_field) {
ret = BT_COMPONENT_STATUS_ERROR;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
return ret;
}
+BT_HIDDEN
struct bt_ctf_field *ctf_copy_packet_context(FILE *err,
struct bt_ctf_packet *packet,
struct bt_ctf_stream *writer_stream)
struct bt_ctf_field_type *struct_type = NULL, *writer_packet_context_type = NULL;
struct bt_ctf_stream_class *writer_stream_class = NULL;
struct bt_ctf_field *field = NULL;
- struct bt_ctf_field_type *field_type;
+ struct bt_ctf_field_type *field_type = NULL;
int nr_fields, i;
packet_context = bt_ctf_packet_get_context(packet);
if (!packet_context) {
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto error;
+ goto end;
}
writer_stream_class = bt_ctf_stream_get_class(writer_stream);
__FILE__, __LINE__);
goto error;
}
- if (bt_ctf_field_type_structure_get_field(struct_type,
+ if (bt_ctf_field_type_structure_get_field_by_index(struct_type,
&field_name, &field_type, i) < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
goto error;
}
- if (!strncmp(field_name, "content_size", strlen("content_size")) ||
- !strncmp(field_name, "packet_size",
- strlen("packet_size"))) {
- BT_PUT(field_type);
- BT_PUT(field);
- continue;
- }
if (bt_ctf_field_type_get_type_id(field_type) != BT_CTF_FIELD_TYPE_ID_INTEGER) {
fprintf(err, "[error] Unexpected packet context field type\n");
return writer_packet_context;
}
+BT_HIDDEN
int ctf_copy_event_header(FILE *err, struct bt_ctf_event *event,
struct bt_ctf_event_class *writer_event_class,
struct bt_ctf_event *writer_event,
return ret;
}
+BT_HIDDEN
struct bt_ctf_event *ctf_copy_event(FILE *err, struct bt_ctf_event *event,
struct bt_ctf_event_class *writer_event_class,
bool override_ts64)
/* Optional field, so it can fail silently. */
field = bt_ctf_event_get_stream_event_context(event);
- copy_field = bt_ctf_field_copy(field);
- if (copy_field) {
+ if (field) {
+ copy_field = bt_ctf_field_copy(field);
+ if (!copy_field) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__,
+ __FILE__, __LINE__);
+ goto error;
+ }
ret = bt_ctf_event_set_stream_event_context(writer_event,
copy_field);
if (ret < 0) {
__FILE__, __LINE__);
goto error;
}
+ BT_PUT(field);
+ BT_PUT(copy_field);
}
- BT_PUT(field);
- BT_PUT(copy_field);
/* Optional field, so it can fail silently. */
field = bt_ctf_event_get_event_context(event);
- copy_field = bt_ctf_field_copy(field);
- if (copy_field) {
+ if (field) {
+ copy_field = bt_ctf_field_copy(field);
+ if (!copy_field) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__,
+ __FILE__, __LINE__);
+ goto error;
+ }
ret = bt_ctf_event_set_event_context(writer_event, copy_field);
if (ret < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
goto error;
}
+ BT_PUT(field);
+ BT_PUT(copy_field);
}
- BT_PUT(field);
- BT_PUT(copy_field);
- field = bt_ctf_event_get_payload_field(event);
- if (!field) {
- fprintf(err, "[error] %s in %s:%d\n", __func__,
- __FILE__, __LINE__);
- goto error;
- }
- copy_field = bt_ctf_field_copy(field);
- if (copy_field) {
- ret = bt_ctf_event_set_payload_field(writer_event, copy_field);
+ field = bt_ctf_event_get_event_payload(event);
+ if (field) {
+ copy_field = bt_ctf_field_copy(field);
+ if (!copy_field) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__,
+ __FILE__, __LINE__);
+ goto error;
+ }
+ ret = bt_ctf_event_set_event_payload(writer_event, copy_field);
if (ret < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
goto error;
}
+ BT_PUT(field);
+ BT_PUT(copy_field);
}
- BT_PUT(field);
- BT_PUT(copy_field);
goto end;
return writer_event;
}
+BT_HIDDEN
enum bt_component_status ctf_copy_trace(FILE *err, struct bt_ctf_trace *trace,
struct bt_ctf_trace *writer_trace)
{
enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
int field_count, i, int_ret;
struct bt_ctf_field_type *header_type = NULL;
+ enum bt_ctf_byte_order order;
+ const char *trace_name;
field_count = bt_ctf_trace_get_environment_field_count(trace);
for (i = 0; i < field_count; i++) {
const char *name;
struct bt_value *value = NULL;
- name = bt_ctf_trace_get_environment_field_name(trace, i);
+ name = bt_ctf_trace_get_environment_field_name_by_index(
+ trace, i);
if (!name) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
ret = BT_COMPONENT_STATUS_ERROR;
goto end;
}
- value = bt_ctf_trace_get_environment_field_value(trace, i);
+ value = bt_ctf_trace_get_environment_field_value_by_index(
+ trace, i);
if (!value) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
}
}
- header_type = bt_ctf_trace_get_packet_header_type(writer_trace);
- if (!header_type) {
+ order = bt_ctf_trace_get_native_byte_order(trace);
+ if (order == BT_CTF_BYTE_ORDER_UNKNOWN) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__, __LINE__);
ret = BT_COMPONENT_STATUS_ERROR;
goto end;
}
- int_ret = bt_ctf_trace_set_packet_header_type(writer_trace, header_type);
- BT_PUT(header_type);
- if (int_ret < 0) {
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__, __LINE__);
- ret = BT_COMPONENT_STATUS_ERROR;
- goto end;
+ /*
+ * Only explicitly set the writer trace's native byte order if
+ * the original trace has a specific one. Otherwise leave what
+ * the CTF writer object chooses, which is the machine's native
+ * byte order.
+ */
+ if (order != BT_CTF_BYTE_ORDER_UNSPECIFIED) {
+ ret = bt_ctf_trace_set_native_byte_order(writer_trace, order);
+ if (ret) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__, __LINE__);
+ ret = BT_COMPONENT_STATUS_ERROR;
+ goto end;
+ }
+ }
+
+ header_type = bt_ctf_trace_get_packet_header_type(writer_trace);
+ if (header_type) {
+ int_ret = bt_ctf_trace_set_packet_header_type(writer_trace, header_type);
+ BT_PUT(header_type);
+ if (int_ret < 0) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__, __LINE__);
+ ret = BT_COMPONENT_STATUS_ERROR;
+ goto end;
+ }
+ }
+
+ trace_name = bt_ctf_trace_get_name(trace);
+ if (trace_name) {
+ int_ret = bt_ctf_trace_set_name(writer_trace, trace_name);
+ if (int_ret < 0) {
+ fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__, __LINE__);
+ ret = BT_COMPONENT_STATUS_ERROR;
+ goto end;
+ }
}
end:
projects / babeltrace.git / blobdiff