X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=include%2Fbabeltrace%2Fctf-ir%2Fevent-internal.h;h=dccc5726f3a84e52d49dfd0e51bb3f0522654ad5;hp=d9d0fe3e15b46ebfff0ccedd80ecd4681ddf2c1c;hb=312c056ae3d374b253fa0cfe5ed576c0b0e5e569;hpb=3dca22768a95bef664012559aa9ac977091de6ac diff --git a/include/babeltrace/ctf-ir/event-internal.h b/include/babeltrace/ctf-ir/event-internal.h index d9d0fe3e..dccc5726 100644 --- a/include/babeltrace/ctf-ir/event-internal.h +++ b/include/babeltrace/ctf-ir/event-internal.h @@ -36,6 +36,7 @@ #include #include #include +#include #include #include #include @@ -46,7 +47,7 @@ struct bt_stream_pos; struct bt_event_common { struct bt_object base; struct bt_event_class_common *class; - struct bt_field_common *header_field; + struct bt_field_wrapper *header_field; struct bt_field_common *stream_event_context_field; struct bt_field_common *context_field; struct bt_field_common *payload_field; @@ -83,15 +84,6 @@ void _bt_event_freeze(struct bt_event *event); #define BT_ASSERT_PRE_EVENT_COMMON_HOT(_event, _name) \ BT_ASSERT_PRE_HOT((_event), (_name), ": +%!+_e", (_event)) -static inline struct bt_packet *bt_event_borrow_packet(struct bt_event *event) -{ - BT_ASSERT(event); - return event->packet; -} - -BT_HIDDEN -struct bt_stream *bt_event_borrow_stream(struct bt_event *event); - static inline struct bt_event_class_common *bt_event_common_borrow_class( struct bt_event_common *event) @@ -100,13 +92,6 @@ struct bt_event_class_common *bt_event_common_borrow_class( return event->class; } -static inline -struct bt_event_class *bt_event_borrow_class(struct bt_event *event) -{ - return BT_FROM_COMMON(bt_event_common_borrow_class( - BT_TO_COMMON(event))); -} - BT_HIDDEN int bt_event_common_initialize(struct bt_event_common *event, struct bt_event_class_common *event_class, @@ -117,10 +102,13 @@ int bt_event_common_initialize(struct bt_event_common *event, int (*map_clock_classes_func)(struct bt_stream_class_common *stream_class, struct bt_field_type_common *packet_context_field_type, struct bt_field_type_common *event_header_field_type), - void *(*create_field_func)(void *)); + void *(*create_field_func)(void *), + void (*release_field_func)(void *), + void *(*create_header_field_func)(void *, void *), + void (*release_header_field_func)(void *)); static inline -struct bt_field_common *bt_event_common_get_payload( +struct bt_field_common *bt_event_common_borrow_payload( struct bt_event_common *event) { struct bt_field_common *payload = NULL; @@ -136,47 +124,13 @@ struct bt_field_common *bt_event_common_get_payload( } payload = event->payload_field; - bt_get(payload); end: return payload; } static inline -int bt_event_common_set_payload(struct bt_event_common *event, - struct bt_field_common *payload) -{ - BT_ASSERT_PRE_NON_NULL(event, "Event"); - BT_ASSERT_PRE_EVENT_COMMON_HOT(event, "Event"); - - if (payload) { - BT_ASSERT_PRE(bt_field_type_common_compare(payload->type, - event->class->payload_field_type) == 0, - "Payload field's type is different from the " - "expected field type: %![event-]+_e, %![ft-]+_F, " - "%![expected-ft-]+_F", - event, payload->type, - event->class->payload_field_type); - } else { - BT_ASSERT_PRE(!event->class->payload_field_type, - "Setting no event payload field, " - "but event payload field type is not NULL: ", - "%![event-]+_e, %![payload-ft-]+_F", - event, event->class->payload_field_type); - } - - bt_put(event->payload_field); - event->payload_field = bt_get(payload); - BT_LOGV("Set event's payload field: event-addr=%p, " - "event-class-name=\"%s\", event-class-id=%" PRId64 ", " - "payload-field-addr=%p", - event, bt_event_class_common_get_name(event->class), - bt_event_class_common_get_id(event->class), payload); - return 0; -} - -static inline -struct bt_field_common *bt_event_common_get_header( +struct bt_field_common *bt_event_common_borrow_header( struct bt_event_common *event) { struct bt_field_common *header = NULL; @@ -191,53 +145,14 @@ struct bt_field_common *bt_event_common_get_header( goto end; } - header = event->header_field; - bt_get(header); + header = event->header_field->field; end: return header; } static inline -int bt_event_common_set_header(struct bt_event_common *event, - struct bt_field_common *header) -{ - BT_ASSERT_PRE_NON_NULL(event, "Event"); - BT_ASSERT_PRE_EVENT_COMMON_HOT(event, "Event"); - - /* - * Ensure the provided header's type matches the one registered to the - * stream class. - */ - if (header) { - BT_ASSERT_PRE(bt_field_type_common_compare(header->type, - bt_event_class_common_borrow_stream_class(event->class)->event_header_field_type) == 0, - "Header field's type is different from the " - "expected field type: %![event-]+_e, %![ft-]+_F, " - "%![expected-ft-]+_F", - event, header->type, - bt_event_class_common_borrow_stream_class(event->class)->event_header_field_type); - } else { - BT_ASSERT_PRE(!bt_event_class_common_borrow_stream_class(event->class)->event_header_field_type, - "Setting no event header field, " - "but event header field type is not NULL: ", - "%![event-]+_e, %![header-ft-]+_F", - event, - bt_event_class_common_borrow_stream_class(event->class)->event_header_field_type); - } - - bt_put(event->header_field); - event->header_field = bt_get(header); - BT_LOGV("Set event's header field: event-addr=%p, " - "event-class-name=\"%s\", event-class-id=%" PRId64 ", " - "header-field-addr=%p", - event, bt_event_class_common_get_name(event->class), - bt_event_class_common_get_id(event->class), header); - return 0; -} - -static inline -struct bt_field_common *bt_event_common_get_context( +struct bt_field_common *bt_event_common_borrow_context( struct bt_event_common *event) { struct bt_field_common *context = NULL; @@ -253,46 +168,13 @@ struct bt_field_common *bt_event_common_get_context( } context = event->context_field; - bt_get(context); end: return context; } static inline -int bt_event_common_set_context(struct bt_event_common *event, - struct bt_field_common *context) -{ - BT_ASSERT_PRE_NON_NULL(event, "Event"); - BT_ASSERT_PRE_EVENT_COMMON_HOT(event, "Event"); - - if (context) { - BT_ASSERT_PRE(bt_field_type_common_compare(context->type, - event->class->context_field_type) == 0, - "Context field's type is different from the " - "expected field type: %![event-]+_e, %![ft-]+_F, " - "%![expected-ft-]+_F", - event, context->type, event->class->context_field_type); - } else { - BT_ASSERT_PRE(!event->class->context_field_type, - "Setting no event context field, " - "but event context field type is not NULL: ", - "%![event-]+_e, %![context-ft-]+_F", - event, event->class->context_field_type); - } - - bt_put(event->context_field); - event->context_field = bt_get(context); - BT_LOGV("Set event's context field: event-addr=%p, " - "event-class-name=\"%s\", event-class-id=%" PRId64 ", " - "context-field-addr=%p", - event, bt_event_class_common_get_name(event->class), - bt_event_class_common_get_id(event->class), context); - return 0; -} - -static inline -struct bt_field_common *bt_event_common_get_stream_event_context( +struct bt_field_common *bt_event_common_borrow_stream_event_context( struct bt_event_common *event) { struct bt_field_common *stream_event_context = NULL; @@ -310,54 +192,47 @@ struct bt_field_common *bt_event_common_get_stream_event_context( stream_event_context = event->stream_event_context_field; end: - return bt_get(stream_event_context); -} - -static inline -int bt_event_common_set_stream_event_context(struct bt_event_common *event, - struct bt_field_common *stream_event_context) -{ - BT_ASSERT_PRE_NON_NULL(event, "Event"); - BT_ASSERT_PRE_EVENT_COMMON_HOT(event, "Event"); - - if (stream_event_context) { - BT_ASSERT_PRE(bt_field_type_common_compare(stream_event_context->type, - bt_event_class_common_borrow_stream_class(event->class)->event_context_field_type) == 0, - "Stream event context field's type is different from the " - "expected field type: %![event-]+_e, %![ft-]+_F, " - "%![expected-ft-]+_F", - event, stream_event_context->type, - bt_event_class_common_borrow_stream_class(event->class)->event_context_field_type); - } else { - BT_ASSERT_PRE(!bt_event_class_common_borrow_stream_class(event->class)->event_context_field_type, - "Setting no stream event context field, " - "but stream event context field type is not NULL: ", - "%![event-]+_e, %![context-ft-]+_F", - event, - bt_event_class_common_borrow_stream_class(event->class)->event_context_field_type); - } - - bt_get(stream_event_context); - BT_MOVE(event->stream_event_context_field, stream_event_context); - BT_LOGV("Set event's stream event context field: event-addr=%p, " - "event-class-name=\"%s\", event-class-id=%" PRId64 ", " - "stream-event-context-field-addr=%p", - event, bt_event_class_common_get_name(event->class), - bt_event_class_common_get_id(event->class), - stream_event_context); - return 0; + return stream_event_context; } static inline -void bt_event_common_finalize(struct bt_object *obj) +void bt_event_common_finalize(struct bt_object *obj, + void (*field_release_func)(void *), + void (*header_field_release_func)(void *, struct bt_event_common *)) { struct bt_event_common *event = (void *) obj; BT_LOGD("Destroying event: addr=%p, " "event-class-name=\"%s\", event-class-id=%" PRId64, - event, bt_event_class_common_get_name(event->class), - bt_event_class_common_get_id(event->class)); + event, + event->class ? bt_event_class_common_get_name(event->class) : NULL, + event->class ? bt_event_class_common_get_id(event->class) : INT64_C(-1)); + + if (event->header_field) { + BT_LOGD_STR("Releasing event's header field."); + header_field_release_func(event->header_field, event); + } + + if (event->stream_event_context_field) { + BT_LOGD_STR("Releasing event's stream event context field."); + field_release_func(event->stream_event_context_field); + } + + if (event->context_field) { + BT_LOGD_STR("Releasing event's context field."); + field_release_func(event->context_field); + } + if (event->payload_field) { + BT_LOGD_STR("Releasing event's payload field."); + field_release_func(event->payload_field); + } + + /* + * Leave this after calling header_field_release_func() because + * this function receives the event object and could need its + * class to perform some cleanup. + */ if (!event->base.parent) { /* * Event was keeping a reference to its class since it shared no @@ -366,15 +241,22 @@ void bt_event_common_finalize(struct bt_object *obj) */ bt_put(event->class); } - - bt_put(event->header_field); - BT_LOGD_STR("Putting event's stream event context field."); - bt_put(event->stream_event_context_field); - BT_LOGD_STR("Putting event's context field."); - bt_put(event->context_field); - BT_LOGD_STR("Putting event's payload field."); - bt_put(event->payload_field); - BT_LOGD_STR("Putting event's packet."); } +BT_HIDDEN +struct bt_event *bt_event_new(struct bt_event_class *event_class); + +BT_HIDDEN +struct bt_event *bt_event_create(struct bt_event_class *event_class, + struct bt_packet *packet); + +BT_HIDDEN +void bt_event_recycle(struct bt_event *event); + +BT_HIDDEN +void bt_event_destroy(struct bt_event *event); + +BT_HIDDEN +int bt_event_set_packet(struct bt_event *event, struct bt_packet *packet); + #endif /* BABELTRACE_CTF_IR_EVENT_INTERNAL_H */