[babeltrace.git] / converter / babeltrace.c

/*
 * babeltrace.c
 *
 * Babeltrace Trace Converter
 *
 * Copyright 2010-2011 EfficiOS Inc. and Linux Foundation
 *
 * Author: Mathieu Desnoyers <mathieu.desnoyers@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/babeltrace.h>
#include <babeltrace/plugin/component-factory.h>
#include <babeltrace/plugin/plugin.h>
#include <babeltrace/plugin/component-class.h>
#include <babeltrace/plugin/notification/iterator.h>
#include <babeltrace/ref.h>
#include <babeltrace/values.h>
#include <stdlib.h>
#include <babeltrace/ctf-ir/metadata.h>	/* for clocks */
#include <popt.h>
#include <string.h>
#include <stdio.h>
#include "babeltrace-cfg.h"

static
const char *component_type_str(enum bt_component_type type)
{
	switch (type) {
	case BT_COMPONENT_TYPE_SOURCE:
		return "source";
	case BT_COMPONENT_TYPE_SINK:
		return "sink";
	case BT_COMPONENT_TYPE_FILTER:
		return "filter";
	case BT_COMPONENT_TYPE_UNKNOWN:
	default:
		return "unknown";
	}
}

static
void print_component_classes_found(struct bt_component_factory *factory)
{
	int count, i;

	if (!babeltrace_verbose) {
		return;
	}

	count = bt_component_factory_get_component_class_count(factory);
	if (count <= 0) {
		fprintf(stderr, "No component classes found. Please make sure your plug-in search path is set correctly.");
		return;
	}

	printf_verbose("Found %d component classes.\n", count);
	for (i = 0; i < count; i++) {
		struct bt_component_class *component_class =
				bt_component_factory_get_component_class_index(
				factory, i);
		struct bt_plugin *plugin = bt_component_class_get_plugin(
				component_class);
		const char *plugin_name = bt_plugin_get_name(plugin);
		const char *component_name = bt_component_class_get_name(
				component_class);
		const char *path = bt_plugin_get_path(plugin);
		const char *author = bt_plugin_get_author(plugin);
		const char *license = bt_plugin_get_license(plugin);
		const char *plugin_description = bt_plugin_get_description(
				plugin);
		const char *component_description =
				bt_component_class_get_description(
					component_class);
		enum bt_component_type type = bt_component_class_get_type(
				component_class);

		printf_verbose("[%s - %s (%s)]\n", plugin_name, component_name,
			       component_type_str(type));
		printf_verbose("\tpath: %s\n", path);
		printf_verbose("\tauthor: %s\n", author);
		printf_verbose("\tlicense: %s\n", license);
		printf_verbose("\tplugin description: %s\n",
				plugin_description ? plugin_description : "None");
		printf_verbose("\tcomponent description: %s\n",
				component_description ? component_description : "None");

		bt_put(plugin);
		bt_put(component_class);
	}
}

static
void print_indent(size_t indent)
{
	size_t i;

	for (i = 0; i < indent; i++) {
		printf(" ");
	}
}

static
void print_value(struct bt_value *, size_t, bool);

static
bool print_map_value(const char *key, struct bt_value *object, void *data)
{
	size_t indent = (size_t) data;

	print_indent(indent);
	printf("\"%s\": ", key);
	print_value(object, indent, false);

	return true;
}

