[babeltrace.git] / lib / component / 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.h>
#include <babeltrace/component/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_get_method notification_iterator_get_method,
		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_get_method ||
			!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.get = notification_iterator_get_method;
	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_get_method notification_iterator_get_method,
		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_get_method ||
			!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.get = notification_iterator_get_method;
	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_destroy_method(
		struct bt_component_class *component_class,
		bt_component_class_destroy_method destroy_method)
{
	int ret = 0;

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

	component_class->methods.destroy = destroy_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_destroy_method(
		struct bt_component_class *component_class,
		bt_component_class_notification_iterator_destroy_method notification_iterator_destroy_method)
{
	struct bt_component_class_source *source_class;
	int ret = 0;

	if (!component_class || component_class->frozen ||
			!notification_iterator_destroy_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.destroy =
		notification_iterator_destroy_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_destroy_method(
		struct bt_component_class *component_class,
		bt_component_class_notification_iterator_destroy_method notification_iterator_destroy_method)
{
	struct bt_component_class_filter *filter_class;
	int ret = 0;

	if (!component_class || component_class->frozen ||
			!notification_iterator_destroy_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.destroy =
		notification_iterator_destroy_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
	29	#include <babeltrace/compiler.h>
33b34c43	30	#include <babeltrace/component/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 PP	110	bt_component_class_notification_iterator_get_method notification_iterator_get_method,
d3eb6e8f PP	111	bt_component_class_notification_iterator_next_method notification_iterator_next_method)
d3e4dcd8 PP	112	{
	113	struct bt_component_class_source *source_class = NULL;
	114	int ret;
	115
d3eb6e8f PP	116	if (!name \|\| !notification_iterator_get_method \|\|
d3eb6e8f PP	117	!notification_iterator_next_method) {
6ba0b073 PP	118	goto end;
6ba0b073 PP	119	}
fb2dcc52	120
d3e4dcd8 PP	121	source_class = g_new0(struct bt_component_class_source, 1);
d3e4dcd8 PP	122	if (!source_class) {
fb2dcc52 JG	123	goto end;
	124	}
	125
d3e4dcd8 PP	126	ret = bt_component_class_init(&source_class->parent,
	127	BT_COMPONENT_CLASS_TYPE_SOURCE, name);
	128	if (ret) {
	129	/*
	130	* If bt_component_class_init() fails, the component
	131	* class is put, therefore its memory is already
	132	* freed.
	133	*/
	134	source_class = NULL;
	135	goto end;
	136	}
	137
d3eb6e8f PP	138	source_class->methods.iterator.get = notification_iterator_get_method;
d3eb6e8f PP	139	source_class->methods.iterator.next = notification_iterator_next_method;
d3e4dcd8 PP	140
	141	end:
	142	return &source_class->parent;
	143	}
	144
	145	struct bt_component_class bt_component_class_filter_create(const char name,
d3eb6e8f PP	146	bt_component_class_notification_iterator_get_method notification_iterator_get_method,
d3eb6e8f PP	147	bt_component_class_notification_iterator_next_method notification_iterator_next_method)
d3e4dcd8 PP	148	{
	149	struct bt_component_class_filter *filter_class = NULL;
	150	int ret;
	151
d3eb6e8f PP	152	if (!name \|\| !notification_iterator_get_method \|\|
d3eb6e8f PP	153	!notification_iterator_next_method) {
fb2dcc52 JG	154	goto end;
fb2dcc52 JG	155	}
6ba0b073	156
d3e4dcd8 PP	157	filter_class = g_new0(struct bt_component_class_filter, 1);
	158	if (!filter_class) {
	159	goto end;
6ba0b073 PP	160	}
6ba0b073 PP	161
d3e4dcd8 PP	162	ret = bt_component_class_init(&filter_class->parent,
	163	BT_COMPONENT_CLASS_TYPE_FILTER, name);
	164	if (ret) {
	165	/*
	166	* If bt_component_class_init() fails, the component
	167	* class is put, therefore its memory is already
	168	* freed.
	169	*/
	170	filter_class = NULL;
33b34c43 PP	171	goto end;
33b34c43 PP	172	}
d3e4dcd8	173
d3eb6e8f PP	174	filter_class->methods.iterator.get = notification_iterator_get_method;
d3eb6e8f PP	175	filter_class->methods.iterator.next = notification_iterator_next_method;
d3e4dcd8	176
fb2dcc52	177	end:
d3e4dcd8 PP	178	return &filter_class->parent;
	179	}
	180
	181	struct bt_component_class bt_component_class_sink_create(const char name,
	182	bt_component_class_sink_consume_method consume_method)
	183	{
	184	struct bt_component_class_sink *sink_class = NULL;
	185	int ret;
	186
	187	if (!name \|\| !consume_method) {
	188	goto end;
	189	}
	190
	191	sink_class = g_new0(struct bt_component_class_sink, 1);
	192	if (!sink_class) {
	193	goto end;
	194	}
	195
	196	ret = bt_component_class_init(&sink_class->parent,
	197	BT_COMPONENT_CLASS_TYPE_SINK, name);
	198	if (ret) {
	199	/*
	200	* If bt_component_class_init() fails, the component
	201	* class is put, therefore its memory is already
	202	* freed.
	203	*/
	204	sink_class = NULL;
	205	goto end;
	206	}
	207
	208	sink_class->methods.consume = consume_method;
	209
	210	end:
	211	return &sink_class->parent;
	212	}
	213
	214	int bt_component_class_set_init_method(
	215	struct bt_component_class *component_class,
	216	bt_component_class_init_method init_method)
	217	{
	218	int ret = 0;
	219
1e4d8103	220	if (!component_class \|\| component_class->frozen \|\| !init_method) {
d3e4dcd8 PP	221	ret = -1;
	222	goto end;
	223	}
	224
	225	component_class->methods.init = init_method;
	226
	227	end:
	228	return ret;
	229	}
	230
a67681c1	231	int bt_component_class_set_query_method(
efa96d5d	232	struct bt_component_class *component_class,
a67681c1	233	bt_component_class_query_method query_method)
efa96d5d PP	234	{
	235	int ret = 0;
	236
a67681c1	237	if (!component_class \|\| component_class->frozen \|\| !query_method) {
efa96d5d PP	238	ret = -1;
	239	goto end;
	240	}
	241
a67681c1	242	component_class->methods.query = query_method;
efa96d5d PP	243
	244	end:
	245	return ret;
	246	}
	247
72b913fb	248	int bt_component_class_set_accept_port_connection_method(
2d41b99e	249	struct bt_component_class *component_class,
72b913fb	250	bt_component_class_accept_port_connection_method method)
2d41b99e JG	251	{
	252	int ret = 0;
	253
72b913fb	254	if (!component_class \|\| component_class->frozen \|\| !method) {
2d41b99e JG	255	ret = -1;
	256	goto end;
	257	}
	258
72b913fb PP	259	component_class->methods.accept_port_connection = method;
	260
	261	end:
	262	return ret;
	263	}
	264
	265	int bt_component_class_set_port_disconnected_method(
	266	struct bt_component_class *component_class,
	267	bt_component_class_port_disconnected_method method)
	268	{
	269	int ret = 0;
	270
	271	if (!component_class \|\| component_class->frozen \|\| !method) {
	272	ret = -1;
	273	goto end;
	274	}
	275
	276	component_class->methods.port_disconnected = method;
2d41b99e JG	277
	278	end:
	279	return ret;
	280	}
	281
d3e4dcd8 PP	282	int bt_component_class_set_destroy_method(
	283	struct bt_component_class *component_class,
	284	bt_component_class_destroy_method destroy_method)
	285	{
	286	int ret = 0;
	287
1e4d8103	288	if (!component_class \|\| component_class->frozen \|\| !destroy_method) {
d3e4dcd8 PP	289	ret = -1;
	290	goto end;
	291	}
	292
	293	component_class->methods.destroy = destroy_method;
	294
	295	end:
	296	return ret;
	297	}
	298
d3eb6e8f PP	299	int bt_component_class_source_set_notification_iterator_init_method(
	300	struct bt_component_class *component_class,
	301	bt_component_class_notification_iterator_init_method notification_iterator_init_method)
	302	{
	303	struct bt_component_class_source *source_class;
	304	int ret = 0;
	305
	306	if (!component_class \|\| component_class->frozen \|\|
	307	!notification_iterator_init_method \|\|
	308	component_class->type != BT_COMPONENT_CLASS_TYPE_SOURCE) {
	309	ret = -1;
	310	goto end;
	311	}
	312
	313	source_class = container_of(component_class,
	314	struct bt_component_class_source, parent);
	315	source_class->methods.iterator.init = notification_iterator_init_method;
	316
	317	end:
	318	return ret;
	319	}
	320
	321	int bt_component_class_source_set_notification_iterator_destroy_method(
	322	struct bt_component_class *component_class,
	323	bt_component_class_notification_iterator_destroy_method notification_iterator_destroy_method)
	324	{
	325	struct bt_component_class_source *source_class;
	326	int ret = 0;
	327
	328	if (!component_class \|\| component_class->frozen \|\|
	329	!notification_iterator_destroy_method \|\|
	330	component_class->type != BT_COMPONENT_CLASS_TYPE_SOURCE) {
	331	ret = -1;
	332	goto end;
	333	}
	334
	335	source_class = container_of(component_class,
	336	struct bt_component_class_source, parent);
	337	source_class->methods.iterator.destroy =
	338	notification_iterator_destroy_method;
	339
	340	end:
	341	return ret;
	342	}
	343
	344	int bt_component_class_source_set_notification_iterator_seek_time_method(
	345	struct bt_component_class *component_class,
	346	bt_component_class_notification_iterator_seek_time_method notification_iterator_seek_time_method)
	347	{
	348	struct bt_component_class_source *source_class;
	349	int ret = 0;
	350
	351	if (!component_class \|\| component_class->frozen \|\|
	352	!notification_iterator_seek_time_method \|\|
	353	component_class->type != BT_COMPONENT_CLASS_TYPE_SOURCE) {
	354	ret = -1;
	355	goto end;
	356	}
	357
	358	source_class = container_of(component_class,
	359	struct bt_component_class_source, parent);
	360	source_class->methods.iterator.seek_time =
	361	notification_iterator_seek_time_method;
	362
363	end:
364	return ret;
365	}
366
367	int bt_component_class_filter_set_notification_iterator_init_method(
368	struct bt_component_class *component_class,
369	bt_component_class_notification_iterator_init_method notification_iterator_init_method)
370	{
371	struct bt_component_class_filter *filter_class;
372	int ret = 0;
373
374	if (!component_class \|\| component_class->frozen \|\|
375	!notification_iterator_init_method \|\|
376	component_class->type != BT_COMPONENT_CLASS_TYPE_FILTER) {
377	ret = -1;
378	goto end;
379	}
380
381	filter_class = container_of(component_class,
382	struct bt_component_class_filter, parent);
383	filter_class->methods.iterator.init = notification_iterator_init_method;
384
385	end:
386	return ret;
387	}
388
389	int bt_component_class_filter_set_notification_iterator_destroy_method(
390	struct bt_component_class *component_class,
391	bt_component_class_notification_iterator_destroy_method notification_iterator_destroy_method)
392	{
393	struct bt_component_class_filter *filter_class;
394	int ret = 0;
395
396	if (!component_class \|\| component_class->frozen \|\|
397	!notification_iterator_destroy_method \|\|
398	component_class->type != BT_COMPONENT_CLASS_TYPE_FILTER) {
399	ret = -1;
400	goto end;
401	}
402
403	filter_class = container_of(component_class,
404	struct bt_component_class_filter, parent);
405	filter_class->methods.iterator.destroy =
406	notification_iterator_destroy_method;
407
408	end:
409	return ret;
410	}
411
412	int bt_component_class_filter_set_notification_iterator_seek_time_method(
413	struct bt_component_class *component_class,
414	bt_component_class_notification_iterator_seek_time_method notification_iterator_seek_time_method)
415	{
416	struct bt_component_class_filter *filter_class;
417	int ret = 0;
418
419	if (!component_class \|\| component_class->frozen \|\|
420	!notification_iterator_seek_time_method \|\|
421	component_class->type != BT_COMPONENT_CLASS_TYPE_FILTER) {
422	ret = -1;
423	goto end;
424	}
425
426	filter_class = container_of(component_class,
427	struct bt_component_class_filter, parent);
428	filter_class->methods.iterator.seek_time =
429	notification_iterator_seek_time_method;
430
431	end:
432	return ret;
433	}
434
435	int bt_component_class_set_description(
d3e4dcd8 PP	436	struct bt_component_class *component_class,
	437	const char *description)
	438	{
	439	int ret = 0;
	440
1e4d8103	441	if (!component_class \|\| component_class->frozen \|\| !description) {
d3e4dcd8 PP	442	ret = -1;
	443	goto end;
	444	}
	445
	446	g_string_assign(component_class->description, description);
	447
	448	end:
	449	return ret;
fb2dcc52	450	}
38b48196	451
5536d9a6 PP	452	int bt_component_class_set_help(
	453	struct bt_component_class *component_class,
	454	const char *help)
	455	{
	456	int ret = 0;
	457
	458	if (!component_class \|\| component_class->frozen \|\| !help) {
	459	ret = -1;
	460	goto end;
	461	}
	462
	463	g_string_assign(component_class->help, help);
	464
	465	end:
	466	return ret;
	467	}
	468
38b48196 JG	469	const char *bt_component_class_get_name(
	470	struct bt_component_class *component_class)
	471	{
	472	return component_class ? component_class->name->str : NULL;
	473	}
	474
d3e4dcd8	475	enum bt_component_class_type bt_component_class_get_type(
38b48196 JG	476	struct bt_component_class *component_class)
	477	{
	478	return component_class ? component_class->type :
d3e4dcd8	479	BT_COMPONENT_CLASS_TYPE_UNKNOWN;
38b48196 JG	480	}
38b48196 JG	481
33b34c43	482	const char *bt_component_class_get_description(
38b48196 JG	483	struct bt_component_class *component_class)
38b48196 JG	484	{
22e22462 PP	485	return component_class && component_class->description &&
22e22462 PP	486	component_class->description->str[0] != '\0' ?
6ba0b073	487	component_class->description->str : NULL;
38b48196	488	}
7c7c0433	489
5536d9a6 PP	490	const char *bt_component_class_get_help(
	491	struct bt_component_class *component_class)
	492	{
22e22462 PP	493	return component_class && component_class->help &&
22e22462 PP	494	component_class->help->str[0] != '\0' ?
5536d9a6 PP	495	component_class->help->str : NULL;
	496	}
	497
33b34c43 PP	498	BT_HIDDEN
	499	int bt_component_class_add_destroy_listener(struct bt_component_class *class,
	500	bt_component_class_destroy_listener_func func, void *data)
7c7c0433	501	{
33b34c43	502	int ret = 0;
d3e4dcd8	503	struct bt_component_class_destroy_listener listener;
33b34c43	504
1e4d8103	505	if (!class \|\| class->frozen \|\| !func) {
33b34c43 PP	506	ret = -1;
	507	goto end;
	508	}
	509
	510	listener.func = func;
	511	listener.data = data;
	512	g_array_append_val(class->destroy_listeners, listener);
	513
	514	end:
	515	return ret;
7c7c0433	516	}
d3e4dcd8	517
1e4d8103 PP	518	int bt_component_class_freeze(
	519	struct bt_component_class *component_class)
	520	{
	521	int ret = 0;
	522
	523	if (!component_class) {
	524	ret = -1;
	525	goto end;
	526	}
	527
	528	component_class->frozen = true;
	529
	530	end:
	531	return ret;
	532	}
efa96d5d	533
a67681c1	534	struct bt_value *bt_component_class_query(
efa96d5d	535	struct bt_component_class *component_class,
a67681c1	536	const char object, struct bt_value params)
efa96d5d PP	537	{
	538	struct bt_value *results = NULL;
	539
a67681c1 PP	540	if (!component_class \|\| !object \|\| !params \|\|
a67681c1 PP	541	!component_class->methods.query) {
efa96d5d PP	542	goto end;
	543	}
	544
a67681c1 PP	545	results = component_class->methods.query(component_class,
a67681c1 PP	546	object, params);
efa96d5d PP	547
	548	end:
	549	return results;
	550	}