4 * Babeltrace Trace Converter
6 * Copyright 2010-2011 EfficiOS Inc. and Linux Foundation
8 * Author: Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
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:
17 * The above copyright notice and this permission notice shall be included in
18 * all copies or substantial portions of the Software.
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
29 #include <babeltrace/babeltrace.h>
30 #include <babeltrace/plugin/component-factory.h>
31 #include <babeltrace/plugin/plugin.h>
32 #include <babeltrace/plugin/component-class.h>
33 #include <babeltrace/plugin/notification/iterator.h>
34 #include <babeltrace/ref.h>
35 #include <babeltrace/values.h>
37 #include <babeltrace/ctf-ir/metadata.h> /* for clocks */
41 #include "babeltrace-cfg.h"
44 const char *component_type_str(enum bt_component_type type
)
47 case BT_COMPONENT_TYPE_SOURCE
:
49 case BT_COMPONENT_TYPE_SINK
:
51 case BT_COMPONENT_TYPE_FILTER
:
53 case BT_COMPONENT_TYPE_UNKNOWN
:
60 void print_component_classes_found(struct bt_component_factory
*factory
)
64 if (!babeltrace_verbose
) {
68 count
= bt_component_factory_get_component_class_count(factory
);
70 fprintf(stderr
, "No component classes found. Please make sure your plug-in search path is set correctly.");
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(
79 struct bt_plugin
*plugin
= bt_component_class_get_plugin(
81 const char *plugin_name
= bt_plugin_get_name(plugin
);
82 const char *component_name
= bt_component_class_get_name(
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(
89 const char *component_description
=
90 bt_component_class_get_description(
92 enum bt_component_type type
= bt_component_class_get_type(
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");
106 bt_put(component_class
);
111 void print_indent(size_t indent
)
115 for (i
= 0; i
< indent
; i
++) {
121 void print_value(struct bt_value
*, size_t, bool);
124 bool print_map_value(const char *key
, struct bt_value
*object
, void *data
)
126 size_t indent
= (size_t) data
;
128 print_indent(indent
);
129 printf("\"%s\": ", key
);
130 print_value(object
, indent
, false);
136 void print_value(struct bt_value
*value
, size_t indent
, bool do_indent
)
150 print_indent(indent
);
153 switch (bt_value_get_type(value
)) {
154 case BT_VALUE_TYPE_NULL
:
157 case BT_VALUE_TYPE_BOOL
:
158 bt_value_bool_get(value
, &bool_val
);
159 printf("%s\n", bool_val
? "true" : "false");
161 case BT_VALUE_TYPE_INTEGER
:
162 bt_value_integer_get(value
, &int_val
);
163 printf("%" PRId64
"\n", int_val
);
165 case BT_VALUE_TYPE_FLOAT
:
166 bt_value_float_get(value
, &dbl_val
);
167 printf("%lf\n", dbl_val
);
169 case BT_VALUE_TYPE_STRING
:
170 bt_value_string_get(value
, &str_val
);
171 printf("\"%s\"\n", str_val
);
173 case BT_VALUE_TYPE_ARRAY
:
174 size
= bt_value_array_size(value
);
177 for (i
= 0; i
< size
; i
++) {
178 struct bt_value
*element
=
179 bt_value_array_get(value
, i
);
181 print_value(element
, indent
+ 2, true);
185 print_indent(indent
);
188 case BT_VALUE_TYPE_MAP
:
189 if (bt_value_map_is_empty(value
)) {
195 bt_value_map_foreach(value
, print_map_value
,
196 (void *) (indent
+ 2));
197 print_indent(indent
);
206 void print_bt_config_component(struct bt_config_component
*bt_config_component
)
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);
215 void print_bt_config_components(GPtrArray
*array
)
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
);
228 void print_cfg(struct bt_config
*cfg
)
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
);
239 print_bt_config_components(cfg
->sinks
);
242 int main(int argc
, char **argv
)
245 struct bt_component_factory
*component_factory
= NULL
;
246 struct bt_component_class
*source_class
= NULL
;
247 struct bt_component_class
*sink_class
= NULL
;
248 struct bt_component
*source
= NULL
, *sink
= NULL
;
249 struct bt_value
*source_params
= NULL
, *sink_params
= NULL
;
250 struct bt_config
*cfg
;
251 struct bt_notification_iterator
*it
= NULL
;
252 enum bt_component_status sink_status
;
253 struct bt_value
*first_plugin_path_value
= NULL
;
254 const char *first_plugin_path
;
255 struct bt_config_component
*cfg_component
;
257 cfg
= bt_config_from_args(argc
, argv
, &ret
);
264 babeltrace_verbose
= cfg
->verbose
;
265 babeltrace_debug
= cfg
->debug
;
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");
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
);
280 printf_verbose("Verbose mode active.\n");
281 printf_debug("Debug mode active.\n");
283 if (bt_value_array_is_empty(cfg
->plugin_paths
)) {
284 fprintf(stderr
, "No plugin path specified, aborting...\n");
288 component_factory
= bt_component_factory_create();
289 if (!component_factory
) {
290 fprintf(stderr
, "Failed to create component factory.\n");
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
);
298 ret
= bt_component_factory_load_recursive(component_factory
,
301 fprintf(stderr
, "Failed to load plugins.\n");
305 print_component_classes_found(component_factory
);
306 source_class
= bt_component_factory_get_component_class(
307 component_factory
, "ctf", BT_COMPONENT_TYPE_SOURCE
,
310 fprintf(stderr
, "Could not find ctf-fs source component class. Aborting...\n");
315 sink_class
= bt_component_factory_get_component_class(component_factory
,
316 NULL
, BT_COMPONENT_TYPE_SINK
, "text");
318 fprintf(stderr
, "Could not find text output component class. Aborting...\n");
323 source
= bt_component_create(source_class
, "ctf-fs", source_params
);
325 fprintf(stderr
, "Failed to instantiate ctf-fs source component. Aborting...\n");
330 sink
= bt_component_create(sink_class
, "text", sink_params
);
332 fprintf(stderr
, "Failed to instanciate text output component. Aborting...\n");
337 it
= bt_component_source_create_iterator(source
);
339 fprintf(stderr
, "Failed to instantiate source iterator. Aborting...\n");
344 sink_status
= bt_component_sink_add_iterator(sink
, it
);
345 if (sink_status
!= BT_COMPONENT_STATUS_OK
) {
351 sink_status
= bt_component_sink_consume(sink
);
352 switch (sink_status
) {
353 case BT_COMPONENT_STATUS_AGAIN
:
354 /* Wait for an arbitraty 500 ms. */
357 case BT_COMPONENT_STATUS_OK
:
359 case BT_COMPONENT_STATUS_END
:
362 fprintf(stderr
, "Sink component returned an error, aborting...\n");
368 BT_PUT(component_factory
);
370 BT_PUT(source_class
);
373 BT_PUT(source_params
);
377 BT_PUT(first_plugin_path_value
);