static
void print_value(struct bt_value *value, size_t indent, bool do_indent)
{
	bool bool_val;
	int64_t int_val;
	double dbl_val;
	const char *str_val;
	int size;
	int i;

	if (!value) {
		return;
	}

	if (do_indent) {
		print_indent(indent);
	}

	switch (bt_value_get_type(value)) {
	case BT_VALUE_TYPE_NULL:
		printf("null\n");
		break;
	case BT_VALUE_TYPE_BOOL:
		bt_value_bool_get(value, &bool_val);
		printf("%s\n", bool_val ? "true" : "false");
		break;
	case BT_VALUE_TYPE_INTEGER:
		bt_value_integer_get(value, &int_val);
		printf("%" PRId64 "\n", int_val);
		break;
	case BT_VALUE_TYPE_FLOAT:
		bt_value_float_get(value, &dbl_val);
		printf("%lf\n", dbl_val);
		break;
	case BT_VALUE_TYPE_STRING:
		bt_value_string_get(value, &str_val);
		printf("\"%s\"\n", str_val);
		break;
	case BT_VALUE_TYPE_ARRAY:
		size = bt_value_array_size(value);
		printf("[\n");

		for (i = 0; i < size; i++) {
			struct bt_value *element =
					bt_value_array_get(value, i);

			print_value(element, indent + 2, true);
			BT_PUT(element);
		}

		print_indent(indent);
		printf("]\n");
		break;
	case BT_VALUE_TYPE_MAP:
		if (bt_value_map_is_empty(value)) {
			printf("{}\n");
			return;
		}

		printf("{\n");
		bt_value_map_foreach(value, print_map_value,
			(void *) (indent + 2));
		print_indent(indent);
		printf("}\n");
		break;
	default:
		assert(false);
	}
}

static
void print_bt_config_component(struct bt_config_component *bt_config_component)
{
	printf("  %s/%s\n", bt_config_component->plugin_name->str,
		bt_config_component->component_name->str);
	printf("    params:\n");
	print_value(bt_config_component->params, 6, true);
}

static
void print_bt_config_components(GPtrArray *array)
{
	size_t i;

	for (i = 0; i < array->len; i++) {
		struct bt_config_component *cfg_component =
			bt_config_get_component(array, i);
		print_bt_config_component(cfg_component);
		BT_PUT(cfg_component);
	}
}

static
void print_cfg(struct bt_config *cfg)
{
	printf("debug:           %d\n", cfg->debug);
	printf("verbose:         %d\n", cfg->verbose);
	printf("do list:         %d\n", cfg->do_list);
	printf("force correlate: %d\n", cfg->force_correlate);
	printf("plugin paths:\n");
	print_value(cfg->plugin_paths, 2, true);
	printf("sources:\n");
	print_bt_config_components(cfg->sources);
	printf("sinks:\n");
	print_bt_config_components(cfg->sinks);
}

