[babeltrace.git] / lib / graph / component-class.c

/*
 * component-class.c
 *
 * Babeltrace Plugin Component Class
 *
 * Copyright 2016 Jérémie Galarneau <jeremie.galarneau@efficios.com>
 *
 * Author: Jérémie Galarneau <jeremie.galarneau@efficios.com>
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */

#include <babeltrace/compiler-internal.h>
#include <babeltrace/graph/component-class-internal.h>
#include <babeltrace/ref.h>
#include <stdbool.h>
#include <glib.h>

static
void bt_component_class_destroy(struct bt_object *obj)
{
	struct bt_component_class *class;
	int i;

	assert(obj);
	class = container_of(obj, struct bt_component_class, base);

	/* Call destroy listeners in reverse registration order */
	for (i = class->destroy_listeners->len - 1; i >= 0; i--) {
		struct bt_component_class_destroy_listener *listener =
			&g_array_index(class->destroy_listeners,
				struct bt_component_class_destroy_listener,
				i);

		listener->func(class, listener->data);
	}

	if (class->name) {
		g_string_free(class->name, TRUE);
	}
	if (class->description) {
		g_string_free(class->description, TRUE);
	}
	if (class->help) {
		g_string_free(class->help, TRUE);
	}
	if (class->destroy_listeners) {
		g_array_free(class->destroy_listeners, TRUE);
	}

	g_free(class);
}

static
int bt_component_class_init(struct bt_component_class *class,
		enum bt_component_class_type type, const char *name)
{
	int ret = 0;

	bt_object_init(class, bt_component_class_destroy);
	class->type = type;
	class->name = g_string_new(name);
	if (!class->name) {
		goto error;
	}

	class->description = g_string_new(NULL);
	if (!class->description) {
		goto error;
	}

	class->help = g_string_new(NULL);
	if (!class->help) {
		goto error;
	}

	class->destroy_listeners = g_array_new(FALSE, TRUE,
		sizeof(struct bt_component_class_destroy_listener));
	if (!class->destroy_listeners) {
		goto error;
	}

	goto end;

error:
	BT_PUT(class);
	ret = -1;

end:
	return ret;
}

struct bt_component_class *bt_component_class_source_create(const char *name,
		bt_component_class_notification_iterator_next_method notification_iterator_next_method)
{
	struct bt_component_class_source *source_class = NULL;
	int ret;

	if (!name || !notification_iterator_next_method) {
		goto end;
	}

	source_class = g_new0(struct bt_component_class_source, 1);
	if (!source_class) {
		goto end;
	}

	ret = bt_component_class_init(&source_class->parent,
		BT_COMPONENT_CLASS_TYPE_SOURCE, name);
	if (ret) {
		/*
		 * If bt_component_class_init() fails, the component
		 * class is put, therefore its memory is already
		 * freed.
		 */
		source_class = NULL;
		goto end;
	}

	source_class->methods.iterator.next = notification_iterator_next_method;

end:
	return &source_class->parent;
}

struct bt_component_class *bt_component_class_filter_create(const char *name,
		bt_component_class_notification_iterator_next_method notification_iterator_next_method)
{
	struct bt_component_class_filter *filter_class = NULL;
	int ret;

	if (!name || !notification_iterator_next_method) {
		goto end;
	}

	filter_class = g_new0(struct bt_component_class_filter, 1);
	if (!filter_class) {
		goto end;
	}

	ret = bt_component_class_init(&filter_class->parent,
		BT_COMPONENT_CLASS_TYPE_FILTER, name);
	if (ret) {
		/*
		 * If bt_component_class_init() fails, the component
		 * class is put, therefore its memory is already
		 * freed.
		 */
		filter_class = NULL;
		goto end;
	}

	filter_class->methods.iterator.next = notification_iterator_next_method;

end:
	return &filter_class->parent;
}

