summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
67d4532)
When multiple LoadPlugin options are used with a plugin, the plugin is
only loaded once, however the plugin's read function is invoked
multiple times at every interval. This in turn causes undesired
redundant data to be sent to the write plugins.
This patch prevents a plugin's read function from being re-added to
the read_heap and read_list during plugin registration.
Signed-off-by: Blaise Tarr <blaise.tarr@gmail.com>
Signed-off-by: Florian Forster <octo@huhu.verplant.org>
- le = llentry_create (rf->rf_name, rf);
+ le = llist_search (read_list, rf->rf_name);
- pthread_mutex_unlock (&read_lock);
- ERROR ("plugin_insert_read: llentry_create failed.");
- return (-1);
- }
+ le = llentry_create (rf->rf_name, rf);
+ if (le == NULL)
+ {
+ pthread_mutex_unlock (&read_lock);
+ ERROR ("plugin_insert_read: llentry_create failed.");
+ return (-1);
+ }
+
+ status = c_heap_insert (read_heap, rf);
+ if (status != 0)
+ {
+ pthread_mutex_unlock (&read_lock);
+ ERROR ("plugin_insert_read: c_heap_insert failed.");
+ llentry_destroy (le);
+ return (-1);
+ }
- status = c_heap_insert (read_heap, rf);
- if (status != 0)
+ /* This does not fail. */
+ llist_append (read_list, le);
+ }
+ else
- pthread_mutex_unlock (&read_lock);
- ERROR ("plugin_insert_read: c_heap_insert failed.");
- llentry_destroy (le);
- return (-1);
+ INFO ("plugin: plugin_insert_read: "
+ "read function for plugin `%s' already added.",
+ rf->rf_name);
- /* This does not fail. */
- llist_append (read_list, le);
-
pthread_mutex_unlock (&read_lock);
return (0);
} /* int plugin_insert_read */
pthread_mutex_unlock (&read_lock);
return (0);
} /* int plugin_insert_read */