1 #ifndef BABELTRACE_CTF_IR_STREAM_CLASS_INTERNAL_H
2 #define BABELTRACE_CTF_IR_STREAM_CLASS_INTERNAL_H
5 * BabelTrace - CTF IR: Stream class internal
7 * Copyright 2013, 2014 Jérémie Galarneau <jeremie.galarneau@efficios.com>
9 * Author: Jérémie Galarneau <jeremie.galarneau@efficios.com>
11 * Permission is hereby granted, free of charge, to any person obtaining a copy
12 * of this software and associated documentation files (the "Software"), to deal
13 * in the Software without restriction, including without limitation the rights
14 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
15 * copies of the Software, and to permit persons to whom the Software is
16 * furnished to do so, subject to the following conditions:
18 * The above copyright notice and this permission notice shall be included in
19 * all copies or substantial portions of the Software.
21 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
22 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
23 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
24 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
25 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
26 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
30 #include <babeltrace/assert-internal.h>
31 #include <babeltrace/common-internal.h>
32 #include <babeltrace/ctf-ir/validation-internal.h>
33 #include <babeltrace/ctf-ir/field-types-internal.h>
34 #include <babeltrace/ctf-ir/utils-internal.h>
35 #include <babeltrace/ctf-ir/visitor.h>
36 #include <babeltrace/object-internal.h>
37 #include <babeltrace/babeltrace-internal.h>
41 struct bt_stream_class_common
{
42 struct bt_object base
;
45 /* Array of pointers to event class addresses */
46 GPtrArray
*event_classes
;
48 /* event class id (int64_t) to event class address */
49 GHashTable
*event_classes_ht
;
52 int64_t next_event_id
;
53 struct bt_field_type_common
*packet_context_field_type
;
54 struct bt_field_type_common
*event_header_field_type
;
55 struct bt_field_type_common
*event_context_field_type
;
60 * This flag indicates if the stream class is valid. A valid
61 * stream class is _always_ frozen.
66 * Unique clock class mapped to any field type within this
67 * stream class, including all the stream class's event class
68 * field types. This is only set if the stream class is frozen.
70 * If the stream class is frozen and this is still NULL, it is
71 * still possible that it becomes non-NULL because
72 * bt_stream_class_add_event_class() can add an event class
73 * containing a field type mapped to some clock class. In this
74 * case, this is the mapped clock class, and at this point, both
75 * the new event class and the stream class are frozen, so the
76 * next added event classes are expected to contain field types
77 * which only map to this specific clock class.
79 * If this is a CTF writer stream class, then this is the
80 * backing clock class of the `clock` member above.
82 struct bt_clock_class
*clock_class
;
85 struct bt_stream_class
{
86 struct bt_stream_class_common common
;
89 struct bt_event_class_common
;
92 int bt_stream_class_common_initialize(struct bt_stream_class_common
*stream_class
,
93 const char *name
, bt_object_release_func release_func
);
96 void bt_stream_class_common_finalize(struct bt_stream_class_common
*stream_class
);
99 void bt_stream_class_common_freeze(struct bt_stream_class_common
*stream_class
);
102 void bt_stream_class_freeze(struct bt_stream_class
*stream_class
);
105 const char *bt_stream_class_common_get_name(
106 struct bt_stream_class_common
*stream_class
)
108 BT_ASSERT_PRE_NON_NULL(stream_class
, "Stream class");
109 return stream_class
->name
->len
> 0 ? stream_class
->name
->str
: NULL
;
113 int64_t bt_stream_class_common_get_id(
114 struct bt_stream_class_common
*stream_class
)
118 BT_ASSERT_PRE_NON_NULL(stream_class
, "Stream class");
120 if (!stream_class
->id_set
) {
121 BT_LOGV("Stream class's ID is not set: addr=%p, name=\"%s\"",
123 bt_stream_class_common_get_name(stream_class
));
128 ret
= stream_class
->id
;
135 void bt_stream_class_common_set_byte_order(
136 struct bt_stream_class_common
*stream_class
, int byte_order
);
139 int bt_stream_class_common_validate_single_clock_class(
140 struct bt_stream_class_common
*stream_class
,
141 struct bt_clock_class
**expected_clock_class
);
144 int bt_stream_class_common_add_event_class(
145 struct bt_stream_class_common
*stream_class
,
146 struct bt_event_class_common
*event_class
,
147 bt_validation_flag_copy_field_type_func copy_field_type_func
);
150 int bt_stream_class_common_visit(struct bt_stream_class_common
*stream_class
,
151 bt_visitor visitor
, void *data
);
154 struct bt_trace_common
*bt_stream_class_common_borrow_trace(
155 struct bt_stream_class_common
*stream_class
)
157 BT_ASSERT(stream_class
);
158 return (void *) bt_object_borrow_parent(stream_class
);
162 struct bt_trace
*bt_stream_class_borrow_trace(
163 struct bt_stream_class
*stream_class
)
165 return BT_FROM_COMMON(bt_stream_class_common_borrow_trace(
166 BT_TO_COMMON(stream_class
)));
170 struct bt_trace_common
*bt_stream_class_common_get_trace(
171 struct bt_stream_class_common
*stream_class
)
173 BT_ASSERT_PRE_NON_NULL(stream_class
, "Stream class");
174 return bt_get(bt_stream_class_common_borrow_trace(stream_class
));
178 int bt_stream_class_common_set_name(struct bt_stream_class_common
*stream_class
,
184 BT_LOGW_STR("Invalid parameter: stream class is NULL.");
189 if (stream_class
->frozen
) {
190 BT_LOGW("Invalid parameter: stream class is frozen: "
191 "addr=%p, name=\"%s\", id=%" PRId64
,
193 bt_stream_class_common_get_name(stream_class
),
194 bt_stream_class_common_get_id(stream_class
));
200 g_string_assign(stream_class
->name
, "");
202 if (strlen(name
) == 0) {
203 BT_LOGW("Invalid parameter: name is empty.");
208 g_string_assign(stream_class
->name
, name
);
211 BT_LOGV("Set stream class's name: "
212 "addr=%p, name=\"%s\", id=%" PRId64
,
213 stream_class
, bt_stream_class_common_get_name(stream_class
),
214 bt_stream_class_common_get_id(stream_class
));
220 void _bt_stream_class_common_set_id(
221 struct bt_stream_class_common
*stream_class
, int64_t id
)
223 BT_ASSERT(stream_class
);
224 stream_class
->id
= id
;
225 stream_class
->id_set
= 1;
226 BT_LOGV("Set stream class's ID (internal): "
227 "addr=%p, name=\"%s\", id=%" PRId64
,
228 stream_class
, bt_stream_class_common_get_name(stream_class
),
229 bt_stream_class_common_get_id(stream_class
));
233 int bt_stream_class_common_set_id_no_check(
234 struct bt_stream_class_common
*stream_class
, int64_t id
)
236 _bt_stream_class_common_set_id(stream_class
, id
);
241 int bt_stream_class_common_set_id(struct bt_stream_class_common
*stream_class
,
245 int64_t id
= (int64_t) id_param
;
248 BT_LOGW_STR("Invalid parameter: stream class is NULL.");
253 if (stream_class
->frozen
) {
254 BT_LOGW("Invalid parameter: stream class is frozen: "
255 "addr=%p, name=\"%s\", id=%" PRId64
,
257 bt_stream_class_common_get_name(stream_class
),
258 bt_stream_class_common_get_id(stream_class
));
264 BT_LOGW("Invalid parameter: invalid stream class's ID: "
265 "stream-class-addr=%p, stream-class-name=\"%s\", "
266 "stream-class-id=%" PRId64
", id=%" PRIu64
,
268 bt_stream_class_common_get_name(stream_class
),
269 bt_stream_class_common_get_id(stream_class
),
275 ret
= bt_stream_class_common_set_id_no_check(stream_class
, id
);
277 BT_LOGV("Set stream class's ID: "
278 "addr=%p, name=\"%s\", id=%" PRId64
,
280 bt_stream_class_common_get_name(stream_class
),
281 bt_stream_class_common_get_id(stream_class
));
288 int64_t bt_stream_class_common_get_event_class_count(
289 struct bt_stream_class_common
*stream_class
)
294 BT_LOGW_STR("Invalid parameter: stream class is NULL.");
299 ret
= (int64_t) stream_class
->event_classes
->len
;
305 struct bt_event_class_common
*bt_stream_class_common_get_event_class_by_index(
306 struct bt_stream_class_common
*stream_class
, uint64_t index
)
308 BT_ASSERT_PRE_NON_NULL(stream_class
, "Stream class");
309 BT_ASSERT_PRE(index
< stream_class
->event_classes
->len
,
310 "Index is out of bounds: index=%" PRIu64
", "
312 index
, stream_class
->event_classes
->len
);
313 return bt_get(g_ptr_array_index(stream_class
->event_classes
, index
));
317 struct bt_event_class_common
*bt_stream_class_common_get_event_class_by_id(
318 struct bt_stream_class_common
*stream_class
, uint64_t id
)
320 int64_t id_key
= (int64_t) id
;
322 BT_ASSERT_PRE_NON_NULL(stream_class
, "Stream class");
323 BT_ASSERT_PRE(id_key
>= 0,
324 "Invalid event class ID: %" PRIu64
, id
);
325 return bt_get(g_hash_table_lookup(stream_class
->event_classes_ht
,
330 struct bt_field_type_common
*bt_stream_class_common_get_packet_context_field_type(
331 struct bt_stream_class_common
*stream_class
)
333 BT_ASSERT_PRE_NON_NULL(stream_class
, "Stream class");
334 return bt_get(stream_class
->packet_context_field_type
);
338 int bt_stream_class_common_set_packet_context_field_type(
339 struct bt_stream_class_common
*stream_class
,
340 struct bt_field_type_common
*packet_context_type
)
345 BT_LOGW_STR("Invalid parameter: stream class is NULL.");
350 if (stream_class
->frozen
) {
351 BT_LOGW("Invalid parameter: stream class is frozen: "
352 "addr=%p, name=\"%s\", id=%" PRId64
,
353 stream_class
, bt_stream_class_common_get_name(stream_class
),
354 bt_stream_class_common_get_id(stream_class
));
359 if (packet_context_type
&&
360 bt_field_type_common_get_type_id(packet_context_type
) !=
361 BT_FIELD_TYPE_ID_STRUCT
) {
362 /* A packet context must be a structure. */
363 BT_LOGW("Invalid parameter: stream class's packet context field type must be a structure: "
364 "addr=%p, name=\"%s\", id=%" PRId64
", "
365 "packet-context-ft-addr=%p, packet-context-ft-id=%s",
366 stream_class
, bt_stream_class_common_get_name(stream_class
),
367 bt_stream_class_common_get_id(stream_class
),
369 bt_common_field_type_id_string(
370 bt_field_type_common_get_type_id(packet_context_type
)));
375 bt_put(stream_class
->packet_context_field_type
);
376 bt_get(packet_context_type
);
377 stream_class
->packet_context_field_type
= packet_context_type
;
378 BT_LOGV("Set stream class's packet context field type: "
379 "addr=%p, name=\"%s\", id=%" PRId64
", "
380 "packet-context-ft-addr=%p",
381 stream_class
, bt_stream_class_common_get_name(stream_class
),
382 bt_stream_class_common_get_id(stream_class
),
383 packet_context_type
);
390 struct bt_field_type_common
*bt_stream_class_common_get_event_header_field_type(
391 struct bt_stream_class_common
*stream_class
)
393 struct bt_field_type_common
*ret
= NULL
;
395 BT_ASSERT_PRE_NON_NULL(stream_class
, "Stream class");
397 if (!stream_class
->event_header_field_type
) {
398 BT_LOGV("Stream class has no event header field type: "
399 "addr=%p, name=\"%s\", id=%" PRId64
,
401 bt_stream_class_common_get_name(stream_class
),
402 bt_stream_class_common_get_id(stream_class
));
406 ret
= bt_get(stream_class
->event_header_field_type
);
413 int bt_stream_class_common_set_event_header_field_type(
414 struct bt_stream_class_common
*stream_class
,
415 struct bt_field_type_common
*event_header_type
)
420 BT_LOGW_STR("Invalid parameter: stream class is NULL.");
425 if (stream_class
->frozen
) {
426 BT_LOGW("Invalid parameter: stream class is frozen: "
427 "addr=%p, name=\"%s\", id=%" PRId64
,
429 bt_stream_class_common_get_name(stream_class
),
430 bt_stream_class_common_get_id(stream_class
));
435 if (event_header_type
&&
436 bt_field_type_common_get_type_id(event_header_type
) !=
437 BT_FIELD_TYPE_ID_STRUCT
) {
438 /* An event header must be a structure. */
439 BT_LOGW("Invalid parameter: stream class's event header field type must be a structure: "
440 "addr=%p, name=\"%s\", id=%" PRId64
", "
441 "event-header-ft-addr=%p, event-header-ft-id=%s",
442 stream_class
, bt_stream_class_common_get_name(stream_class
),
443 bt_stream_class_common_get_id(stream_class
),
445 bt_common_field_type_id_string(
446 bt_field_type_common_get_type_id(event_header_type
)));
451 bt_put(stream_class
->event_header_field_type
);
452 stream_class
->event_header_field_type
= bt_get(event_header_type
);
453 BT_LOGV("Set stream class's event header field type: "
454 "addr=%p, name=\"%s\", id=%" PRId64
", "
455 "event-header-ft-addr=%p",
456 stream_class
, bt_stream_class_common_get_name(stream_class
),
457 bt_stream_class_common_get_id(stream_class
),
464 struct bt_field_type_common
*bt_stream_class_common_get_event_context_field_type(
465 struct bt_stream_class_common
*stream_class
)
467 struct bt_field_type_common
*ret
= NULL
;
469 BT_ASSERT_PRE_NON_NULL(stream_class
, "Stream class");
471 if (!stream_class
->event_context_field_type
) {
475 ret
= bt_get(stream_class
->event_context_field_type
);
482 int bt_stream_class_common_set_event_context_field_type(
483 struct bt_stream_class_common
*stream_class
,
484 struct bt_field_type_common
*event_context_type
)
489 BT_LOGW_STR("Invalid parameter: stream class is NULL.");
494 if (stream_class
->frozen
) {
495 BT_LOGW("Invalid parameter: stream class is frozen: "
496 "addr=%p, name=\"%s\", id=%" PRId64
,
497 stream_class
, bt_stream_class_common_get_name(stream_class
),
498 bt_stream_class_common_get_id(stream_class
));
503 if (event_context_type
&&
504 bt_field_type_common_get_type_id(event_context_type
) !=
505 BT_FIELD_TYPE_ID_STRUCT
) {
506 /* A packet context must be a structure. */
507 BT_LOGW("Invalid parameter: stream class's event context field type must be a structure: "
508 "addr=%p, name=\"%s\", id=%" PRId64
", "
509 "event-context-ft-addr=%p, event-context-ft-id=%s",
510 stream_class
, bt_stream_class_common_get_name(stream_class
),
511 bt_stream_class_common_get_id(stream_class
),
513 bt_common_field_type_id_string(
514 bt_field_type_common_get_type_id(event_context_type
)));
519 bt_put(stream_class
->event_context_field_type
);
520 stream_class
->event_context_field_type
= bt_get(event_context_type
);
521 BT_LOGV("Set stream class's event context field type: "
522 "addr=%p, name=\"%s\", id=%" PRId64
", "
523 "event-context-ft-addr=%p",
524 stream_class
, bt_stream_class_common_get_name(stream_class
),
525 bt_stream_class_common_get_id(stream_class
),
531 #endif /* BABELTRACE_CTF_IR_STREAM_CLASS_INTERNAL_H */