struct bt_component_class *bt_component_class_sink_create(const char *name,
		bt_component_class_sink_consume_method consume_method)
{
	struct bt_component_class_sink *sink_class = NULL;
	int ret;

	if (!name || !consume_method) {
		goto end;
	}

	sink_class = g_new0(struct bt_component_class_sink, 1);
	if (!sink_class) {
		goto end;
	}

	ret = bt_component_class_init(&sink_class->parent,
		BT_COMPONENT_CLASS_TYPE_SINK, name);
	if (ret) {
		/*
		 * If bt_component_class_init() fails, the component
		 * class is put, therefore its memory is already
		 * freed.
		 */
		sink_class = NULL;
		goto end;
	}

	sink_class->methods.consume = consume_method;

end:
	return &sink_class->parent;
}

int bt_component_class_set_init_method(
		struct bt_component_class *component_class,
		bt_component_class_init_method init_method)
{
	int ret = 0;

	if (!component_class || component_class->frozen || !init_method) {
		ret = -1;
		goto end;
	}

	component_class->methods.init = init_method;

end:
	return ret;
}

int bt_component_class_set_query_method(
		struct bt_component_class *component_class,
		bt_component_class_query_method query_method)
{
	int ret = 0;

	if (!component_class || component_class->frozen || !query_method) {
		ret = -1;
		goto end;
	}

	component_class->methods.query = query_method;

end:
	return ret;
}

int bt_component_class_set_accept_port_connection_method(
		struct bt_component_class *component_class,
		bt_component_class_accept_port_connection_method method)
{
	int ret = 0;

	if (!component_class || component_class->frozen || !method) {
		ret = -1;
		goto end;
	}

	component_class->methods.accept_port_connection = method;

end:
	return ret;
}

int bt_component_class_set_port_disconnected_method(
		struct bt_component_class *component_class,
		bt_component_class_port_disconnected_method method)
{
	int ret = 0;

	if (!component_class || component_class->frozen || !method) {
		ret = -1;
		goto end;
	}

	component_class->methods.port_disconnected = method;

end:
	return ret;
}

int bt_component_class_set_finalize_method(
		struct bt_component_class *component_class,
		bt_component_class_finalize_method finalize_method)
{
	int ret = 0;

	if (!component_class || component_class->frozen || !finalize_method) {
		ret = -1;
		goto end;
	}

	component_class->methods.finalize = finalize_method;

end:
	return ret;
}

int bt_component_class_source_set_notification_iterator_init_method(
		struct bt_component_class *component_class,
		bt_component_class_notification_iterator_init_method notification_iterator_init_method)
{
	struct bt_component_class_source *source_class;
	int ret = 0;

	if (!component_class || component_class->frozen ||
			!notification_iterator_init_method ||
			component_class->type != BT_COMPONENT_CLASS_TYPE_SOURCE) {
		ret = -1;
		goto end;
	}

	source_class = container_of(component_class,
		struct bt_component_class_source, parent);
	source_class->methods.iterator.init = notification_iterator_init_method;

end:
	return ret;
}

int bt_component_class_source_set_notification_iterator_finalize_method(
		struct bt_component_class *component_class,
		bt_component_class_notification_iterator_finalize_method notification_iterator_finalize_method)
{
	struct bt_component_class_source *source_class;
	int ret = 0;

	if (!component_class || component_class->frozen ||
			!notification_iterator_finalize_method ||
			component_class->type != BT_COMPONENT_CLASS_TYPE_SOURCE) {
		ret = -1;
		goto end;
	}

	source_class = container_of(component_class,
		struct bt_component_class_source, parent);
	source_class->methods.iterator.finalize =
		notification_iterator_finalize_method;

end:
	return ret;
}

int bt_component_class_source_set_notification_iterator_seek_time_method(
		struct bt_component_class *component_class,
		bt_component_class_notification_iterator_seek_time_method notification_iterator_seek_time_method)
{
	struct bt_component_class_source *source_class;
	int ret = 0;

	if (!component_class || component_class->frozen ||
			!notification_iterator_seek_time_method ||
			component_class->type != BT_COMPONENT_CLASS_TYPE_SOURCE) {
		ret = -1;
		goto end;
	}

	source_class = container_of(component_class,
		struct bt_component_class_source, parent);
	source_class->methods.iterator.seek_time =
		notification_iterator_seek_time_method;

end:
	return ret;
}