int main(int argc, char **argv)
{
	int ret;
	struct bt_component_factory *component_factory = NULL;
	struct bt_component_class *source_class = NULL;
	struct bt_component_class *sink_class = NULL;
	struct bt_component *source = NULL, *sink = NULL;
	struct bt_value *source_params = NULL, *sink_params = NULL;
	struct bt_config *cfg;
	struct bt_notification_iterator *it = NULL;
	enum bt_component_status sink_status;
	struct bt_value *first_plugin_path_value = NULL;
	const char *first_plugin_path;
	struct bt_config_component *cfg_component;

	cfg = bt_config_from_args(argc, argv, &ret);
	if (cfg) {
		print_cfg(cfg);
	} else {
		goto end;
	}

	babeltrace_verbose = cfg->verbose;
	babeltrace_debug = cfg->debug;

	/* TODO handle more than 1 source and 1 sink. */
	if (cfg->sources->len != 1 || cfg->sinks->len != 1) {
		fprintf(stderr, "Unexpected configuration, aborting.../n");
		ret = -1;
		goto end;
	}
	cfg_component = bt_config_get_component(cfg->sources, 0);
	source_params = bt_get(cfg_component->params);
	BT_PUT(cfg_component);
	cfg_component = bt_config_get_component(cfg->sinks, 0);
	sink_params = bt_get(cfg_component->params);
	BT_PUT(cfg_component);

	printf_verbose("Verbose mode active.\n");
	printf_debug("Debug mode active.\n");

	if (bt_value_array_is_empty(cfg->plugin_paths)) {
		fprintf(stderr, "No plugin path specified, aborting...\n");
		ret = -1;
		goto end;
	}
	component_factory = bt_component_factory_create();
	if (!component_factory) {
		fprintf(stderr, "Failed to create component factory.\n");
		ret = -1;
		goto end;
	}

	first_plugin_path_value = bt_value_array_get(cfg->plugin_paths, 0);
	bt_value_string_get(first_plugin_path_value, &first_plugin_path);

	ret = bt_component_factory_load_recursive(component_factory,
			first_plugin_path);
	if (ret) {
		fprintf(stderr, "Failed to load plugins.\n");
		goto end;
	}

	print_component_classes_found(component_factory);
	source_class = bt_component_factory_get_component_class(
			component_factory, "ctf", BT_COMPONENT_TYPE_SOURCE,
			"fs");
	if (!source_class) {
		fprintf(stderr, "Could not find ctf-fs source component class. Aborting...\n");
		ret = -1;
		goto end;
	}

	sink_class = bt_component_factory_get_component_class(component_factory,
			NULL, BT_COMPONENT_TYPE_SINK, "text");
	if (!sink_class) {
		fprintf(stderr, "Could not find text output component class. Aborting...\n");
		ret = -1;
		goto end;
	}

	source = bt_component_create(source_class, "ctf-fs", source_params);
	if (!source) {
		fprintf(stderr, "Failed to instantiate ctf-fs source component. Aborting...\n");
                ret = -1;
                goto end;
        }

	sink = bt_component_create(sink_class, "text", sink_params);
	if (!sink) {
		fprintf(stderr, "Failed to instanciate text output component. Aborting...\n");
		ret = -1;
		goto end;
	}

	it = bt_component_source_create_iterator(source);
	if (!it) {
		fprintf(stderr, "Failed to instantiate source iterator. Aborting...\n");
                ret = -1;
                goto end;
        }

	sink_status = bt_component_sink_add_iterator(sink, it);
	if (sink_status != BT_COMPONENT_STATUS_OK) {
		ret = -1;
		goto end;
	}

	while (true) {
		sink_status = bt_component_sink_consume(sink);
		switch (sink_status) {
		case BT_COMPONENT_STATUS_AGAIN:
			/* Wait for an arbitraty 500 ms. */
			usleep(500000);
			break;
		case BT_COMPONENT_STATUS_OK:
			break;
		case BT_COMPONENT_STATUS_END:
			goto end;
		default:
			fprintf(stderr, "Sink component returned an error, aborting...\n");
			ret = -1;
			goto end;
		}
	}
end:
	BT_PUT(component_factory);
	BT_PUT(sink_class);
	BT_PUT(source_class);
	BT_PUT(source);
	BT_PUT(sink);
	BT_PUT(source_params);
	BT_PUT(sink_params);
	BT_PUT(it);
	BT_PUT(cfg);
	BT_PUT(first_plugin_path_value);
	return ret ? 1 : 0;
}
Commit	Line	Data
34ac0e6c MD	1	/*
	2	* babeltrace.c
	3	*
	4	* Babeltrace Trace Converter
	5	*
64fa3fec MD	6	* Copyright 2010-2011 EfficiOS Inc. and Linux Foundation
	7	*
	8	* Author: Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
34ac0e6c MD	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.
c462e188 MD	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.
34ac0e6c	27	*/
4c8bfb7e	28
95d36295	29	#include <babeltrace/babeltrace.h>
33bceaf8	30	#include <babeltrace/plugin/component-factory.h>
7c7c0433 JG	31	#include <babeltrace/plugin/plugin.h>
7c7c0433 JG	32	#include <babeltrace/plugin/component-class.h>
90298357	33	#include <babeltrace/plugin/notification/iterator.h>
2e339de1 JG	34	#include <babeltrace/ref.h>
2e339de1 JG	35	#include <babeltrace/values.h>
34ac0e6c	36	#include <stdlib.h>
a44bc4c9	37	#include <babeltrace/ctf-ir/metadata.h> /* for clocks */
7f26a816 PP	38	#include <popt.h>
	39	#include <string.h>
	40	#include <stdio.h>
c42c79ea	41	#include "babeltrace-cfg.h"
34ac0e6c	42
7c7c0433 JG	43	static
	44	const char *component_type_str(enum bt_component_type type)
	45	{
	46	switch (type) {
	47	case BT_COMPONENT_TYPE_SOURCE:
	48	return "source";
	49	case BT_COMPONENT_TYPE_SINK:
	50	return "sink";
	51	case BT_COMPONENT_TYPE_FILTER:
	52	return "filter";
	53	case BT_COMPONENT_TYPE_UNKNOWN:
	54	default:
	55	return "unknown";
	56	}
	57	}
	58
	59	static
