projects
/
collectd.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
e3051bf
)
network plugin: Add a `flush' callback.
author
Florian Forster
<octo@huhu.verplant.org>
Wed, 27 Feb 2008 08:29:17 +0000
(09:29 +0100)
committer
Florian Forster
<octo@huhu.verplant.org>
Wed, 27 Feb 2008 08:29:17 +0000
(09:29 +0100)
src/network.c
patch
|
blob
|
history
diff --git
a/src/network.c
b/src/network.c
index
34cf018
..
618bf52
100644
(file)
--- a/
src/network.c
+++ b/
src/network.c
@@
-1602,9
+1602,25
@@
static int network_init (void)
return (0);
} /* int network_init */
return (0);
} /* int network_init */
+static int network_flush (int timeout)
+{
+ pthread_mutex_lock (&send_buffer_lock);
+
+ if (((time (NULL) - cache_flush_last) >= timeout)
+ && (send_buffer_fill > 0))
+ {
+ flush_buffer ();
+ }
+
+ pthread_mutex_unlock (&send_buffer_lock);
+
+ return (0);
+} /* int network_flush */
+
void module_register (void)
{
plugin_register_config ("network", network_config,
config_keys, config_keys_num);
plugin_register_init ("network", network_init);
void module_register (void)
{
plugin_register_config ("network", network_config,
config_keys, config_keys_num);
plugin_register_init ("network", network_init);
+ plugin_register_flush ("network", network_flush);
} /* void module_register */
} /* void module_register */