Merge branch 'collectd-5.5'
[collectd.git] / src / daemon / utils_complain.c
1 /**
2  * collectd - src/utils_complain.c
3  * Copyright (C) 2006-2013  Florian octo Forster
4  * Copyright (C) 2008       Sebastian tokkee Harl
5  *
6  * Permission is hereby granted, free of charge, to any person obtaining a
7  * copy of this software and associated documentation files (the "Software"),
8  * to deal in the Software without restriction, including without limitation
9  * the rights to use, copy, modify, merge, publish, distribute, sublicense,
10  * and/or sell copies of the Software, and to permit persons to whom the
11  * Software is furnished to do so, subject to the following conditions:
12  *
13  * The above copyright notice and this permission notice shall be included in
14  * all copies or substantial portions of the Software.
15  *
16  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
19  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
21  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
22  * DEALINGS IN THE SOFTWARE.
23  *
24  * Authors:
25  *   Florian octo Forster <octo at collectd.org>
26  *   Sebastian tokkee Harl <sh at tokkee.org>
27  **/
28
29 #include "collectd.h"
30 #include "utils_complain.h"
31 #include "plugin.h"
32
33 /* vcomplain returns 0 if it did not report, 1 else */
34 static int vcomplain (int level, c_complain_t *c,
35                 const char *format, va_list ap)
36 {
37         cdtime_t now;
38         char   message[512];
39
40         now = cdtime ();
41
42         if (c->last + c->interval > now)
43                 return 0;
44
45         c->last = now;
46
47         if (c->interval < plugin_get_interval ())
48                 c->interval = plugin_get_interval ();
49         else
50                 c->interval *= 2;
51
52         if (c->interval > TIME_T_TO_CDTIME_T (86400))
53                 c->interval = TIME_T_TO_CDTIME_T (86400);
54
55         vsnprintf (message, sizeof (message), format, ap);
56         message[sizeof (message) - 1] = '\0';
57
58         plugin_log (level, "%s", message);
59         return 1;
60 } /* vcomplain */
61
62 void c_complain (int level, c_complain_t *c, const char *format, ...)
63 {
64         va_list ap;
65
66         va_start (ap, format);
67         if (vcomplain (level, c, format, ap))
68                 c->complained_once = 1;
69         va_end (ap);
70 } /* c_complain */
71
72 void c_complain_once (int level, c_complain_t *c, const char *format, ...)
73 {
74         va_list ap;
75
76         if (c->complained_once)
77                 return;
78
79         va_start (ap, format);
80         if (vcomplain (level, c, format, ap))
81                 c->complained_once = 1;
82         va_end (ap);
83 } /* c_complain_once */
84
85 void c_do_release (int level, c_complain_t *c, const char *format, ...)
86 {
87         char message[512];
88         va_list ap;
89
90         if (c->interval == 0)
91                 return;
92
93         c->interval = 0;
94         c->complained_once = 0;
95
96         va_start (ap, format);
97         vsnprintf (message, sizeof (message), format, ap);
98         message[sizeof (message) - 1] = '\0';
99         va_end (ap);
100
101         plugin_log (level, "%s", message);
102 } /* c_release */
103
104 /* vim: set sw=4 ts=4 tw=78 noexpandtab : */
105