int bt_component_class_filter_set_notification_iterator_init_method(
		struct bt_component_class *component_class,
		bt_component_class_notification_iterator_init_method notification_iterator_init_method)
{
	struct bt_component_class_filter *filter_class;
	int ret = 0;

	if (!component_class || component_class->frozen ||
			!notification_iterator_init_method ||
			component_class->type != BT_COMPONENT_CLASS_TYPE_FILTER) {
		ret = -1;
		goto end;
	}

	filter_class = container_of(component_class,
		struct bt_component_class_filter, parent);
	filter_class->methods.iterator.init = notification_iterator_init_method;

end:
	return ret;
}

int bt_component_class_filter_set_notification_iterator_finalize_method(
		struct bt_component_class *component_class,
		bt_component_class_notification_iterator_finalize_method notification_iterator_finalize_method)
{
	struct bt_component_class_filter *filter_class;
	int ret = 0;

	if (!component_class || component_class->frozen ||
			!notification_iterator_finalize_method ||
			component_class->type != BT_COMPONENT_CLASS_TYPE_FILTER) {
		ret = -1;
		goto end;
	}

	filter_class = container_of(component_class,
		struct bt_component_class_filter, parent);
	filter_class->methods.iterator.finalize =
		notification_iterator_finalize_method;

end:
	return ret;
}

int bt_component_class_filter_set_notification_iterator_seek_time_method(
		struct bt_component_class *component_class,
		bt_component_class_notification_iterator_seek_time_method notification_iterator_seek_time_method)
{
	struct bt_component_class_filter *filter_class;
	int ret = 0;

	if (!component_class || component_class->frozen ||
			!notification_iterator_seek_time_method ||
			component_class->type != BT_COMPONENT_CLASS_TYPE_FILTER) {
		ret = -1;
		goto end;
	}

	filter_class = container_of(component_class,
		struct bt_component_class_filter, parent);
	filter_class->methods.iterator.seek_time =
		notification_iterator_seek_time_method;

end:
	return ret;
}

int bt_component_class_set_description(
		struct bt_component_class *component_class,
		const char *description)
{
	int ret = 0;

	if (!component_class || component_class->frozen || !description) {
		ret = -1;
		goto end;
	}

	g_string_assign(component_class->description, description);

end:
	return ret;
}

int bt_component_class_set_help(
		struct bt_component_class *component_class,
		const char *help)
{
	int ret = 0;

	if (!component_class || component_class->frozen || !help) {
		ret = -1;
		goto end;
	}

	g_string_assign(component_class->help, help);

end:
	return ret;
}

const char *bt_component_class_get_name(
		struct bt_component_class *component_class)
{
	return component_class ? component_class->name->str : NULL;
}

enum bt_component_class_type bt_component_class_get_type(
		struct bt_component_class *component_class)
{
	return component_class ? component_class->type :
			BT_COMPONENT_CLASS_TYPE_UNKNOWN;
}

const char *bt_component_class_get_description(
		struct bt_component_class *component_class)
{
	return component_class && component_class->description &&
		component_class->description->str[0] != '\0' ?
		component_class->description->str : NULL;
}

const char *bt_component_class_get_help(
		struct bt_component_class *component_class)
{
	return component_class && component_class->help &&
		component_class->help->str[0] != '\0' ?
		component_class->help->str : NULL;
}

BT_HIDDEN
int bt_component_class_add_destroy_listener(struct bt_component_class *class,
		bt_component_class_destroy_listener_func func, void *data)
{
	int ret = 0;
	struct bt_component_class_destroy_listener listener;

	if (!class || class->frozen || !func) {
		ret = -1;
		goto end;
	}

	listener.func = func;
	listener.data = data;
	g_array_append_val(class->destroy_listeners, listener);

end:
	return ret;
}

