X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fplugins%2Ftext%2Fpretty%2Fpretty.c;h=1e248644398022c43b59e94173a15235ef0d25f6;hb=a3f0c7db90f4cfc81090a83a7442b7bc624d5789;hp=0a85530e7f95d49a1206fe1086deaaa0e36e30dc;hpb=d24d56638469189904fb6ddbb3c725817b3e9417;p=babeltrace.git

diff --git a/src/plugins/text/pretty/pretty.c b/src/plugins/text/pretty/pretty.c
index 0a85530e..1e248644 100644
--- a/src/plugins/text/pretty/pretty.c
+++ b/src/plugins/text/pretty/pretty.c
@@ -23,6 +23,11 @@
  * SOFTWARE.
  */
 
+#define BT_COMP_LOG_SELF_COMP self_comp
+#define BT_LOG_OUTPUT_LEVEL log_level
+#define BT_LOG_TAG "PLUGIN/SINK.TEXT.PRETTY"
+#include "logging/comp-logging.h"
+
 #include <babeltrace2/babeltrace.h>
 #include "compat/compiler.h"
 #include "common/common.h"
@@ -31,43 +36,20 @@
 #include <glib.h>
 #include <string.h>
 #include "common/assert.h"
+#include "plugins/common/param-validation/param-validation.h"
 
 #include "pretty.h"
 
-GQuark stream_packet_context_quarks[STREAM_PACKET_CONTEXT_QUARKS_LEN];
-
-static
-const char *plugin_options[] = {
-	"color",
-	"path",
-	"no-delta",
-	"clock-cycles",
-	"clock-seconds",
-	"clock-date",
-	"clock-gmt",
-	"verbose",
-	"name-default",		/* show/hide */
-	"name-payload",
-	"name-context",
-	"name-scope",
-	"name-header",
-	"field-default",	/* show/hide */
-	"field-trace",
-	"field-trace:hostname",
-	"field-trace:domain",
-	"field-trace:procname",
-	"field-trace:vpid",
-	"field-loglevel",
-	"field-emf",
-	"field-callsite",
-};
-
 static
 const char * const in_port_name = "in";
 
 static
 void destroy_pretty_data(struct pretty_component *pretty)
 {
+	if (!pretty) {
+		goto end;
+	}
+
 	bt_self_component_port_input_message_iterator_put_ref(pretty->iterator);
 
 	if (pretty->string) {
@@ -88,6 +70,9 @@ void destroy_pretty_data(struct pretty_component *pretty)
 	}
 	g_free(pretty->options.output_path);
 	g_free(pretty);
+
+end:
+	return;
 }
 
 static
@@ -124,25 +109,25 @@ void pretty_finalize(bt_self_component_sink *comp)
 }
 
 static
