X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fplugins%2Fctf%2Flttng-live%2Flttng-live.c;h=4586d9ccc6732a6d22a4f78a4bc807d100e69d36;hb=0f1979c3efe2c5b253edb5944d2ba561347ece2e;hp=1962aa2de3e4fdd9a25ac88bd1208a21d2fd4fc0;hpb=1d314141f3caff4e68ca9d61186bfa02bc230296;p=babeltrace.git

diff --git a/src/plugins/ctf/lttng-live/lttng-live.c b/src/plugins/ctf/lttng-live/lttng-live.c
index 1962aa2d..4586d9cc 100644
--- a/src/plugins/ctf/lttng-live/lttng-live.c
+++ b/src/plugins/ctf/lttng-live/lttng-live.c
@@ -43,6 +43,7 @@
 #include <babeltrace2/types.h>
 
 #include "plugins/common/muxing/muxing.h"
+#include "plugins/common/param-validation/param-validation.h"
 
 #include "data-stream.h"
 #include "metadata.h"
@@ -50,6 +51,7 @@
 
 #define MAX_QUERY_SIZE			    (256*1024)
 #define URL_PARAM			    "url"
+#define INPUTS_PARAM			    "inputs"
 #define SESS_NOT_FOUND_ACTION_PARAM	    "session-not-found-action"
 #define SESS_NOT_FOUND_ACTION_CONTINUE_STR  "continue"
 #define SESS_NOT_FOUND_ACTION_FAIL_STR	    "fail"
@@ -184,7 +186,7 @@ struct lttng_live_trace *lttng_live_create_trace(struct lttng_live_session *sess
 	trace->trace_class = NULL;
 	trace->trace = NULL;
 	trace->stream_iterators = g_ptr_array_new_with_free_func(
-			(GDestroyNotify) lttng_live_stream_iterator_destroy);
+		(GDestroyNotify) lttng_live_stream_iterator_destroy);
 	BT_ASSERT(trace->stream_iterators);
 	trace->new_metadata_needed = true;
 	g_ptr_array_add(session->traces, trace);
@@ -235,7 +237,7 @@ int lttng_live_add_session(struct lttng_live_msg_iter *lttng_live_msg_iter,
 	session->self_comp = lttng_live_msg_iter->self_comp;
 	session->id = session_id;
 	session->traces = g_ptr_array_new_with_free_func(
-			(GDestroyNotify) lttng_live_destroy_trace);
+		(GDestroyNotify) lttng_live_destroy_trace);
 	BT_ASSERT(session->traces);
 	session->lttng_live_msg_iter = lttng_live_msg_iter;
 	session->new_streams_needed = true;