int bt_component_class_freeze(
		struct bt_component_class *component_class)
{
	int ret = 0;

	if (!component_class) {
		ret = -1;
		goto end;
	}

	component_class->frozen = true;

end:
	return ret;
}

struct bt_value *bt_component_class_query(
		struct bt_component_class *component_class,
		const char *object, struct bt_value *params)
{
	struct bt_value *results = NULL;

	if (!component_class || !object || !params ||
			!component_class->methods.query) {
		goto end;
	}

	results = component_class->methods.query(component_class,
		object, params);

end:
	return results;
}
Commit	Line	Data
fb2dcc52 JG	1	/*
	2	* component-class.c
	3	*
	4	* Babeltrace Plugin Component Class
33b34c43	5	*
3310b217	6	* Copyright 2016 Jérémie Galarneau <jeremie.galarneau@efficios.com>
fb2dcc52 JG	7	*
	8	* Author: Jérémie Galarneau <jeremie.galarneau@efficios.com>
	9	*
	10	* Permission is hereby granted, free of charge, to any person obtaining a copy
	11	* of this software and associated documentation files (the "Software"), to deal
	12	* in the Software without restriction, including without limitation the rights
	13	* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
	14	* copies of the Software, and to permit persons to whom the Software is
	15	* furnished to do so, subject to the following conditions:
	16	*
	17	* The above copyright notice and this permission notice shall be included in
	18	* all copies or substantial portions of the Software.
	19	*
	20	* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
	21	* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
	22	* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
	23	* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
	24	* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
	25	* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
	26	* SOFTWARE.
	27	*/
	28
3d9990ac	29	#include <babeltrace/compiler-internal.h>
b2e0c907	30	#include <babeltrace/graph/component-class-internal.h>
b8a06801	31	#include <babeltrace/ref.h>
1e4d8103	32	#include <stdbool.h>
fb2dcc52 JG	33	#include <glib.h>
	34
	35	static
b8a06801	36	void bt_component_class_destroy(struct bt_object *obj)
fb2dcc52 JG	37	{
fb2dcc52 JG	38	struct bt_component_class *class;
33b34c43	39	int i;
fb2dcc52	40
b8a06801 JG	41	assert(obj);
b8a06801 JG	42	class = container_of(obj, struct bt_component_class, base);
33b34c43 PP	43
	44	/* Call destroy listeners in reverse registration order */
	45	for (i = class->destroy_listeners->len - 1; i >= 0; i--) {
d3e4dcd8	46	struct bt_component_class_destroy_listener *listener =
33b34c43	47	&g_array_index(class->destroy_listeners,
d3e4dcd8	48	struct bt_component_class_destroy_listener,
33b34c43 PP	49	i);
	50
	51	listener->func(class, listener->data);
	52	}
	53
fb2dcc52 JG	54	if (class->name) {
	55	g_string_free(class->name, TRUE);
	56	}
7c7c0433 JG	57	if (class->description) {
	58	g_string_free(class->description, TRUE);
	59	}
5536d9a6 PP	60	if (class->help) {
	61	g_string_free(class->help, TRUE);
	62	}
33b34c43 PP	63	if (class->destroy_listeners) {
	64	g_array_free(class->destroy_listeners, TRUE);
	65	}
b8a06801	66
fb2dcc52 JG	67	g_free(class);
	68	}
	69
d3e4dcd8 PP	70	static
	71	int bt_component_class_init(struct bt_component_class *class,
	72	enum bt_component_class_type type, const char *name)
