X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=liblttng-ust%2Fust-events-internal.h;h=af72aa665fd847a3d7d2d53d6cd33c43b6adf61f;hb=dc325c1d762bbbdc1866e590f4649078f8600664;hp=d79278d7ec513958c1032c4db9c1497bb827cd5d;hpb=e7bc0ef6c86ae97886cf5f8b28854cf281d4962b;p=lttng-ust.git diff --git a/liblttng-ust/ust-events-internal.h b/liblttng-ust/ust-events-internal.h index d79278d7..af72aa66 100644 --- a/liblttng-ust/ust-events-internal.h +++ b/liblttng-ust/ust-events-internal.h @@ -7,6 +7,7 @@ #ifndef _LTTNG_UST_EVENTS_INTERNAL_H #define _LTTNG_UST_EVENTS_INTERNAL_H +#include #include #include @@ -94,13 +95,13 @@ struct lttng_event_notifier_enabler { uint64_t num_captures; }; -enum lttng_ust_bytecode_node_type { - LTTNG_UST_BYTECODE_NODE_TYPE_FILTER, - LTTNG_UST_BYTECODE_NODE_TYPE_CAPTURE, +enum lttng_ust_bytecode_type { + LTTNG_UST_BYTECODE_TYPE_FILTER, + LTTNG_UST_BYTECODE_TYPE_CAPTURE, }; struct lttng_ust_bytecode_node { - enum lttng_ust_bytecode_node_type type; + enum lttng_ust_bytecode_type type; struct cds_list_head node; struct lttng_enabler *enabler; struct { @@ -111,6 +112,26 @@ struct lttng_ust_bytecode_node { } bc; }; +/* + * Bytecode interpreter return value. + */ +enum lttng_ust_bytecode_interpreter_ret { + LTTNG_UST_BYTECODE_INTERPRETER_ERROR = -1, + LTTNG_UST_BYTECODE_INTERPRETER_OK = 0, +}; + +struct lttng_interpreter_output; +struct lttng_ust_bytecode_runtime_private; + +enum lttng_ust_bytecode_filter_result { + LTTNG_UST_BYTECODE_FILTER_ACCEPT = 0, + LTTNG_UST_BYTECODE_FILTER_REJECT = 1, +}; + +struct lttng_ust_bytecode_filter_ctx { + enum lttng_ust_bytecode_filter_result result; +}; + struct lttng_ust_excluder_node { struct cds_list_head node; struct lttng_enabler *enabler; @@ -220,9 +241,9 @@ struct lttng_event_notifier_group { int notification_fd; struct cds_list_head node; /* Event notifier group handle list */ struct cds_list_head enablers_head; - struct cds_list_head event_notifiers_head; /* list of event_notifiers */ + struct cds_list_head event_notifiers_head; /* list of event_notifiers */ struct lttng_ust_event_notifier_ht event_notifiers_ht; /* hashtable of event_notifiers */ - struct lttng_ust_ctx *ctx; /* contexts for filters. */ + struct lttng_ust_ctx *ctx; /* contexts for filters. */ struct lttng_counter *error_counter; size_t error_counter_len; @@ -231,7 +252,7 @@ struct lttng_event_notifier_group { struct lttng_transport { char *name; struct cds_list_head node; - struct lttng_ust_channel_ops ops; + struct lttng_ust_channel_buffer_ops ops; const struct lttng_ust_lib_ring_buffer_config *client_config; }; @@ -248,8 +269,12 @@ struct lttng_ust_event_common_private { struct lttng_ust_event_desc *desc; /* Backward references: list of lttng_enabler_ref (ref to enablers) */ struct cds_list_head enablers_ref_head; - int registered; /* has reg'd tracepoint probe */ + int registered; /* has reg'd tracepoint probe */ uint64_t user_token; + + int has_enablers_without_filter_bytecode; + /* list of struct lttng_ust_bytecode_runtime, sorted by seqnum */ + struct cds_list_head filter_bytecode_runtime_head; }; struct lttng_ust_event_recorder_private { @@ -258,6 +283,7 @@ struct lttng_ust_event_recorder_private { struct lttng_ust_event_recorder *pub; /* Public event interface */ struct cds_list_head node; /* Event recorder list */ struct cds_hlist_node hlist; /* Hash table of event recorders */ + struct lttng_ust_ctx *ctx; }; struct lttng_ust_event_notifier_private { @@ -269,13 +295,17 @@ struct lttng_ust_event_notifier_private { uint64_t error_counter_index; struct cds_list_head node; /* Event notifier list */ struct cds_hlist_node hlist; /* Hash table of event notifiers */ + struct cds_list_head capture_bytecode_runtime_head; }; -struct lttng_ust_bytecode_runtime_private { - struct bytecode_runtime *pub; /* Public bytecode runtime interface */ - +struct lttng_ust_bytecode_runtime { + enum lttng_ust_bytecode_type type; struct lttng_ust_bytecode_node *bc; int link_failed; + int (*interpreter_func)(struct lttng_ust_bytecode_runtime *bytecode_runtime, + const char *interpreter_stack_data, + void *ctx); + struct cds_list_head node; /* list of bytecode runtime in event */ /* * Pointer to a URCU-protected pointer owned by an `struct * lttng_session`or `struct lttng_event_notifier_group`. @@ -292,34 +322,34 @@ struct lttng_ust_session_private { struct cds_list_head events_head; /* list of events */ struct cds_list_head node; /* Session list */ - /* New UST 2.1 */ /* List of enablers */ struct cds_list_head enablers_head; struct lttng_ust_event_ht events_ht; /* ht of events */ void *owner; /* object owner */ int tstate:1; /* Transient enable state */ - /* New UST 2.4 */ int statedump_pending:1; - /* New UST 2.8 */ struct lttng_ust_enum_ht enums_ht; /* ht of enumerations */ struct cds_list_head enums_head; - struct lttng_ust_ctx *ctx; /* contexts for filters. */ + struct lttng_ust_ctx *ctx; /* contexts for filters. */ + + unsigned char uuid[LTTNG_UST_UUID_LEN]; /* Trace session unique ID */ + bool uuid_set; /* Is uuid set ? */ }; struct lttng_enum { struct lttng_ust_enum_desc *desc; struct lttng_ust_session *session; - struct cds_list_head node; /* Enum list in session */ - struct cds_hlist_node hlist; /* Session ht of enums */ - uint64_t id; /* Enumeration ID in sessiond */ + struct cds_list_head node; /* Enum list in session */ + struct cds_hlist_node hlist; /* Session ht of enums */ + uint64_t id; /* Enumeration ID in sessiond */ }; struct lttng_ust_shm_handle; -struct lttng_ust_channel_ops_private { - struct lttng_ust_channel_ops *pub; /* Public channels ops interface */ +struct lttng_ust_channel_buffer_ops_private { + struct lttng_ust_channel_buffer_ops *pub; /* Public channel buffer ops interface */ struct lttng_ust_channel_buffer *(*channel_create)(const char *name, void *buf_addr, @@ -336,29 +366,29 @@ struct lttng_ust_channel_ops_private { * packet. Note that the size returned is only a hint, since it * may change due to concurrent writes. */ - size_t (*packet_avail_size)(struct lttng_ust_lib_ring_buffer_channel *chan, - struct lttng_ust_shm_handle *handle); - int (*is_finalized)(struct lttng_ust_lib_ring_buffer_channel *chan); - int (*is_disabled)(struct lttng_ust_lib_ring_buffer_channel *chan); - int (*flush_buffer)(struct lttng_ust_lib_ring_buffer_channel *chan, - struct lttng_ust_shm_handle *handle); + size_t (*packet_avail_size)(struct lttng_ust_channel_buffer *chan); + int (*is_finalized)(struct lttng_ust_channel_buffer *chan); + int (*is_disabled)(struct lttng_ust_channel_buffer *chan); + int (*flush_buffer)(struct lttng_ust_channel_buffer *chan); }; struct lttng_ust_channel_common_private { struct lttng_ust_channel_common *pub; /* Public channel interface */ - int objd; /* Object associated with channel. */ - int tstate:1; /* Transient enable state */ + int objd; /* Object associated with channel. */ + int tstate:1; /* Transient enable state */ }; struct lttng_ust_channel_buffer_private { struct lttng_ust_channel_common_private parent; struct lttng_ust_channel_buffer *pub; /* Public channel buffer interface */ - struct cds_list_head node; /* Channel list in session */ - int header_type; /* 0: unset, 1: compact, 2: large */ - unsigned int id; /* Channel ID */ + struct cds_list_head node; /* Channel list in session */ + int header_type; /* 0: unset, 1: compact, 2: large */ + unsigned int id; /* Channel ID */ enum lttng_ust_abi_chan_type type; + struct lttng_ust_ctx *ctx; + struct lttng_ust_lib_ring_buffer_channel *rb_chan; /* Ring buffer channel */ unsigned char uuid[LTTNG_UST_UUID_LEN]; /* Trace session unique ID */ }; @@ -479,7 +509,7 @@ struct lttng_ust_type_common *lttng_ust_create_type_array_text(unsigned int leng array_type->alignment = 0; array_type->encoding = lttng_ust_string_encoding_UTF8; array_type->elem_type = lttng_ust_create_type_integer(sizeof(char) * CHAR_BIT, - lttng_alignof(char) * CHAR_BIT, lttng_is_signed_type(char), + lttng_ust_rb_alignof(char) * CHAR_BIT, lttng_ust_is_signed_type(char), BYTE_ORDER, 10); if (!array_type->elem_type) goto error_elem; @@ -724,7 +754,7 @@ struct lttng_counter *lttng_ust_counter_create( const char *counter_transport_name, size_t number_dimensions, const struct lttng_counter_dimension *dimensions); -#ifdef HAVE_PERF_EVENT +#ifdef HAVE_LINUX_PERF_EVENT_H __attribute__((visibility("hidden"))) int lttng_add_perf_counter_to_ctx(uint32_t type, @@ -738,7 +768,7 @@ int lttng_perf_counter_init(void); __attribute__((visibility("hidden"))) void lttng_perf_counter_exit(void); -#else /* #ifdef HAVE_PERF_EVENT */ +#else /* #ifdef HAVE_LINUX_PERF_EVENT_H */ static inline int lttng_add_perf_counter_to_ctx(uint32_t type, @@ -757,7 +787,7 @@ static inline void lttng_perf_counter_exit(void) { } -#endif /* #else #ifdef HAVE_PERF_EVENT */ +#endif /* #else #ifdef HAVE_LINUX_PERF_EVENT_H */ __attribute__((visibility("hidden"))) int lttng_probes_get_event_list(struct lttng_ust_tracepoint_list *list); @@ -861,4 +891,20 @@ struct lttng_ust_channel_buffer *lttng_ust_alloc_channel_buffer(void); __attribute__((visibility("hidden"))) void lttng_ust_free_channel_common(struct lttng_ust_channel_common *chan); +__attribute__((visibility("hidden"))) +int lttng_ust_interpret_event_filter(struct lttng_ust_event_common *event, + const char *interpreter_stack_data, + void *filter_ctx); + +__attribute__((visibility("hidden"))) +int lttng_ust_session_uuid_validate(struct lttng_ust_session *session, + unsigned char *uuid); + +__attribute__((visibility("hidden"))) +bool lttng_ust_validate_event_name(const struct lttng_ust_event_desc *desc); + +__attribute__((visibility("hidden"))) +void lttng_ust_format_event_name(const struct lttng_ust_event_desc *desc, + char *name); + #endif /* _LTTNG_UST_EVENTS_INTERNAL_H */