c42c79ea	60	void print_component_classes_found(struct bt_component_factory *factory)
7c7c0433 JG	61	{
	62	int count, i;
	63
	64	if (!babeltrace_verbose) {
	65	return;
	66	}
	67
	68	count = bt_component_factory_get_component_class_count(factory);
	69	if (count <= 0) {
	70	fprintf(stderr, "No component classes found. Please make sure your plug-in search path is set correctly.");
	71	return;
	72	}
	73
	74	printf_verbose("Found %d component classes.\n", count);
	75	for (i = 0; i < count; i++) {
	76	struct bt_component_class *component_class =
	77	bt_component_factory_get_component_class_index(
	78	factory, i);
	79	struct bt_plugin *plugin = bt_component_class_get_plugin(
	80	component_class);
	81	const char *plugin_name = bt_plugin_get_name(plugin);
	82	const char *component_name = bt_component_class_get_name(
	83	component_class);
	84	const char *path = bt_plugin_get_path(plugin);
	85	const char *author = bt_plugin_get_author(plugin);
	86	const char *license = bt_plugin_get_license(plugin);
	87	const char *plugin_description = bt_plugin_get_description(
	88	plugin);
	89	const char *component_description =
	90	bt_component_class_get_description(
	91	component_class);
	92	enum bt_component_type type = bt_component_class_get_type(
	93	component_class);
	94
	95	printf_verbose("[%s - %s (%s)]\n", plugin_name, component_name,
	96	component_type_str(type));
	97	printf_verbose("\tpath: %s\n", path);
	98	printf_verbose("\tauthor: %s\n", author);
	99	printf_verbose("\tlicense: %s\n", license);
	100	printf_verbose("\tplugin description: %s\n",
	101	plugin_description ? plugin_description : "None");
	102	printf_verbose("\tcomponent description: %s\n",
	103	component_description ? component_description : "None");
0cc9e945 JG	104
	105	bt_put(plugin);
	106	bt_put(component_class);
7c7c0433 JG	107	}
	108	}
	109
