diff --git a/src/plugin.c b/src/plugin.c
index bf8fb085685e0e48ba4bf6c570b0b31618e1d60c..83ee8e6ce30e76a17dbafdcd7cbd8b4a4f8d2c4f 100644 (file)
--- a/src/plugin.c
+++ b/src/plugin.c
pthread_mutex_unlock (&read_lock);
} /* void plugin_read_all */
-int plugin_flush_one (int timeout, const char *name)
-{
- int (*callback) (int);
- llentry_t *le;
- int status;
-
- if (list_flush == NULL)
- return (-1);
-
- le = llist_search (list_flush, name);
- if (le == NULL)
- return (-1);
- callback = (int (*) (int)) le->value;
-
- status = (*callback) (timeout);
-
- return (status);
-} /* int plugin_flush_ont */
-
void plugin_flush_all (int timeout)
{
- int (*callback) (int);
+ int (*callback) (int timeout, const char *identifier);
llentry_t *le;
if (list_flush == NULL)
le = llist_head (list_flush);
while (le != NULL)
{
- callback = (int (*) (int)) le->value;
+ callback = (int (*) (int, const char *)) le->value;
le = le->next;
- (*callback) (timeout);
+ (*callback) (timeout, NULL);
}
} /* void plugin_flush_all */
{
if ((plugin != NULL)
&& (strcmp (plugin, le->key) != 0))
+ {
+ le = le->next;
continue;
+ }
callback = (int (*) (int, const char *)) le->value;
- le = le->next;
-
(*callback) (timeout, identifier);
+
+ le = le->next;
}
return (0);
} /* int plugin_flush */
+/* FIXME: Remove this function once the perl plugin has been updated. */
+int plugin_flush_one (int timeout, const char *name)
+{
+ return (plugin_flush (name, timeout, NULL));
+} /* int plugin_flush_one */
+
void plugin_shutdown_all (void)
{
int (*callback) (void);