X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fnotification-thread-events.c;h=c318f833c87f6f2930b1090b384f31cea3d62013;hp=40450304297230b96cdf980afde1b516dc6c02c9;hb=fbc9f37df245d544a7705ba576297df791220b44;hpb=f8522f5cc357c0d80257d5ace1cd556a88305c0c

diff --git a/src/bin/lttng-sessiond/notification-thread-events.c b/src/bin/lttng-sessiond/notification-thread-events.c
index 404503042..c318f833c 100644
--- a/src/bin/lttng-sessiond/notification-thread-events.c
+++ b/src/bin/lttng-sessiond/notification-thread-events.c
@@ -1984,6 +1984,61 @@ end:
 	return ret;
 }
 
+static int handle_notification_thread_command_list_triggers(
+		struct notification_thread_handle *handle,
+		struct notification_thread_state *state,
+		uid_t client_uid,
+		struct lttng_triggers **triggers,
+		enum lttng_error_code *_cmd_result)
+{
+	int ret = 0;
+	enum lttng_error_code cmd_result = LTTNG_OK;
+	struct cds_lfht_iter iter;
+	struct lttng_trigger_ht_element *trigger_ht_element;
+	struct lttng_triggers *local_triggers = NULL;
+	const struct lttng_credentials *creds;
+
+	rcu_read_lock();
+
+	local_triggers = lttng_triggers_create();
+	if (!local_triggers) {
+		/* Not a fatal error. */
+		cmd_result = LTTNG_ERR_NOMEM;
+		goto end;
+	}
+
+	cds_lfht_for_each_entry(state->triggers_ht, &iter,
+			trigger_ht_element, node) {
+		/*
+		 * Only return the triggers to which the client has access.
+		 * The root user has visibility over all triggers.
+		 */
+		creds = lttng_trigger_get_credentials(trigger_ht_element->trigger);
+		if (client_uid != lttng_credentials_get_uid(creds) && client_uid != 0) {
+			continue;
+		}
+
+		ret = lttng_triggers_add(local_triggers,
+				trigger_ht_element->trigger);
+		if (ret < 0) {
+			/* Not a fatal error. */
+			ret = 0;
+			cmd_result = LTTNG_ERR_NOMEM;
+			goto end;
+		}
+	}
+
+	/* Transferring ownership to the caller. */
+	*triggers = local_triggers;
+	local_triggers = NULL;
+
+end:
+	rcu_read_unlock();
+	lttng_triggers_destroy(local_triggers);
+	*_cmd_result = cmd_result;
+	return ret;
+}
+
 static
 int condition_is_supported(struct lttng_condition *condition)
 {
@@ -2658,6 +2713,20 @@ int handle_notification_thread_command(
 				cmd->parameters.session_rotation.location,
 				&cmd->reply_code);
 		break;
+	case NOTIFICATION_COMMAND_TYPE_LIST_TRIGGERS:
+	{
+		struct lttng_triggers *triggers = NULL;
+
+		ret = handle_notification_thread_command_list_triggers(
+				handle,
+				state,
+				cmd->parameters.list_triggers.uid,
+				&triggers,
+				&cmd->reply_code);
+		cmd->reply.list_triggers.triggers = triggers;
+		ret = 0;
+		break;
+	}
 	case NOTIFICATION_COMMAND_TYPE_QUIT:
 		DBG("[notification-thread] Received quit command");
 		cmd->reply_code = LTTNG_OK;