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
31 #include "plugin.h"
32 #include "utils_complain.h"
33
34 /* vcomplain returns 0 if it did not report, 1 else */
35 __attribute__((format(printf, 3, 0))) static int
vcomplain(int level,c_complain_t * c,const char * format,va_list ap)36 vcomplain(int level, c_complain_t *c, const char *format, va_list ap) {
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
c_complain(int level,c_complain_t * c,const char * format,...)62 void c_complain(int level, c_complain_t *c, const char *format, ...) {
63 va_list ap;
64
65 va_start(ap, format);
66 if (vcomplain(level, c, format, ap))
67 c->complained_once = true;
68 va_end(ap);
69 } /* c_complain */
70
c_complain_once(int level,c_complain_t * c,const char * format,...)71 void c_complain_once(int level, c_complain_t *c, const char *format, ...) {
72 va_list ap;
73
74 if (c->complained_once)
75 return;
76
77 va_start(ap, format);
78 if (vcomplain(level, c, format, ap))
79 c->complained_once = true;
80 va_end(ap);
81 } /* c_complain_once */
82
c_do_release(int level,c_complain_t * c,const char * format,...)83 void c_do_release(int level, c_complain_t *c, const char *format, ...) {
84 char message[512];
85 va_list ap;
86
87 if (c->interval == 0)
88 return;
89
90 c->interval = 0;
91 c->complained_once = false;
92
93 va_start(ap, format);
94 vsnprintf(message, sizeof(message), format, ap);
95 message[sizeof(message) - 1] = '\0';
96 va_end(ap);
97
98 plugin_log(level, "%s", message);
99 } /* c_release */
100