fb2dcc52	73	{
d3e4dcd8 PP	74	int ret = 0;
	75
	76	bt_object_init(class, bt_component_class_destroy);
	77	class->type = type;
	78	class->name = g_string_new(name);
	79	if (!class->name) {
	80	goto error;
	81	}
	82
	83	class->description = g_string_new(NULL);
	84	if (!class->description) {
	85	goto error;
	86	}
	87
5536d9a6 PP	88	class->help = g_string_new(NULL);
	89	if (!class->help) {
	90	goto error;
	91	}
	92
d3e4dcd8 PP	93	class->destroy_listeners = g_array_new(FALSE, TRUE,
	94	sizeof(struct bt_component_class_destroy_listener));
	95	if (!class->destroy_listeners) {
	96	goto error;
	97	}
	98
	99	goto end;
6ba0b073	100
d3e4dcd8 PP	101	error:
	102	BT_PUT(class);
	103	ret = -1;
	104
	105	end:
	106	return ret;
	107	}
	108
	109	struct bt_component_class bt_component_class_source_create(const char name,
d3eb6e8f	110	bt_component_class_notification_iterator_next_method notification_iterator_next_method)
d3e4dcd8 PP	111	{
	112	struct bt_component_class_source *source_class = NULL;
	113	int ret;
	114
41a2b7ae	115	if (!name \|\| !notification_iterator_next_method) {
6ba0b073 PP	116	goto end;
6ba0b073 PP	117	}
fb2dcc52	118
d3e4dcd8 PP	119	source_class = g_new0(struct bt_component_class_source, 1);
d3e4dcd8 PP	120	if (!source_class) {
fb2dcc52 JG	121	goto end;
	122	}
	123
d3e4dcd8 PP	124	ret = bt_component_class_init(&source_class->parent,
	125	BT_COMPONENT_CLASS_TYPE_SOURCE, name);
	126	if (ret) {
	127	/*
	128	* If bt_component_class_init() fails, the component
	129	* class is put, therefore its memory is already
	130	* freed.
	131	*/
	132	source_class = NULL;
	133	goto end;
	134	}
	135
d3eb6e8f	136	source_class->methods.iterator.next = notification_iterator_next_method;
d3e4dcd8 PP	137
	138	end:
	139	return &source_class->parent;
	140	}
	141
	142	struct bt_component_class bt_component_class_filter_create(const char name,
d3eb6e8f	143	bt_component_class_notification_iterator_next_method notification_iterator_next_method)
d3e4dcd8 PP	144	{
	145	struct bt_component_class_filter *filter_class = NULL;
	146	int ret;
	147
41a2b7ae	148	if (!name \|\| !notification_iterator_next_method) {
fb2dcc52 JG	149	goto end;
fb2dcc52 JG	150	}
6ba0b073	151
d3e4dcd8 PP	152	filter_class = g_new0(struct bt_component_class_filter, 1);
	153	if (!filter_class) {
	154	goto end;
6ba0b073 PP	155	}
6ba0b073 PP	156
d3e4dcd8 PP	157	ret = bt_component_class_init(&filter_class->parent,
	158	BT_COMPONENT_CLASS_TYPE_FILTER, name);
	159	if (ret) {
	160	/*
	161	* If bt_component_class_init() fails, the component
	162	* class is put, therefore its memory is already
	163	* freed.
	164	*/
	165	filter_class = NULL;
33b34c43 PP	166	goto end;
33b34c43 PP	167	}
d3e4dcd8	168
d3eb6e8f	169	filter_class->methods.iterator.next = notification_iterator_next_method;
d3e4dcd8	170
fb2dcc52	171	end:
d3e4dcd8 PP	172	return &filter_class->parent;
	173	}
	174
	175	struct bt_component_class bt_component_class_sink_create(const char name,
	176	bt_component_class_sink_consume_method consume_method)
	177	{
	178	struct bt_component_class_sink *sink_class = NULL;
	179	int ret;
	180
	181	if (!name \|\| !consume_method) {
	182	goto end;
	183	}
	184
	185	sink_class = g_new0(struct bt_component_class_sink, 1);
	186	if (!sink_class) {
	187	goto end;
	188	}
	189
	190	ret = bt_component_class_init(&sink_class->parent,
	191	BT_COMPONENT_CLASS_TYPE_SINK, name);
	192	if (ret) {
	193	/*
	194	* If bt_component_class_init() fails, the component
	195	* class is put, therefore its memory is already
	196	* freed.
	197	*/
	198	sink_class = NULL;
	199	goto end;
	200	}
	201
	202	sink_class->methods.consume = consume_method;
	203
	204	end:
	205	return &sink_class->parent;
	206	}
	207
	208	int bt_component_class_set_init_method(
	209	struct bt_component_class *component_class,
	210	bt_component_class_init_method init_method)
	211	{
	212	int ret = 0;
	213
1e4d8103	214	if (!component_class \|\| component_class->frozen \|\| !init_method) {
d3e4dcd8 PP	215	ret = -1;
	216	goto end;
	217	}
	218
	219	component_class->methods.init = init_method;
	220
	221	end:
	222	return ret;
	223	}
	224
