flt.lttng-utils.debug-info: use BT_COMP_LOG*() instead of BT_LOG*()
[babeltrace.git] / src / plugins / lttng-utils / debug-info / trace-ir-mapping.h
CommitLineData
ca9f27f3
FD
1#ifndef BABELTRACE_PLUGIN_DEBUG_INFO_TRACE_IR_MAPPING_H
2#define BABELTRACE_PLUGIN_DEBUG_INFO_TRACE_IR_MAPPING_H
3/*
4 * Copyright 2019 Francis Deslauriers francis.deslauriers@efficios.com>
5 *
6 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 * of this software and associated documentation files (the "Software"), to deal
8 * in the Software without restriction, including without limitation the rights
9 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10 * copies of the Software, and to permit persons to whom the Software is
11 * furnished to do so, subject to the following conditions:
12 *
13 * The above copyright notice and this permission notice shall be included in
14 * all copies or substantial portions of the Software.
15 *
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
19 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
22 * SOFTWARE.
23 */
24
25#include <glib.h>
26
578e048b 27#include "common/assert.h"
91d81473 28#include "common/macros.h"
3fadfbc0 29#include <babeltrace2/babeltrace.h>
ca9f27f3
FD
30
31#include "debug-info.h"
32
33/* Used to resolve field paths for dynamic arrays and variant field classes. */
34struct field_class_resolving_context {
35 /* Weak reference. Owned by input stream class. */
36 const bt_field_class *packet_context;
37 /* Weak reference. Owned by input stream class. */
38 const bt_field_class *event_common_context;
39 /* Weak reference. Owned by input event class. */
40 const bt_field_class *event_specific_context;
41 /* Weak reference. Owned by input event class. */
42 const bt_field_class *event_payload;
43};
44
45struct trace_ir_metadata_maps {
3a3d15f3 46 bt_logging_level log_level;
91bc8451 47 bt_self_component *self_comp;
ca9f27f3
FD
48 const bt_trace_class *input_trace_class;
49 bt_trace_class *output_trace_class;
50
51 /*
52 * Map between input stream class and its corresponding output stream
53 * class.
54 * input stream class: weak reference. Owned by an upstream
55 * component.
56 * output stream class: owned by this structure.
57 */
58 GHashTable *stream_class_map;
59
60 /*
61 * Map between input event class and its corresponding output event
62 * class.
63 * input event class: weak reference. Owned by an upstream component.
64 * output event class: owned by this structure.
65 */
66 GHashTable *event_class_map;
67
68 /*
69 * Map between input field class and its corresponding output field
70 * class.
71 * input field class: weak reference. Owned by an upstream component.
72 * output field class: owned by this structure.
73 */
74 GHashTable *field_class_map;
75
76 /*
77 * Map between input clock class and its corresponding output clock
78 * class.
79 * input clock class: weak reference. Owned by an upstream component.
80 * output clock class: owned by this structure.
81 */
82 GHashTable *clock_class_map;
83
84 struct field_class_resolving_context *fc_resolving_ctx;
85
86 uint64_t destruction_listener_id;
87};
88
89struct trace_ir_data_maps {
3a3d15f3 90 bt_logging_level log_level;
91bc8451 91 bt_self_component *self_comp;
ca9f27f3
FD
92 const bt_trace *input_trace;
93 bt_trace *output_trace;
94
95 /*
96 * Map between input stream its corresponding output stream.
97 * input stream: weak reference. Owned by an upstream component.
98 * output stream: owned by this structure.
99 */
100 GHashTable *stream_map;
101
102 /*
103 * Map between input packet its corresponding output packet.
104 * input packet: weak reference. Owned by an upstream packet component.
105 * output packet: owned by this structure.
106 */
107 GHashTable *packet_map;
108
109 uint64_t destruction_listener_id;
110};
111
112struct trace_ir_maps {
3a3d15f3
PP
113 bt_logging_level log_level;
114
ca9f27f3
FD
115 /*
116 * input trace -> trace_ir_data_maps.
117 * input trace: weak reference. Owned by an upstream component.
118 * trace_ir_data_maps: Owned by this structure.
119 */
120 GHashTable *data_maps;
121
122 /*
123 * input trace class -> trace_ir_metadata_maps.
124 * input trace class: weak reference. Owned by an upstream component.
125 * trace_ir_metadata_maps: Owned by this structure.
126 */
127 GHashTable *metadata_maps;
128
129 char *debug_info_field_class_name;
130
131 bt_self_component *self_comp;
132};
133
134BT_HIDDEN
135struct trace_ir_maps *trace_ir_maps_create(bt_self_component *self_comp,
3a3d15f3 136 const char *debug_info_field_name, bt_logging_level log_level);
ca9f27f3
FD
137
138BT_HIDDEN
139void trace_ir_maps_clear(struct trace_ir_maps *maps);
140
141BT_HIDDEN
142void trace_ir_maps_destroy(struct trace_ir_maps *maps);
143
144BT_HIDDEN
145struct trace_ir_data_maps *trace_ir_data_maps_create(
146 struct trace_ir_maps *ir_maps,
147 const bt_trace *in_trace);
148
149BT_HIDDEN
150void trace_ir_data_maps_destroy(struct trace_ir_data_maps *d_maps);
151
152BT_HIDDEN
153struct trace_ir_metadata_maps *trace_ir_metadata_maps_create(
154 struct trace_ir_maps *ir_maps,
155 const bt_trace_class *in_trace_class);
156
157BT_HIDDEN
158void trace_ir_metadata_maps_destroy(struct trace_ir_metadata_maps *md_maps);
159
160BT_HIDDEN
161bt_stream *trace_ir_mapping_create_new_mapped_stream(
162 struct trace_ir_maps *ir_maps,
163 const bt_stream *in_stream);
164
165BT_HIDDEN
166bt_stream *trace_ir_mapping_borrow_mapped_stream(
167 struct trace_ir_maps *ir_maps,
168 const bt_stream *in_stream);
169
170BT_HIDDEN
171void trace_ir_mapping_remove_mapped_stream(
172 struct trace_ir_maps *ir_maps,
173 const bt_stream *in_stream);
174
175BT_HIDDEN
176bt_event_class *trace_ir_mapping_create_new_mapped_event_class(
177 struct trace_ir_maps *ir_maps,
178 const bt_event_class *in_event_class);
179
180BT_HIDDEN
181bt_event_class *trace_ir_mapping_borrow_mapped_event_class(
182 struct trace_ir_maps *ir_maps,
183 const bt_event_class *in_event_class);
184
185BT_HIDDEN
186bt_packet *trace_ir_mapping_create_new_mapped_packet(
187 struct trace_ir_maps *ir_maps,
188 const bt_packet *in_packet);
189
190BT_HIDDEN
191bt_packet *trace_ir_mapping_borrow_mapped_packet(
192 struct trace_ir_maps *ir_maps,
193 const bt_packet *in_packet);
194
195BT_HIDDEN
196void trace_ir_mapping_remove_mapped_packet(
197 struct trace_ir_maps *ir_maps,
198 const bt_packet *in_packet);
199
200static inline
201struct trace_ir_data_maps *borrow_data_maps_from_input_trace(
202 struct trace_ir_maps *ir_maps, const bt_trace *in_trace)
203{
204 BT_ASSERT(ir_maps);
205 BT_ASSERT(in_trace);
206
207 struct trace_ir_data_maps *d_maps =
208 g_hash_table_lookup(ir_maps->data_maps, (gpointer) in_trace);
209 if (!d_maps) {
210 d_maps = trace_ir_data_maps_create(ir_maps, in_trace);
211 g_hash_table_insert(ir_maps->data_maps, (gpointer) in_trace, d_maps);
212 }
213
214 return d_maps;
215}
216
217static inline
218struct trace_ir_data_maps *borrow_data_maps_from_input_stream(
219 struct trace_ir_maps *ir_maps, const bt_stream *in_stream)
220{
221 BT_ASSERT(ir_maps);
222 BT_ASSERT(in_stream);
223
224 return borrow_data_maps_from_input_trace(ir_maps,
225 bt_stream_borrow_trace_const(in_stream));
226}
227
228static inline
229struct trace_ir_data_maps *borrow_data_maps_from_input_packet(
230 struct trace_ir_maps *ir_maps, const bt_packet *in_packet)
231{
232 BT_ASSERT(ir_maps);
233 BT_ASSERT(in_packet);
234
235 return borrow_data_maps_from_input_stream(ir_maps,
236 bt_packet_borrow_stream_const(in_packet));
237}
238
239static inline
240struct trace_ir_metadata_maps *borrow_metadata_maps_from_input_trace_class(
241 struct trace_ir_maps *ir_maps,
242 const bt_trace_class *in_trace_class)
243{
244 BT_ASSERT(ir_maps);
245 BT_ASSERT(in_trace_class);
246
247 struct trace_ir_metadata_maps *md_maps =
248 g_hash_table_lookup(ir_maps->metadata_maps,
249 (gpointer) in_trace_class);
250 if (!md_maps) {
251 md_maps = trace_ir_metadata_maps_create(ir_maps, in_trace_class);
252 g_hash_table_insert(ir_maps->metadata_maps,
253 (gpointer) in_trace_class, md_maps);
254 }
255
256 return md_maps;
257}
258
259static inline
260struct trace_ir_metadata_maps *borrow_metadata_maps_from_input_stream_class(
261 struct trace_ir_maps *ir_maps,
262 const bt_stream_class *in_stream_class) {
263
264 BT_ASSERT(in_stream_class);
265
266 return borrow_metadata_maps_from_input_trace_class(ir_maps,
267 bt_stream_class_borrow_trace_class_const(in_stream_class));
268}
269
270static inline
271struct trace_ir_metadata_maps *borrow_metadata_maps_from_input_event_class(
272 struct trace_ir_maps *ir_maps,
273 const bt_event_class *in_event_class) {
274
275 BT_ASSERT(in_event_class);
276
277 return borrow_metadata_maps_from_input_stream_class(ir_maps,
278 bt_event_class_borrow_stream_class_const(in_event_class));
279}
280
281#endif /* BABELTRACE_PLUGIN_DEBUG_INFO_TRACE_IR_MAPPING_H */
This page took 0.039389 seconds and 4 git commands to generate.