c42c79ea PP	110	static
	111	void print_indent(size_t indent)
	112	{
	113	size_t i;
	114
	115	for (i = 0; i < indent; i++) {
	116	printf(" ");
	117	}
	118	}
	119
	120	static
	121	void print_value(struct bt_value *, size_t, bool);
	122
	123	static
	124	bool print_map_value(const char key, struct bt_value object, void *data)
	125	{
	126	size_t indent = (size_t) data;
	127
	128	print_indent(indent);
	129	printf("\"%s\": ", key);
	130	print_value(object, indent, false);
	131
	132	return true;
	133	}
	134
	135	static
	136	void print_value(struct bt_value *value, size_t indent, bool do_indent)
	137	{
	138	bool bool_val;
	139	int64_t int_val;
	140	double dbl_val;
	141	const char *str_val;
	142	int size;
	143	int i;
	144
	145	if (!value) {
	146	return;
	147	}
	148
	149	if (do_indent) {
	150	print_indent(indent);
	151	}
	152
	153	switch (bt_value_get_type(value)) {
	154	case BT_VALUE_TYPE_NULL:
	155	printf("null\n");
	156	break;
	157	case BT_VALUE_TYPE_BOOL:
	158	bt_value_bool_get(value, &bool_val);
	159	printf("%s\n", bool_val ? "true" : "false");
	160	break;
	161	case BT_VALUE_TYPE_INTEGER:
	162	bt_value_integer_get(value, &int_val);
	163	printf("%" PRId64 "\n", int_val);
	164	break;
	165	case BT_VALUE_TYPE_FLOAT:
	166	bt_value_float_get(value, &dbl_val);
	167	printf("%lf\n", dbl_val);
	168	break;
	169	case BT_VALUE_TYPE_STRING:
	170	bt_value_string_get(value, &str_val);
	171	printf("\"%s\"\n", str_val);
	172	break;
	173	case BT_VALUE_TYPE_ARRAY:
174	size = bt_value_array_size(value);
175	printf("[\n");
176
177	for (i = 0; i < size; i++) {
178	struct bt_value *element =
179	bt_value_array_get(value, i);
180
181	print_value(element, indent + 2, true);
182	BT_PUT(element);
183	}
184
185	print_indent(indent);
186	printf("]\n");
187	break;
188	case BT_VALUE_TYPE_MAP:
189	if (bt_value_map_is_empty(value)) {
190	printf("{}\n");
191	return;
192	}
193
194	printf("{\n");
195	bt_value_map_foreach(value, print_map_value,
196	(void *) (indent + 2));
197	print_indent(indent);
198	printf("}\n");
199	break;
200	default:
201	assert(false);
202	}
203	}
204
205	static
206	void print_bt_config_component(struct bt_config_component *bt_config_component)
207	{
208	printf(" %s/%s\n", bt_config_component->plugin_name->str,
209	bt_config_component->component_name->str);
210	printf(" params:\n");
211	print_value(bt_config_component->params, 6, true);
212	}
213
214	static
215	void print_bt_config_components(GPtrArray *array)
216	{
217	size_t i;
218
219	for (i = 0; i < array->len; i++) {
220	struct bt_config_component *cfg_component =
221	bt_config_get_component(array, i);
222	print_bt_config_component(cfg_component);
223	BT_PUT(cfg_component);
224	}
225	}
226
227	static
228	void print_cfg(struct bt_config *cfg)
229	{
230	printf("debug: %d\n", cfg->debug);
231	printf("verbose: %d\n", cfg->verbose);
232	printf("do list: %d\n", cfg->do_list);
233	printf("force correlate: %d\n", cfg->force_correlate);
234	printf("plugin paths:\n");
235	print_value(cfg->plugin_paths, 2, true);
236	printf("sources:\n");
237	print_bt_config_components(cfg->sources);
238	printf("sinks:\n");
239	print_bt_config_components(cfg->sinks);
240	}
241
bbefb8dd	242	int main(int argc, char **argv)
34ac0e6c	243	{
7f26a816	244	int ret;
7c7c0433	245	struct bt_component_factory *component_factory = NULL;
c42c79ea PP	246	struct bt_component_class *source_class = NULL;
c42c79ea PP	247	struct bt_component_class *sink_class = NULL;
7c7c0433 JG	248	struct bt_component source = NULL, sink = NULL;
7c7c0433 JG	249	struct bt_value source_params = NULL, sink_params = NULL;
c42c79ea	250	struct bt_config *cfg;
90298357	251	struct bt_notification_iterator *it = NULL;
fec2a9f2	252	enum bt_component_status sink_status;
c42c79ea PP	253	struct bt_value *first_plugin_path_value = NULL;
	254	const char *first_plugin_path;
	255	struct bt_config_component *cfg_component;
	256
	257	cfg = bt_config_from_args(argc, argv, &ret);
	258	if (cfg) {
	259	print_cfg(cfg);
	260	} else {
56a1cced JG	261	goto end;
	262	}
	263
8b596b57 JG	264	babeltrace_verbose = cfg->verbose;
	265	babeltrace_debug = cfg->debug;
	266
c42c79ea PP	267	/* TODO handle more than 1 source and 1 sink. */
	268	if (cfg->sources->len != 1 \|\| cfg->sinks->len != 1) {
	269	fprintf(stderr, "Unexpected configuration, aborting.../n");
56a1cced JG	270	ret = -1;
	271	goto end;
	272	}
c42c79ea PP	273	cfg_component = bt_config_get_component(cfg->sources, 0);
	274	source_params = bt_get(cfg_component->params);
	275	BT_PUT(cfg_component);
	276	cfg_component = bt_config_get_component(cfg->sinks, 0);
	277	sink_params = bt_get(cfg_component->params);
	278	BT_PUT(cfg_component);
56a1cced	279
34ac0e6c MD	280	printf_verbose("Verbose mode active.\n");
	281	printf_debug("Debug mode active.\n");
	282
c42c79ea	283	if (bt_value_array_is_empty(cfg->plugin_paths)) {
33bceaf8 JG	284	fprintf(stderr, "No plugin path specified, aborting...\n");
	285	ret = -1;
	286	goto end;
	287	}
33bceaf8 JG	288	component_factory = bt_component_factory_create();
	289	if (!component_factory) {
	290	fprintf(stderr, "Failed to create component factory.\n");
	291	ret = -1;
	292	goto end;
	293	}
	294
c42c79ea PP	295	first_plugin_path_value = bt_value_array_get(cfg->plugin_paths, 0);
	296	bt_value_string_get(first_plugin_path_value, &first_plugin_path);
	297
	298	ret = bt_component_factory_load_recursive(component_factory,
	299	first_plugin_path);
33bceaf8 JG	300	if (ret) {
	301	fprintf(stderr, "Failed to load plugins.\n");
	302	goto end;
	303	}
	304
c42c79ea	305	print_component_classes_found(component_factory);
56a1cced JG	306	source_class = bt_component_factory_get_component_class(
	307	component_factory, "ctf", BT_COMPONENT_TYPE_SOURCE,
	308	"fs");
	309	if (!source_class) {
043e2020	310	fprintf(stderr, "Could not find ctf-fs source component class. Aborting...\n");
56a1cced JG	311	ret = -1;
	312	goto end;
	313	}
7c7c0433 JG	314
7c7c0433 JG	315	sink_class = bt_component_factory_get_component_class(component_factory,
c42c79ea	316	NULL, BT_COMPONENT_TYPE_SINK, "text");
7c7c0433	317	if (!sink_class) {
c42c79ea	318	fprintf(stderr, "Could not find text output component class. Aborting...\n");
7c7c0433 JG	319	ret = -1;
	320	goto end;
	321	}
	322
56a1cced JG	323	source = bt_component_create(source_class, "ctf-fs", source_params);
56a1cced JG	324	if (!source) {
c42c79ea PP	325	fprintf(stderr, "Failed to instantiate ctf-fs source component. Aborting...\n");
	326	ret = -1;
	327	goto end;
	328	}
56a1cced	329
c42c79ea	330	sink = bt_component_create(sink_class, "text", sink_params);
7c7c0433	331	if (!sink) {
c42c79ea	332	fprintf(stderr, "Failed to instanciate text output component. Aborting...\n");
7c7c0433	333	ret = -1;
2e339de1 JG	334	goto end;
	335	}
	336
90298357 JG	337	it = bt_component_source_create_iterator(source);
	338	if (!it) {
	339	fprintf(stderr, "Failed to instantiate source iterator. Aborting...\n");
c42c79ea PP	340	ret = -1;
	341	goto end;
	342	}
90298357	343
fec2a9f2 JG	344	sink_status = bt_component_sink_add_iterator(sink, it);
	345	if (sink_status != BT_COMPONENT_STATUS_OK) {
	346	ret = -1;
	347	goto end;
	348	}
78586d8a	349
fec2a9f2 JG	350	while (true) {
fec2a9f2 JG	351	sink_status = bt_component_sink_consume(sink);
fec2a9f2 JG	352	switch (sink_status) {
	353	case BT_COMPONENT_STATUS_AGAIN:
	354	/* Wait for an arbitraty 500 ms. */
	355	usleep(500000);
78586d8a	356	break;
fec2a9f2 JG	357	case BT_COMPONENT_STATUS_OK:
	358	break;
	359	case BT_COMPONENT_STATUS_END:
	360	goto end;
	361	default:
	362	fprintf(stderr, "Sink component returned an error, aborting...\n");
	363	ret = -1;
	364	goto end;
78586d8a	365	}
fec2a9f2	366	}
11e1d048	367	end:
2e339de1	368	BT_PUT(component_factory);
7c7c0433 JG	369	BT_PUT(sink_class);
	370	BT_PUT(source_class);
	371	BT_PUT(source);
	372	BT_PUT(sink);
	373	BT_PUT(source_params);
	374	BT_PUT(sink_params);
90298357	375	BT_PUT(it);
c42c79ea PP	376	BT_PUT(cfg);
c42c79ea PP	377	BT_PUT(first_plugin_path_value);
7f26a816	378	return ret ? 1 : 0;
4c8bfb7e	379	}