diff options
Diffstat (limited to 'plugins/check_ups.c')
| -rw-r--r-- | plugins/check_ups.c | 309 |
1 files changed, 147 insertions, 162 deletions
diff --git a/plugins/check_ups.c b/plugins/check_ups.c index 526a29df..54decce3 100644 --- a/plugins/check_ups.c +++ b/plugins/check_ups.c | |||
| @@ -39,69 +39,29 @@ const char *email = "devel@monitoring-plugins.org"; | |||
| 39 | #include "common.h" | 39 | #include "common.h" |
| 40 | #include "netutils.h" | 40 | #include "netutils.h" |
| 41 | #include "utils.h" | 41 | #include "utils.h" |
| 42 | 42 | #include "check_ups.d/config.h" | |
| 43 | enum { | 43 | #include "states.h" |
| 44 | PORT = 3493 | ||
| 45 | }; | ||
| 46 | |||
| 47 | #define UPS_NONE 0 /* no supported options */ | ||
| 48 | #define UPS_UTILITY 1 /* supports utility line */ | ||
| 49 | #define UPS_BATTPCT 2 /* supports percent battery remaining */ | ||
| 50 | #define UPS_STATUS 4 /* supports UPS status */ | ||
| 51 | #define UPS_TEMP 8 /* supports UPS temperature */ | ||
| 52 | #define UPS_LOADPCT 16 /* supports load percent */ | ||
| 53 | #define UPS_REALPOWER 32 /* supports real power */ | ||
| 54 | |||
| 55 | #define UPSSTATUS_NONE 0 | ||
| 56 | #define UPSSTATUS_OFF 1 | ||
| 57 | #define UPSSTATUS_OL 2 | ||
| 58 | #define UPSSTATUS_OB 4 | ||
| 59 | #define UPSSTATUS_LB 8 | ||
| 60 | #define UPSSTATUS_CAL 16 | ||
| 61 | #define UPSSTATUS_RB 32 /*Replace Battery */ | ||
| 62 | #define UPSSTATUS_BYPASS 64 | ||
| 63 | #define UPSSTATUS_OVER 128 | ||
| 64 | #define UPSSTATUS_TRIM 256 | ||
| 65 | #define UPSSTATUS_BOOST 512 | ||
| 66 | #define UPSSTATUS_CHRG 1024 | ||
| 67 | #define UPSSTATUS_DISCHRG 2048 | ||
| 68 | #define UPSSTATUS_UNKNOWN 4096 | ||
| 69 | #define UPSSTATUS_ALARM 8192 | ||
| 70 | 44 | ||
| 71 | enum { | 45 | enum { |
| 72 | NOSUCHVAR = ERROR - 1 | 46 | NOSUCHVAR = ERROR - 1 |
| 73 | }; | 47 | }; |
| 74 | 48 | ||
| 75 | typedef struct ups_config { | ||
| 76 | unsigned int server_port; | ||
| 77 | char *server_address; | ||
| 78 | char *ups_name; | ||
| 79 | double warning_value; | ||
| 80 | double critical_value; | ||
| 81 | bool check_warn; | ||
| 82 | bool check_crit; | ||
| 83 | int check_variable; | ||
| 84 | int status; | ||
| 85 | bool temp_output_c; | ||
| 86 | } ups_config; | ||
| 87 | |||
| 88 | ups_config ups_config_init(void) { | ||
| 89 | ups_config tmp = {0}; | ||
| 90 | tmp.server_port = PORT; | ||
| 91 | tmp.server_address = NULL; | ||
| 92 | tmp.ups_name = NULL; | ||
| 93 | tmp.check_variable = UPS_NONE; | ||
| 94 | tmp.status = UPSSTATUS_NONE; | ||
| 95 | |||
| 96 | return tmp; | ||
| 97 | } | ||
| 98 | |||
| 99 | // Forward declarations | 49 | // Forward declarations |
| 100 | static int determine_status(ups_config * /*config*/, int *supported_options); | 50 | typedef struct { |
| 101 | static int get_ups_variable(const char * /*varname*/, char * /*buf*/, ups_config config); | 51 | int errorcode; |
| 52 | int ups_status; | ||
| 53 | int supported_options; | ||
| 54 | } determine_status_result; | ||
| 55 | static determine_status_result determine_status(check_ups_config /*config*/); | ||
| 56 | static int get_ups_variable(const char * /*varname*/, char * /*buf*/, check_ups_config config); | ||
| 57 | |||
| 58 | typedef struct { | ||
| 59 | int errorcode; | ||
| 60 | check_ups_config config; | ||
| 61 | } check_ups_config_wrapper; | ||
| 62 | static check_ups_config_wrapper process_arguments(int /*argc*/, char ** /*argv*/); | ||
| 63 | static check_ups_config_wrapper validate_arguments(check_ups_config_wrapper /*config_wrapper*/); | ||
| 102 | 64 | ||
| 103 | static int process_arguments(int /*argc*/, char ** /*argv*/, ups_config * /*config*/); | ||
| 104 | static int validate_arguments(ups_config /*config*/); | ||
| 105 | static void print_help(void); | 65 | static void print_help(void); |
| 106 | void print_usage(void); | 66 | void print_usage(void); |
| 107 | 67 | ||
| @@ -109,28 +69,16 @@ int main(int argc, char **argv) { | |||
| 109 | setlocale(LC_ALL, ""); | 69 | setlocale(LC_ALL, ""); |
| 110 | bindtextdomain(PACKAGE, LOCALEDIR); | 70 | bindtextdomain(PACKAGE, LOCALEDIR); |
| 111 | textdomain(PACKAGE); | 71 | textdomain(PACKAGE); |
| 112 | |||
| 113 | char *ups_status; | ||
| 114 | ups_status = strdup("N/A"); | ||
| 115 | |||
| 116 | char *data; | ||
| 117 | data = strdup(""); | ||
| 118 | |||
| 119 | char *message; | ||
| 120 | message = strdup(""); | ||
| 121 | |||
| 122 | // Exit result | ||
| 123 | int result = STATE_UNKNOWN; | ||
| 124 | |||
| 125 | /* Parse extra opts if any */ | 72 | /* Parse extra opts if any */ |
| 126 | argv = np_extra_opts(&argc, argv, progname); | 73 | argv = np_extra_opts(&argc, argv, progname); |
| 127 | 74 | ||
| 128 | // Config from commandline | 75 | check_ups_config_wrapper tmp_config = process_arguments(argc, argv); |
| 129 | ups_config config = ups_config_init(); | ||
| 130 | 76 | ||
| 131 | if (process_arguments(argc, argv, &config) == ERROR) { | 77 | if (tmp_config.errorcode == ERROR) { |
| 132 | usage4(_("Could not parse arguments")); | 78 | usage4(_("Could not parse arguments")); |
| 133 | } | 79 | } |
| 80 | // Config from commandline | ||
| 81 | check_ups_config config = tmp_config.config; | ||
| 134 | 82 | ||
| 135 | /* initialize alarm signal handling */ | 83 | /* initialize alarm signal handling */ |
| 136 | signal(SIGALRM, socket_timeout_alarm_handler); | 84 | signal(SIGALRM, socket_timeout_alarm_handler); |
| @@ -138,71 +86,76 @@ int main(int argc, char **argv) { | |||
| 138 | /* set socket timeout */ | 86 | /* set socket timeout */ |
| 139 | alarm(socket_timeout); | 87 | alarm(socket_timeout); |
| 140 | 88 | ||
| 141 | int supported_options = UPS_NONE; | ||
| 142 | |||
| 143 | /* get the ups status if possible */ | 89 | /* get the ups status if possible */ |
| 144 | if (determine_status(&config, &supported_options) != OK) { | 90 | determine_status_result query_result = determine_status(config); |
| 91 | if (query_result.errorcode != OK) { | ||
| 145 | return STATE_CRITICAL; | 92 | return STATE_CRITICAL; |
| 146 | } | 93 | } |
| 147 | 94 | ||
| 148 | if (supported_options & UPS_STATUS) { | 95 | int ups_status_flags = query_result.ups_status; |
| 96 | int supported_options = query_result.supported_options; | ||
| 149 | 97 | ||
| 150 | ups_status = strdup(""); | 98 | // Exit result |
| 99 | mp_state_enum result = STATE_UNKNOWN; | ||
| 100 | char *message = NULL; | ||
| 151 | 101 | ||
| 102 | if (supported_options & UPS_STATUS) { | ||
| 103 | char *ups_status = strdup(""); | ||
| 152 | result = STATE_OK; | 104 | result = STATE_OK; |
| 153 | 105 | ||
| 154 | if (config.status & UPSSTATUS_OFF) { | 106 | if (ups_status_flags & UPSSTATUS_OFF) { |
| 155 | xasprintf(&ups_status, "Off"); | 107 | xasprintf(&ups_status, "Off"); |
| 156 | result = STATE_CRITICAL; | 108 | result = STATE_CRITICAL; |
| 157 | } else if ((config.status & (UPSSTATUS_OB | UPSSTATUS_LB)) == (UPSSTATUS_OB | UPSSTATUS_LB)) { | 109 | } else if ((ups_status_flags & (UPSSTATUS_OB | UPSSTATUS_LB)) == |
| 110 | (UPSSTATUS_OB | UPSSTATUS_LB)) { | ||
| 158 | xasprintf(&ups_status, _("On Battery, Low Battery")); | 111 | xasprintf(&ups_status, _("On Battery, Low Battery")); |
| 159 | result = STATE_CRITICAL; | 112 | result = STATE_CRITICAL; |
| 160 | } else { | 113 | } else { |
| 161 | if (config.status & UPSSTATUS_OL) { | 114 | if (ups_status_flags & UPSSTATUS_OL) { |
| 162 | xasprintf(&ups_status, "%s%s", ups_status, _("Online")); | 115 | xasprintf(&ups_status, "%s%s", ups_status, _("Online")); |
| 163 | } | 116 | } |
| 164 | if (config.status & UPSSTATUS_OB) { | 117 | if (ups_status_flags & UPSSTATUS_OB) { |
| 165 | xasprintf(&ups_status, "%s%s", ups_status, _("On Battery")); | 118 | xasprintf(&ups_status, "%s%s", ups_status, _("On Battery")); |
| 166 | result = max_state(result, STATE_WARNING); | 119 | result = max_state(result, STATE_WARNING); |
| 167 | } | 120 | } |
| 168 | if (config.status & UPSSTATUS_LB) { | 121 | if (ups_status_flags & UPSSTATUS_LB) { |
| 169 | xasprintf(&ups_status, "%s%s", ups_status, _(", Low Battery")); | 122 | xasprintf(&ups_status, "%s%s", ups_status, _(", Low Battery")); |
| 170 | result = max_state(result, STATE_WARNING); | 123 | result = max_state(result, STATE_WARNING); |
| 171 | } | 124 | } |
| 172 | if (config.status & UPSSTATUS_CAL) { | 125 | if (ups_status_flags & UPSSTATUS_CAL) { |
| 173 | xasprintf(&ups_status, "%s%s", ups_status, _(", Calibrating")); | 126 | xasprintf(&ups_status, "%s%s", ups_status, _(", Calibrating")); |
| 174 | } | 127 | } |
| 175 | if (config.status & UPSSTATUS_RB) { | 128 | if (ups_status_flags & UPSSTATUS_RB) { |
| 176 | xasprintf(&ups_status, "%s%s", ups_status, _(", Replace Battery")); | 129 | xasprintf(&ups_status, "%s%s", ups_status, _(", Replace Battery")); |
| 177 | result = max_state(result, STATE_WARNING); | 130 | result = max_state(result, STATE_WARNING); |
| 178 | } | 131 | } |
| 179 | if (config.status & UPSSTATUS_BYPASS) { | 132 | if (ups_status_flags & UPSSTATUS_BYPASS) { |
| 180 | xasprintf(&ups_status, "%s%s", ups_status, _(", On Bypass")); | 133 | xasprintf(&ups_status, "%s%s", ups_status, _(", On Bypass")); |
| 181 | // Bypassing the battery is likely a bad thing | 134 | // Bypassing the battery is likely a bad thing |
| 182 | result = STATE_CRITICAL; | 135 | result = STATE_CRITICAL; |
| 183 | } | 136 | } |
| 184 | if (config.status & UPSSTATUS_OVER) { | 137 | if (ups_status_flags & UPSSTATUS_OVER) { |
| 185 | xasprintf(&ups_status, "%s%s", ups_status, _(", Overload")); | 138 | xasprintf(&ups_status, "%s%s", ups_status, _(", Overload")); |
| 186 | result = max_state(result, STATE_WARNING); | 139 | result = max_state(result, STATE_WARNING); |
| 187 | } | 140 | } |
| 188 | if (config.status & UPSSTATUS_TRIM) { | 141 | if (ups_status_flags & UPSSTATUS_TRIM) { |
| 189 | xasprintf(&ups_status, "%s%s", ups_status, _(", Trimming")); | 142 | xasprintf(&ups_status, "%s%s", ups_status, _(", Trimming")); |
| 190 | } | 143 | } |
| 191 | if (config.status & UPSSTATUS_BOOST) { | 144 | if (ups_status_flags & UPSSTATUS_BOOST) { |
| 192 | xasprintf(&ups_status, "%s%s", ups_status, _(", Boosting")); | 145 | xasprintf(&ups_status, "%s%s", ups_status, _(", Boosting")); |
| 193 | } | 146 | } |
| 194 | if (config.status & UPSSTATUS_CHRG) { | 147 | if (ups_status_flags & UPSSTATUS_CHRG) { |
| 195 | xasprintf(&ups_status, "%s%s", ups_status, _(", Charging")); | 148 | xasprintf(&ups_status, "%s%s", ups_status, _(", Charging")); |
| 196 | } | 149 | } |
| 197 | if (config.status & UPSSTATUS_DISCHRG) { | 150 | if (ups_status_flags & UPSSTATUS_DISCHRG) { |
| 198 | xasprintf(&ups_status, "%s%s", ups_status, _(", Discharging")); | 151 | xasprintf(&ups_status, "%s%s", ups_status, _(", Discharging")); |
| 199 | result = max_state(result, STATE_WARNING); | 152 | result = max_state(result, STATE_WARNING); |
| 200 | } | 153 | } |
| 201 | if (config.status & UPSSTATUS_ALARM) { | 154 | if (ups_status_flags & UPSSTATUS_ALARM) { |
| 202 | xasprintf(&ups_status, "%s%s", ups_status, _(", ALARM")); | 155 | xasprintf(&ups_status, "%s%s", ups_status, _(", ALARM")); |
| 203 | result = STATE_CRITICAL; | 156 | result = STATE_CRITICAL; |
| 204 | } | 157 | } |
| 205 | if (config.status & UPSSTATUS_UNKNOWN) { | 158 | if (ups_status_flags & UPSSTATUS_UNKNOWN) { |
| 206 | xasprintf(&ups_status, "%s%s", ups_status, _(", Unknown")); | 159 | xasprintf(&ups_status, "%s%s", ups_status, _(", Unknown")); |
| 207 | } | 160 | } |
| 208 | } | 161 | } |
| @@ -211,7 +164,7 @@ int main(int argc, char **argv) { | |||
| 211 | 164 | ||
| 212 | int res; | 165 | int res; |
| 213 | char temp_buffer[MAX_INPUT_BUFFER]; | 166 | char temp_buffer[MAX_INPUT_BUFFER]; |
| 214 | 167 | char *performance_data = strdup(""); | |
| 215 | /* get the ups utility voltage if possible */ | 168 | /* get the ups utility voltage if possible */ |
| 216 | res = get_ups_variable("input.voltage", temp_buffer, config); | 169 | res = get_ups_variable("input.voltage", temp_buffer, config); |
| 217 | if (res == NOSUCHVAR) { | 170 | if (res == NOSUCHVAR) { |
| @@ -239,11 +192,15 @@ int main(int argc, char **argv) { | |||
| 239 | } else if (config.check_warn && ups_utility_deviation >= config.warning_value) { | 192 | } else if (config.check_warn && ups_utility_deviation >= config.warning_value) { |
| 240 | result = max_state(result, STATE_WARNING); | 193 | result = max_state(result, STATE_WARNING); |
| 241 | } | 194 | } |
| 242 | xasprintf(&data, "%s", | 195 | xasprintf(&performance_data, "%s", |
| 243 | perfdata("voltage", (long)(1000 * ups_utility_voltage), "mV", config.check_warn, (long)(1000 * config.warning_value), | 196 | perfdata("voltage", (long)(1000 * ups_utility_voltage), "mV", |
| 244 | config.check_crit, (long)(1000 * config.critical_value), true, 0, false, 0)); | 197 | config.check_warn, (long)(1000 * config.warning_value), |
| 198 | config.check_crit, (long)(1000 * config.critical_value), true, 0, | ||
| 199 | false, 0)); | ||
| 245 | } else { | 200 | } else { |
| 246 | xasprintf(&data, "%s", perfdata("voltage", (long)(1000 * ups_utility_voltage), "mV", false, 0, false, 0, true, 0, false, 0)); | 201 | xasprintf(&performance_data, "%s", |
| 202 | perfdata("voltage", (long)(1000 * ups_utility_voltage), "mV", false, 0, false, | ||
| 203 | 0, true, 0, false, 0)); | ||
| 247 | } | 204 | } |
| 248 | } | 205 | } |
| 249 | 206 | ||
| @@ -266,11 +223,14 @@ int main(int argc, char **argv) { | |||
| 266 | } else if (config.check_warn && ups_battery_percent <= config.warning_value) { | 223 | } else if (config.check_warn && ups_battery_percent <= config.warning_value) { |
| 267 | result = max_state(result, STATE_WARNING); | 224 | result = max_state(result, STATE_WARNING); |
| 268 | } | 225 | } |
| 269 | xasprintf(&data, "%s %s", data, | 226 | xasprintf(&performance_data, "%s %s", performance_data, |
| 270 | perfdata("battery", (long)ups_battery_percent, "%", config.check_warn, (long)(config.warning_value), | 227 | perfdata("battery", (long)ups_battery_percent, "%", config.check_warn, |
| 271 | config.check_crit, (long)(config.critical_value), true, 0, true, 100)); | 228 | (long)(config.warning_value), config.check_crit, |
| 229 | (long)(config.critical_value), true, 0, true, 100)); | ||
| 272 | } else { | 230 | } else { |
| 273 | xasprintf(&data, "%s %s", data, perfdata("battery", (long)ups_battery_percent, "%", false, 0, false, 0, true, 0, true, 100)); | 231 | xasprintf(&performance_data, "%s %s", performance_data, |
| 232 | perfdata("battery", (long)ups_battery_percent, "%", false, 0, false, 0, true, | ||
| 233 | 0, true, 100)); | ||
| 274 | } | 234 | } |
| 275 | } | 235 | } |
| 276 | 236 | ||
| @@ -293,11 +253,14 @@ int main(int argc, char **argv) { | |||
| 293 | } else if (config.check_warn && ups_load_percent >= config.warning_value) { | 253 | } else if (config.check_warn && ups_load_percent >= config.warning_value) { |
| 294 | result = max_state(result, STATE_WARNING); | 254 | result = max_state(result, STATE_WARNING); |
| 295 | } | 255 | } |
| 296 | xasprintf(&data, "%s %s", data, | 256 | xasprintf(&performance_data, "%s %s", performance_data, |
| 297 | perfdata("load", (long)ups_load_percent, "%", config.check_warn, (long)(config.warning_value), config.check_crit, | 257 | perfdata("load", (long)ups_load_percent, "%", config.check_warn, |
| 258 | (long)(config.warning_value), config.check_crit, | ||
| 298 | (long)(config.critical_value), true, 0, true, 100)); | 259 | (long)(config.critical_value), true, 0, true, 100)); |
| 299 | } else { | 260 | } else { |
| 300 | xasprintf(&data, "%s %s", data, perfdata("load", (long)ups_load_percent, "%", false, 0, false, 0, true, 0, true, 100)); | 261 | xasprintf(&performance_data, "%s %s", performance_data, |
| 262 | perfdata("load", (long)ups_load_percent, "%", false, 0, false, 0, true, 0, | ||
| 263 | true, 100)); | ||
| 301 | } | 264 | } |
| 302 | } | 265 | } |
| 303 | 266 | ||
| @@ -329,11 +292,14 @@ int main(int argc, char **argv) { | |||
| 329 | } else if (config.check_warn && ups_temperature >= config.warning_value) { | 292 | } else if (config.check_warn && ups_temperature >= config.warning_value) { |
| 330 | result = max_state(result, STATE_WARNING); | 293 | result = max_state(result, STATE_WARNING); |
| 331 | } | 294 | } |
| 332 | xasprintf(&data, "%s %s", data, | 295 | xasprintf(&performance_data, "%s %s", performance_data, |
| 333 | perfdata("temp", (long)ups_temperature, tunits, config.check_warn, (long)(config.warning_value), config.check_crit, | 296 | perfdata("temp", (long)ups_temperature, tunits, config.check_warn, |
| 297 | (long)(config.warning_value), config.check_crit, | ||
| 334 | (long)(config.critical_value), true, 0, false, 0)); | 298 | (long)(config.critical_value), true, 0, false, 0)); |
| 335 | } else { | 299 | } else { |
| 336 | xasprintf(&data, "%s %s", data, perfdata("temp", (long)ups_temperature, tunits, false, 0, false, 0, true, 0, false, 0)); | 300 | xasprintf(&performance_data, "%s %s", performance_data, |
| 301 | perfdata("temp", (long)ups_temperature, tunits, false, 0, false, 0, true, 0, | ||
| 302 | false, 0)); | ||
| 337 | } | 303 | } |
| 338 | } | 304 | } |
| 339 | 305 | ||
| @@ -355,11 +321,14 @@ int main(int argc, char **argv) { | |||
| 355 | } else if (config.check_warn && ups_realpower >= config.warning_value) { | 321 | } else if (config.check_warn && ups_realpower >= config.warning_value) { |
| 356 | result = max_state(result, STATE_WARNING); | 322 | result = max_state(result, STATE_WARNING); |
| 357 | } | 323 | } |
| 358 | xasprintf(&data, "%s %s", data, | 324 | xasprintf(&performance_data, "%s %s", performance_data, |
| 359 | perfdata("realpower", (long)ups_realpower, "W", config.check_warn, (long)(config.warning_value), config.check_crit, | 325 | perfdata("realpower", (long)ups_realpower, "W", config.check_warn, |
| 326 | (long)(config.warning_value), config.check_crit, | ||
| 360 | (long)(config.critical_value), true, 0, false, 0)); | 327 | (long)(config.critical_value), true, 0, false, 0)); |
| 361 | } else { | 328 | } else { |
| 362 | xasprintf(&data, "%s %s", data, perfdata("realpower", (long)ups_realpower, "W", false, 0, false, 0, true, 0, false, 0)); | 329 | xasprintf(&performance_data, "%s %s", performance_data, |
| 330 | perfdata("realpower", (long)ups_realpower, "W", false, 0, false, 0, true, 0, | ||
| 331 | false, 0)); | ||
| 363 | } | 332 | } |
| 364 | } | 333 | } |
| 365 | 334 | ||
| @@ -373,71 +342,79 @@ int main(int argc, char **argv) { | |||
| 373 | /* reset timeout */ | 342 | /* reset timeout */ |
| 374 | alarm(0); | 343 | alarm(0); |
| 375 | 344 | ||
| 376 | printf("UPS %s - %s|%s\n", state_text(result), message, data); | 345 | printf("UPS %s - %s|%s\n", state_text(result), message, performance_data); |
| 377 | return result; | 346 | exit(result); |
| 378 | } | 347 | } |
| 379 | 348 | ||
| 380 | /* determines what options are supported by the UPS */ | 349 | /* determines what options are supported by the UPS */ |
| 381 | int determine_status(ups_config *config, int *supported_options) { | 350 | determine_status_result determine_status(const check_ups_config config) { |
| 382 | char recv_buffer[MAX_INPUT_BUFFER]; | ||
| 383 | 351 | ||
| 384 | int res = get_ups_variable("ups.status", recv_buffer, *config); | 352 | determine_status_result result = { |
| 353 | .errorcode = OK, | ||
| 354 | .ups_status = UPSSTATUS_NONE, | ||
| 355 | .supported_options = 0, | ||
| 356 | }; | ||
| 357 | |||
| 358 | char recv_buffer[MAX_INPUT_BUFFER]; | ||
| 359 | int res = get_ups_variable("ups.status", recv_buffer, config); | ||
| 385 | if (res == NOSUCHVAR) { | 360 | if (res == NOSUCHVAR) { |
| 386 | return OK; | 361 | return result; |
| 387 | } | 362 | } |
| 388 | 363 | ||
| 389 | if (res != STATE_OK) { | 364 | if (res != STATE_OK) { |
| 390 | printf("%s\n", _("Invalid response received from host")); | 365 | printf("%s\n", _("Invalid response received from host")); |
| 391 | return ERROR; | 366 | result.errorcode = ERROR; |
| 367 | return result; | ||
| 392 | } | 368 | } |
| 393 | 369 | ||
| 394 | *supported_options |= UPS_STATUS; | 370 | result.supported_options |= UPS_STATUS; |
| 395 | 371 | ||
| 396 | char temp_buffer[MAX_INPUT_BUFFER]; | 372 | char temp_buffer[MAX_INPUT_BUFFER]; |
| 397 | 373 | ||
| 398 | strcpy(temp_buffer, recv_buffer); | 374 | strcpy(temp_buffer, recv_buffer); |
| 399 | for (char *ptr = (char *)strtok(temp_buffer, " "); ptr != NULL; ptr = (char *)strtok(NULL, " ")) { | 375 | for (char *ptr = strtok(temp_buffer, " "); ptr != NULL; ptr = strtok(NULL, " ")) { |
| 400 | if (!strcmp(ptr, "OFF")) { | 376 | if (!strcmp(ptr, "OFF")) { |
| 401 | config->status |= UPSSTATUS_OFF; | 377 | result.ups_status |= UPSSTATUS_OFF; |
| 402 | } else if (!strcmp(ptr, "OL")) { | 378 | } else if (!strcmp(ptr, "OL")) { |
| 403 | config->status |= UPSSTATUS_OL; | 379 | result.ups_status |= UPSSTATUS_OL; |
| 404 | } else if (!strcmp(ptr, "OB")) { | 380 | } else if (!strcmp(ptr, "OB")) { |
| 405 | config->status |= UPSSTATUS_OB; | 381 | result.ups_status |= UPSSTATUS_OB; |
| 406 | } else if (!strcmp(ptr, "LB")) { | 382 | } else if (!strcmp(ptr, "LB")) { |
| 407 | config->status |= UPSSTATUS_LB; | 383 | result.ups_status |= UPSSTATUS_LB; |
| 408 | } else if (!strcmp(ptr, "CAL")) { | 384 | } else if (!strcmp(ptr, "CAL")) { |
| 409 | config->status |= UPSSTATUS_CAL; | 385 | result.ups_status |= UPSSTATUS_CAL; |
| 410 | } else if (!strcmp(ptr, "RB")) { | 386 | } else if (!strcmp(ptr, "RB")) { |
| 411 | config->status |= UPSSTATUS_RB; | 387 | result.ups_status |= UPSSTATUS_RB; |
| 412 | } else if (!strcmp(ptr, "BYPASS")) { | 388 | } else if (!strcmp(ptr, "BYPASS")) { |
| 413 | config->status |= UPSSTATUS_BYPASS; | 389 | result.ups_status |= UPSSTATUS_BYPASS; |
| 414 | } else if (!strcmp(ptr, "OVER")) { | 390 | } else if (!strcmp(ptr, "OVER")) { |
| 415 | config->status |= UPSSTATUS_OVER; | 391 | result.ups_status |= UPSSTATUS_OVER; |
| 416 | } else if (!strcmp(ptr, "TRIM")) { | 392 | } else if (!strcmp(ptr, "TRIM")) { |
| 417 | config->status |= UPSSTATUS_TRIM; | 393 | result.ups_status |= UPSSTATUS_TRIM; |
| 418 | } else if (!strcmp(ptr, "BOOST")) { | 394 | } else if (!strcmp(ptr, "BOOST")) { |
| 419 | config->status |= UPSSTATUS_BOOST; | 395 | result.ups_status |= UPSSTATUS_BOOST; |
| 420 | } else if (!strcmp(ptr, "CHRG")) { | 396 | } else if (!strcmp(ptr, "CHRG")) { |
| 421 | config->status |= UPSSTATUS_CHRG; | 397 | result.ups_status |= UPSSTATUS_CHRG; |
| 422 | } else if (!strcmp(ptr, "DISCHRG")) { | 398 | } else if (!strcmp(ptr, "DISCHRG")) { |
| 423 | config->status |= UPSSTATUS_DISCHRG; | 399 | result.ups_status |= UPSSTATUS_DISCHRG; |
| 424 | } else if (!strcmp(ptr, "ALARM")) { | 400 | } else if (!strcmp(ptr, "ALARM")) { |
| 425 | config->status |= UPSSTATUS_ALARM; | 401 | result.ups_status |= UPSSTATUS_ALARM; |
| 426 | } else { | 402 | } else { |
| 427 | config->status |= UPSSTATUS_UNKNOWN; | 403 | result.ups_status |= UPSSTATUS_UNKNOWN; |
| 428 | } | 404 | } |
| 429 | } | 405 | } |
| 430 | 406 | ||
| 431 | return OK; | 407 | return result; |
| 432 | } | 408 | } |
| 433 | 409 | ||
| 434 | /* gets a variable value for a specific UPS */ | 410 | /* gets a variable value for a specific UPS */ |
| 435 | int get_ups_variable(const char *varname, char *buf, const ups_config config) { | 411 | int get_ups_variable(const char *varname, char *buf, const check_ups_config config) { |
| 436 | char send_buffer[MAX_INPUT_BUFFER]; | 412 | char send_buffer[MAX_INPUT_BUFFER]; |
| 437 | 413 | ||
| 438 | /* create the command string to send to the UPS daemon */ | 414 | /* create the command string to send to the UPS daemon */ |
| 439 | /* Add LOGOUT to avoid read failure logs */ | 415 | /* Add LOGOUT to avoid read failure logs */ |
| 440 | int res = snprintf(send_buffer, sizeof(send_buffer), "GET VAR %s %s\nLOGOUT\n", config.ups_name, varname); | 416 | int res = snprintf(send_buffer, sizeof(send_buffer), "GET VAR %s %s\nLOGOUT\n", config.ups_name, |
| 417 | varname); | ||
| 441 | if ((res > 0) && ((size_t)res >= sizeof(send_buffer))) { | 418 | if ((res > 0) && ((size_t)res >= sizeof(send_buffer))) { |
| 442 | printf("%s\n", _("UPS name to long for buffer")); | 419 | printf("%s\n", _("UPS name to long for buffer")); |
| 443 | return ERROR; | 420 | return ERROR; |
| @@ -446,7 +423,8 @@ int get_ups_variable(const char *varname, char *buf, const ups_config config) { | |||
| 446 | char temp_buffer[MAX_INPUT_BUFFER]; | 423 | char temp_buffer[MAX_INPUT_BUFFER]; |
| 447 | 424 | ||
| 448 | /* send the command to the daemon and get a response back */ | 425 | /* send the command to the daemon and get a response back */ |
| 449 | if (process_tcp_request(config.server_address, config.server_port, send_buffer, temp_buffer, sizeof(temp_buffer)) != STATE_OK) { | 426 | if (process_tcp_request(config.server_address, config.server_port, send_buffer, temp_buffer, |
| 427 | sizeof(temp_buffer)) != STATE_OK) { | ||
| 450 | printf("%s\n", _("Invalid response received from host")); | 428 | printf("%s\n", _("Invalid response received from host")); |
| 451 | return ERROR; | 429 | return ERROR; |
| 452 | } | 430 | } |
| @@ -500,7 +478,7 @@ int get_ups_variable(const char *varname, char *buf, const ups_config config) { | |||
| 500 | [-wv warn_value] [-cv crit_value] [-to to_sec] */ | 478 | [-wv warn_value] [-cv crit_value] [-to to_sec] */ |
| 501 | 479 | ||
| 502 | /* process command-line arguments */ | 480 | /* process command-line arguments */ |
| 503 | int process_arguments(int argc, char **argv, ups_config *config) { | 481 | check_ups_config_wrapper process_arguments(int argc, char **argv) { |
| 504 | 482 | ||
| 505 | static struct option longopts[] = {{"hostname", required_argument, 0, 'H'}, | 483 | static struct option longopts[] = {{"hostname", required_argument, 0, 'H'}, |
| 506 | {"ups", required_argument, 0, 'u'}, | 484 | {"ups", required_argument, 0, 'u'}, |
| @@ -514,8 +492,14 @@ int process_arguments(int argc, char **argv, ups_config *config) { | |||
| 514 | {"help", no_argument, 0, 'h'}, | 492 | {"help", no_argument, 0, 'h'}, |
| 515 | {0, 0, 0, 0}}; | 493 | {0, 0, 0, 0}}; |
| 516 | 494 | ||
| 495 | check_ups_config_wrapper result = { | ||
| 496 | .errorcode = OK, | ||
| 497 | .config = check_ups_config_init(), | ||
| 498 | }; | ||
| 499 | |||
| 517 | if (argc < 2) { | 500 | if (argc < 2) { |
| 518 | return ERROR; | 501 | result.errorcode = ERROR; |
| 502 | return result; | ||
| 519 | } | 503 | } |
| 520 | 504 | ||
| 521 | int c; | 505 | int c; |
| @@ -542,52 +526,52 @@ int process_arguments(int argc, char **argv, ups_config *config) { | |||
| 542 | usage5(); | 526 | usage5(); |
| 543 | case 'H': /* hostname */ | 527 | case 'H': /* hostname */ |
| 544 | if (is_host(optarg)) { | 528 | if (is_host(optarg)) { |
| 545 | config->server_address = optarg; | 529 | result.config.server_address = optarg; |
| 546 | } else { | 530 | } else { |
| 547 | usage2(_("Invalid hostname/address"), optarg); | 531 | usage2(_("Invalid hostname/address"), optarg); |
| 548 | } | 532 | } |
| 549 | break; | 533 | break; |
| 550 | case 'T': /* FIXME: to be improved (ie "-T C" for Celsius or "-T F" for | 534 | case 'T': /* FIXME: to be improved (ie "-T C" for Celsius or "-T F" for |
| 551 | Fahrenheit) */ | 535 | Fahrenheit) */ |
| 552 | config->temp_output_c = true; | 536 | result.config.temp_output_c = true; |
| 553 | break; | 537 | break; |
| 554 | case 'u': /* ups name */ | 538 | case 'u': /* ups name */ |
| 555 | config->ups_name = optarg; | 539 | result.config.ups_name = optarg; |
| 556 | break; | 540 | break; |
| 557 | case 'p': /* port */ | 541 | case 'p': /* port */ |
| 558 | if (is_intpos(optarg)) { | 542 | if (is_intpos(optarg)) { |
| 559 | config->server_port = atoi(optarg); | 543 | result.config.server_port = atoi(optarg); |
| 560 | } else { | 544 | } else { |
| 561 | usage2(_("Port must be a positive integer"), optarg); | 545 | usage2(_("Port must be a positive integer"), optarg); |
| 562 | } | 546 | } |
| 563 | break; | 547 | break; |
| 564 | case 'c': /* critical time threshold */ | 548 | case 'c': /* critical time threshold */ |
| 565 | if (is_intnonneg(optarg)) { | 549 | if (is_intnonneg(optarg)) { |
| 566 | config->critical_value = atoi(optarg); | 550 | result.config.critical_value = atoi(optarg); |
| 567 | config->check_crit = true; | 551 | result.config.check_crit = true; |
| 568 | } else { | 552 | } else { |
| 569 | usage2(_("Critical time must be a positive integer"), optarg); | 553 | usage2(_("Critical time must be a positive integer"), optarg); |
| 570 | } | 554 | } |
| 571 | break; | 555 | break; |
| 572 | case 'w': /* warning time threshold */ | 556 | case 'w': /* warning time threshold */ |
| 573 | if (is_intnonneg(optarg)) { | 557 | if (is_intnonneg(optarg)) { |
| 574 | config->warning_value = atoi(optarg); | 558 | result.config.warning_value = atoi(optarg); |
| 575 | config->check_warn = true; | 559 | result.config.check_warn = true; |
| 576 | } else { | 560 | } else { |
| 577 | usage2(_("Warning time must be a positive integer"), optarg); | 561 | usage2(_("Warning time must be a positive integer"), optarg); |
| 578 | } | 562 | } |
| 579 | break; | 563 | break; |
| 580 | case 'v': /* variable */ | 564 | case 'v': /* variable */ |
| 581 | if (!strcmp(optarg, "LINE")) { | 565 | if (!strcmp(optarg, "LINE")) { |
| 582 | config->check_variable = UPS_UTILITY; | 566 | result.config.check_variable = UPS_UTILITY; |
| 583 | } else if (!strcmp(optarg, "TEMP")) { | 567 | } else if (!strcmp(optarg, "TEMP")) { |
| 584 | config->check_variable = UPS_TEMP; | 568 | result.config.check_variable = UPS_TEMP; |
| 585 | } else if (!strcmp(optarg, "BATTPCT")) { | 569 | } else if (!strcmp(optarg, "BATTPCT")) { |
| 586 | config->check_variable = UPS_BATTPCT; | 570 | result.config.check_variable = UPS_BATTPCT; |
| 587 | } else if (!strcmp(optarg, "LOADPCT")) { | 571 | } else if (!strcmp(optarg, "LOADPCT")) { |
| 588 | config->check_variable = UPS_LOADPCT; | 572 | result.config.check_variable = UPS_LOADPCT; |
| 589 | } else if (!strcmp(optarg, "REALPOWER")) { | 573 | } else if (!strcmp(optarg, "REALPOWER")) { |
| 590 | config->check_variable = UPS_REALPOWER; | 574 | result.config.check_variable = UPS_REALPOWER; |
| 591 | } else { | 575 | } else { |
| 592 | usage2(_("Unrecognized UPS variable"), optarg); | 576 | usage2(_("Unrecognized UPS variable"), optarg); |
| 593 | } | 577 | } |
| @@ -608,27 +592,27 @@ int process_arguments(int argc, char **argv, ups_config *config) { | |||
| 608 | } | 592 | } |
| 609 | } | 593 | } |
| 610 | 594 | ||
| 611 | if (config->server_address == NULL && argc > optind) { | 595 | if (result.config.server_address == NULL && argc > optind) { |
| 612 | if (is_host(argv[optind])) { | 596 | if (is_host(argv[optind])) { |
| 613 | config->server_address = argv[optind++]; | 597 | result.config.server_address = argv[optind++]; |
| 614 | } else { | 598 | } else { |
| 615 | usage2(_("Invalid hostname/address"), optarg); | 599 | usage2(_("Invalid hostname/address"), optarg); |
| 616 | } | 600 | } |
| 617 | } | 601 | } |
| 618 | 602 | ||
| 619 | if (config->server_address == NULL) { | 603 | if (result.config.server_address == NULL) { |
| 620 | config->server_address = strdup("127.0.0.1"); | 604 | result.config.server_address = strdup("127.0.0.1"); |
| 621 | } | 605 | } |
| 622 | 606 | ||
| 623 | return validate_arguments(*config); | 607 | return validate_arguments(result); |
| 624 | } | 608 | } |
| 625 | 609 | ||
| 626 | int validate_arguments(ups_config config) { | 610 | check_ups_config_wrapper validate_arguments(check_ups_config_wrapper config_wrapper) { |
| 627 | if (!config.ups_name) { | 611 | if (config_wrapper.config.ups_name) { |
| 628 | printf("%s\n", _("Error : no UPS indicated")); | 612 | printf("%s\n", _("Error : no UPS indicated")); |
| 629 | return ERROR; | 613 | config_wrapper.errorcode = ERROR; |
| 630 | } | 614 | } |
| 631 | return OK; | 615 | return config_wrapper; |
| 632 | } | 616 | } |
| 633 | 617 | ||
| 634 | void print_help(void) { | 618 | void print_help(void) { |
| @@ -660,7 +644,8 @@ void print_help(void) { | |||
| 660 | printf(" %s\n", "-T, --temperature"); | 644 | printf(" %s\n", "-T, --temperature"); |
| 661 | printf(" %s\n", _("Output of temperatures in Celsius")); | 645 | printf(" %s\n", _("Output of temperatures in Celsius")); |
| 662 | printf(" %s\n", "-v, --variable=STRING"); | 646 | printf(" %s\n", "-v, --variable=STRING"); |
| 663 | printf(" %s %s\n", _("Valid values for STRING are"), "LINE, TEMP, BATTPCT, LOADPCT or REALPOWER"); | 647 | printf(" %s %s\n", _("Valid values for STRING are"), |
| 648 | "LINE, TEMP, BATTPCT, LOADPCT or REALPOWER"); | ||
| 664 | 649 | ||
| 665 | printf(UT_WARN_CRIT); | 650 | printf(UT_WARN_CRIT); |
| 666 | 651 | ||