-bt_component_class_message_iterator_next_method_status handle_message(
+bt_message_iterator_class_next_method_status handle_message(
 		struct pretty_component *pretty,
 		const bt_message *message)
 {
-	bt_component_class_message_iterator_next_method_status ret =
-		BT_COMPONENT_CLASS_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_OK;
+	bt_message_iterator_class_next_method_status ret =
+		BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_OK;
 
-	BT_ASSERT(pretty);
+	BT_ASSERT_DBG(pretty);
 
 	switch (bt_message_get_type(message)) {
 	case BT_MESSAGE_TYPE_EVENT:
 		if (pretty_print_event(pretty, message)) {
-			ret = BT_COMPONENT_CLASS_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_ERROR;
+			ret = BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_ERROR;
 		}
 		break;
 	case BT_MESSAGE_TYPE_DISCARDED_EVENTS:
 	case BT_MESSAGE_TYPE_DISCARDED_PACKETS:
 		if (pretty_print_discarded_items(pretty, message)) {
-			ret = BT_COMPONENT_CLASS_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_ERROR;
+			ret = BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_ERROR;
 		}
 		break;
 	default:
@@ -156,21 +141,26 @@ BT_HIDDEN
 bt_component_class_sink_graph_is_configured_method_status
 pretty_graph_is_configured(bt_self_component_sink *comp)
 {
-	bt_component_class_sink_graph_is_configured_method_status status =
-		BT_COMPONENT_CLASS_SINK_GRAPH_IS_CONFIGURED_METHOD_STATUS_OK;
+	bt_component_class_sink_graph_is_configured_method_status status;
+	bt_self_component_port_input_message_iterator_create_from_sink_component_status
+		msg_iter_status;
 	struct pretty_component *pretty;
 
 	pretty = bt_self_component_get_data(
 			bt_self_component_sink_as_self_component(comp));
 	BT_ASSERT(pretty);
 	BT_ASSERT(!pretty->iterator);
-	pretty->iterator = bt_self_component_port_input_message_iterator_create(
-		bt_self_component_sink_borrow_input_port_by_name(comp,
-			in_port_name));
-	if (!pretty->iterator) {
-		status = BT_COMPONENT_CLASS_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_MEMORY_ERROR;
+	msg_iter_status = bt_self_component_port_input_message_iterator_create_from_sink_component(
+		comp, bt_self_component_sink_borrow_input_port_by_name(comp,
+			in_port_name), &pretty->iterator);
+	if (msg_iter_status != BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_CREATE_FROM_SINK_COMPONENT_STATUS_OK) {
+		status = (int) msg_iter_status;
+		goto end;
 	}
 
+	status = BT_COMPONENT_CLASS_SINK_GRAPH_IS_CONFIGURED_METHOD_STATUS_OK;
+
+end:
 	return status;
 }
 
@@ -178,7 +168,8 @@ BT_HIDDEN
 bt_component_class_sink_consume_method_status pretty_consume(
 		bt_self_component_sink *comp)
 {
-	bt_component_class_sink_consume_method_status ret;
+	bt_component_class_sink_consume_method_status ret =
+		BT_COMPONENT_CLASS_SINK_CONSUME_METHOD_STATUS_OK;
 	bt_message_array_const msgs;
 	bt_self_component_port_input_message_iterator *it;
 	struct pretty_component *pretty = bt_self_component_get_data(
@@ -208,10 +199,10 @@ bt_component_class_sink_consume_method_status pretty_consume(
 		goto end;
 	}
 
-	BT_ASSERT(next_status == BT_MESSAGE_ITERATOR_NEXT_STATUS_OK);
+	BT_ASSERT_DBG(next_status == BT_MESSAGE_ITERATOR_NEXT_STATUS_OK);
 
 	for (i = 0; i < count; i++) {
-		ret = handle_message(pretty, msgs[i]);
+		ret = (int) handle_message(pretty, msgs[i]);
 		if (ret) {
 			goto end;
 		}
@@ -227,40 +218,6 @@ end:
 	return ret;
 }
 
-static
-int add_params_to_map(bt_value *plugin_opt_map)
-{
-	int ret = 0;
-	unsigned int i;
-
-	for (i = 0; i < BT_ARRAY_SIZE(plugin_options); i++) {
-		const char *key = plugin_options[i];
-
-		if (bt_value_map_insert_entry(plugin_opt_map, key,
-				bt_value_null) < 0) {
-			ret = -1;
-			goto end;
-		}
-	}
-
-end:
-	return ret;
-}
-
-static
-bt_bool check_param_exists(const char *key, const bt_value *object,
-		void *data)
-{
-	struct pretty_component *pretty = data;
-
-	if (!bt_value_map_has_entry(pretty->plugin_opt_map,
-				    key)) {
-		fprintf(pretty->err,
-			"[warning] Parameter \"%s\" unknown to \"text.pretty\" sink component\n", key);
-	}
-	return BT_TRUE;
-}
-
 static
 void apply_one_string(const char *key, const bt_value *params, char **option)
 {
@@ -271,9 +228,7 @@ void apply_one_string(const char *key, const bt_value *params, char **option)
 	if (!value) {
 		goto end;
 	}
-	if (bt_value_is_null(value)) {
-		goto end;
-	}
+
 	str = bt_value_string_get(value);
 	*option = g_strdup(str);
 
@@ -281,32 +236,38 @@ end:
 	return;
 }
 
+/*
+ * Apply parameter with key `key` to `option`.  Use `def` as the value, if
+ * the parameter is not specified.
+ */
+
 static
-void apply_one_bool(const char *key, const bt_value *params, bool *option,
-		bool *found)
+void apply_one_bool_with_default(const char *key, const bt_value *params,
+		bool *option, bool def)
 {
-	const bt_value *value = NULL;
-	bt_bool bool_val;
+	const bt_value *value;
 
 	value = bt_value_map_borrow_entry_value_const(params, key);
-	if (!value) {
-		goto end;
-	}
-	bool_val = bt_value_bool_get(value);
-	*option = (bool) bool_val;
-	if (found) {
-		*found = true;
-	}
+	if (value) {
+		bt_bool bool_val = bt_value_bool_get(value);
 
-end:
-	return;
+		*option = (bool) bool_val;
+	} else {
+		*option = def;
+	}
 }
 
 static
-void warn_wrong_color_param(struct pretty_component *pretty)
+void apply_one_bool_if_specified(const char *key, const bt_value *params, bool *option)
 {
-	fprintf(pretty->err,
-		"[warning] Accepted values for the \"color\" parameter are:\n    \"always\", \"auto\", \"never\"\n");
+	const bt_value *value;
+
+	value = bt_value_map_borrow_entry_value_const(params, key);
+	if (value) {
+		bt_bool bool_val = bt_value_bool_get(value);
+
+		*option = (bool) bool_val;
+	}
 }
 
 static
@@ -332,98 +293,123 @@ end:
 	return ret;
 }
 
+static const char *color_choices[] = { "never", "auto", "always", NULL };
+static const char *show_hide_choices[] = { "show", "hide", NULL };
+
 static
-int apply_params(struct pretty_component *pretty, const bt_value *params)
-{
-	int ret = 0;
-	bool value, found;
-	char *str = NULL;
+struct bt_param_validation_map_value_entry_descr pretty_params[] = {
+	{ "color", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { BT_VALUE_TYPE_STRING, .string = {
+		.choices = color_choices,
+	} } },
+	{ "path", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_STRING } },
+	{ "no-delta", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "clock-cycles", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "clock-seconds", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "clock-date", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "clock-gmt", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "verbose", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+
+	{ "name-default", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { BT_VALUE_TYPE_STRING, .string = {
+		.choices = show_hide_choices,
+	} } },
+	{ "name-payload", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "name-context", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "name-scope", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "name-header", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+
+	{ "field-default", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { BT_VALUE_TYPE_STRING, .string = {
+		.choices = show_hide_choices,
+	} } },
+	{ "field-trace", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "field-trace:hostname", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "field-trace:domain", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "field-trace:procname", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "field-trace:vpid", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "field-loglevel", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "field-emf", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	{ "field-callsite", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, { .type = BT_VALUE_TYPE_BOOL } },
+	BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_END
+};
 
-	pretty->plugin_opt_map = bt_value_map_create();
-	if (!pretty->plugin_opt_map) {
-		ret = -1;
-		goto end;
-	}
-	ret = add_params_to_map(pretty->plugin_opt_map);
-	if (ret) {
+static
+bt_component_class_initialize_method_status apply_params(
+		struct pretty_component *pretty, const bt_value *params,
+		bt_self_component *self_comp, bt_logging_level log_level)
+{
+	int ret;
+	const bt_value *value;
+	bt_component_class_initialize_method_status status;
+	enum bt_param_validation_status validation_status;
+	gchar *validate_error = NULL;
+
+	validation_status = bt_param_validation_validate(params,
+		pretty_params, &validate_error);
+	if (validation_status == BT_PARAM_VALIDATION_STATUS_MEMORY_ERROR) {
+		status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
 		goto end;
-	}
-	/* Report unknown parameters. */
-	if (bt_value_map_foreach_entry_const(params,
-			check_param_exists, pretty) < 0) {
-		ret = -1;
+	} else if (validation_status == BT_PARAM_VALIDATION_STATUS_VALIDATION_ERROR) {
+		status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR;
+		BT_COMP_LOGE_APPEND_CAUSE(self_comp, "%s", validate_error);
 		goto end;
 	}
 
 	/* Known parameters. */
 	pretty->options.color = PRETTY_COLOR_OPT_AUTO;
-	if (bt_value_map_has_entry(params, "color")) {
-		const bt_value *color_value;
-		const char *color;
-
-		color_value = bt_value_map_borrow_entry_value_const(params,
-			"color");
-		if (!color_value) {
-			goto end;
-		}
-
-		color = bt_value_string_get(color_value);
+	value = bt_value_map_borrow_entry_value_const(params, "color");
+	if (value) {
+		const char *color = bt_value_string_get(value);
 
 		if (strcmp(color, "never") == 0) {
 			pretty->options.color = PRETTY_COLOR_OPT_NEVER;
 		} else if (strcmp(color, "auto") == 0) {
 			pretty->options.color = PRETTY_COLOR_OPT_AUTO;
-		} else if (strcmp(color, "always") == 0) {
-			pretty->options.color = PRETTY_COLOR_OPT_ALWAYS;
 		} else {
-			warn_wrong_color_param(pretty);
+			BT_ASSERT(strcmp(color, "always") == 0);
+			pretty->options.color = PRETTY_COLOR_OPT_ALWAYS;
 		}
 	}
 
 	apply_one_string("path", params, &pretty->options.output_path);
 	ret = open_output_file(pretty);
 	if (ret) {
+		status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR;
 		goto end;
 	}
 
-	value = false;		/* Default. */
-	apply_one_bool("no-delta", params, &value, NULL);
-	pretty->options.print_delta_field = !value;	/* Reverse logic. */
+	apply_one_bool_with_default("no-delta", params,
+		&pretty->options.print_delta_field, false);
+	/* Reverse logic. */
+	pretty->options.print_delta_field = !pretty->options.print_delta_field;
 
-	value = false;		/* Default. */
-	apply_one_bool("clock-cycles", params, &value, NULL);
-	pretty->options.print_timestamp_cycles = value;
+	apply_one_bool_with_default("clock-cycles", params,
+		&pretty->options.print_timestamp_cycles, false);
 
-	value = false;		/* Default. */
-	apply_one_bool("clock-seconds", params, &value, NULL);
-	pretty->options.clock_seconds = value;
+	apply_one_bool_with_default("clock-seconds", params,
+		&pretty->options.clock_seconds , false);
 
-	value = false;		/* Default. */
-	apply_one_bool("clock-date", params, &value, NULL);
-	pretty->options.clock_date = value;
+	apply_one_bool_with_default("clock-date", params,
+		&pretty->options.clock_date, false);
 
-	value = false;		/* Default. */
-	apply_one_bool("clock-gmt", params, &value, NULL);
-	pretty->options.clock_gmt = value;
+	apply_one_bool_with_default("clock-gmt", params,
+		&pretty->options.clock_gmt, false);
 
-	value = false;		/* Default. */
-	apply_one_bool("verbose", params, &value, NULL);
-	pretty->options.verbose = value;
+	apply_one_bool_with_default("verbose", params,
+		&pretty->options.verbose, false);
 
 	/* Names. */
-	apply_one_string("name-default", params, &str);
-	if (!str) {
-		pretty->options.name_default = PRETTY_DEFAULT_UNSET;
-	} else if (!strcmp(str, "show")) {
-		pretty->options.name_default = PRETTY_DEFAULT_SHOW;
-	} else if (!strcmp(str, "hide")) {
-		pretty->options.name_default = PRETTY_DEFAULT_HIDE;
+	value = bt_value_map_borrow_entry_value_const(params, "name-default");
+	if (value) {
+		const char *str = bt_value_string_get(value);
+
+		if (strcmp(str, "show") == 0) {
+			pretty->options.name_default = PRETTY_DEFAULT_SHOW;
+		} else {
+			BT_ASSERT(strcmp(str, "hide") == 0);
+			pretty->options.name_default = PRETTY_DEFAULT_HIDE;
+		}
 	} else {
-		ret = -1;
-		goto end;
+		pretty->options.name_default = PRETTY_DEFAULT_UNSET;
 	}
-	g_free(str);
-	str = NULL;
 
 	switch (pretty->options.name_default) {
 	case PRETTY_DEFAULT_UNSET:
@@ -445,52 +431,35 @@ int apply_params(struct pretty_component *pretty, const bt_value *params)
 		pretty->options.print_scope_field_names = false;
 		break;
 	default:
-		ret = -1;
-		goto end;
+		bt_common_abort();
 	}
 
-	value = false;
-	found = false;
-	apply_one_bool("name-payload", params, &value, &found);
-	if (found) {
-		pretty->options.print_payload_field_names = value;
-	}
+	apply_one_bool_if_specified("name-payload", params,
+		&pretty->options.print_payload_field_names);
 
-	value = false;
-	found = false;
-	apply_one_bool("name-context", params, &value, &found);
-	if (found) {
-		pretty->options.print_context_field_names = value;
-	}
+	apply_one_bool_if_specified("name-context", params,
+		&pretty->options.print_context_field_names);
 
-	value = false;
-	found = false;
-	apply_one_bool("name-header", params, &value, &found);
-	if (found) {
-		pretty->options.print_header_field_names = value;
-	}
+	apply_one_bool_if_specified("name-header", params,
+		&pretty->options.print_header_field_names);
 
-	value = false;
-	found = false;
-	apply_one_bool("name-scope", params, &value, &found);
-	if (found) {
-		pretty->options.print_scope_field_names = value;
-	}
+	apply_one_bool_if_specified("name-scope", params,
+		&pretty->options.print_scope_field_names);
 
 	/* Fields. */
-	apply_one_string("field-default", params, &str);
-	if (!str) {
-		pretty->options.field_default = PRETTY_DEFAULT_UNSET;
-	} else if (!strcmp(str, "show")) {
-		pretty->options.field_default = PRETTY_DEFAULT_SHOW;
-	} else if (!strcmp(str, "hide")) {
-		pretty->options.field_default = PRETTY_DEFAULT_HIDE;
+	value = bt_value_map_borrow_entry_value_const(params, "field-default");
+	if (value) {
+		const char *str = bt_value_string_get(value);
+
+		if (strcmp(str, "show") == 0) {
+			pretty->options.field_default = PRETTY_DEFAULT_SHOW;
+		} else {
+			BT_ASSERT(strcmp(str, "hide") == 0);
+			pretty->options.field_default = PRETTY_DEFAULT_HIDE;
+		}
 	} else {
-		ret = -1;
-		goto end;
+		pretty->options.field_default = PRETTY_DEFAULT_UNSET;
 	}
-	g_free(str);
-	str = NULL;
 
 	switch (pretty->options.field_default) {
 	case PRETTY_DEFAULT_UNSET:
@@ -524,71 +493,40 @@ int apply_params(struct pretty_component *pretty, const bt_value *params)
 		pretty->options.print_callsite_field = false;
 		break;
 	default:
-		ret = -1;
-		goto end;
+		bt_common_abort();
 	}
 
-	value = false;
-	found = false;
-	apply_one_bool("field-trace", params, &value, &found);
-	if (found) {
-		pretty->options.print_trace_field = value;
-	}
+	apply_one_bool_if_specified("field-trace", params,
+		&pretty->options.print_trace_field);
 
-	value = false;
-	found = false;
-	apply_one_bool("field-trace:hostname", params, &value, &found);
-	if (found) {
-		pretty->options.print_trace_hostname_field = value;
-	}
+	apply_one_bool_if_specified("field-trace:hostname", params,
+		&pretty->options.print_trace_hostname_field);
 
-	value = false;
-	found = false;
-	apply_one_bool("field-trace:domain", params, &value, &found);
-	if (found) {
-		pretty->options.print_trace_domain_field = value;
-	}
+	apply_one_bool_if_specified("field-trace:domain", params,
+		&pretty->options.print_trace_domain_field);
 
-	value = false;
-	found = false;
-	apply_one_bool("field-trace:procname", params, &value, &found);
-	if (found) {
-		pretty->options.print_trace_procname_field = value;
-	}
+	apply_one_bool_if_specified("field-trace:procname", params,
+		&pretty->options.print_trace_procname_field);
 
-	value = false;
-	found = false;
-	apply_one_bool("field-trace:vpid", params, &value, &found);
-	if (found) {
-		pretty->options.print_trace_vpid_field = value;
-	}
+	apply_one_bool_if_specified("field-trace:vpid", params,
+		&pretty->options.print_trace_vpid_field);
 
-	value = false;
-	found = false;
-	apply_one_bool("field-loglevel", params, &value, &found);
-	if (found) {
-		pretty->options.print_loglevel_field = value;
-	}
+	apply_one_bool_if_specified("field-loglevel", params,
+		&pretty->options.print_loglevel_field);
 
-	value = false;
-	found = false;
-	apply_one_bool("field-emf", params, &value, &found);
-	if (found) {
-		pretty->options.print_emf_field = value;
-	}
+	apply_one_bool_if_specified("field-emf", params,
+		&pretty->options.print_emf_field);
 
-	value = false;
-	found = false;
-	apply_one_bool("field-callsite", params, &value, &found);
-	if (found) {
-		pretty->options.print_callsite_field = value;
-	}
+	apply_one_bool_if_specified("field-callsite", params,
+		&pretty->options.print_callsite_field);
+
+	pretty_print_init();
+	status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK;
 
 end:
-	bt_value_put_ref(pretty->plugin_opt_map);
-	pretty->plugin_opt_map = NULL;
-	g_free(str);
-	return ret;
+	g_free(validate_error);
+
+	return status;
 }
 
 static
@@ -608,42 +546,30 @@ void set_use_colors(struct pretty_component *pretty)
 	}
 }
 
-static
-void init_stream_packet_context_quarks(void)
-{
-	stream_packet_context_quarks[Q_TIMESTAMP_BEGIN] =
-		g_quark_from_string("timestamp_begin");
-	stream_packet_context_quarks[Q_TIMESTAMP_BEGIN] =
-		g_quark_from_string("timestamp_begin");
-	stream_packet_context_quarks[Q_TIMESTAMP_END] =
-		g_quark_from_string("timestamp_end");
-	stream_packet_context_quarks[Q_EVENTS_DISCARDED] =
-		g_quark_from_string("events_discarded");
-	stream_packet_context_quarks[Q_CONTENT_SIZE] =
-		g_quark_from_string("content_size");
-	stream_packet_context_quarks[Q_PACKET_SIZE] =
-		g_quark_from_string("packet_size");
-	stream_packet_context_quarks[Q_PACKET_SEQ_NUM] =
-		g_quark_from_string("packet_seq_num");
-}
-
 BT_HIDDEN
-bt_component_class_init_method_status pretty_init(
-		bt_self_component_sink *comp, const bt_value *params,
+bt_component_class_initialize_method_status pretty_init(
+		bt_self_component_sink *self_comp_sink,
+		bt_self_component_sink_configuration *config,
+		const bt_value *params,
 		__attribute__((unused)) void *init_method_data)
 {
-	bt_component_class_init_method_status ret =
-		BT_COMPONENT_CLASS_INIT_METHOD_STATUS_OK;
+	bt_component_class_initialize_method_status status;
+	bt_self_component_add_port_status add_port_status;
 	struct pretty_component *pretty = create_pretty();
+	bt_self_component *self_comp =
+		bt_self_component_sink_as_self_component(self_comp_sink);
+	const bt_component *comp = bt_self_component_as_component(self_comp);
+	bt_logging_level log_level = bt_component_get_logging_level(comp);
 
 	if (!pretty) {
-		ret = BT_COMPONENT_CLASS_INIT_METHOD_STATUS_MEMORY_ERROR;
-		goto end;
+		status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
+		goto error;
 	}
 
-	if (bt_self_component_sink_add_input_port(comp,
-			in_port_name, NULL, NULL) < 0) {
-		ret = BT_COMPONENT_CLASS_INIT_METHOD_STATUS_MEMORY_ERROR;
+	add_port_status = bt_self_component_sink_add_input_port(self_comp_sink,
+		in_port_name, NULL, NULL);
+	if (add_port_status != BT_SELF_COMPONENT_ADD_PORT_STATUS_OK) {
+		status = (int) add_port_status;
 		goto error;
 	}
 
@@ -656,20 +582,20 @@ bt_component_class_init_method_status pretty_init(
 	pretty->delta_real_timestamp = -1ULL;
 	pretty->last_real_timestamp = -1ULL;
 
-	if (apply_params(pretty, params)) {
-		ret = BT_COMPONENT_CLASS_INIT_METHOD_STATUS_ERROR;
+	status = apply_params(pretty, params, self_comp, log_level);
+	if (status != BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK) {
 		goto error;
 	}
 
 	set_use_colors(pretty);
-	bt_self_component_set_data(
-		bt_self_component_sink_as_self_component(comp), pretty);
-	init_stream_packet_context_quarks();
+	bt_self_component_set_data(self_comp, pretty);
 
-end:
-	return ret;
+	status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK;
+	goto end;
 
 error:
 	destroy_pretty_data(pretty);
-	return ret;
+
+end:
+	return status;
 }