X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Flttng-events.c;h=b6375338bc822ed3ecd83da5f221bafd5aeaf30a;hb=3622cd4764b4d108ffc4c2074a359bf1b3edf86e;hp=a6a7904e2e2133cec6b060372dbbe704971cbad7;hpb=1e06b222ea9254fc9e8c82a613d52c92e01fe55d;p=lttng-modules.git diff --git a/src/lttng-events.c b/src/lttng-events.c index a6a7904e..b6375338 100644 --- a/src/lttng-events.c +++ b/src/lttng-events.c @@ -2222,6 +2222,15 @@ void lttng_create_event_if_missing(struct lttng_event_enabler_common *event_enab } } +static +void lttng_event_enabler_init_event_filter(struct lttng_event_enabler_common *event_enabler, + struct lttng_kernel_event_common *event) +{ + /* Link filter bytecodes if not linked yet. */ + lttng_enabler_link_bytecode(event->priv->desc, lttng_static_ctx, + &event->priv->filter_bytecode_runtime_head, &event_enabler->filter_bytecode_head); +} + static void lttng_event_enabler_init_event_capture(struct lttng_event_enabler_common *event_enabler, struct lttng_kernel_event_common *event) @@ -2254,75 +2263,25 @@ void lttng_event_enabler_init_event_capture(struct lttng_event_enabler_common *e * Should be called with sessions mutex held. */ static -int lttng_event_enabler_ref_events(struct lttng_event_recorder_enabler *event_enabler) +int lttng_event_enabler_ref_events(struct lttng_event_enabler_common *event_enabler) { - struct lttng_event_enabler_common *base_enabler = lttng_event_recorder_enabler_as_enabler(event_enabler); - struct lttng_kernel_event_recorder_private *event_recorder_priv; - struct list_head *event_list_head = lttng_get_event_list_head_from_enabler(&event_enabler->parent); + struct list_head *event_list_head = lttng_get_event_list_head_from_enabler(event_enabler); + struct lttng_kernel_event_common_private *event_priv; - lttng_syscall_table_set_wildcard_all(base_enabler); + lttng_syscall_table_set_wildcard_all(event_enabler); /* First ensure that probe events are created for this enabler. */ - lttng_create_event_if_missing(&event_enabler->parent); + lttng_create_event_if_missing(event_enabler); - /* For each event matching event_enabler in session event list. */ - list_for_each_entry(event_recorder_priv, event_list_head, parent.node) { - struct lttng_kernel_event_recorder *event_recorder = event_recorder_priv->pub; + /* Link the created event with its associated enabler. */ + list_for_each_entry(event_priv, event_list_head, node) { + struct lttng_kernel_event_common *event = event_priv->pub; struct lttng_enabler_ref *enabler_ref; - if (!lttng_event_enabler_match_event(&event_enabler->parent, &event_recorder->parent)) + if (!lttng_event_enabler_match_event(event_enabler, event)) continue; - enabler_ref = lttng_enabler_ref(&event_recorder_priv->parent.enablers_ref_head, - lttng_event_recorder_enabler_as_enabler(event_enabler)); - if (!enabler_ref) { - /* - * If no backward ref, create it. - * Add backward ref from event to event_enabler. - */ - enabler_ref = kzalloc(sizeof(*enabler_ref), GFP_KERNEL); - if (!enabler_ref) - return -ENOMEM; - enabler_ref->ref = lttng_event_recorder_enabler_as_enabler(event_enabler); - list_add(&enabler_ref->node, - &event_recorder_priv->parent.enablers_ref_head); - } - /* - * Link filter bytecodes if not linked yet. - */ - lttng_enabler_link_bytecode(event_recorder_priv->parent.desc, - lttng_static_ctx, - &event_recorder_priv->parent.filter_bytecode_runtime_head, - <tng_event_recorder_enabler_as_enabler(event_enabler)->filter_bytecode_head); - } - return 0; -} - -/* - * Create event_notifiers associated with a event_notifier enabler (if not already present). - */ -static -int lttng_event_notifier_enabler_ref_event_notifiers( - struct lttng_event_notifier_enabler *event_notifier_enabler) -{ - struct lttng_kernel_event_notifier_private *event_notifier_priv; - struct list_head *event_list_head = lttng_get_event_list_head_from_enabler(&event_notifier_enabler->parent); - - lttng_syscall_table_set_wildcard_all(&event_notifier_enabler->parent); - - /* First ensure that probe event_notifiers are created for this enabler. */ - lttng_create_event_if_missing(&event_notifier_enabler->parent); - - /* Link the created event_notifier with its associated enabler. */ - list_for_each_entry(event_notifier_priv, event_list_head, parent.node) { - struct lttng_kernel_event_notifier *event_notifier = event_notifier_priv->pub; - struct lttng_enabler_ref *enabler_ref; - - if (!lttng_event_enabler_match_event(&event_notifier_enabler->parent, &event_notifier->parent)) - continue; - - enabler_ref = lttng_enabler_ref(&event_notifier_priv->parent.enablers_ref_head, - lttng_event_notifier_enabler_as_enabler(event_notifier_enabler)); + enabler_ref = lttng_enabler_ref(&event_priv->enablers_ref_head, event_enabler); if (!enabler_ref) { /* * If no backward ref, create it. @@ -2332,20 +2291,12 @@ int lttng_event_notifier_enabler_ref_event_notifiers( if (!enabler_ref) return -ENOMEM; - enabler_ref->ref = lttng_event_notifier_enabler_as_enabler( - event_notifier_enabler); - list_add(&enabler_ref->node, - &event_notifier_priv->parent.enablers_ref_head); + enabler_ref->ref = event_enabler; + list_add(&enabler_ref->node, &event_priv->enablers_ref_head); } - /* - * Link filter bytecodes if not linked yet. - */ - lttng_enabler_link_bytecode(event_notifier_priv->parent.desc, - lttng_static_ctx, &event_notifier_priv->parent.filter_bytecode_runtime_head, - <tng_event_notifier_enabler_as_enabler(event_notifier_enabler)->filter_bytecode_head); - - lttng_event_enabler_init_event_capture(&event_notifier_enabler->parent, &event_notifier->parent); + lttng_event_enabler_init_event_filter(event_enabler, event); + lttng_event_enabler_init_event_capture(event_enabler, event); } return 0; } @@ -2659,7 +2610,7 @@ void lttng_session_sync_event_enablers(struct lttng_kernel_session *session) struct lttng_kernel_event_recorder_private *event_recorder_priv; list_for_each_entry(event_enabler, &session->priv->enablers_head, node) - lttng_event_enabler_ref_events(event_enabler); + lttng_event_enabler_ref_events(&event_enabler->parent); /* * For each event, if at least one of its enablers is enabled, * and its channel and session transient states are enabled, we @@ -2754,7 +2705,7 @@ void lttng_event_notifier_group_sync_enablers(struct lttng_event_notifier_group struct lttng_kernel_event_notifier_private *event_notifier_priv; list_for_each_entry(event_notifier_enabler, &event_notifier_group->enablers_head, node) - lttng_event_notifier_enabler_ref_event_notifiers(event_notifier_enabler); + lttng_event_enabler_ref_events(&event_notifier_enabler->parent); /* * For each event_notifier, if at least one of its enablers is enabled,