X-Git-Url: https://git.octo.it/?p=collectd.git;a=blobdiff_plain;f=src%2Fcsv.c;h=953473fce56a2e6a43ad2d5fa882f212556d2a2c;hp=e4c84f7fea9b5e4f264650a8a2a1ecebd520fc3d;hb=54619dc85fd308b21ed09a0271e5c7383c7921b9;hpb=b165cd13cd30a30ac830df1f6f6fbd52474a6f64 diff --git a/src/csv.c b/src/csv.c index e4c84f7f..953473fc 100644 --- a/src/csv.c +++ b/src/csv.c @@ -23,8 +23,8 @@ #include "collectd.h" -#include "common.h" #include "plugin.h" +#include "utils/common/common.h" #include "utils_cache.h" /* @@ -33,9 +33,9 @@ static const char *config_keys[] = {"DataDir", "StoreRates"}; static int config_keys_num = STATIC_ARRAY_SIZE(config_keys); -static char *datadir = NULL; -static int store_rates = 0; -static int use_stdio = 0; +static char *datadir; +static int store_rates; +static int use_stdio; static int value_list_to_string(char *buffer, int buffer_len, const data_set_t *ds, const value_list_t *vl) { @@ -47,7 +47,7 @@ static int value_list_to_string(char *buffer, int buffer_len, memset(buffer, '\0', buffer_len); - status = ssnprintf(buffer, buffer_len, "%.3f", CDTIME_T_TO_DOUBLE(vl->time)); + status = snprintf(buffer, buffer_len, "%.3f", CDTIME_T_TO_DOUBLE(vl->time)); if ((status < 1) || (status >= buffer_len)) return -1; offset = status; @@ -62,8 +62,8 @@ static int value_list_to_string(char *buffer, int buffer_len, } if (ds->ds[i].type == DS_TYPE_GAUGE) { - status = ssnprintf(buffer + offset, buffer_len - offset, ",%lf", - vl->values[i].gauge); + status = snprintf(buffer + offset, buffer_len - offset, ",%lf", + vl->values[i].gauge); } else if (store_rates != 0) { if (rates == NULL) rates = uc_get_rate(ds, vl); @@ -72,17 +72,16 @@ static int value_list_to_string(char *buffer, int buffer_len, "uc_get_rate failed."); return -1; } - status = - ssnprintf(buffer + offset, buffer_len - offset, ",%lf", rates[i]); + status = snprintf(buffer + offset, buffer_len - offset, ",%lf", rates[i]); } else if (ds->ds[i].type == DS_TYPE_COUNTER) { - status = ssnprintf(buffer + offset, buffer_len - offset, ",%llu", - vl->values[i].counter); + status = snprintf(buffer + offset, buffer_len - offset, ",%" PRIu64, + (uint64_t)vl->values[i].counter); } else if (ds->ds[i].type == DS_TYPE_DERIVE) { - status = ssnprintf(buffer + offset, buffer_len - offset, ",%" PRIi64, - vl->values[i].derive); + status = snprintf(buffer + offset, buffer_len - offset, ",%" PRIi64, + vl->values[i].derive); } else if (ds->ds[i].type == DS_TYPE_ABSOLUTE) { - status = ssnprintf(buffer + offset, buffer_len - offset, ",%" PRIu64, - vl->values[i].absolute); + status = snprintf(buffer + offset, buffer_len - offset, ",%" PRIu64, + vl->values[i].absolute); } if ((status < 1) || (status >= (buffer_len - offset))) { @@ -162,9 +161,7 @@ static int csv_create_file(const char *filename, const data_set_t *ds) { csv = fopen(filename, "w"); if (csv == NULL) { - char errbuf[1024]; - ERROR("csv plugin: fopen (%s) failed: %s", filename, - sstrerror(errno, errbuf, sizeof(errbuf))); + ERROR("csv plugin: fopen (%s) failed: %s", filename, STRERRNO); return -1; } @@ -193,12 +190,12 @@ static int csv_config(const char *key, const char *value) { } datadir = strdup(value); if (datadir != NULL) { - int len = strlen(datadir); + size_t len = strlen(datadir); while ((len > 0) && (datadir[len - 1] == '/')) { len--; datadir[len] = '\0'; } - if (len <= 0) { + if (len == 0) { free(datadir); datadir = NULL; } @@ -259,9 +256,7 @@ static int csv_write(const data_set_t *ds, const value_list_t *vl, if (csv_create_file(filename, ds)) return -1; } else { - char errbuf[1024]; - ERROR("stat(%s) failed: %s", filename, - sstrerror(errno, errbuf, sizeof(errbuf))); + ERROR("stat(%s) failed: %s", filename, STRERRNO); return -1; } } else if (!S_ISREG(statbuf.st_mode)) { @@ -271,9 +266,7 @@ static int csv_write(const data_set_t *ds, const value_list_t *vl, csv = fopen(filename, "a"); if (csv == NULL) { - char errbuf[1024]; - ERROR("csv plugin: fopen (%s) failed: %s", filename, - sstrerror(errno, errbuf, sizeof(errbuf))); + ERROR("csv plugin: fopen (%s) failed: %s", filename, STRERRNO); return -1; } csv_fd = fileno(csv); @@ -284,9 +277,7 @@ static int csv_write(const data_set_t *ds, const value_list_t *vl, status = fcntl(csv_fd, F_SETLK, &fl); if (status != 0) { - char errbuf[1024]; - ERROR("csv plugin: flock (%s) failed: %s", filename, - sstrerror(errno, errbuf, sizeof(errbuf))); + ERROR("csv plugin: flock (%s) failed: %s", filename, STRERRNO); fclose(csv); return -1; }