@@ -376,10 +378,9 @@ enum lttng_live_iterator_status lttng_live_iterator_next_handle_one_no_data_stre
 {
 	bt_logging_level log_level = lttng_live_msg_iter->log_level;
 	bt_self_component *self_comp = lttng_live_msg_iter->self_comp;
-	enum lttng_live_iterator_status ret =
-			LTTNG_LIVE_ITERATOR_STATUS_OK;
-	struct packet_index index;
+	enum lttng_live_iterator_status ret = LTTNG_LIVE_ITERATOR_STATUS_OK;
 	enum lttng_live_stream_state orig_state = lttng_live_stream->state;
+	struct packet_index index;
 
 	if (lttng_live_stream->trace->new_metadata_needed) {
 		ret = LTTNG_LIVE_ITERATOR_STATUS_CONTINUE;
@@ -509,8 +510,7 @@ enum lttng_live_iterator_status
 lttng_live_iterator_handle_new_streams_and_metadata(
 		struct lttng_live_msg_iter *lttng_live_msg_iter)
 {
-	enum lttng_live_iterator_status ret =
-			LTTNG_LIVE_ITERATOR_STATUS_OK;
+	enum lttng_live_iterator_status ret = LTTNG_LIVE_ITERATOR_STATUS_OK;
 	uint64_t session_idx = 0, nr_sessions_opened = 0;
 	struct lttng_live_session *session;
 	enum session_not_found_action sess_not_found_act =
@@ -571,16 +571,14 @@ enum lttng_live_iterator_status emit_inactivity_message(
 		struct lttng_live_stream_iterator *stream_iter,
 		bt_message **message, uint64_t timestamp)
 {
-	enum lttng_live_iterator_status ret =
-			LTTNG_LIVE_ITERATOR_STATUS_OK;
+	enum lttng_live_iterator_status ret = LTTNG_LIVE_ITERATOR_STATUS_OK;
 	bt_message *msg = NULL;
 
 	BT_ASSERT(stream_iter->trace->clock_class);
 
 	msg = bt_message_message_iterator_inactivity_create(
-			lttng_live_msg_iter->self_msg_iter,
-			stream_iter->trace->clock_class,
-			timestamp);
+		lttng_live_msg_iter->self_msg_iter,
+		stream_iter->trace->clock_class, timestamp);
 	if (!msg) {
 		goto error;
 	}
@@ -601,8 +599,7 @@ enum lttng_live_iterator_status lttng_live_iterator_next_handle_one_quiescent_st
 		struct lttng_live_stream_iterator *lttng_live_stream,
 		bt_message **message)
 {
-	enum lttng_live_iterator_status ret =
-			LTTNG_LIVE_ITERATOR_STATUS_OK;
+	enum lttng_live_iterator_status ret = LTTNG_LIVE_ITERATOR_STATUS_OK;
 
 	if (lttng_live_stream->state != LTTNG_LIVE_STREAM_QUIESCENT) {
 		return LTTNG_LIVE_ITERATOR_STATUS_OK;
@@ -616,10 +613,10 @@ enum lttng_live_iterator_status lttng_live_iterator_next_handle_one_quiescent_st
 	}
 
 	ret = emit_inactivity_message(lttng_live_msg_iter, lttng_live_stream,
-			message, lttng_live_stream->current_inactivity_ts);
+		message, lttng_live_stream->current_inactivity_ts);
 
 	lttng_live_stream->last_inactivity_ts =
-			lttng_live_stream->current_inactivity_ts;
+		lttng_live_stream->current_inactivity_ts;
 end:
 	return ret;
 }
@@ -645,8 +642,7 @@ int live_get_msg_ts_ns(struct lttng_live_stream_iterator *stream_iter,
 
 	switch (bt_message_get_type(msg)) {
 	case BT_MESSAGE_TYPE_EVENT:
-		clock_class =
-			bt_message_event_borrow_stream_class_default_clock_class_const(
+		clock_class = bt_message_event_borrow_stream_class_default_clock_class_const(
 				msg);
 		BT_ASSERT(clock_class);
 
@@ -654,8 +650,7 @@ int live_get_msg_ts_ns(struct lttng_live_stream_iterator *stream_iter,
 			msg);
 		break;
 	case BT_MESSAGE_TYPE_PACKET_BEGINNING:
-		clock_class =
-			bt_message_packet_beginning_borrow_stream_class_default_clock_class_const(
+		clock_class = bt_message_packet_beginning_borrow_stream_class_default_clock_class_const(
 			msg);
 		BT_ASSERT(clock_class);
 
@@ -663,8 +658,7 @@ int live_get_msg_ts_ns(struct lttng_live_stream_iterator *stream_iter,
 			msg);
 		break;
 	case BT_MESSAGE_TYPE_PACKET_END:
-		clock_class =
-			bt_message_packet_end_borrow_stream_class_default_clock_class_const(
+		clock_class = bt_message_packet_end_borrow_stream_class_default_clock_class_const(
 			msg);
 		BT_ASSERT(clock_class);
 
@@ -672,8 +666,7 @@ int live_get_msg_ts_ns(struct lttng_live_stream_iterator *stream_iter,
 			msg);
 		break;
 	case BT_MESSAGE_TYPE_DISCARDED_EVENTS:
-		clock_class =
-			bt_message_discarded_events_borrow_stream_class_default_clock_class_const(
+		clock_class = bt_message_discarded_events_borrow_stream_class_default_clock_class_const(
 			msg);
 		BT_ASSERT(clock_class);
 
@@ -681,8 +674,7 @@ int live_get_msg_ts_ns(struct lttng_live_stream_iterator *stream_iter,
 			msg);
 		break;
 	case BT_MESSAGE_TYPE_DISCARDED_PACKETS:
-		clock_class =
-			bt_message_discarded_packets_borrow_stream_class_default_clock_class_const(
+		clock_class = bt_message_discarded_packets_borrow_stream_class_default_clock_class_const(
 			msg);
 		BT_ASSERT(clock_class);
 
@@ -690,9 +682,8 @@ int live_get_msg_ts_ns(struct lttng_live_stream_iterator *stream_iter,
 			msg);
 		break;
 	case BT_MESSAGE_TYPE_MESSAGE_ITERATOR_INACTIVITY:
-		clock_snapshot =
-			bt_message_message_iterator_inactivity_borrow_default_clock_snapshot_const(
-				msg);
+		clock_snapshot = bt_message_message_iterator_inactivity_borrow_default_clock_snapshot_const(
+			msg);
 		break;
 	default:
 		/* All the other messages have a higher priority */
@@ -734,10 +725,10 @@ enum lttng_live_iterator_status lttng_live_iterator_next_handle_one_active_data_
 		bt_message **message)
 {
 	enum lttng_live_iterator_status ret = LTTNG_LIVE_ITERATOR_STATUS_OK;
-	enum bt_msg_iter_status status;
-	uint64_t session_idx, trace_idx;
 	bt_logging_level log_level = lttng_live_msg_iter->log_level;
 	bt_self_component *self_comp = lttng_live_msg_iter->self_comp;
+	enum bt_msg_iter_status status;
+	uint64_t session_idx, trace_idx;
 
 	for (session_idx = 0; session_idx < lttng_live_msg_iter->sessions->len;
 			session_idx++) {
@@ -808,9 +799,9 @@ enum lttng_live_iterator_status lttng_live_iterator_close_stream(
 	 * `bt_msg_iter` should simply realize that it needs to close the
 	 * stream properly by emitting the necessary stream end message.
 	 */
-	enum bt_msg_iter_status status =
-		bt_msg_iter_get_next_message(stream_iter->msg_iter,
-			lttng_live_msg_iter->self_msg_iter, curr_msg);
+	enum bt_msg_iter_status status = bt_msg_iter_get_next_message(
+		stream_iter->msg_iter, lttng_live_msg_iter->self_msg_iter,
+		curr_msg);
 
 	if (status == BT_MSG_ITER_STATUS_ERROR) {
 		live_status = LTTNG_LIVE_ITERATOR_STATUS_ERROR;
@@ -895,12 +886,12 @@ enum lttng_live_iterator_status lttng_live_iterator_next_msg_on_stream(
 retry:
 	print_stream_state(stream_iter);
 	live_status = lttng_live_iterator_handle_new_streams_and_metadata(
-			lttng_live_msg_iter);
+		lttng_live_msg_iter);
 	if (live_status != LTTNG_LIVE_ITERATOR_STATUS_OK) {
 		goto end;
 	}
 	live_status = lttng_live_iterator_next_handle_one_no_data_stream(
-			lttng_live_msg_iter, stream_iter);
+		lttng_live_msg_iter, stream_iter);
 
 	if (live_status != LTTNG_LIVE_ITERATOR_STATUS_OK) {
 		if (live_status == LTTNG_LIVE_ITERATOR_STATUS_END) {
@@ -914,7 +905,7 @@ retry:
 		goto end;
 	}
 	live_status = lttng_live_iterator_next_handle_one_quiescent_stream(
-			lttng_live_msg_iter, stream_iter, curr_msg);
+		lttng_live_msg_iter, stream_iter, curr_msg);
 	if (live_status != LTTNG_LIVE_ITERATOR_STATUS_OK) {
 		BT_ASSERT(!*curr_msg);
 		goto end;
@@ -923,7 +914,7 @@ retry:
 		goto end;
 	}
 	live_status = lttng_live_iterator_next_handle_one_active_data_stream(
-			lttng_live_msg_iter, stream_iter, curr_msg);
+		lttng_live_msg_iter, stream_iter, curr_msg);
 	if (live_status != LTTNG_LIVE_ITERATOR_STATUS_OK) {
 		BT_ASSERT(!*curr_msg);
 	}
@@ -943,11 +934,11 @@ enum lttng_live_iterator_status next_stream_iterator_for_trace(
 		struct lttng_live_stream_iterator **youngest_trace_stream_iter)
 {
 	struct lttng_live_stream_iterator *youngest_candidate_stream_iter = NULL;
+	bt_logging_level log_level = lttng_live_msg_iter->log_level;
+	bt_self_component *self_comp = lttng_live_msg_iter->self_comp;
 	enum lttng_live_iterator_status stream_iter_status;;
 	int64_t youngest_candidate_msg_ts = INT64_MAX;
 	uint64_t stream_iter_idx;
-	bt_logging_level log_level = lttng_live_msg_iter->log_level;
-	bt_self_component *self_comp = lttng_live_msg_iter->self_comp;
 
 	BT_ASSERT(live_trace);
 	BT_ASSERT(live_trace->stream_iterators);
@@ -962,7 +953,7 @@ enum lttng_live_iterator_status next_stream_iterator_for_trace(
 		bool stream_iter_is_ended = false;
 		struct lttng_live_stream_iterator *stream_iter =
 			g_ptr_array_index(live_trace->stream_iterators,
-					stream_iter_idx);
+				stream_iter_idx);
 
 		/*
 		 * Since we may remove elements from the GPtrArray as we
@@ -982,10 +973,10 @@ enum lttng_live_iterator_status next_stream_iterator_for_trace(
 			bt_message *msg = NULL;
 			int64_t curr_msg_ts_ns = INT64_MAX;
 			stream_iter_status = lttng_live_iterator_next_msg_on_stream(
-					lttng_live_msg_iter, stream_iter, &msg);
+				lttng_live_msg_iter, stream_iter, &msg);
 
 			BT_COMP_LOGD("live stream iterator returned status :%s",
-					print_live_iterator_status(stream_iter_status));
+				print_live_iterator_status(stream_iter_status));
 			if (stream_iter_status == LTTNG_LIVE_ITERATOR_STATUS_END) {
 				stream_iter_is_ended = true;
 				break;
@@ -1442,13 +1433,14 @@ no_session:
 }
 
 BT_HIDDEN
-bt_component_class_message_iterator_init_method_status lttng_live_msg_iter_init(
+bt_component_class_message_iterator_initialize_method_status lttng_live_msg_iter_init(
 		bt_self_message_iterator *self_msg_it,
+		bt_self_message_iterator_configuration *config,
 		bt_self_component_source *self_comp_src,
 		bt_self_component_port_output *self_port)
 {
-	bt_component_class_message_iterator_init_method_status ret =
-		BT_COMPONENT_CLASS_MESSAGE_ITERATOR_INIT_METHOD_STATUS_OK;
+	bt_component_class_message_iterator_initialize_method_status ret =
+		BT_COMPONENT_CLASS_MESSAGE_ITERATOR_INITIALIZE_METHOD_STATUS_OK;
 	bt_self_component *self_comp =
 		bt_self_component_source_as_self_component(self_comp_src);
 	struct lttng_live_component *lttng_live;
@@ -1467,7 +1459,7 @@ bt_component_class_message_iterator_init_method_status lttng_live_msg_iter_init(
 
 	lttng_live_msg_iter = g_new0(struct lttng_live_msg_iter, 1);
 	if (!lttng_live_msg_iter) {
-		ret = BT_COMPONENT_CLASS_MESSAGE_ITERATOR_INIT_METHOD_STATUS_ERROR;
+		ret = BT_COMPONENT_CLASS_MESSAGE_ITERATOR_INITIALIZE_METHOD_STATUS_ERROR;
 		goto end;
 	}
 
@@ -1519,17 +1511,8 @@ bt_component_class_message_iterator_init_method_status lttng_live_msg_iter_init(
 				SESS_NOT_FOUND_ACTION_END_STR,
 				lttng_live->params.url->str);
 			break;
-		case SESSION_NOT_FOUND_ACTION_UNKNOWN:
 		default:
-			/* Fallthrough */
-			BT_COMP_LOGE("Unknown action for session not found"
-				"error. Fail the message iterator"
-				"initialization because of %s=\"%s\" "
-				"component parameter: url =\"%s\"",
-				SESS_NOT_FOUND_ACTION_PARAM,
-				SESS_NOT_FOUND_ACTION_FAIL_STR,
-				lttng_live->params.url->str);
-			break;
+			abort();
 		}
 	}
 
@@ -1537,48 +1520,53 @@ bt_component_class_message_iterator_init_method_status lttng_live_msg_iter_init(
 
 	goto end;
 error:
-	ret = BT_COMPONENT_CLASS_MESSAGE_ITERATOR_INIT_METHOD_STATUS_ERROR;
+	ret = BT_COMPONENT_CLASS_MESSAGE_ITERATOR_INITIALIZE_METHOD_STATUS_ERROR;
 	lttng_live_msg_iter_destroy(lttng_live_msg_iter);
 end:
 	return ret;
 }
 
+static struct bt_param_validation_map_value_entry_descr list_sessions_params[] = {
+	{ URL_PARAM, BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_MANDATORY, { .type = BT_VALUE_TYPE_STRING } },
+	BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_END
+};
+
 static
 bt_component_class_query_method_status lttng_live_query_list_sessions(
 		const bt_value *params, const bt_value **result,
+		bt_self_component_class *self_comp_class,
 		bt_logging_level log_level)
 {
-	bt_component_class_query_method_status status =
-		BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_OK;
+	bt_component_class_query_method_status status;
 	const bt_value *url_value = NULL;
 	const char *url;
 	struct live_viewer_connection *viewer_connection = NULL;
-	bt_self_component *self_comp = NULL;
+	enum bt_param_validation_status validation_status;
+	gchar *validate_error = NULL;
 
-	url_value = bt_value_map_borrow_entry_value_const(params, URL_PARAM);
-	if (!url_value) {
-		BT_COMP_LOGE("Mandatory `%s` parameter missing", URL_PARAM);
-		status = BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_ERROR;
+	validation_status = bt_param_validation_validate(params,
+		list_sessions_params, &validate_error);
+	if (validation_status == BT_PARAM_VALIDATION_STATUS_MEMORY_ERROR) {
+		status = BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_MEMORY_ERROR;
 		goto error;
-	}
-
-	if (!bt_value_is_string(url_value)) {
-		BT_COMP_LOGE("`%s` parameter is required to be a string value",
-			URL_PARAM);
+	} else if (validation_status == BT_PARAM_VALIDATION_STATUS_VALIDATION_ERROR) {
 		status = BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_ERROR;
+		BT_COMP_CLASS_LOGE_APPEND_CAUSE(self_comp_class, "%s", validate_error);
 		goto error;
 	}
 
+	url_value = bt_value_map_borrow_entry_value_const(params, URL_PARAM);
 	url = bt_value_string_get(url_value);
 
 	viewer_connection = live_viewer_connection_create(url, true, NULL,
 		log_level);
 	if (!viewer_connection) {
+		status = BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_ERROR;
 		goto error;
 	}
 
 	status = live_viewer_connection_list_sessions(viewer_connection,
-			result);
+		result);
 	if (status != BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_OK) {
 		goto error;
 	}
@@ -1596,6 +1584,84 @@ end:
 	if (viewer_connection) {
 		live_viewer_connection_destroy(viewer_connection);
 	}
+
+	g_free(validate_error);
+
+	return status;
+}
+
+static
+bt_component_class_query_method_status lttng_live_query_support_info(
+		const bt_value *params, const bt_value **result,
+		bt_logging_level log_level)
+{
+	bt_component_class_query_method_status status =
+		BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_OK;
+	const bt_value *input_type_value;
+	const bt_value *input_value;
+	double weight = 0;
+	struct bt_common_lttng_live_url_parts parts = { 0 };
+
+	/* Used by the logging macros */
+	__attribute__((unused)) bt_self_component *self_comp = NULL;
+
+	*result = NULL;
+	input_type_value = bt_value_map_borrow_entry_value_const(params,
+		"type");
+	if (!input_type_value) {
+		BT_COMP_LOGE("Missing expected `type` parameter.");
+		goto error;
+	}
+
+	if (!bt_value_is_string(input_type_value)) {
+		BT_COMP_LOGE("`type` parameter is not a string value.");
+		goto error;
+	}
+
+	if (strcmp(bt_value_string_get(input_type_value), "string") != 0) {
+		/* We don't handle file system paths */
+		goto create_result;
+	}
+
+	input_value = bt_value_map_borrow_entry_value_const(params, "input");
+	if (!input_value) {
+		BT_COMP_LOGE("Missing expected `input` parameter.");
+		goto error;
+	}
+
+	if (!bt_value_is_string(input_value)) {
+		BT_COMP_LOGE("`input` parameter is not a string value.");
+		goto error;
+	}
+
+	parts = bt_common_parse_lttng_live_url(bt_value_string_get(input_value),
+		NULL, 0);
+	if (parts.session_name) {
+		/*
+		 * Looks pretty much like an LTTng live URL: we got the
+		 * session name part, which forms a complete URL.
+		 */
+		weight = .75;
+	}
+
+create_result:
+	*result = bt_value_real_create_init(weight);
+	if (!*result) {
+		status = BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_MEMORY_ERROR;
+		goto error;
+	}
+
+	goto end;
+
+error:
+	if (status >= 0) {
+		status = BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_ERROR;
+	}
+
+	BT_ASSERT(!*result);
+
+end:
+	bt_common_destroy_lttng_live_url_parts(&parts);
 	return status;
 }
 
@@ -1610,12 +1676,17 @@ bt_component_class_query_method_status lttng_live_query(
 	bt_component_class_query_method_status status =
 		BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_OK;
 	bt_self_component *self_comp = NULL;
+	bt_self_component_class *self_comp_class =
+		bt_self_component_class_source_as_self_component_class(comp_class);
 	bt_logging_level log_level = bt_query_executor_get_logging_level(
 		bt_private_query_executor_as_query_executor_const(
 			priv_query_exec));
 
 	if (strcmp(object, "sessions") == 0) {
 		status = lttng_live_query_list_sessions(params, result,
+			self_comp_class, log_level);
+	} else if (strcmp(object, "babeltrace.support-info") == 0) {
+		status = lttng_live_query_support_info(params, result,
 			log_level);
 	} else {
 		BT_COMP_LOGI("Unknown query object `%s`", object);
@@ -1643,7 +1714,7 @@ BT_HIDDEN
 void lttng_live_component_finalize(bt_self_component_source *component)
 {
 	void *data = bt_self_component_get_data(
-			bt_self_component_source_as_self_component(component));
+		bt_self_component_source_as_self_component(component));
 
 	if (!data) {
 		return;
@@ -1656,30 +1727,72 @@ enum session_not_found_action parse_session_not_found_action_param(
 	const bt_value *no_session_param)
 {
 	enum session_not_found_action action;
-	const char *no_session_act_str;
-	no_session_act_str = bt_value_string_get(no_session_param);
+	const char *no_session_act_str = bt_value_string_get(no_session_param);
+
 	if (strcmp(no_session_act_str, SESS_NOT_FOUND_ACTION_CONTINUE_STR) == 0) {
 		action = SESSION_NOT_FOUND_ACTION_CONTINUE;
 	} else if (strcmp(no_session_act_str, SESS_NOT_FOUND_ACTION_FAIL_STR) == 0) {
 		action = SESSION_NOT_FOUND_ACTION_FAIL;
-	} else if (strcmp(no_session_act_str, SESS_NOT_FOUND_ACTION_END_STR) == 0) {
-		action = SESSION_NOT_FOUND_ACTION_END;
 	} else {
-		action = SESSION_NOT_FOUND_ACTION_UNKNOWN;
+		BT_ASSERT(strcmp(no_session_act_str, SESS_NOT_FOUND_ACTION_END_STR) == 0);
+		action = SESSION_NOT_FOUND_ACTION_END;
 	}
 
 	return action;
 }
 
-struct lttng_live_component *lttng_live_component_create(const bt_value *params,
-		bt_logging_level log_level, bt_self_component *self_comp)
+static struct bt_param_validation_value_descr inputs_elem_descr = {
+	.type = BT_VALUE_TYPE_STRING,
+};
+
+static const char *sess_not_found_action_choices[] = {
+	SESS_NOT_FOUND_ACTION_CONTINUE_STR,
+	SESS_NOT_FOUND_ACTION_FAIL_STR,
+	SESS_NOT_FOUND_ACTION_END_STR,
+};
+
+static struct bt_param_validation_map_value_entry_descr params_descr[] = {
+	{ INPUTS_PARAM, BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_MANDATORY, { BT_VALUE_TYPE_ARRAY, .array = {
+		.min_length = 1,
+		.max_length = 1,
+		.element_type = &inputs_elem_descr,
+	} } },
+	{ SESS_NOT_FOUND_ACTION_PARAM, BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { BT_VALUE_TYPE_STRING, .string = {
+		.choices = sess_not_found_action_choices,
+	} } },
+	BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_END
+};
+
+static
+bt_component_class_initialize_method_status lttng_live_component_create(
+		const bt_value *params,
+		bt_logging_level log_level,
+		bt_self_component *self_comp,
+		struct lttng_live_component **component)
 {
-	struct lttng_live_component *lttng_live;
-	const bt_value *value = NULL;
+	struct lttng_live_component *lttng_live = NULL;
+	const bt_value *inputs_value;
+	const bt_value *url_value;
+	const bt_value *value;
 	const char *url;
+	enum bt_param_validation_status validation_status;
+	gchar *validation_error = NULL;
+	bt_component_class_initialize_method_status status;
+
+	validation_status = bt_param_validation_validate(params, params_descr,
+		&validation_error);
+	if (validation_status == BT_PARAM_VALIDATION_STATUS_MEMORY_ERROR) {
+		status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
+		goto error;
+	} else if (validation_status == BT_PARAM_VALIDATION_STATUS_VALIDATION_ERROR) {
+		BT_COMP_LOGE_APPEND_CAUSE(self_comp, "%s", validation_error);
+		status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR;
+		goto error;
+	}
 
 	lttng_live = g_new0(struct lttng_live_component, 1);
 	if (!lttng_live) {
+		status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
 		goto end;
 	}
 	lttng_live->log_level = log_level;
@@ -1687,80 +1800,70 @@ struct lttng_live_component *lttng_live_component_create(const bt_value *params,
 	lttng_live->max_query_size = MAX_QUERY_SIZE;
 	lttng_live->has_msg_iter = false;
 
-	value = bt_value_map_borrow_entry_value_const(params, URL_PARAM);
-	if (!value || !bt_value_is_string(value)) {
-		BT_COMP_LOGW("Mandatory `%s` parameter missing or not a string",
-			URL_PARAM);
-		goto error;
-	}
-	url = bt_value_string_get(value);
+	inputs_value =
+		bt_value_map_borrow_entry_value_const(params, INPUTS_PARAM);
+	url_value =
+		bt_value_array_borrow_element_by_index_const(inputs_value, 0);
+	url = bt_value_string_get(url_value);
+
 	lttng_live->params.url = g_string_new(url);
 	if (!lttng_live->params.url) {
+		status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
 		goto error;
 	}
 
 	value = bt_value_map_borrow_entry_value_const(params,
 		SESS_NOT_FOUND_ACTION_PARAM);
-
-	if (value && bt_value_is_string(value)) {
+	if (value) {
 		lttng_live->params.sess_not_found_act =
 			parse_session_not_found_action_param(value);
-		if (lttng_live->params.sess_not_found_act == SESSION_NOT_FOUND_ACTION_UNKNOWN) {
-			BT_COMP_LOGE("Unexpected value for `%s` parameter: "
-				"value=\"%s\"", SESS_NOT_FOUND_ACTION_PARAM,
-				bt_value_string_get(value));
-			goto error;
-		}
 	} else {
-		BT_COMP_LOGW("Optional `%s` parameter is missing or "
-			"not a string value. Defaulting to %s=\"%s\".",
-			SESS_NOT_FOUND_ACTION_PARAM,
+		BT_COMP_LOGI("Optional `%s` parameter is missing: "
+			"defaulting to `%s`.",
 			SESS_NOT_FOUND_ACTION_PARAM,
 			SESS_NOT_FOUND_ACTION_CONTINUE_STR);
 		lttng_live->params.sess_not_found_act =
 			SESSION_NOT_FOUND_ACTION_CONTINUE;
 	}
 
+	status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK;
 	goto end;
 
 error:
 	lttng_live_component_destroy_data(lttng_live);
 	lttng_live = NULL;
 end:
-	return lttng_live;
+	g_free(validation_error);
+
+	*component = lttng_live;
+	return status;
 }
 
 BT_HIDDEN
-bt_component_class_init_method_status lttng_live_component_init(
+bt_component_class_initialize_method_status lttng_live_component_init(
 		bt_self_component_source *self_comp_src,
-		const bt_value *params, __attribute__((unused)) void *init_method_data)
+		bt_self_component_source_configuration *config,
+		const bt_value *params,
+		__attribute__((unused)) void *init_method_data)
 {
 	struct lttng_live_component *lttng_live;
-	bt_component_class_init_method_status ret =
-		BT_COMPONENT_CLASS_INIT_METHOD_STATUS_OK;
+	bt_component_class_initialize_method_status ret;
 	bt_self_component *self_comp =
 		bt_self_component_source_as_self_component(self_comp_src);
 	bt_logging_level log_level = bt_component_get_logging_level(
 		bt_self_component_as_component(self_comp));
 	bt_self_component_add_port_status add_port_status;
 
-	lttng_live = lttng_live_component_create(params, log_level, self_comp);
-	if (!lttng_live) {
-		ret = BT_COMPONENT_CLASS_INIT_METHOD_STATUS_MEMORY_ERROR;
+	ret = lttng_live_component_create(params, log_level, self_comp, &lttng_live);
+	if (ret != BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK) {
 		goto error;
 	}
 
 	add_port_status = bt_self_component_source_add_output_port(
 		self_comp_src, "out", NULL, NULL);
-	switch (add_port_status) {
-	case BT_SELF_COMPONENT_ADD_PORT_STATUS_ERROR:
-		ret = BT_COMPONENT_CLASS_INIT_METHOD_STATUS_ERROR;
-		goto error;
-	case BT_SELF_COMPONENT_ADD_PORT_STATUS_MEMORY_ERROR:
-		ret = BT_COMPONENT_CLASS_INIT_METHOD_STATUS_MEMORY_ERROR;
-		goto error;
-	default:
-		break;
+	if (add_port_status != BT_SELF_COMPONENT_ADD_PORT_STATUS_OK) {
+		ret = (int) add_port_status;
+		goto end;
 	}
 
 	bt_self_component_set_data(self_comp, lttng_live);