1 // SPDX-License-Identifier: LGPL-2.1
3 * Copyright (C) 2009, 2010 Red Hat Inc, Steven Rostedt <srostedt@redhat.com>
12 #include <sys/types.h>
17 #include "event-parse.h"
18 #include "event-parse-local.h"
19 #include "event-utils.h"
20 #include "trace-seq.h"
22 #define LOCAL_PLUGIN_DIR ".local/lib/traceevent/plugins/"
24 static struct registered_plugin_options {
25 struct registered_plugin_options *next;
26 struct tep_plugin_option *options;
27 } *registered_options;
29 static struct trace_plugin_options {
30 struct trace_plugin_options *next;
34 } *trace_plugin_options;
36 struct tep_plugin_list {
37 struct tep_plugin_list *next;
42 struct tep_plugins_dir {
43 struct tep_plugins_dir *next;
45 enum tep_plugin_load_priority prio;
48 static void lower_case(char *str)
56 static int update_option_value(struct tep_plugin_option *op, const char *val)
61 /* toggle, only if option is boolean */
70 * If the option has a value then it takes a string
71 * otherwise the option is a boolean.
78 /* Option is boolean, must be either "1", "0", "true" or "false" */
85 if (strcmp(val, "1") == 0 || strcmp(val, "true") == 0)
87 else if (strcmp(val, "0") == 0 || strcmp(val, "false") == 0)
95 * tep_plugin_list_options - get list of plugin options
97 * Returns an array of char strings that list the currently registered
98 * plugin options in the format of <plugin>:<option>. This list can be
99 * used by toggling the option.
101 * Returns NULL if there's no options registered. On error it returns
102 * INVALID_PLUGIN_LIST_OPTION
104 * Must be freed with tep_plugin_free_options_list().
106 char **tep_plugin_list_options(void)
108 struct registered_plugin_options *reg;
109 struct tep_plugin_option *op;
114 for (reg = registered_options; reg; reg = reg->next) {
115 for (op = reg->options; op->name; op++) {
116 char *alias = op->plugin_alias ? op->plugin_alias : op->file;
120 ret = asprintf(&name, "%s:%s", alias, op->name);
124 list = realloc(list, count + 2);
130 list[count++] = name;
141 return INVALID_PLUGIN_LIST_OPTION;
144 void tep_plugin_free_options_list(char **list)
151 if (list == INVALID_PLUGIN_LIST_OPTION)
154 for (i = 0; list[i]; i++)
161 update_option(const char *file, struct tep_plugin_option *option)
163 struct trace_plugin_options *op;
167 if (option->plugin_alias) {
168 plugin = strdup(option->plugin_alias);
173 plugin = strdup(file);
176 p = strstr(plugin, ".");
181 /* first look for named options */
182 for (op = trace_plugin_options; op; op = op->next) {
185 if (strcmp(op->plugin, plugin) != 0)
187 if (strcmp(op->option, option->name) != 0)
190 ret = update_option_value(option, op->value);
196 /* first look for unnamed options */
197 for (op = trace_plugin_options; op; op = op->next) {
200 if (strcmp(op->option, option->name) != 0)
203 ret = update_option_value(option, op->value);
213 * tep_plugin_add_options - Add a set of options by a plugin
214 * @name: The name of the plugin adding the options
215 * @options: The set of options being loaded
217 * Sets the options with the values that have been added by user.
219 int tep_plugin_add_options(const char *name,
220 struct tep_plugin_option *options)
222 struct registered_plugin_options *reg;
224 reg = malloc(sizeof(*reg));
227 reg->next = registered_options;
228 reg->options = options;
229 registered_options = reg;
231 while (options->name) {
232 update_option(name, options);
239 * tep_plugin_remove_options - remove plugin options that were registered
240 * @options: Options to removed that were registered with tep_plugin_add_options
242 void tep_plugin_remove_options(struct tep_plugin_option *options)
244 struct registered_plugin_options **last;
245 struct registered_plugin_options *reg;
247 for (last = ®istered_options; *last; last = &(*last)->next) {
248 if ((*last)->options == options) {
257 static int parse_option_name(char **option, char **plugin)
263 if ((p = strstr(*option, ":"))) {
266 *option = strdup(p + 1);
273 static struct tep_plugin_option *
274 find_registered_option(const char *plugin, const char *option)
276 struct registered_plugin_options *reg;
277 struct tep_plugin_option *op;
278 const char *op_plugin;
280 for (reg = registered_options; reg; reg = reg->next) {
281 for (op = reg->options; op->name; op++) {
282 if (op->plugin_alias)
283 op_plugin = op->plugin_alias;
285 op_plugin = op->file;
287 if (plugin && strcmp(plugin, op_plugin) != 0)
289 if (strcmp(option, op->name) != 0)
299 static int process_option(const char *plugin, const char *option, const char *val)
301 struct tep_plugin_option *op;
303 op = find_registered_option(plugin, option);
307 return update_option_value(op, val);
311 * tep_plugin_add_option - add an option/val pair to set plugin options
312 * @name: The name of the option (format: <plugin>:<option> or just <option>)
313 * @val: (optional) the value for the option
315 * Modify a plugin option. If @val is given than the value of the option
316 * is set (note, some options just take a boolean, so @val must be either
317 * "1" or "0" or "true" or "false").
319 int tep_plugin_add_option(const char *name, const char *val)
321 struct trace_plugin_options *op;
325 option_str = strdup(name);
329 if (parse_option_name(&option_str, &plugin) < 0)
332 /* If the option exists, update the val */
333 for (op = trace_plugin_options; op; op = op->next) {
334 /* Both must be NULL or not NULL */
335 if ((!plugin || !op->plugin) && plugin != op->plugin)
337 if (plugin && strcmp(plugin, op->plugin) != 0)
339 if (strcmp(op->option, option_str) != 0)
345 op->value = strdup(val);
351 /* plugin and option_str don't get freed at the end */
356 option_str = op->option;
360 /* If not found, create */
362 op = malloc(sizeof(*op));
365 memset(op, 0, sizeof(*op));
366 op->next = trace_plugin_options;
367 trace_plugin_options = op;
370 op->option = option_str;
373 op->value = strdup(val);
379 return process_option(plugin, option_str, val);
385 static void print_op_data(struct trace_seq *s, const char *name,
389 trace_seq_printf(s, "%8s:\t%s\n", name, op);
393 * tep_plugin_print_options - print out the registered plugin options
394 * @s: The trace_seq descriptor to write the plugin options into
396 * Writes a list of options into trace_seq @s.
398 void tep_plugin_print_options(struct trace_seq *s)
400 struct registered_plugin_options *reg;
401 struct tep_plugin_option *op;
403 for (reg = registered_options; reg; reg = reg->next) {
404 if (reg != registered_options)
405 trace_seq_printf(s, "============\n");
406 for (op = reg->options; op->name; op++) {
407 if (op != reg->options)
408 trace_seq_printf(s, "------------\n");
409 print_op_data(s, "file", op->file);
410 print_op_data(s, "plugin", op->plugin_alias);
411 print_op_data(s, "option", op->name);
412 print_op_data(s, "desc", op->description);
413 print_op_data(s, "value", op->value);
414 trace_seq_printf(s, "%8s:\t%d\n", "set", op->set);
420 * tep_print_plugins - print out the list of plugins loaded
421 * @s: the trace_seq descripter to write to
422 * @prefix: The prefix string to add before listing the option name
423 * @suffix: The suffix string ot append after the option name
424 * @list: The list of plugins (usually returned by tep_load_plugins()
426 * Writes to the trace_seq @s the list of plugins (files) that is
427 * returned by tep_load_plugins(). Use @prefix and @suffix for formating:
428 * @prefix = " ", @suffix = "\n".
430 void tep_print_plugins(struct trace_seq *s,
431 const char *prefix, const char *suffix,
432 const struct tep_plugin_list *list)
435 trace_seq_printf(s, "%s%s%s", prefix, list->name, suffix);
441 load_plugin(struct tep_handle *tep, const char *path,
442 const char *file, void *data)
444 struct tep_plugin_list **plugin_list = data;
445 struct tep_plugin_option *options;
446 tep_plugin_load_func func;
447 struct tep_plugin_list *list;
453 ret = asprintf(&plugin, "%s/%s", path, file);
455 warning("could not allocate plugin memory\n");
459 handle = dlopen(plugin, RTLD_NOW | RTLD_GLOBAL);
461 warning("could not load plugin '%s'\n%s\n",
466 alias = dlsym(handle, TEP_PLUGIN_ALIAS_NAME);
470 options = dlsym(handle, TEP_PLUGIN_OPTIONS_NAME);
472 while (options->name) {
473 ret = update_option(alias, options);
480 func = dlsym(handle, TEP_PLUGIN_LOADER_NAME);
482 warning("could not find func '%s' in plugin '%s'\n%s\n",
483 TEP_PLUGIN_LOADER_NAME, plugin, dlerror());
487 list = malloc(sizeof(*list));
489 warning("could not allocate plugin memory\n");
493 list->next = *plugin_list;
494 list->handle = handle;
498 pr_stat("registering plugin: %s", plugin);
507 load_plugins_dir(struct tep_handle *tep, const char *suffix,
509 void (*load_plugin)(struct tep_handle *tep,
520 ret = stat(path, &st);
524 if (!S_ISDIR(st.st_mode))
531 while ((dent = readdir(dir))) {
532 const char *name = dent->d_name;
534 if (strcmp(name, ".") == 0 ||
535 strcmp(name, "..") == 0)
538 /* Only load plugins that end in suffix */
539 if (strcmp(name + (strlen(name) - strlen(suffix)), suffix) != 0)
542 load_plugin(tep, path, name, data);
549 * tep_load_plugins_hook - call a user specified callback to load a plugin
550 * @tep: handler to traceevent context
551 * @suffix: filter only plugin files with given suffix
552 * @load_plugin: user specified callback, called for each plugin file
553 * @data: custom context, passed to @load_plugin
555 * Searches for traceevent plugin files and calls @load_plugin for each
556 * The order of plugins search is:
557 * - Directories, specified in @tep->plugins_dir and priority TEP_PLUGIN_FIRST
558 * - Directory, specified at compile time with PLUGIN_TRACEEVENT_DIR
559 * - Directory, specified by environment variable TRACEEVENT_PLUGIN_DIR
560 * - In user's home: ~/.local/lib/traceevent/plugins/
561 * - Directories, specified in @tep->plugins_dir and priority TEP_PLUGIN_LAST
564 void tep_load_plugins_hook(struct tep_handle *tep, const char *suffix,
565 void (*load_plugin)(struct tep_handle *tep,
571 struct tep_plugins_dir *dir = NULL;
577 if (tep && tep->flags & TEP_DISABLE_PLUGINS)
581 dir = tep->plugins_dir;
583 if (dir->prio == TEP_PLUGIN_FIRST)
584 load_plugins_dir(tep, suffix, dir->path,
590 * If a system plugin directory was defined,
594 if (!tep || !(tep->flags & TEP_DISABLE_SYS_PLUGINS))
595 load_plugins_dir(tep, suffix, PLUGIN_DIR,
600 * Next let the environment-set plugin directory
601 * override the system defaults.
603 envdir = getenv("TRACEEVENT_PLUGIN_DIR");
605 load_plugins_dir(tep, suffix, envdir, load_plugin, data);
608 * Now let the home directory override the environment
609 * or system defaults.
611 home = getenv("HOME");
615 ret = asprintf(&path, "%s/%s", home, LOCAL_PLUGIN_DIR);
617 warning("could not allocate plugin memory\n");
621 load_plugins_dir(tep, suffix, path, load_plugin, data);
624 dir = tep->plugins_dir;
626 if (dir->prio == TEP_PLUGIN_LAST)
627 load_plugins_dir(tep, suffix, dir->path,
635 struct tep_plugin_list*
636 tep_load_plugins(struct tep_handle *tep)
638 struct tep_plugin_list *list = NULL;
640 tep_load_plugins_hook(tep, ".so", load_plugin, &list);
645 * tep_add_plugin_path - Add a new plugin directory.
646 * @tep: Trace event handler.
647 * @path: Path to a directory. All files with extension .so in that
648 * directory will be loaded as plugins.
649 *@prio: Load priority of the plugins in that directory.
651 * Returns -1 in case of an error, 0 otherwise.
653 int tep_add_plugin_path(struct tep_handle *tep, char *path,
654 enum tep_plugin_load_priority prio)
656 struct tep_plugins_dir *dir;
661 dir = calloc(1, sizeof(*dir));
665 dir->path = strdup(path);
667 dir->next = tep->plugins_dir;
668 tep->plugins_dir = dir;
673 void tep_free_plugin_paths(struct tep_handle *tep)
675 struct tep_plugins_dir *dir;
680 dir = tep->plugins_dir;
682 tep->plugins_dir = tep->plugins_dir->next;
685 dir = tep->plugins_dir;
690 tep_unload_plugins(struct tep_plugin_list *plugin_list, struct tep_handle *tep)
692 tep_plugin_unload_func func;
693 struct tep_plugin_list *list;
695 while (plugin_list) {
697 plugin_list = list->next;
698 func = dlsym(list->handle, TEP_PLUGIN_UNLOADER_NAME);
701 dlclose(list->handle);