Merge pull request #2348 from maryamtahhan/feat_dpdkevents_fixes
[collectd.git] / src / match_timediff.c
1 /**
2  * collectd - src/match_timediff.c
3  * Copyright (C) 2008,2009  Florian Forster
4  *
5  * Permission is hereby granted, free of charge, to any person obtaining a
6  * copy of this software and associated documentation files (the "Software"),
7  * to deal in the Software without restriction, including without limitation
8  * the rights to use, copy, modify, merge, publish, distribute, sublicense,
9  * and/or sell copies of the Software, and to permit persons to whom the
10  * Software is furnished to do so, subject to the following conditions:
11  *
12  * The above copyright notice and this permission notice shall be included in
13  * all copies or substantial portions of the Software.
14  *
15  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
16  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
18  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
19  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
20  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
21  * DEALINGS IN THE SOFTWARE.
22  *
23  * Authors:
24  *   Florian Forster <octo at collectd.org>
25  **/
26
27 #include "collectd.h"
28
29 #include "common.h"
30 #include "filter_chain.h"
31
32 #define SATISFY_ALL 0
33 #define SATISFY_ANY 1
34
35 /*
36  * private data types
37  */
38 struct mt_match_s;
39 typedef struct mt_match_s mt_match_t;
40 struct mt_match_s {
41   cdtime_t future;
42   cdtime_t past;
43 };
44
45 /*
46  * internal helper functions
47  */
48 static int mt_create(const oconfig_item_t *ci, void **user_data) /* {{{ */
49 {
50   mt_match_t *m;
51   int status;
52
53   m = calloc(1, sizeof(*m));
54   if (m == NULL) {
55     ERROR("mt_create: calloc failed.");
56     return -ENOMEM;
57   }
58
59   m->future = 0;
60   m->past = 0;
61
62   status = 0;
63   for (int i = 0; i < ci->children_num; i++) {
64     oconfig_item_t *child = ci->children + i;
65
66     if (strcasecmp("Future", child->key) == 0)
67       status = cf_util_get_cdtime(child, &m->future);
68     else if (strcasecmp("Past", child->key) == 0)
69       status = cf_util_get_cdtime(child, &m->past);
70     else {
71       ERROR("timediff match: The `%s' configuration option is not "
72             "understood and will be ignored.",
73             child->key);
74       status = 0;
75     }
76
77     if (status != 0)
78       break;
79   }
80
81   /* Additional sanity-checking */
82   while (status == 0) {
83     if ((m->future == 0) && (m->past == 0)) {
84       ERROR("timediff match: Either `Future' or `Past' must be configured. "
85             "This match will be ignored.");
86       status = -1;
87     }
88
89     break;
90   }
91
92   if (status != 0) {
93     free(m);
94     return status;
95   }
96
97   *user_data = m;
98   return 0;
99 } /* }}} int mt_create */
100
101 static int mt_destroy(void **user_data) /* {{{ */
102 {
103   if (user_data != NULL) {
104     sfree(*user_data);
105   }
106
107   return 0;
108 } /* }}} int mt_destroy */
109
110 static int mt_match(const data_set_t __attribute__((unused)) * ds, /* {{{ */
111                     const value_list_t *vl,
112                     notification_meta_t __attribute__((unused)) * *meta,
113                     void **user_data) {
114   mt_match_t *m;
115   cdtime_t now;
116
117   if ((user_data == NULL) || (*user_data == NULL))
118     return -1;
119
120   m = *user_data;
121   now = cdtime();
122
123   if (m->future != 0) {
124     if (vl->time >= (now + m->future))
125       return FC_MATCH_MATCHES;
126   }
127
128   if (m->past != 0) {
129     if (vl->time <= (now - m->past))
130       return FC_MATCH_MATCHES;
131   }
132
133   return FC_MATCH_NO_MATCH;
134 } /* }}} int mt_match */
135
136 void module_register(void) {
137   match_proc_t mproc = {0};
138
139   mproc.create = mt_create;
140   mproc.destroy = mt_destroy;
141   mproc.match = mt_match;
142   fc_register_match("timediff", mproc);
143 } /* module_register */