Merge pull request #2796 from elfiesmelfie/feat_ipmi_SEL_ignore_list
[collectd.git] / src / utils_cmd_getval.c
1 /**
2  * collectd - src/utils_cmd_getval.c
3  * Copyright (C) 2008       Florian octo 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 octo Forster <octo at collectd.org>
25  **/
26
27 #include "collectd.h"
28
29 #include "common.h"
30 #include "plugin.h"
31
32 #include "utils_cache.h"
33 #include "utils_cmd_getval.h"
34 #include "utils_parse_option.h"
35
36 cmd_status_t cmd_parse_getval(size_t argc, char **argv,
37                               cmd_getval_t *ret_getval,
38                               const cmd_options_t *opts,
39                               cmd_error_handler_t *err) {
40   char *identifier_copy;
41   int status;
42
43   if ((ret_getval == NULL) || (opts == NULL)) {
44     errno = EINVAL;
45     cmd_error(CMD_ERROR, err, "Invalid arguments to cmd_parse_getval.");
46     return CMD_ERROR;
47   }
48
49   if (argc != 1) {
50     if (argc == 0)
51       cmd_error(CMD_PARSE_ERROR, err, "Missing identifier.");
52     else
53       cmd_error(CMD_PARSE_ERROR, err, "Garbage after identifier: `%s'.",
54                 argv[1]);
55     return CMD_PARSE_ERROR;
56   }
57
58   /* parse_identifier() modifies its first argument,
59    * returning pointers into it */
60   identifier_copy = sstrdup(argv[0]);
61
62   status = parse_identifier(
63       argv[0], &ret_getval->identifier.host, &ret_getval->identifier.plugin,
64       &ret_getval->identifier.plugin_instance, &ret_getval->identifier.type,
65       &ret_getval->identifier.type_instance, opts->identifier_default_host);
66   if (status != 0) {
67     DEBUG("cmd_parse_getval: Cannot parse identifier `%s'.", identifier_copy);
68     cmd_error(CMD_PARSE_ERROR, err, "Cannot parse identifier `%s'.",
69               identifier_copy);
70     sfree(identifier_copy);
71     return CMD_PARSE_ERROR;
72   }
73
74   ret_getval->raw_identifier = identifier_copy;
75   return CMD_OK;
76 } /* cmd_status_t cmd_parse_getval */
77
78 #define print_to_socket(fh, ...)                                               \
79   do {                                                                         \
80     if (fprintf(fh, __VA_ARGS__) < 0) {                                        \
81       WARNING("cmd_handle_getval: failed to write to socket #%i: %s",          \
82               fileno(fh), STRERRNO);                                           \
83       return -1;                                                               \
84     }                                                                          \
85     fflush(fh);                                                                \
86   } while (0)
87
88 cmd_status_t cmd_handle_getval(FILE *fh, char *buffer) {
89   cmd_error_handler_t err = {cmd_error_fh, fh};
90   cmd_status_t status;
91   cmd_t cmd;
92
93   gauge_t *values;
94   size_t values_num;
95
96   const data_set_t *ds;
97
98   if ((fh == NULL) || (buffer == NULL))
99     return -1;
100
101   DEBUG("utils_cmd_getval: cmd_handle_getval (fh = %p, buffer = %s);",
102         (void *)fh, buffer);
103
104   if ((status = cmd_parse(buffer, &cmd, NULL, &err)) != CMD_OK)
105     return status;
106   if (cmd.type != CMD_GETVAL) {
107     cmd_error(CMD_UNKNOWN_COMMAND, &err, "Unexpected command: `%s'.",
108               CMD_TO_STRING(cmd.type));
109     cmd_destroy(&cmd);
110     return CMD_UNKNOWN_COMMAND;
111   }
112
113   ds = plugin_get_ds(cmd.cmd.getval.identifier.type);
114   if (ds == NULL) {
115     DEBUG("cmd_handle_getval: plugin_get_ds (%s) == NULL;",
116           cmd.cmd.getval.identifier.type);
117     cmd_error(CMD_ERROR, &err, "Type `%s' is unknown.\n",
118               cmd.cmd.getval.identifier.type);
119     cmd_destroy(&cmd);
120     return -1;
121   }
122
123   values = NULL;
124   values_num = 0;
125   status =
126       uc_get_rate_by_name(cmd.cmd.getval.raw_identifier, &values, &values_num);
127   if (status != 0) {
128     cmd_error(CMD_ERROR, &err, "No such value.");
129     cmd_destroy(&cmd);
130     return CMD_ERROR;
131   }
132
133   if (ds->ds_num != values_num) {
134     ERROR("ds[%s]->ds_num = %" PRIsz ", "
135           "but uc_get_rate_by_name returned %" PRIsz " values.",
136           ds->type, ds->ds_num, values_num);
137     cmd_error(CMD_ERROR, &err, "Error reading value from cache.");
138     sfree(values);
139     cmd_destroy(&cmd);
140     return CMD_ERROR;
141   }
142
143   print_to_socket(fh, "%" PRIsz " Value%s found\n", values_num,
144                   (values_num == 1) ? "" : "s");
145   for (size_t i = 0; i < values_num; i++) {
146     print_to_socket(fh, "%s=", ds->ds[i].name);
147     if (isnan(values[i])) {
148       print_to_socket(fh, "NaN\n");
149     } else {
150       print_to_socket(fh, "%12e\n", values[i]);
151     }
152   }
153
154   sfree(values);
155   cmd_destroy(&cmd);
156
157   return CMD_OK;
158 } /* cmd_status_t cmd_handle_getval */
159
160 void cmd_destroy_getval(cmd_getval_t *getval) {
161   if (getval == NULL)
162     return;
163
164   sfree(getval->raw_identifier);
165 } /* void cmd_destroy_getval */