bt_trace *create_new_mapped_trace(struct trace_ir_maps *ir_maps,
const bt_trace *in_trace)
{
bt_trace *create_new_mapped_trace(struct trace_ir_maps *ir_maps,
const bt_trace *in_trace)
{
metadata_maps->output_trace_class =
create_new_mapped_trace_class(ir_maps, in_trace_class);
if (!metadata_maps->output_trace_class) {
metadata_maps->output_trace_class =
create_new_mapped_trace_class(ir_maps, in_trace_class);
if (!metadata_maps->output_trace_class) {
out_trace = bt_trace_create(metadata_maps->output_trace_class);
if (!out_trace) {
BT_COMP_LOGE_STR("Error create output trace");
goto end;
}
out_trace = bt_trace_create(metadata_maps->output_trace_class);
if (!out_trace) {
BT_COMP_LOGE_STR("Error create output trace");
goto end;
}
copy_trace_content(in_trace, out_trace, ir_maps->log_level,
ir_maps->self_comp);
copy_trace_content(in_trace, out_trace, ir_maps->log_level,
ir_maps->self_comp);
bt_stream_class *create_new_mapped_stream_class(struct trace_ir_maps *ir_maps,
const bt_stream_class *in_stream_class)
{
bt_stream_class *create_new_mapped_stream_class(struct trace_ir_maps *ir_maps,
const bt_stream_class *in_stream_class)
{
out_stream_class = bt_stream_class_create_with_id(
md_maps->output_trace_class,
bt_stream_class_get_id(in_stream_class));
out_stream_class = bt_stream_class_create_with_id(
md_maps->output_trace_class,
bt_stream_class_get_id(in_stream_class));
g_hash_table_insert(md_maps->stream_class_map,
(gpointer) in_stream_class, out_stream_class);
g_hash_table_insert(md_maps->stream_class_map,
(gpointer) in_stream_class, out_stream_class);
d_maps = borrow_data_maps_from_input_trace(ir_maps, in_trace);
if (!d_maps->output_trace) {
d_maps = borrow_data_maps_from_input_trace(ir_maps, in_trace);
if (!d_maps->output_trace) {
d_maps->output_trace = create_new_mapped_trace(ir_maps, in_trace);
if (!d_maps->output_trace) {
goto end;
d_maps->output_trace = create_new_mapped_trace(ir_maps, in_trace);
if (!d_maps->output_trace) {
goto end;
md_maps = borrow_metadata_maps_from_input_stream_class(ir_maps, in_stream_class);
out_stream_class = borrow_mapped_stream_class(md_maps, in_stream_class);
if (!out_stream_class) {
md_maps = borrow_metadata_maps_from_input_stream_class(ir_maps, in_stream_class);
out_stream_class = borrow_mapped_stream_class(md_maps, in_stream_class);
if (!out_stream_class) {
copy_stream_content(in_stream, out_stream, ir_maps->log_level,
ir_maps->self_comp);
copy_stream_content(in_stream, out_stream, ir_maps->log_level,
ir_maps->self_comp);
bt_stream *trace_ir_mapping_borrow_mapped_stream(struct trace_ir_maps *ir_maps,
const bt_stream *in_stream)
{
bt_stream *trace_ir_mapping_borrow_mapped_stream(struct trace_ir_maps *ir_maps,
const bt_stream *in_stream)
{
d_maps = borrow_data_maps_from_input_stream(ir_maps, in_stream);
/* Return the mapped stream. */
d_maps = borrow_data_maps_from_input_stream(ir_maps, in_stream);
/* Return the mapped stream. */
struct trace_ir_maps *ir_maps,
const bt_event_class *in_event_class)
{
struct trace_ir_maps *ir_maps,
const bt_event_class *in_event_class)
{
out_stream_class = borrow_mapped_stream_class(md_maps, in_stream_class);
BT_ASSERT(out_stream_class);
out_stream_class = borrow_mapped_stream_class(md_maps, in_stream_class);
BT_ASSERT(out_stream_class);
g_hash_table_insert(md_maps->event_class_map,
(gpointer) in_event_class, out_event_class);
g_hash_table_insert(md_maps->event_class_map,
(gpointer) in_event_class, out_event_class);
in_trace = bt_stream_borrow_trace_const(in_stream);
d_maps = borrow_data_maps_from_input_trace(ir_maps, in_trace);
in_trace = bt_stream_borrow_trace_const(in_stream);
d_maps = borrow_data_maps_from_input_trace(ir_maps, in_trace);
copy_packet_content(in_packet, out_packet, ir_maps->log_level,
ir_maps->self_comp);
copy_packet_content(in_packet, out_packet, ir_maps->log_level,
ir_maps->self_comp);
g_hash_table_insert(d_maps->packet_map,
(gpointer) in_packet, out_packet);
g_hash_table_insert(d_maps->packet_map,
(gpointer) in_packet, out_packet);
void trace_ir_mapping_remove_mapped_packet(struct trace_ir_maps *ir_maps,
const bt_packet *in_packet)
{
void trace_ir_mapping_remove_mapped_packet(struct trace_ir_maps *ir_maps,
const bt_packet *in_packet)
{
void trace_ir_mapping_remove_mapped_stream(struct trace_ir_maps *ir_maps,
const bt_stream *in_stream)
{
void trace_ir_mapping_remove_mapped_stream(struct trace_ir_maps *ir_maps,
const bt_stream *in_stream)
{
struct trace_ir_data_maps *trace_ir_data_maps_create(struct trace_ir_maps *ir_maps,
const bt_trace *in_trace)
{
struct trace_ir_data_maps *trace_ir_data_maps_create(struct trace_ir_maps *ir_maps,
const bt_trace *in_trace)
{
/* Create the hashtables used to map data objects. */
d_maps->stream_map = g_hash_table_new_full(g_direct_hash,
/* Create the hashtables used to map data objects. */
d_maps->stream_map = g_hash_table_new_full(g_direct_hash,
add_listener_status = bt_trace_add_destruction_listener(
in_trace, trace_ir_data_maps_remove_func,
add_listener_status = bt_trace_add_destruction_listener(
in_trace, trace_ir_data_maps_remove_func,
struct trace_ir_maps *ir_maps,
const bt_trace_class *in_trace_class)
{
struct trace_ir_maps *ir_maps,
const bt_trace_class *in_trace_class)
{
struct trace_ir_metadata_maps *md_maps =
g_new0(struct trace_ir_metadata_maps, 1);
struct trace_ir_metadata_maps *md_maps =
g_new0(struct trace_ir_metadata_maps, 1);
struct trace_ir_maps *trace_ir_maps_create(bt_self_component *self_comp,
const char *debug_info_field_name, bt_logging_level log_level)
{
struct trace_ir_maps *trace_ir_maps_create(bt_self_component *self_comp,
const char *debug_info_field_name, bt_logging_level log_level)
{
if (!ir_maps) {
BT_COMP_LOG_CUR_LVL(BT_LOG_ERROR, log_level, self_comp,
"Error allocating trace_ir_maps");
if (!ir_maps) {
BT_COMP_LOG_CUR_LVL(BT_LOG_ERROR, log_level, self_comp,
"Error allocating trace_ir_maps");