static
void unref_stream_class(struct bt_stream_class *writer_stream_class)
{
- bt_put(writer_stream_class);
+ bt_object_put_ref(writer_stream_class);
}
static
void unref_stream(struct bt_stream_class *writer_stream)
{
- bt_put(writer_stream);
+ bt_object_put_ref(writer_stream);
}
static
goto end;
error:
- BT_PUT(writer_stream_class);
+ BT_OBJECT_PUT_REF_AND_RESET(writer_stream_class);
end:
- bt_put(writer_trace);
- bt_put(trace);
+ bt_object_put_ref(writer_trace);
+ bt_object_put_ref(trace);
return writer_stream_class;
}
ret = ctf_copy_trace(writer_component->err, trace, writer_trace);
if (ret != BT_COMPONENT_STATUS_OK) {
BT_LOGE_STR("Failed to copy trace.");
- BT_PUT(ctf_writer);
+ BT_OBJECT_PUT_REF_AND_RESET(ctf_writer);
goto error;
}
fs_writer->trace = trace;
fs_writer->writer_trace = writer_trace;
fs_writer->writer_component = writer_component;
- BT_PUT(writer_trace);
+ BT_OBJECT_PUT_REF_AND_RESET(writer_trace);
fs_writer->stream_class_map = g_hash_table_new_full(g_direct_hash,
g_direct_equal, NULL, (GDestroyNotify) unref_stream_class);
fs_writer->stream_map = g_hash_table_new_full(g_direct_hash,
BT_ASSERT(stream);
insert_new_stream_state(writer_component, fs_writer, stream);
- BT_PUT(stream);
+ BT_OBJECT_PUT_REF_AND_RESET(stream);
}
/* Check if the trace is already static or register a listener. */
error:
g_free(fs_writer);
fs_writer = NULL;
- bt_put(writer_trace);
- bt_put(stream);
- BT_PUT(ctf_writer);
+ bt_object_put_ref(writer_trace);
+ bt_object_put_ref(stream);
+ BT_OBJECT_PUT_REF_AND_RESET(ctf_writer);
end:
return fs_writer;
}
if (!fs_writer) {
fs_writer = insert_new_writer(writer_component, trace);
}
- BT_PUT(trace);
+ BT_OBJECT_PUT_REF_AND_RESET(trace);
return fs_writer;
}
fs_writer = get_fs_writer(writer_component, stream_class);
- bt_put(stream_class);
+ bt_object_put_ref(stream_class);
return fs_writer;
}
{
struct bt_stream *writer_stream = NULL;
struct bt_stream_class *writer_stream_class = NULL;
- struct bt_ctf_writer *ctf_writer = bt_get(fs_writer->writer);
+ struct bt_ctf_writer *ctf_writer = bt_object_get_ref(fs_writer->writer);
writer_stream_class = lookup_stream_class(writer_component,
stream_class);
goto error;
}
}
- bt_get(writer_stream_class);
+ bt_object_get_ref(writer_stream_class);
writer_stream = bt_stream_create(writer_stream_class,
bt_stream_get_name(stream));
goto end;
error:
- BT_PUT(writer_stream);
+ BT_OBJECT_PUT_REF_AND_RESET(writer_stream);
end:
- bt_put(ctf_writer);
- bt_put(writer_stream_class);
+ bt_object_put_ref(ctf_writer);
+ bt_object_put_ref(writer_stream_class);
return writer_stream;
}
BT_LOGE_STR("Failed to find existing stream.");
goto error;
}
- bt_get(writer_stream);
+ bt_object_get_ref(writer_stream);
goto end;
error:
- BT_PUT(writer_stream);
+ BT_OBJECT_PUT_REF_AND_RESET(writer_stream);
end:
return writer_stream;
}
error:
ret = BT_COMPONENT_STATUS_ERROR;
end:
- bt_put(stream_class);
+ bt_object_put_ref(stream_class);
return ret;
}
error:
ret = BT_COMPONENT_STATUS_ERROR;
end:
- BT_PUT(trace);
- BT_PUT(stream_class);
+ BT_OBJECT_PUT_REF_AND_RESET(trace);
+ BT_OBJECT_PUT_REF_AND_RESET(stream_class);
return ret;
}
BT_LOGE_STR("Failed to get writer_stream.");
goto error;
}
- BT_PUT(stream);
+ BT_OBJECT_PUT_REF_AND_RESET(stream);
int_ret = ctf_stream_copy_packet_context(
writer_component->err, packet, writer_stream);
error:
ret = BT_COMPONENT_STATUS_ERROR;
end:
- bt_put(writer_stream);
- bt_put(stream);
+ bt_object_put_ref(writer_stream);
+ bt_object_put_ref(stream);
return ret;
}
BT_LOGE_STR("Failed to find existing stream.");
goto error;
}
- BT_PUT(stream);
+ BT_OBJECT_PUT_REF_AND_RESET(stream);
- bt_get(writer_stream);
+ bt_object_get_ref(writer_stream);
ret = bt_stream_flush(writer_stream);
if (ret) {
goto error;
}
- BT_PUT(writer_stream);
+ BT_OBJECT_PUT_REF_AND_RESET(writer_stream);
ret = BT_COMPONENT_STATUS_OK;
goto end;
error:
ret = BT_COMPONENT_STATUS_ERROR;
end:
- bt_put(writer_stream);
- bt_put(stream);
+ bt_object_put_ref(writer_stream);
+ bt_object_put_ref(stream);
return ret;
}
BT_ASSERT(stream);
writer_stream = lookup_stream(writer_component, stream);
- if (!writer_stream || !bt_get(writer_stream)) {
+ if (!writer_stream || !bt_object_get_ref(writer_stream)) {
BT_LOGE_STR("Failed for find existing stream.");
goto error;
}
BT_ASSERT(stream_class);
writer_stream_class = lookup_stream_class(writer_component, stream_class);
- if (!writer_stream_class || !bt_get(writer_stream_class)) {
+ if (!writer_stream_class || !bt_object_get_ref(writer_stream_class)) {
BT_LOGE_STR("Failed to find existing stream_class.");
goto error;
}
error:
ret = BT_COMPONENT_STATUS_ERROR;
end:
- bt_put(writer_trace);
- bt_put(writer_event);
- bt_put(writer_event_class);
- bt_put(writer_stream_class);
- bt_put(stream_class);
- bt_put(writer_stream);
- bt_put(stream);
- bt_put(event_class);
+ bt_object_put_ref(writer_trace);
+ bt_object_put_ref(writer_event);
+ bt_object_put_ref(writer_event_class);
+ bt_object_put_ref(writer_stream_class);
+ bt_object_put_ref(stream_class);
+ bt_object_put_ref(writer_stream);
+ bt_object_put_ref(stream);
+ bt_object_put_ref(event_class);
return ret;
}