int update_header_clock_int_field_type(FILE *err, struct bt_ctf_field_type *type,
struct bt_ctf_clock_class *writer_clock_class)
{
- struct bt_ctf_clock_class *clock;
+ struct bt_ctf_clock_class *clock = NULL;
int ret;
clock = bt_ctf_field_type_integer_get_mapped_clock_class(type);
if (!clock) {
return 0;
}
- bt_put(clock);
+ BT_PUT(clock);
ret = bt_ctf_field_type_integer_set_size(type, 64);
if (ret) {
struct bt_ctf_clock_class *writer_clock_class)
{
int count, i, ret;
+ struct bt_ctf_field_type *entry_type = NULL;
count = bt_ctf_field_type_variant_get_field_count(type);
for (i = 0; i < count; i++) {
- struct bt_ctf_field_type *entry_type;
const char *entry_name;
ret = bt_ctf_field_type_variant_get_field(type,
if (ret) {
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- ret = -1;
- goto end;
+ goto error;
}
ret = find_update_clock_fields(err, entry_type,
writer_clock_class);
- bt_put(entry_type);
if (ret) {
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- ret = -1;
- goto end;
+ goto error;
}
+ BT_PUT(entry_type);
}
ret = 0;
+ goto end;
+error:
+ ret = -1;
end:
+ bt_put(entry_type);
return ret;
}
struct bt_ctf_clock_class *writer_clock_class)
{
int count, i, ret;
+ struct bt_ctf_field_type *entry_type = NULL;
count = bt_ctf_field_type_structure_get_field_count(type);
for (i = 0; i < count; i++) {
- struct bt_ctf_field_type *entry_type;
const char *entry_name;
ret = bt_ctf_field_type_structure_get_field(type,
if (ret) {
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- ret = -1;
- goto end;
+ goto error;
}
ret = find_update_clock_fields(err, entry_type,
writer_clock_class);
- bt_put(entry_type);
if (ret) {
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- ret = -1;
- goto end;
+ goto error;
}
+ BT_PUT(entry_type);
}
ret = 0;
+ goto end;
+error:
+ bt_put(entry_type);
end:
return ret;
}
struct bt_ctf_clock_class *writer_clock_class)
{
int ret;
- struct bt_ctf_field_type *entry_type;
+ struct bt_ctf_field_type *entry_type = NULL;
entry_type = bt_ctf_field_type_sequence_get_element_type(type);
+ if (!entry_type) {
+ fprintf(err, "[error] %s in %s:%d\n",
+ __func__, __FILE__, __LINE__);
+ goto error;
+ }
ret = find_update_clock_fields(err, entry_type, writer_clock_class);
- bt_put(entry_type);
+ BT_PUT(entry_type);
if (ret) {
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- ret = -1;
- goto end;
+ goto error;
}
ret = 0;
+ goto end;
+error:
+ ret = -1;
end:
return ret;
}
struct bt_ctf_clock_class *writer_clock_class)
{
int ret;
- struct bt_ctf_field_type *entry_type;
+ struct bt_ctf_field_type *entry_type = NULL;
entry_type = bt_ctf_field_type_array_get_element_type(type);
+ if (!entry_type) {
+ fprintf(err, "[error] %s in %s:%d\n",
+ __func__, __FILE__, __LINE__);
+ goto error;
+ }
ret = find_update_clock_fields(err, entry_type, writer_clock_class);
- bt_put(entry_type);
+ BT_PUT(entry_type);
if (ret) {
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
}
ret = 0;
+ goto end;
+error:
+ ret = -1;
end:
return ret;
}
struct bt_ctf_clock_class *writer_clock_class)
{
int ret;
- struct bt_ctf_field_type *entry_type;
+ struct bt_ctf_field_type *entry_type = NULL;
entry_type = bt_ctf_field_type_enumeration_get_container_type(type);
+ if (!entry_type) {
+ fprintf(err, "[error] %s in %s:%d\n",
+ __func__, __FILE__, __LINE__);
+ goto error;
+ }
ret = find_update_clock_fields(err, entry_type, writer_clock_class);
- bt_put(entry_type);
+ BT_PUT(entry_type);
if (ret) {
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- ret = -1;
- goto end;
+ goto error;
}
ret = 0;
+ goto end;
+error:
+ ret = -1;
end:
return ret;
}
struct bt_ctf_trace *writer_trace)
{
struct bt_ctf_field_type *new_type = NULL;
+ struct bt_ctf_clock_class *writer_clock_class = NULL;
int ret;
- struct bt_ctf_clock_class *writer_clock_class;
/* FIXME multi-clock? */
writer_clock_class = bt_ctf_trace_get_clock_class(writer_trace, 0);
if (!writer_clock_class) {
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end;
+ goto error;
}
new_type = bt_ctf_field_type_copy(type);
if (!new_type) {
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put;
+ goto error;
}
if (bt_ctf_field_type_get_type_id(new_type) != BT_CTF_TYPE_ID_STRUCT) {
__func__, __FILE__, __LINE__);
goto error;
}
+ BT_PUT(writer_clock_class);
- goto end_put;
+ goto end;
error:
- BT_PUT(new_type);
-end_put:
bt_put(writer_clock_class);
+ BT_PUT(new_type);
end:
return new_type;
}
struct bt_ctf_event *writer_event, struct bt_ctf_field *field,
struct bt_ctf_field *copy_field)
{
- struct bt_ctf_field_type *type;
+ struct bt_ctf_field_type *type = NULL;
int ret;
type = bt_ctf_field_get_type(field);
}
ret = 0;
- bt_put(type);
+ BT_PUT(type);
end:
return ret;
struct bt_ctf_field_type *type, struct bt_ctf_field *copy_field)
{
int ret;
- struct bt_ctf_field *container, *copy_container;
+ struct bt_ctf_field *container = NULL, *copy_container = NULL;
container = bt_ctf_field_enumeration_get_container(field);
if (!container) {
ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_container;
+ goto error;
}
ret = copy_override_field(err, event, writer_event, container,
ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_copy_container;
+ goto error;
}
+
+ ret = 0;
+ goto end;
-end_put_copy_container:
+error:
+ ret = -1;
+end:
bt_put(copy_container);
-end_put_container:
bt_put(container);
-end:
return ret;
}
struct bt_ctf_field_type *type, struct bt_ctf_field *copy_field)
{
int ret;
- struct bt_ctf_field *tag;
- struct bt_ctf_field *variant_field, *copy_variant_field;
+ struct bt_ctf_field *tag = NULL;
+ struct bt_ctf_field *variant_field = NULL, *copy_variant_field = NULL;
tag = bt_ctf_field_variant_get_tag(field);
if (!tag) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
variant_field = bt_ctf_field_variant_get_field(field, tag);
if (!variant_field) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_tag;
+ goto error;
}
copy_variant_field = bt_ctf_field_variant_get_field(copy_field, tag);
if (!copy_variant_field) {
- bt_put(variant_field);
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_variant_field;
+ goto error;
}
ret = copy_override_field(err, event, writer_event, variant_field,
copy_variant_field);
if (ret) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_copy_variand_field;
+ goto error;
}
ret = 0;
+ goto end;
-end_put_copy_variand_field:
+error:
+ ret = -1;
+end:
bt_put(copy_variant_field);
-end_put_variant_field:
bt_put(variant_field);
-end_put_tag:
bt_put(tag);
-end:
return ret;
}
{
int ret;
uint64_t i, count;
- struct bt_ctf_field_type *entry_type;
- struct bt_ctf_field *length_field;
-
- entry_type = bt_ctf_field_type_sequence_get_element_type(type);
- if (!entry_type) {
- ret = -1;
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto end;
- }
+ struct bt_ctf_field *length_field = NULL;
+ struct bt_ctf_field *entry_field = NULL, *entry_copy = NULL;
length_field = bt_ctf_field_sequence_get_length(field);
if (!length_field) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = bt_ctf_field_unsigned_integer_get_value(length_field, &count);
if (ret) {
- bt_put(length_field);
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = bt_ctf_field_sequence_set_length(copy_field, length_field);
- bt_put(length_field);
if (ret) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
+ BT_PUT(length_field);
for (i = 0; i < count; i++) {
- struct bt_ctf_field *entry_field, *entry_copy;
-
entry_field = bt_ctf_field_sequence_get_field(field, i);
if (!entry_field) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
entry_copy = bt_ctf_field_sequence_get_field(copy_field, i);
if (!entry_copy) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = copy_override_field(err, event, writer_event, entry_field,
entry_copy);
- bt_put(entry_field);
- bt_put(entry_copy);
if (ret) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
+ BT_PUT(entry_field);
+ BT_PUT(entry_copy);
}
- bt_put(entry_type);
ret = 0;
+ goto end;
+error:
+ bt_put(length_field);
+ bt_put(entry_field);
+ bt_put(entry_copy);
+ ret = -1;
end:
return ret;
}
struct bt_ctf_field *copy_field)
{
int ret, count, i;
- struct bt_ctf_field_type *entry_type;
+ struct bt_ctf_field *entry_field = NULL, *entry_copy = NULL;
count = bt_ctf_field_type_array_get_length(type);
- entry_type = bt_ctf_field_type_array_get_element_type(type);
- if (!entry_type) {
- ret = -1;
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto end;
- }
for (i = 0; i < count; i++) {
- struct bt_ctf_field *entry_field, *entry_copy;
-
entry_field = bt_ctf_field_array_get_field(field, i);
if (!entry_field) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
entry_copy = bt_ctf_field_array_get_field(copy_field, i);
if (!entry_copy) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = copy_override_field(err, event, writer_event, entry_field,
entry_copy);
- bt_put(entry_field);
- bt_put(entry_copy);
if (ret) {
ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
+ BT_PUT(entry_field);
+ BT_PUT(entry_copy);
}
- bt_put(entry_type);
ret = 0;
+ goto end;
+
+error:
+ bt_put(entry_field);
+ bt_put(entry_copy);
end:
return ret;
struct bt_ctf_field *copy_field)
{
int count, i, ret;
+ struct bt_ctf_field_type *entry_type = NULL;
+ struct bt_ctf_field *entry_field = NULL, *entry_copy = NULL;
count = bt_ctf_field_type_structure_get_field_count(type);
for (i = 0; i < count; i++) {
- struct bt_ctf_field_type *entry_type;
- struct bt_ctf_field *entry_field;
const char *entry_name;
- struct bt_ctf_field *entry_copy;
entry_field = bt_ctf_field_structure_get_field_by_index(field, i);
if (!entry_field) {
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = bt_ctf_field_type_structure_get_field(type, &entry_name,
&entry_type, i);
if (ret) {
- bt_put(entry_field);
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end;
+ goto error;
}
entry_copy = bt_ctf_field_structure_get_field_by_index(copy_field, i);
if (!entry_copy) {
- bt_put(entry_field);
- bt_put(entry_type);
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = copy_override_field(err, event, writer_event, entry_field,
entry_copy);
-
- bt_put(entry_copy);
- bt_put(entry_field);
- bt_put(entry_type);
if (ret) {
- BT_PUT(entry_copy);
- ret = -1;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
+ BT_PUT(entry_copy);
+ BT_PUT(entry_field);
+ BT_PUT(entry_type);
}
ret = 0;
+ goto end;
+error:
+ bt_put(entry_type);
+ bt_put(entry_field);
+ bt_put(entry_copy);
+ ret = -1;
end:
return ret;
}
__FILE__, __LINE__);
goto end;
}
- printf(" - v(s) = %ld\n", value);
ret = bt_ctf_field_signed_integer_set_value(copy_field, value);
if (ret) {
ret = -1;
struct bt_ctf_clock_class *stream_class_get_clock_class(FILE *err,
struct bt_ctf_stream_class *stream_class)
{
- struct bt_ctf_trace *trace;
+ struct bt_ctf_trace *trace = NULL;
struct bt_ctf_clock_class *clock_class = NULL;
trace = bt_ctf_stream_class_get_trace(stream_class);
struct bt_ctf_clock_class *event_get_clock_class(FILE *err, struct bt_ctf_event *event)
{
- struct bt_ctf_event_class *event_class;
- struct bt_ctf_stream_class *stream_class;
+ struct bt_ctf_event_class *event_class = NULL;
+ struct bt_ctf_stream_class *stream_class = NULL;
struct bt_ctf_clock_class *clock_class = NULL;
event_class = bt_ctf_event_get_class(event);
}
stream_class = bt_ctf_event_class_get_stream_class(event_class);
+ BT_PUT(event_class);
if (!stream_class) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_event_class;
+ goto end;
}
clock_class = stream_class_get_clock_class(err, stream_class);
bt_put(stream_class);
-end_put_event_class:
- bt_put(event_class);
end:
return clock_class;
}
struct bt_ctf_field *field, struct bt_ctf_field_type *type,
struct bt_ctf_field *copy_field)
{
- struct bt_ctf_clock_class *clock_class, *writer_clock_class;
- struct bt_ctf_clock_value *clock_value, *writer_clock_value;
+ struct bt_ctf_clock_class *clock_class = NULL, *writer_clock_class = NULL;
+ struct bt_ctf_clock_value *clock_value = NULL, *writer_clock_value = NULL;
uint64_t value;
int ret;
}
clock_value = bt_ctf_event_get_clock_value(event, clock_class);
- bt_put(clock_class);
+ BT_PUT(clock_class);
if (!clock_value) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = bt_ctf_clock_value_get_value(clock_value, &value);
- bt_put(clock_value);
+ BT_PUT(clock_value);
if (ret) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = bt_ctf_field_unsigned_integer_set_value(copy_field, value);
if (ret) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
writer_clock_class = event_get_clock_class(err, writer_event);
if (!writer_clock_class) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
writer_clock_value = bt_ctf_clock_value_create(writer_clock_class, value);
- bt_put(writer_clock_class);
+ BT_PUT(writer_clock_class);
if (!writer_clock_value) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = bt_ctf_event_set_clock_value(writer_event, writer_clock_value);
- bt_put(writer_clock_value);
+ BT_PUT(writer_clock_value);
if (ret) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = 0;
+ goto end;
+error:
+ ret = -1;
end:
return ret;
}
if (!attr_name) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- BT_PUT(writer_event_class);
- goto end;
+ goto error;
}
attr_value = bt_ctf_event_class_get_attribute_value(event_class, i);
if (!attr_value) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- BT_PUT(writer_event_class);
- goto end;
+ goto error;
}
ret = bt_ctf_event_class_set_attribute(writer_event_class,
attr_name, attr_value);
- bt_put(attr_value);
+ BT_PUT(attr_value);
if (ret < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- BT_PUT(writer_event_class);
- goto end;
+ goto error;
}
}
&field_type, i);
if (ret < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__, __LINE__);
- BT_PUT(writer_event_class);
- goto end;
+ goto error;
}
ret = bt_ctf_event_class_add_field(writer_event_class, field_type,
field_name);
+ BT_PUT(field_type);
if (ret < 0) {
fprintf(err, "[error] Cannot add field %s\n", field_name);
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__, __LINE__);
- bt_put(field_type);
- BT_PUT(writer_event_class);
- goto end;
+ goto error;
}
- bt_put(field_type);
}
+ goto end;
+
+error:
+ BT_PUT(writer_event_class);
end:
return writer_event_class;
}
struct bt_ctf_stream_class *writer_stream_class)
{
enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
+ struct bt_ctf_event_class *event_class = NULL, *writer_event_class = NULL;
int count, i;
count = bt_ctf_stream_class_get_event_class_count(stream_class);
}
for (i = 0; i < count; i++) {
- struct bt_ctf_event_class *event_class, *writer_event_class;
struct bt_ctf_field_type *context;
int int_ret;
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
ret = BT_COMPONENT_STATUS_ERROR;
- bt_put(event_class);
- goto end;
+ 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;
- bt_put(event_class);
- goto end;
+ goto error;
}
context = bt_ctf_event_class_get_context_type(event_class);
+ if (!context) {
+ 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);
+ BT_PUT(context);
if (ret < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
int_ret = bt_ctf_stream_class_add_event_class(writer_stream_class,
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
ret = BT_COMPONENT_STATUS_ERROR;
- bt_put(event_class);
- goto end;
+ goto error;
}
- bt_put(event_class);
- bt_put(writer_event_class);
+ BT_PUT(writer_event_class);
+ BT_PUT(event_class);
}
+ goto end;
+
+error:
+ bt_put(event_class);
+ bt_put(writer_event_class);
end:
return ret;
}
struct bt_ctf_trace *writer_trace,
bool override_ts64)
{
- struct bt_ctf_field_type *type, *new_event_header_type;
- struct bt_ctf_stream_class *writer_stream_class;
+ struct bt_ctf_field_type *type = NULL;
+ struct bt_ctf_stream_class *writer_stream_class = NULL;
int ret_int;
const char *name = bt_ctf_stream_class_get_name(stream_class);
ret_int = bt_ctf_stream_class_set_packet_context_type(
writer_stream_class, type);
- bt_put(type);
if (ret_int < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
goto error;
}
+ BT_PUT(type);
type = bt_ctf_stream_class_get_event_header_type(stream_class);
if (!type) {
}
if (override_ts64) {
+ struct bt_ctf_field_type *new_event_header_type;
+
new_event_header_type = override_header_type(err, type,
writer_trace);
- bt_put(type);
if (!new_event_header_type) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
}
ret_int = bt_ctf_stream_class_set_event_header_type(
writer_stream_class, new_event_header_type);
- bt_put(new_event_header_type);
+ BT_PUT(new_event_header_type);
if (ret_int < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
} else {
ret_int = bt_ctf_stream_class_set_event_header_type(
writer_stream_class, type);
- bt_put(type);
if (ret_int < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
goto error;
}
}
+ BT_PUT(type);
type = bt_ctf_stream_class_get_event_context_type(stream_class);
if (type) {
ret_int = bt_ctf_stream_class_set_event_context_type(
writer_stream_class, type);
- bt_put(type);
if (ret_int < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
goto error;
}
}
+ BT_PUT(type);
goto end;
error:
BT_PUT(writer_stream_class);
end:
+ bt_put(type);
return writer_stream_class;
}
struct bt_ctf_field_type *writer_packet_context_type)
{
enum bt_component_status ret;
- struct bt_ctf_field *writer_field;
- struct bt_ctf_field_type *field_type;
+ struct bt_ctf_field *writer_field = NULL;
+ struct bt_ctf_field_type *field_type = NULL;
int int_ret;
uint64_t value;
*/
if (bt_ctf_field_type_get_type_id(field_type) != BT_CTF_TYPE_ID_INTEGER) {
fprintf(err, "[error] Unsupported packet context field type\n");
- bt_put(field_type);
ret = BT_COMPONENT_STATUS_ERROR;
- goto end;
+ goto error;
}
- bt_put(field_type);
+ BT_PUT(field_type);
- /*
- * TODO: handle the special case of the first/last packet that might
- * be trimmed. In these cases, the timestamp_begin/end need to be
- * explicitely set to the first/last event timestamps.
- */
writer_field = bt_ctf_field_structure_get_field(writer_packet_context,
field_name);
if (!writer_field) {
goto end;
}
-
int_ret = bt_ctf_field_unsigned_integer_get_value(field, &value);
if (int_ret < 0) {
fprintf(err, "[error] Wrong packet_context field type\n");
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
ret = BT_COMPONENT_STATUS_ERROR;
- goto end_put_writer_field;
+ goto end;
}
int_ret = bt_ctf_field_unsigned_integer_set_value(writer_field, value);
ret = BT_COMPONENT_STATUS_ERROR;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_writer_field;
+ goto end;
}
ret = BT_COMPONENT_STATUS_OK;
-end_put_writer_field:
- bt_put(writer_field);
+ goto end;
+
+error:
+ bt_put(field_type);
end:
+ bt_put(writer_field);
return ret;
}
struct bt_ctf_stream *writer_stream)
{
enum bt_component_status ret;
- struct bt_ctf_field *packet_context, *writer_packet_context = NULL;
- struct bt_ctf_field_type *struct_type, *writer_packet_context_type;
- struct bt_ctf_stream_class *writer_stream_class;
+ struct bt_ctf_field *packet_context = NULL, *writer_packet_context = NULL;
+ 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;
+ struct bt_ctf_field_type *field_type;
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 end;
+ goto error;
}
writer_stream_class = bt_ctf_stream_get_class(writer_stream);
if (!writer_stream_class) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_packet_context;
+ goto error;
}
writer_packet_context_type = bt_ctf_stream_class_get_packet_context_type(
writer_stream_class);
+ BT_PUT(writer_stream_class);
if (!writer_packet_context_type) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_writer_stream_class;
+ goto error;
}
struct_type = bt_ctf_field_get_type(packet_context);
if (!struct_type) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_writer_packet_context_type;
+ goto error;
}
writer_packet_context = bt_ctf_field_create(writer_packet_context_type);
if (!writer_packet_context) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_struct_type;
+ goto error;
}
nr_fields = bt_ctf_field_type_structure_get_field_count(struct_type);
for (i = 0; i < nr_fields; i++) {
- struct bt_ctf_field *field;
- struct bt_ctf_field_type *field_type;
const char *field_name;
field = bt_ctf_field_structure_get_field_by_index(
packet_context, i);
if (!field) {
- BT_PUT(writer_packet_context);
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_struct_type;
+ goto error;
}
if (bt_ctf_field_type_structure_get_field(struct_type,
&field_name, &field_type, i) < 0) {
- bt_put(field);
- BT_PUT(writer_packet_context);
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_struct_type;
+ 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);
+ BT_PUT(field_type);
+ BT_PUT(field);
continue;
}
if (bt_ctf_field_type_get_type_id(field_type) != BT_CTF_TYPE_ID_INTEGER) {
fprintf(err, "[error] Unexpected packet context field type\n");
- bt_put(field);
- BT_PUT(writer_packet_context);
- goto end_put_struct_type;
+ goto error;
}
ret = ctf_copy_packet_context_field(err, field, field_name,
writer_packet_context, writer_packet_context_type);
- bt_put(field_type);
- bt_put(field);
+ BT_PUT(field_type);
+ BT_PUT(field);
if (ret != BT_COMPONENT_STATUS_OK) {
- BT_PUT(writer_packet_context);
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_struct_type;
+ goto error;
}
}
-end_put_struct_type:
+ goto end;
+
+error:
+ BT_PUT(writer_packet_context);
+end:
+ bt_put(field);
+ bt_put(field_type);
bt_put(struct_type);
-end_put_writer_packet_context_type:
bt_put(writer_packet_context_type);
-end_put_writer_stream_class:
bt_put(writer_stream_class);
-end_put_packet_context:
bt_put(packet_context);
-end:
return writer_packet_context;
}
struct bt_ctf_event *writer_event,
struct bt_ctf_field *event_header)
{
- struct bt_ctf_clock_class *clock_class, *writer_clock_class;
- struct bt_ctf_clock_value *clock_value, *writer_clock_value;
+ struct bt_ctf_clock_class *clock_class = NULL, *writer_clock_class = NULL;
+ struct bt_ctf_clock_value *clock_value = NULL, *writer_clock_value = NULL;
int ret;
struct bt_ctf_field *writer_event_header = NULL;
}
clock_value = bt_ctf_event_get_clock_value(event, clock_class);
- bt_put(clock_class);
+ BT_PUT(clock_class);
if (!clock_value) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
}
ret = bt_ctf_clock_value_get_value(clock_value, &value);
- bt_put(clock_value);
+ BT_PUT(clock_value);
if (ret) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
}
writer_clock_value = bt_ctf_clock_value_create(writer_clock_class, value);
- bt_put(writer_clock_class);
+ BT_PUT(writer_clock_class);
if (!writer_clock_value) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = bt_ctf_event_set_clock_value(writer_event, writer_clock_value);
- bt_put(writer_clock_value);
+ BT_PUT(writer_clock_value);
if (ret) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
if (!writer_event_header) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- ret = -1;
goto end;
}
ret = bt_ctf_event_set_header(writer_event, writer_event_header);
- bt_put(writer_event_header);
+ BT_PUT(writer_event_header);
if (ret < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
goto end;
error:
- BT_PUT(writer_event_header);
ret = -1;
end:
return ret;
struct bt_ctf_event_class *writer_event_class,
bool override_ts64)
{
- struct bt_ctf_event *writer_event;
- struct bt_ctf_field *field, *copy_field;
+ struct bt_ctf_event *writer_event = NULL;
+ struct bt_ctf_field *field = NULL, *copy_field = NULL;
int ret;
writer_event = bt_ctf_event_create(writer_event_class);
field = bt_ctf_event_get_header(event);
if (!field) {
- BT_PUT(writer_event);
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end;
+ goto error;
}
/*
if (override_ts64) {
copy_field = bt_ctf_event_get_header(writer_event);
if (!copy_field) {
- BT_PUT(writer_event);
- bt_put(field);
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end;
+ goto error;
}
ret = copy_override_field(err, event, writer_event, field,
copy_field);
- bt_put(field);
if (ret) {
- BT_PUT(writer_event);
- BT_PUT(copy_field);
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end;
+ goto error;
}
+ BT_PUT(copy_field);
} else {
ret = ctf_copy_event_header(err, event, writer_event_class,
writer_event, field);
if (ret) {
- BT_PUT(writer_event);
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end;
+ goto error;
}
}
+ BT_PUT(field);
/* Optional field, so it can fail silently. */
field = bt_ctf_event_get_stream_event_context(event);
copy_field = bt_ctf_field_copy(field);
- bt_put(field);
if (copy_field) {
ret = bt_ctf_event_set_stream_event_context(writer_event,
copy_field);
- bt_put(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);
/* Optional field, so it can fail silently. */
field = bt_ctf_event_get_event_context(event);
copy_field = bt_ctf_field_copy(field);
- bt_put(field);
if (copy_field) {
ret = bt_ctf_event_set_event_context(writer_event, copy_field);
- bt_put(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);
field = bt_ctf_event_get_payload_field(event);
if (!field) {
- BT_PUT(writer_event);
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end;
+ goto error;
}
copy_field = bt_ctf_field_copy(field);
- bt_put(field);
if (copy_field) {
ret = bt_ctf_event_set_payload_field(writer_event, copy_field);
- bt_put(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);
+
goto end;
error:
BT_PUT(writer_event);
end:
+ bt_put(field);
+ bt_put(copy_field);
return writer_event;
}
{
enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
int field_count, i, int_ret;
- struct bt_ctf_field_type *header_type;
+ struct bt_ctf_field_type *header_type = NULL;
field_count = bt_ctf_trace_get_environment_field_count(trace);
for (i = 0; i < field_count; i++) {
int ret_int;
const char *name;
- struct bt_value *value;
+ struct bt_value *value = NULL;
name = bt_ctf_trace_get_environment_field_name(trace, i);
if (!name) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
ret = BT_COMPONENT_STATUS_ERROR;
- goto end_put_writer_trace;
+ goto end;
}
value = bt_ctf_trace_get_environment_field_value(trace, i);
if (!value) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
ret = BT_COMPONENT_STATUS_ERROR;
- goto end_put_writer_trace;
+ goto end;
}
ret_int = bt_ctf_trace_set_environment_field(writer_trace,
name, value);
- bt_put(value);
+ BT_PUT(value);
if (ret_int < 0) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
fprintf(err, "[error] Unable to set environment field %s\n",
name);
ret = BT_COMPONENT_STATUS_ERROR;
- goto end_put_writer_trace;
+ goto end;
}
}
if (!header_type) {
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__, __LINE__);
ret = BT_COMPONENT_STATUS_ERROR;
- goto end_put_writer_trace;
+ 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_put_header_type;
+ goto end;
}
-end_put_header_type:
- bt_put(header_type);
-end_put_writer_trace:
+end:
return ret;
}
-
struct bt_ctf_packet *packet,
struct bt_ctf_stream *stream)
{
- struct bt_ctf_packet *writer_packet;
+ struct bt_ctf_packet *writer_packet = NULL;
writer_packet = bt_ctf_packet_create(stream);
if (!writer_packet) {
const char *name, int64_t value)
{
enum bt_component_status ret;
- struct bt_ctf_field *packet_context, *writer_packet_context;
- struct bt_ctf_field_type *struct_type, *writer_packet_context_type;
- struct bt_ctf_stream_class *stream_class;
- struct bt_ctf_stream *stream;
+ struct bt_ctf_field *packet_context = NULL, *writer_packet_context = NULL;
+ struct bt_ctf_field_type *struct_type = NULL, *field_type = NULL;
+ struct bt_ctf_field *field = NULL, *writer_field = NULL;
int nr_fields, i, int_ret;
packet_context = bt_ctf_packet_get_context(writer_packet);
if (!packet_context) {
- ret = BT_COMPONENT_STATUS_ERROR;
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto end;
- }
-
- stream = bt_ctf_packet_get_stream(writer_packet);
- if (!stream) {
- ret = BT_COMPONENT_STATUS_ERROR;
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto end_put_packet_context;
- }
-
- stream_class = bt_ctf_stream_get_class(stream);
- if (!stream_class) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_stream;
- }
-
- writer_packet_context_type = bt_ctf_stream_class_get_packet_context_type(
- stream_class);
- if (!writer_packet_context_type) {
- ret = BT_COMPONENT_STATUS_ERROR;
- fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
- __LINE__);
- goto end_put_stream_class;
+ goto error;
}
struct_type = bt_ctf_field_get_type(packet_context);
if (!struct_type) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_writer_packet_context_type;
+ goto error;
}
writer_packet_context = bt_ctf_packet_get_context(writer_packet);
if (!writer_packet_context) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_struct_type;
+ goto error;
}
nr_fields = bt_ctf_field_type_structure_get_field_count(struct_type);
for (i = 0; i < nr_fields; i++) {
- struct bt_ctf_field *field, *writer_field;
- struct bt_ctf_field_type *field_type;
const char *field_name;
field = bt_ctf_field_structure_get_field_by_index(
packet_context, i);
if (!field) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_writer_packet_context;
+ goto error;
}
if (bt_ctf_field_type_structure_get_field(struct_type,
&field_name, &field_type, i) < 0) {
- ret = BT_COMPONENT_STATUS_ERROR;
- bt_put(field);
fprintf(err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_writer_packet_context;
+ goto error;
}
if (strcmp(field_name, name)) {
- bt_put(field_type);
- bt_put(field);
+ BT_PUT(field_type);
+ BT_PUT(field);
continue;
}
if (bt_ctf_field_type_get_type_id(field_type) != BT_CTF_TYPE_ID_INTEGER) {
fprintf(err, "[error] Unexpected packet context field type\n");
- bt_put(field);
- ret = BT_COMPONENT_STATUS_ERROR;
- goto end_put_writer_packet_context;
+ goto error;
}
writer_field = bt_ctf_field_structure_get_field(writer_packet_context,
field_name);
if (!writer_field) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
int_ret = bt_ctf_field_unsigned_integer_set_value(writer_field, value);
- bt_put(writer_field);
if (int_ret < 0) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_writer_packet_context;
+ goto error;
}
-
- bt_put(field_type);
- bt_put(field);
+ BT_PUT(writer_field);
+ BT_PUT(field_type);
+ BT_PUT(field);
}
ret = BT_COMPONENT_STATUS_OK;
+ goto end;
-end_put_writer_packet_context:
- bt_put(writer_packet_context);
-end_put_struct_type:
+error:
+ bt_put(writer_field);
+ bt_put(field_type);
+ bt_put(field);
+ ret = BT_COMPONENT_STATUS_ERROR;
+end:
bt_put(struct_type);
-end_put_writer_packet_context_type:
- bt_put(writer_packet_context_type);
-end_put_stream_class:
- bt_put(stream_class);
-end_put_packet_context:
bt_put(packet_context);
-end_put_stream:
- bt_put(stream);
-end:
return ret;
}
struct trimmer_iterator *trim_it,
struct bt_ctf_packet *packet)
{
- struct bt_ctf_stream *stream;
- struct bt_ctf_field *writer_packet_context;
+ struct bt_ctf_stream *stream = NULL;
+ struct bt_ctf_field *writer_packet_context = NULL;
struct bt_ctf_packet *writer_packet = NULL;
int int_ret;
if (!stream) {
fprintf(trim_it->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end;
+ goto error;
}
/*
writer_packet = lookup_packet(trim_it, packet);
if (writer_packet) {
g_hash_table_remove(trim_it->packet_map, packet);
- bt_put(writer_packet);
+ BT_PUT(writer_packet);
}
writer_packet = insert_new_packet(trim_it, packet, stream);
if (!writer_packet) {
fprintf(trim_it->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put_stream;
+ goto error;
}
bt_get(writer_packet);
writer_packet_context = ctf_copy_packet_context(trim_it->err, packet,
stream);
if (!writer_packet_context) {
- BT_PUT(writer_packet);
fprintf(trim_it->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put_stream;
+ goto error;
}
int_ret = bt_ctf_packet_set_context(writer_packet, writer_packet_context);
if (int_ret) {
- BT_PUT(writer_packet);
fprintf(trim_it->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put_writer_packet_context;
+ goto error;
}
-end_put_writer_packet_context:
+ goto end;
+
+error:
+ BT_PUT(writer_packet);
+end:
bt_put(writer_packet_context);
-end_put_stream:
bt_put(stream);
-end:
return writer_packet;
}
struct trimmer_iterator *trim_it,
struct bt_ctf_packet *packet)
{
- struct bt_ctf_packet *writer_packet;
+ struct bt_ctf_packet *writer_packet = NULL;
writer_packet = lookup_packet(trim_it, packet);
if (!writer_packet) {
struct trimmer_iterator *trim_it,
struct bt_ctf_event *event)
{
- struct bt_ctf_event_class *event_class;
- struct bt_ctf_stream *stream;
- struct bt_ctf_stream_class *stream_class;
+ struct bt_ctf_event_class *event_class = NULL;
struct bt_ctf_event *writer_event = NULL;
- struct bt_ctf_packet *packet, *writer_packet;
+ struct bt_ctf_packet *packet = NULL, *writer_packet = NULL;
const char *event_name;
int int_ret;
if (!event_class) {
fprintf(trim_it->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end;
+ goto error;
}
event_name = bt_ctf_event_class_get_name(event_class);
if (!event_name) {
fprintf(trim_it->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_event_class;
- }
-
- stream = bt_ctf_event_get_stream(event);
- if (!stream) {
- fprintf(trim_it->err, "[error] %s in %s:%d\n", __func__,
- __FILE__, __LINE__);
- goto end_put_event_class;
- }
-
- stream_class = bt_ctf_event_class_get_stream_class(event_class);
- if (!stream_class) {
- fprintf(trim_it->err, "[error] %s in %s:%d\n", __func__,
- __FILE__, __LINE__);
- goto end_put_stream;
+ goto error;
}
writer_event = ctf_copy_event(trim_it->err, event, event_class, false);
__FILE__, __LINE__);
fprintf(trim_it->err, "[error] Failed to copy event %s\n",
bt_ctf_event_class_get_name(event_class));
- goto end_put_stream_class;
+ goto error;
}
packet = bt_ctf_event_get_packet(event);
if (!packet) {
- BT_PUT(writer_event);
fprintf(trim_it->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_stream_class;
+ goto error;
}
writer_packet = lookup_packet(trim_it, packet);
if (!writer_packet) {
- BT_PUT(writer_event);
fprintf(trim_it->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_packet;
+ goto error;
}
bt_get(writer_packet);
int_ret = bt_ctf_event_set_packet(writer_event, writer_packet);
if (int_ret < 0) {
- BT_PUT(writer_event);
fprintf(trim_it->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
fprintf(trim_it->err, "[error] Failed to append event %s\n",
bt_ctf_event_class_get_name(event_class));
- goto end_put_writer_packet;
+ goto error;
}
- /* We keep the reference on the writer event */
+ /* We keep the reference on the writer_event to create a notification. */
+ goto end;
-end_put_writer_packet:
+error:
+ BT_PUT(writer_event);
+end:
bt_put(writer_packet);
-end_put_packet:
bt_put(packet);
-end_put_stream_class:
- bt_put(stream_class);
-end_put_stream:
- bt_put(stream);
-end_put_event_class:
bt_put(event_class);
-end:
return writer_event;
}
struct bt_ctf_stream_class *stream_class)
{
struct bt_ctf_stream_class *writer_stream_class = NULL;
- struct bt_ctf_trace *trace, *writer_trace;
+ struct bt_ctf_trace *trace = NULL, *writer_trace = NULL;
enum bt_component_status ret;
trace = bt_ctf_stream_class_get_trace(stream_class);
fprintf(writer_component->err,
"[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
writer_trace = bt_ctf_writer_get_trace(ctf_writer);
if (!writer_trace) {
- bt_put(trace);
fprintf(writer_component->err,
"[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- ret = BT_COMPONENT_STATUS_ERROR;
- goto end_put_trace;
+ goto error;
}
ret = ctf_copy_clock_classes(writer_component->err, writer_trace,
writer_stream_class, trace);
if (ret != BT_COMPONENT_STATUS_OK) {
- bt_put(trace);
fprintf(writer_component->err,
"[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end_put_writer_trace;
+ goto error;
}
writer_stream_class = ctf_copy_stream_class(writer_component->err,
fprintf(writer_component->err, "[error] Failed to copy stream class\n");
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put_writer_trace;
+ goto error;
}
g_hash_table_insert(writer_component->stream_class_map,
(gpointer) stream_class, writer_stream_class);
-end_put_writer_trace:
+ goto end;
+
+error:
+ BT_PUT(writer_stream_class);
+end:
bt_put(writer_trace);
-end_put_trace:
bt_put(trace);
-end:
return writer_stream_class;
}
struct bt_ctf_stream_class *stream_class,
struct bt_ctf_stream *stream)
{
- struct bt_ctf_stream *writer_stream;
- struct bt_ctf_stream_class *writer_stream_class;
+ struct bt_ctf_stream *writer_stream = NULL;
+ struct bt_ctf_stream_class *writer_stream_class = NULL;
writer_stream_class = g_hash_table_lookup(
writer_component->stream_class_map,
(gpointer) stream_class);
- if (writer_stream_class) {
- if (!bt_get(writer_stream_class)) {
- writer_stream = NULL;
- fprintf(writer_component->err, "[error] %s in %s:%d\n",
- __func__, __FILE__, __LINE__);
- goto end;
- }
- } else {
+ if (!writer_stream_class) {
writer_stream_class = insert_new_stream_class(
writer_component, ctf_writer, stream_class);
if (!writer_stream_class) {
- writer_stream = NULL;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put;
+ goto error;
}
}
+ bt_get(writer_stream_class);
writer_stream = bt_ctf_writer_create_stream(ctf_writer,
writer_stream_class);
if (!writer_stream) {
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put;
+ goto error;
}
g_hash_table_insert(writer_component->stream_map, (gpointer) stream,
writer_stream);
- bt_ctf_writer_flush_metadata(ctf_writer);
+ goto end;
-end_put:
- bt_put(writer_stream_class);
+error:
+ BT_PUT(writer_stream);
end:
+ bt_put(writer_stream_class);
return writer_stream;
}
struct writer_component *writer_component,
struct bt_ctf_trace *trace)
{
- struct bt_ctf_writer *ctf_writer;
- struct bt_ctf_trace *writer_trace;
+ struct bt_ctf_writer *ctf_writer = NULL;
+ struct bt_ctf_trace *writer_trace = NULL;
char trace_name[PATH_MAX];
enum bt_component_status ret;
+ /* FIXME: replace with trace name when it will work. */
snprintf(trace_name, PATH_MAX, "%s/%s_%03d",
writer_component->base_path->str,
writer_component->trace_name_base->str,
if (!ctf_writer) {
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end;
+ goto error;
}
writer_trace = bt_ctf_writer_get_trace(ctf_writer);
if (!writer_trace) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err,
"[error] %s in %s:%d\n", __func__, __FILE__,
__LINE__);
- goto end;
+ goto error;
}
ret = ctf_copy_trace(writer_component->err, trace, writer_trace);
- bt_put(writer_trace);
if (ret != BT_COMPONENT_STATUS_OK) {
fprintf(writer_component->err, "[error] Failed to copy trace\n");
fprintf(writer_component->err, "[error] %s in %s:%d\n",
BT_PUT(ctf_writer);
goto end;
}
+ BT_PUT(writer_trace);
g_hash_table_insert(writer_component->trace_map, (gpointer) trace,
ctf_writer);
+ goto end;
+
+error:
+ bt_put(writer_trace);
+ BT_PUT(ctf_writer);
end:
return ctf_writer;
}
struct bt_ctf_writer *get_writer(struct writer_component *writer_component,
struct bt_ctf_stream_class *stream_class)
{
- struct bt_ctf_trace *trace;
- struct bt_ctf_writer *ctf_writer;
+ struct bt_ctf_trace *trace = NULL;
+ struct bt_ctf_writer *ctf_writer = NULL;
trace = bt_ctf_stream_class_get_trace(stream_class);
if (!trace) {
ctf_writer = NULL;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end;
+ goto error;
}
ctf_writer = g_hash_table_lookup(writer_component->trace_map,
(gpointer) trace);
- if (ctf_writer) {
- if (!bt_get(ctf_writer)) {
- ctf_writer = NULL;
- fprintf(writer_component->err, "[error] %s in %s:%d\n",
- __func__, __FILE__, __LINE__);
- goto end;
- }
- } else {
+ if (!ctf_writer) {
ctf_writer = insert_new_writer(writer_component, trace);
}
- bt_put(trace);
+ bt_get(ctf_writer);
+ BT_PUT(trace);
+ goto end;
+error:
+ BT_PUT(ctf_writer);
end:
return ctf_writer;
}
struct writer_component *writer_component,
struct bt_ctf_packet *packet, struct bt_ctf_stream *stream)
{
- struct bt_ctf_stream_class *stream_class;
- struct bt_ctf_writer *ctf_writer;
- struct bt_ctf_stream *writer_stream;
+ struct bt_ctf_stream_class *stream_class = NULL;
+ struct bt_ctf_writer *ctf_writer = NULL;
+ struct bt_ctf_stream *writer_stream = NULL;
stream_class = bt_ctf_stream_get_class(stream);
if (!stream_class) {
- writer_stream = NULL;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end;
+ goto error;
}
ctf_writer = get_writer(writer_component, stream_class);
if (!ctf_writer) {
- writer_stream = NULL;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put_stream_class;
+ goto error;
}
writer_stream = lookup_stream(writer_component, stream);
-
- if (writer_stream) {
- if (!bt_get(writer_stream)) {
- writer_stream = NULL;
- fprintf(writer_component->err, "[error] %s in %s:%d\n",
- __func__, __FILE__, __LINE__);
- goto end_put_stream_class;
- }
- } else {
+ if (!writer_stream) {
writer_stream = insert_new_stream(writer_component, ctf_writer,
stream_class, stream);
- bt_get(writer_stream);
}
+ bt_get(writer_stream);
+
+ goto end;
+error:
+ BT_PUT(writer_stream);
+end:
bt_put(ctf_writer);
-end_put_stream_class:
bt_put(stream_class);
-end:
return writer_stream;
}
struct writer_component *writer_component,
struct bt_ctf_packet *packet)
{
- struct bt_ctf_stream *stream, *writer_stream;
- struct bt_ctf_field *writer_packet_context;
+ struct bt_ctf_stream *stream = NULL, *writer_stream = NULL;
+ struct bt_ctf_field *writer_packet_context = NULL;
enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
int int_ret;
stream = bt_ctf_packet_get_stream(packet);
if (!stream) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end;
+ goto error;
}
writer_stream = get_writer_stream(writer_component, packet, stream);
if (!writer_stream) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put;
+ goto error;
}
+ BT_PUT(stream);
writer_packet_context = ctf_copy_packet_context(writer_component->err,
packet, writer_stream);
if (!writer_packet_context) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put;
+ goto error;
}
int_ret = bt_ctf_stream_set_packet_context(writer_stream,
writer_packet_context);
if (int_ret < 0) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_writer_packet_context;
+ goto error;
}
+ BT_PUT(writer_stream);
+ BT_PUT(writer_packet_context);
- bt_put(writer_stream);
+ goto end;
-end_put_writer_packet_context:
+error:
+ ret = BT_COMPONENT_STATUS_ERROR;
+end:
+ bt_put(writer_stream);
bt_put(writer_packet_context);
-end_put:
bt_put(stream);
-end:
return ret;
}
struct writer_component *writer_component,
struct bt_ctf_packet *packet)
{
- struct bt_ctf_stream *stream, *writer_stream;
+ struct bt_ctf_stream *stream = NULL, *writer_stream = NULL;
enum bt_component_status ret;
stream = bt_ctf_packet_get_stream(packet);
if (!stream) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end;
+ goto error;
}
writer_stream = lookup_stream(writer_component, stream);
if (!writer_stream) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put;
+ goto error;
}
+ BT_PUT(stream);
- if (!bt_get(writer_stream)) {
- fprintf(writer_component->err,
- "[error] Failed to get reference on writer stream\n");
- fprintf(writer_component->err, "[error] %s in %s:%d\n",
- __func__, __FILE__, __LINE__);
- ret = BT_COMPONENT_STATUS_ERROR;
- goto end_put;
- }
+ bt_get(writer_stream);
ret = bt_ctf_stream_flush(writer_stream);
if (ret < 0) {
fprintf(writer_component->err,
"[error] Failed to flush packet\n");
- ret = BT_COMPONENT_STATUS_ERROR;
+ goto error;
}
+ BT_PUT(writer_stream);
ret = BT_COMPONENT_STATUS_OK;
+ goto end;
+error:
+ ret = BT_COMPONENT_STATUS_ERROR;
+end:
bt_put(writer_stream);
-
-end_put:
bt_put(stream);
-end:
return ret;
}
struct bt_ctf_event *event)
{
enum bt_component_status ret;
- struct bt_ctf_event_class *event_class, *writer_event_class;
- struct bt_ctf_stream *stream, *writer_stream;
- struct bt_ctf_stream_class *stream_class, *writer_stream_class;
- struct bt_ctf_event *writer_event;
+ struct bt_ctf_event_class *event_class = NULL, *writer_event_class = NULL;
+ struct bt_ctf_stream *stream = NULL, *writer_stream = NULL;
+ struct bt_ctf_stream_class *stream_class = NULL, *writer_stream_class = NULL;
+ struct bt_ctf_event *writer_event = NULL;
const char *event_name;
int int_ret;
event_class = bt_ctf_event_get_class(event);
if (!event_class) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end;
+ goto error;
}
event_name = bt_ctf_event_class_get_name(event_class);
if (!event_name) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_event_class;
+ goto error;
}
stream = bt_ctf_event_get_stream(event);
if (!stream) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_event_class;
+ goto error;
}
writer_stream = lookup_stream(writer_component, stream);
if (!writer_stream || !bt_get(writer_stream)) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_stream;
+ goto error;
}
stream_class = bt_ctf_event_class_get_stream_class(event_class);
if (!stream_class) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_writer_stream;
+ goto error;
}
writer_stream_class = g_hash_table_lookup(
writer_component->stream_class_map,
(gpointer) stream_class);
if (!writer_stream_class || !bt_get(writer_stream_class)) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
- goto end_put_stream_class;
+ goto error;
}
writer_event_class = get_event_class(writer_component,
writer_event_class = ctf_copy_event_class(writer_component->err,
event_class);
if (!writer_event_class) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put_writer_stream_class;
+ goto error;
}
int_ret = bt_ctf_stream_class_add_event_class(
writer_stream_class, writer_event_class);
if (int_ret) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n",
__func__, __FILE__, __LINE__);
- goto end_put_writer_stream_class;
+ goto error;
}
}
writer_event = ctf_copy_event(writer_component->err, event,
writer_event_class, true);
if (!writer_event) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
fprintf(writer_component->err, "[error] Failed to copy event %s\n",
bt_ctf_event_class_get_name(writer_event_class));
- goto end_put_writer_event_class;
+ goto error;
}
int_ret = bt_ctf_stream_append_event(writer_stream, writer_event);
if (int_ret < 0) {
- ret = BT_COMPONENT_STATUS_ERROR;
fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
__FILE__, __LINE__);
fprintf(writer_component->err, "[error] Failed to append event %s\n",
bt_ctf_event_class_get_name(writer_event_class));
- goto end_put_writer_event;
+ goto error;
}
ret = BT_COMPONENT_STATUS_OK;
+ goto end;
-end_put_writer_event:
+error:
+ ret = BT_COMPONENT_STATUS_ERROR;
+end:
bt_put(writer_event);
-end_put_writer_event_class:
bt_put(writer_event_class);
-end_put_writer_stream_class:
bt_put(writer_stream_class);
-end_put_stream_class:
bt_put(stream_class);
-end_put_writer_stream:
bt_put(writer_stream);
-end_put_stream:
bt_put(stream);
-end_put_event_class:
bt_put(event_class);
-end:
return ret;
}
static
void unref_stream_class(struct bt_ctf_stream_class *writer_stream_class)
{
- return;
+ bt_put(writer_stream_class);
}
static
static
void unref_trace(struct bt_ctf_writer *writer)
{
- return;
+ bt_put(writer);
}
static
projects / babeltrace.git / commitdiff
