X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Futils_cmd_getval.c;h=354c553e7f0c6d8b256a1ff85cdb8c05d02dcffb;hb=master;hp=f747d5b862e8cf0770698d5e3ebf7d63f8b43ebb;hpb=4c4988b1c5d33ed70b2d6d6e5a4eae13cab9255b;p=collectd.git diff --git a/src/utils_cmd_getval.c b/src/utils_cmd_getval.c deleted file mode 100644 index f747d5b8..00000000 --- a/src/utils_cmd_getval.c +++ /dev/null @@ -1,165 +0,0 @@ -/** - * collectd - src/utils_cmd_getval.c - * Copyright (C) 2008 Florian octo Forster - * - * Permission is hereby granted, free of charge, to any person obtaining a - * copy of this software and associated documentation files (the "Software"), - * to deal in the Software without restriction, including without limitation - * the rights to use, copy, modify, merge, publish, distribute, sublicense, - * and/or sell copies of the Software, and to permit persons to whom the - * Software is furnished to do so, subject to the following conditions: - * - * The above copyright notice and this permission notice shall be included in - * all copies or substantial portions of the Software. - * - * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE - * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER - * DEALINGS IN THE SOFTWARE. - * - * Authors: - * Florian octo Forster - **/ - -#include "collectd.h" - -#include "common.h" -#include "plugin.h" - -#include "utils_cache.h" -#include "utils_cmd_getval.h" -#include "utils_parse_option.h" - -cmd_status_t cmd_parse_getval(size_t argc, char **argv, - cmd_getval_t *ret_getval, - const cmd_options_t *opts, - cmd_error_handler_t *err) { - char *identifier_copy; - int status; - - if ((ret_getval == NULL) || (opts == NULL)) { - errno = EINVAL; - cmd_error(CMD_ERROR, err, "Invalid arguments to cmd_parse_getval."); - return CMD_ERROR; - } - - if (argc != 1) { - if (argc == 0) - cmd_error(CMD_PARSE_ERROR, err, "Missing identifier."); - else - cmd_error(CMD_PARSE_ERROR, err, "Garbage after identifier: `%s'.", - argv[1]); - return CMD_PARSE_ERROR; - } - - /* parse_identifier() modifies its first argument, - * returning pointers into it */ - identifier_copy = sstrdup(argv[0]); - - status = parse_identifier( - argv[0], &ret_getval->identifier.host, &ret_getval->identifier.plugin, - &ret_getval->identifier.plugin_instance, &ret_getval->identifier.type, - &ret_getval->identifier.type_instance, opts->identifier_default_host); - if (status != 0) { - DEBUG("cmd_parse_getval: Cannot parse identifier `%s'.", identifier_copy); - cmd_error(CMD_PARSE_ERROR, err, "Cannot parse identifier `%s'.", - identifier_copy); - sfree(identifier_copy); - return CMD_PARSE_ERROR; - } - - ret_getval->raw_identifier = identifier_copy; - return CMD_OK; -} /* cmd_status_t cmd_parse_getval */ - -#define print_to_socket(fh, ...) \ - do { \ - if (fprintf(fh, __VA_ARGS__) < 0) { \ - WARNING("cmd_handle_getval: failed to write to socket #%i: %s", \ - fileno(fh), STRERRNO); \ - return -1; \ - } \ - fflush(fh); \ - } while (0) - -cmd_status_t cmd_handle_getval(FILE *fh, char *buffer) { - cmd_error_handler_t err = {cmd_error_fh, fh}; - cmd_status_t status; - cmd_t cmd; - - gauge_t *values; - size_t values_num; - - const data_set_t *ds; - - if ((fh == NULL) || (buffer == NULL)) - return -1; - - DEBUG("utils_cmd_getval: cmd_handle_getval (fh = %p, buffer = %s);", - (void *)fh, buffer); - - if ((status = cmd_parse(buffer, &cmd, NULL, &err)) != CMD_OK) - return status; - if (cmd.type != CMD_GETVAL) { - cmd_error(CMD_UNKNOWN_COMMAND, &err, "Unexpected command: `%s'.", - CMD_TO_STRING(cmd.type)); - cmd_destroy(&cmd); - return CMD_UNKNOWN_COMMAND; - } - - ds = plugin_get_ds(cmd.cmd.getval.identifier.type); - if (ds == NULL) { - DEBUG("cmd_handle_getval: plugin_get_ds (%s) == NULL;", - cmd.cmd.getval.identifier.type); - cmd_error(CMD_ERROR, &err, "Type `%s' is unknown.\n", - cmd.cmd.getval.identifier.type); - cmd_destroy(&cmd); - return -1; - } - - values = NULL; - values_num = 0; - status = - uc_get_rate_by_name(cmd.cmd.getval.raw_identifier, &values, &values_num); - if (status != 0) { - cmd_error(CMD_ERROR, &err, "No such value."); - cmd_destroy(&cmd); - return CMD_ERROR; - } - - if (ds->ds_num != values_num) { - ERROR("ds[%s]->ds_num = %" PRIsz ", " - "but uc_get_rate_by_name returned %" PRIsz " values.", - ds->type, ds->ds_num, values_num); - cmd_error(CMD_ERROR, &err, "Error reading value from cache."); - sfree(values); - cmd_destroy(&cmd); - return CMD_ERROR; - } - - print_to_socket(fh, "%" PRIsz " Value%s found\n", values_num, - (values_num == 1) ? "" : "s"); - for (size_t i = 0; i < values_num; i++) { - print_to_socket(fh, "%s=", ds->ds[i].name); - if (isnan(values[i])) { - print_to_socket(fh, "NaN\n"); - } else { - print_to_socket(fh, "%12e\n", values[i]); - } - } - - sfree(values); - cmd_destroy(&cmd); - - return CMD_OK; -} /* cmd_status_t cmd_handle_getval */ - -void cmd_destroy_getval(cmd_getval_t *getval) { - if (getval == NULL) - return; - - sfree(getval->raw_identifier); -} /* void cmd_destroy_getval */