a67681c1	225	int bt_component_class_set_query_method(
efa96d5d	226	struct bt_component_class *component_class,
a67681c1	227	bt_component_class_query_method query_method)
efa96d5d PP	228	{
	229	int ret = 0;
	230
a67681c1	231	if (!component_class \|\| component_class->frozen \|\| !query_method) {
efa96d5d PP	232	ret = -1;
	233	goto end;
	234	}
	235
a67681c1	236	component_class->methods.query = query_method;
efa96d5d PP	237
	238	end:
	239	return ret;
	240	}
	241
72b913fb	242	int bt_component_class_set_accept_port_connection_method(
2d41b99e	243	struct bt_component_class *component_class,
72b913fb	244	bt_component_class_accept_port_connection_method method)
2d41b99e JG	245	{
	246	int ret = 0;
	247
72b913fb	248	if (!component_class \|\| component_class->frozen \|\| !method) {
2d41b99e JG	249	ret = -1;
	250	goto end;
	251	}
	252
72b913fb PP	253	component_class->methods.accept_port_connection = method;
	254
	255	end:
	256	return ret;
	257	}
	258
	259	int bt_component_class_set_port_disconnected_method(
	260	struct bt_component_class *component_class,
	261	bt_component_class_port_disconnected_method method)
	262	{
	263	int ret = 0;
	264
	265	if (!component_class \|\| component_class->frozen \|\| !method) {
	266	ret = -1;
	267	goto end;
	268	}
	269
	270	component_class->methods.port_disconnected = method;
2d41b99e JG	271
	272	end:
	273	return ret;
	274	}
	275
64cadc66	276	int bt_component_class_set_finalize_method(
d3e4dcd8	277	struct bt_component_class *component_class,
64cadc66	278	bt_component_class_finalize_method finalize_method)
d3e4dcd8 PP	279	{
	280	int ret = 0;
	281
64cadc66	282	if (!component_class \|\| component_class->frozen \|\| !finalize_method) {
d3e4dcd8 PP	283	ret = -1;
	284	goto end;
	285	}
	286
64cadc66	287	component_class->methods.finalize = finalize_method;
d3e4dcd8 PP	288
	289	end:
	290	return ret;
	291	}
	292
d3eb6e8f PP	293	int bt_component_class_source_set_notification_iterator_init_method(
	294	struct bt_component_class *component_class,
	295	bt_component_class_notification_iterator_init_method notification_iterator_init_method)
	296	{
	297	struct bt_component_class_source *source_class;
	298	int ret = 0;
	299
	300	if (!component_class \|\| component_class->frozen \|\|
	301	!notification_iterator_init_method \|\|
	302	component_class->type != BT_COMPONENT_CLASS_TYPE_SOURCE) {
	303	ret = -1;
	304	goto end;
	305	}
	306
	307	source_class = container_of(component_class,
	308	struct bt_component_class_source, parent);
	309	source_class->methods.iterator.init = notification_iterator_init_method;
	310
	311	end:
	312	return ret;
	313	}
	314
