9 #define RRD_DATABASE_LIST "rrd_database"
10 #define RRD_DATABASE_NAME "name"
12 static int read_strings_from_list(config_setting_t *list, const char ***strings)
14 config_setting_t *string;
16 int str_count = config_setting_length(list);
19 strs = calloc(sizeof(*strs), str_count + 1);
21 for (j = 0; j < str_count; j++) {
24 string = config_setting_get_elem(list, j);
25 str = config_setting_get_string(string);
26 strs[j] = strdup(str);
33 static int parse_images(config_setting_t *list, struct rrd_database *db)
36 config_setting_t *image, *str_list;
37 const char *database = NULL, *filename = NULL, *timestart = NULL;
38 const char *timeend = NULL, *imageformat = NULL;
39 const char **options = NULL, **text = NULL;
40 const char *updatestr = NULL;
41 int width = 0, height = 0, text_lead = 0;
43 count = config_setting_length(list);
45 pr_info("%s: Parsing %d images\n", db->name, count);
46 db->images = calloc(sizeof(*db->images), count + 1);
48 for (i = 0; i < count; i++) {
49 image = config_setting_get_elem(list, i);
50 db->images[i] = calloc(sizeof(*db->images[i]), 1);
52 config_setting_lookup_string(image, "database", &database);
53 config_setting_lookup_int(image, "text_lead", &text_lead);
56 * The config_setting_lookup_* functions will leave
57 * the destination unchanged in case requested value
58 * is not found. If that is the case, the value from
59 * previous image group is used. That makes it
60 * possible for the user to only define once all
61 * fields and then leave identical fields unset on the
62 * following groups, making it easier to define many
63 * almost identical images.
66 config_setting_lookup_string(image, "filename", &filename);
68 pr_err("Database %s does not have \"filename\" entry "
74 config_setting_lookup_int(image, "width", &width);
76 pr_err("Database %s does not have \"width\" entry "
82 config_setting_lookup_int(image, "height", &height);
84 pr_err("Database %s does not have \"height\" entry "
90 config_setting_lookup_string(image, "timestart", ×tart);
92 pr_err("Database %s does not have \"timestart\" entry "
98 config_setting_lookup_string(image, "timeend", &timeend);
100 pr_err("Database %s does not have \"timeend\" entry "
106 config_setting_lookup_string(image, "imageformat",
109 pr_err("Database %s does not have \"imageformat\" "\
110 "entry in image data\n",
115 config_setting_lookup_string(image, "update_string",
118 str_list = config_setting_get_member(image, "options");
120 read_strings_from_list(str_list, &options);
122 str_list = config_setting_get_member(image, "text");
124 read_strings_from_list(str_list, &text);
126 db->images[i]->rrd_database =
127 database ? strdup(database) : NULL;
128 db->images[i]->image_filename = strdup(filename);
129 db->images[i]->width = width;
130 db->images[i]->height = height;
131 strncpy(db->images[i]->timestart, timestart,
132 sizeof(db->images[i]->timestart));
133 strncpy(db->images[i]->timeend, timeend,
134 sizeof(db->images[i]->timeend));
135 strncpy(db->images[i]->imageformat, imageformat,
136 sizeof(db->images[i]->imageformat));
137 db->images[i]->options = options;
138 db->images[i]->text_lead = text_lead;
139 db->images[i]->text = text;
142 db->images[i]->updatestr = strdup(updatestr);
148 static int (*str_to_parser(const char *str))(char *rrd_data, const char **parser_data)
153 if (!strcmp(str, "cpu"))
156 if (!strcmp(str, "mem"))
159 if (!strcmp(str, "cpu_mem"))
160 return cpu_mem_parser;
162 if (!strcmp(str, "digitemp"))
163 return digitemp_parser;
165 if (!strcmp(str, "digitemp_mod"))
166 return digitemp_parser_mod;
168 if (!strcmp(str, "script"))
169 return script_parser;
171 if (!strcmp(str, "netstats"))
172 return netstats_parser;
174 if (!strcmp(str, "onewire"))
175 return onewire_parser;
180 static int parse_data_sources(config_setting_t *rrd, struct rrd_database *db)
182 config_setting_t *list, *group;
184 const char *type = NULL, *name = NULL;
189 list = config_setting_get_member(rrd, "sources");
191 pr_info("No data sources\n");
195 if (!config_setting_is_list(list)) {
196 pr_err("Data sources have no list\n");
200 count = config_setting_length(list);
201 db->sources = calloc(sizeof(*db->sources), count + 1);
203 for (i = 0; i < count; i++) {
204 group = config_setting_get_elem(list, i);
206 config_setting_lookup_string(group, "type", &type);
207 config_setting_lookup_string(group, "name", &name);
208 config_setting_lookup_float(group, "min", &min);
209 config_setting_lookup_float(group, "max", &max);
210 config_setting_lookup_int(group, "heartbeat", &heartbeat);
212 db->sources[i].type = strdup(type);
213 db->sources[i].name = strdup(name);
214 db->sources[i].heartbeat = heartbeat;
215 db->sources[i].min = min;
216 db->sources[i].max = max;
222 static int parse_archives(config_setting_t *rrd, struct rrd_database *db)
224 config_setting_t *list, *group;
226 const char *type = NULL;
231 list = config_setting_get_member(rrd, "archives");
233 pr_info("No archive found\n");
237 if (!config_setting_is_list(list)) {
238 pr_err("Archive does not contain a list\n");
242 count = config_setting_length(list);
243 db->archives = calloc(sizeof(*db->archives), count + 1);
245 for (i = 0; i < count; i++) {
246 group = config_setting_get_elem(list, i);
248 config_setting_lookup_string(group, "type", &type);
249 config_setting_lookup_float(group, "xff", &xff);
250 config_setting_lookup_int(group, "steps", &steps);
251 config_setting_lookup_int(group, "rows", &rows);
253 db->archives[i].type = strdup(type);
254 db->archives[i].xff = xff;
255 db->archives[i].steps = steps;
256 db->archives[i].rows = rows;
262 static int parse_database(config_setting_t *rrd, struct rrd_database *db)
264 config_setting_t *list, *str_list;
265 const char *name, *parser = NULL, *filename, **parser_data;
266 const char **pre_draw_cmd;
268 if (!config_setting_lookup_string(rrd, "name", &name)) {
269 pr_err("Database entry does not contain name\n");
273 pr_info("parsing database %s\n", name);
274 db->name = strdup(name);
276 if (!config_setting_lookup_string(rrd, "filename", &filename)) {
277 pr_err("Database %s does not contain filename\n", db->name);
280 db->filename = strdup(filename);
282 if (!config_setting_lookup_int(rrd, "interval", &db->interval)) {
283 pr_err("Database %s does not have interval set\n", name);
287 /* Parser is not a mandatory parameter */
288 config_setting_lookup_string(rrd, "parser", &parser);
289 db->parse = str_to_parser(parser);
291 list = config_setting_get_member(rrd, "image");
292 parse_images(list, db);
293 parse_data_sources(rrd, db);
294 parse_archives(rrd, db);
296 str_list = config_setting_get_member(rrd, "parser_data");
298 read_strings_from_list(str_list, &parser_data);
299 db->parser_data = parser_data;
302 str_list = config_setting_get_member(rrd, "pre_draw_cmd");
304 read_strings_from_list(str_list, &pre_draw_cmd);
305 db->pre_draw_cmd = (char *const *)pre_draw_cmd;
311 struct rrd_database **populate_database(const char *conffile)
313 struct rrd_database **rrd_db = NULL;
315 config_setting_t *rrd_database;
318 config_init(&config);
320 if (!config_read_file(&config, conffile)) {
321 pr_err("%s:%d - %s\n", config_error_file(&config),
322 config_error_line(&config),
323 config_error_text(&config));
327 rrd_database = config_lookup(&config, "rrd_database");
328 count = config_setting_length(rrd_database);
331 * Allocate one element extra. The last one is zeroed out to
332 * indicate the end of the db list
334 rrd_db = calloc(count + 1, sizeof(*rrd_db));
336 pr_info("There are %d database entries\n", count);
338 for (i = 0; i < count; i++) {
339 config_setting_t *rrd;
340 rrd_db[i] = calloc(1, sizeof(*rrd_db[i]));
341 rrd = config_setting_get_elem(rrd_database, i);
342 parse_database(rrd, rrd_db[i]);
346 config_destroy(&config);