X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fnotification-thread-events.c;h=ccd285a8103d6a344bcb3344abbd982f079a0c13;hp=7fea927d8ba57015e5d5a228383ab0aec4f4de07;hb=98dfca790cb8fcd3bac11a4f4f58c933f99d2a1a;hpb=82b3cbf431e12b5c5f65eaa474d0328fb86ece87

diff --git a/src/bin/lttng-sessiond/notification-thread-events.c b/src/bin/lttng-sessiond/notification-thread-events.c
index 7fea927d8..ccd285a81 100644
--- a/src/bin/lttng-sessiond/notification-thread-events.c
+++ b/src/bin/lttng-sessiond/notification-thread-events.c
@@ -21,6 +21,8 @@
 #include <common/macros.h>
 #include <lttng/condition/condition.h>
 #include <lttng/action/action-internal.h>
+#include <lttng/action/group-internal.h>
+#include <lttng/domain-internal.h>
 #include <lttng/notification/notification-internal.h>
 #include <lttng/condition/condition-internal.h>
 #include <lttng/condition/buffer-usage-internal.h>
@@ -4350,6 +4352,7 @@ int dispatch_one_event_notifier_notification(struct notification_thread_state *s
 	struct notification_client_list *client_list = NULL;
 	const char *trigger_name;
 	int ret;
+	unsigned int capture_count = 0;
 
 	/* Find triggers associated with this token. */
 	rcu_read_lock();
@@ -4382,14 +4385,34 @@ int dispatch_one_event_notifier_notification(struct notification_thread_state *s
 	trigger_status = lttng_trigger_get_name(element->trigger, &trigger_name);
 	assert(trigger_status == LTTNG_TRIGGER_STATUS_OK);
 
+	if (lttng_condition_event_rule_get_capture_descriptor_count(
+			    lttng_trigger_get_const_condition(element->trigger),
+			    &capture_count) != LTTNG_CONDITION_STATUS_OK) {
+		ERR("Failed to get capture count");
+		ret = -1;
+		goto end;
+	}
+
+	if (!notification->capture_buffer && capture_count != 0) {
+		ERR("Expected capture but capture buffer is null");
+		ret = -1;
+		goto end;
+	}
+
 	evaluation = lttng_evaluation_event_rule_create(
-			trigger_name);
+			container_of(lttng_trigger_get_const_condition(
+						     element->trigger),
+					struct lttng_condition_event_rule,
+					parent),
+			trigger_name,
+			notification->capture_buffer,
+			notification->capture_buf_size, false);
+
 	if (evaluation == NULL) {
 		ERR("[notification-thread] Failed to create event rule hit evaluation while creating and enqueuing action executor job");
 		ret = -1;
 		goto end_unlock;
 	}
-
 	client_list = get_client_list_from_condition(state,
 			lttng_trigger_get_const_condition(element->trigger));
 	executor_status = action_executor_enqueue(state->executor,
@@ -4447,6 +4470,7 @@ next_client:
 		pthread_mutex_unlock(&client_list->lock);
 		break;
 	}
+	case ACTION_EXECUTOR_STATUS_INVALID:
 	case ACTION_EXECUTOR_STATUS_ERROR:
 		/* Fatal error, shut down everything. */
 		ERR("Fatal error encoutered while enqueuing action to the action executor");
@@ -4460,6 +4484,7 @@ next_client:
 end_unlock:
 	notification_client_list_put(client_list);
 	rcu_read_unlock();
+end:
 	return ret;
 }