64cadc66	315	int bt_component_class_source_set_notification_iterator_finalize_method(
d3eb6e8f	316	struct bt_component_class *component_class,
64cadc66	317	bt_component_class_notification_iterator_finalize_method notification_iterator_finalize_method)
d3eb6e8f PP	318	{
	319	struct bt_component_class_source *source_class;
	320	int ret = 0;
	321
	322	if (!component_class \|\| component_class->frozen \|\|
64cadc66	323	!notification_iterator_finalize_method \|\|
d3eb6e8f PP	324	component_class->type != BT_COMPONENT_CLASS_TYPE_SOURCE) {
	325	ret = -1;
	326	goto end;
	327	}
	328
	329	source_class = container_of(component_class,
	330	struct bt_component_class_source, parent);
64cadc66 PP	331	source_class->methods.iterator.finalize =
64cadc66 PP	332	notification_iterator_finalize_method;
d3eb6e8f PP	333
	334	end:
	335	return ret;
	336	}
	337
	338	int bt_component_class_source_set_notification_iterator_seek_time_method(
	339	struct bt_component_class *component_class,
	340	bt_component_class_notification_iterator_seek_time_method notification_iterator_seek_time_method)
	341	{
	342	struct bt_component_class_source *source_class;
	343	int ret = 0;
	344
	345	if (!component_class \|\| component_class->frozen \|\|
	346	!notification_iterator_seek_time_method \|\|
	347	component_class->type != BT_COMPONENT_CLASS_TYPE_SOURCE) {
	348	ret = -1;
	349	goto end;
	350	}
	351
	352	source_class = container_of(component_class,
	353	struct bt_component_class_source, parent);
	354	source_class->methods.iterator.seek_time =
	355	notification_iterator_seek_time_method;
	356
	357	end:
	358	return ret;
	359	}
	360
	361	int bt_component_class_filter_set_notification_iterator_init_method(
	362	struct bt_component_class *component_class,
	363	bt_component_class_notification_iterator_init_method notification_iterator_init_method)
	364	{
	365	struct bt_component_class_filter *filter_class;
	366	int ret = 0;
	367
	368	if (!component_class \|\| component_class->frozen \|\|
	369	!notification_iterator_init_method \|\|
	370	component_class->type != BT_COMPONENT_CLASS_TYPE_FILTER) {
	371	ret = -1;
	372	goto end;
	373	}
	374
	375	filter_class = container_of(component_class,
	376	struct bt_component_class_filter, parent);
	377	filter_class->methods.iterator.init = notification_iterator_init_method;
	378
	379	end:
	380	return ret;
	381	}
	382
64cadc66	383	int bt_component_class_filter_set_notification_iterator_finalize_method(
d3eb6e8f	384	struct bt_component_class *component_class,
64cadc66	385	bt_component_class_notification_iterator_finalize_method notification_iterator_finalize_method)
d3eb6e8f PP	386	{
	387	struct bt_component_class_filter *filter_class;
	388	int ret = 0;
	389
	390	if (!component_class \|\| component_class->frozen \|\|
64cadc66	391	!notification_iterator_finalize_method \|\|
d3eb6e8f PP	392	component_class->type != BT_COMPONENT_CLASS_TYPE_FILTER) {
	393	ret = -1;
	394	goto end;
	395	}
	396
	397	filter_class = container_of(component_class,
	398	struct bt_component_class_filter, parent);
64cadc66 PP	399	filter_class->methods.iterator.finalize =
64cadc66 PP	400	notification_iterator_finalize_method;
d3eb6e8f PP	401
	402	end:
	403	return ret;
	404	}
	405
	406	int bt_component_class_filter_set_notification_iterator_seek_time_method(
	407	struct bt_component_class *component_class,
	408	bt_component_class_notification_iterator_seek_time_method notification_iterator_seek_time_method)
	409	{
	410	struct bt_component_class_filter *filter_class;
	411	int ret = 0;
	412
	413	if (!component_class \|\| component_class->frozen \|\|
	414	!notification_iterator_seek_time_method \|\|
	415	component_class->type != BT_COMPONENT_CLASS_TYPE_FILTER) {
	416	ret = -1;
	417	goto end;
	418	}
	419
	420	filter_class = container_of(component_class,
	421	struct bt_component_class_filter, parent);
	422	filter_class->methods.iterator.seek_time =
	423	notification_iterator_seek_time_method;
	424
	425	end:
	426	return ret;
	427	}
	428
	429	int bt_component_class_set_description(
d3e4dcd8 PP	430	struct bt_component_class *component_class,
	431	const char *description)
	432	{
	433	int ret = 0;
	434
1e4d8103	435	if (!component_class \|\| component_class->frozen \|\| !description) {
d3e4dcd8 PP	436	ret = -1;
	437	goto end;
	438	}
	439
	440	g_string_assign(component_class->description, description);
	441
	442	end:
	443	return ret;
fb2dcc52	444	}
38b48196	445
5536d9a6 PP	446	int bt_component_class_set_help(
	447	struct bt_component_class *component_class,
	448	const char *help)
	449	{
	450	int ret = 0;
	451
	452	if (!component_class \|\| component_class->frozen \|\| !help) {
	453	ret = -1;
	454	goto end;
	455	}
	456
	457	g_string_assign(component_class->help, help);
	458
	459	end:
	460	return ret;
	461	}
	462
38b48196 JG	463	const char *bt_component_class_get_name(
	464	struct bt_component_class *component_class)
	465	{
	466	return component_class ? component_class->name->str : NULL;
	467	}
	468
d3e4dcd8	469	enum bt_component_class_type bt_component_class_get_type(
38b48196 JG	470	struct bt_component_class *component_class)
	471	{
	472	return component_class ? component_class->type :
d3e4dcd8	473	BT_COMPONENT_CLASS_TYPE_UNKNOWN;
38b48196 JG	474	}
38b48196 JG	475
33b34c43	476	const char *bt_component_class_get_description(
38b48196 JG	477	struct bt_component_class *component_class)
38b48196 JG	478	{
22e22462 PP	479	return component_class && component_class->description &&
22e22462 PP	480	component_class->description->str[0] != '\0' ?
6ba0b073	481	component_class->description->str : NULL;
38b48196	482	}
7c7c0433	483
5536d9a6 PP	484	const char *bt_component_class_get_help(
	485	struct bt_component_class *component_class)
	486	{
22e22462 PP	487	return component_class && component_class->help &&
22e22462 PP	488	component_class->help->str[0] != '\0' ?
5536d9a6 PP	489	component_class->help->str : NULL;
	490	}
	491
33b34c43 PP	492	BT_HIDDEN
	493	int bt_component_class_add_destroy_listener(struct bt_component_class *class,
	494	bt_component_class_destroy_listener_func func, void *data)
7c7c0433	495	{
33b34c43	496	int ret = 0;
d3e4dcd8	497	struct bt_component_class_destroy_listener listener;
33b34c43	498
1e4d8103	499	if (!class \|\| class->frozen \|\| !func) {
33b34c43 PP	500	ret = -1;
	501	goto end;
	502	}
	503
	504	listener.func = func;
	505	listener.data = data;
	506	g_array_append_val(class->destroy_listeners, listener);
	507
	508	end:
	509	return ret;
7c7c0433	510	}
d3e4dcd8	511
1e4d8103 PP	512	int bt_component_class_freeze(
	513	struct bt_component_class *component_class)
	514	{
	515	int ret = 0;
	516
	517	if (!component_class) {
	518	ret = -1;
	519	goto end;
	520	}
	521
	522	component_class->frozen = true;
	523
	524	end:
	525	return ret;
	526	}
efa96d5d	527
a67681c1	528	struct bt_value *bt_component_class_query(
efa96d5d	529	struct bt_component_class *component_class,
a67681c1	530	const char object, struct bt_value params)
efa96d5d PP	531	{
	532	struct bt_value *results = NULL;
	533
a67681c1 PP	534	if (!component_class \|\| !object \|\| !params \|\|
a67681c1 PP	535	!component_class->methods.query) {
efa96d5d PP	536	goto end;
	537	}
	538
a67681c1 PP	539	results = component_class->methods.query(component_class,
a67681c1 PP	540	object, params);
efa96d5d PP	541
	542	end:
	543	return results;
	544	}