X-Git-Url: https://git.octo.it/?p=rrdtool.git;a=blobdiff_plain;f=src%2Frrd_dump.c;h=40e707bf44f22a8a90472e9f1dc8011136342c54;hp=7ad85b20e6a53e86f43b6a3517a50f69bbef7c64;hb=e33406dce8476be85e5edc8cdc5579bce0f05af0;hpb=3d068765c6b6c8d096e0692f22e5b5e407948b54 diff --git a/src/rrd_dump.c b/src/rrd_dump.c index 7ad85b2..40e707b 100644 --- a/src/rrd_dump.c +++ b/src/rrd_dump.c @@ -1,5 +1,5 @@ /***************************************************************************** - * RRDtool 1.3rc2 Copyright by Tobi Oetiker, 1997-2008 + * RRDtool 1.3.2 Copyright by Tobi Oetiker, 1997-2008 ***************************************************************************** * rrd_dump Display a RRD ***************************************************************************** @@ -43,34 +43,16 @@ *****************************************************************************/ #include "rrd_tool.h" #include "rrd_rpncalc.h" +#include "rrd_client.h" #if !(defined(NETWARE) || defined(WIN32)) extern char *tzname[2]; #endif -int rrd_dump( - int argc, - char **argv) -{ - int rc; - - if (argc < 2) { - rrd_set_error("Not enough arguments"); - return -1; - } - - if (argc == 3) { - rc = rrd_dump_r(argv[1], argv[2]); - } else { - rc = rrd_dump_r(argv[1], NULL); - } - - return rc; -} - -int rrd_dump_r( +static int rrd_dump_opt_r( const char *filename, - char *outname) + char *outname, + int opt_header) { unsigned int i, ii, ix, iii = 0; time_t now; @@ -83,6 +65,7 @@ int rrd_dump_r( rrd_value_t value; struct tm tm; + rrd_init(&rrd); rrd_file = rrd_open(filename, &rrd, RRD_READONLY | RRD_READAHEAD); if (rrd_file == NULL) { rrd_free(&rrd); @@ -98,18 +81,29 @@ int rrd_dump_r( out_file = stdout; } - fputs("", out_file); - fputs - ("", - out_file); - fputs("", out_file); - fputs("", out_file); + if (opt_header == 1) { + fputs("\n", out_file); + fputs + ("\n", + out_file); + fputs("\n", out_file); + fputs("\n", out_file); + } else if (opt_header == 2) { + fputs("\n", out_file); + fputs("\n", out_file); + fputs("\n", out_file); + } else { + fputs("\n", out_file); + fputs("\n", out_file); + } + if (atoi(rrd.stat_head->version) <= 3) { - fprintf(out_file, "\t %s \n", RRD_VERSION3); + fprintf(out_file, "\t%s\n", RRD_VERSION3); } else { - fprintf(out_file, "\t %s \n", RRD_VERSION); + fprintf(out_file, "\t%s\n", RRD_VERSION); } - fprintf(out_file, "\t %lu \n", + fprintf(out_file, "\t%lu \n", rrd.stat_head->pdp_step); #if HAVE_STRFTIME localtime_r(&rrd.live_head->last_up, &tm); @@ -117,26 +111,26 @@ int rrd_dump_r( #else # error "Need strftime" #endif - fprintf(out_file, "\t %lu \n\n", - (unsigned long) rrd.live_head->last_up, somestring); + fprintf(out_file, "\t%lld \n\n", + (long long) rrd.live_head->last_up, somestring); for (i = 0; i < rrd.stat_head->ds_cnt; i++) { fprintf(out_file, "\t\n"); - fprintf(out_file, "\t\t %s \n", rrd.ds_def[i].ds_nam); - fprintf(out_file, "\t\t %s \n", rrd.ds_def[i].dst); + fprintf(out_file, "\t\t%s\n", rrd.ds_def[i].ds_nam); + fprintf(out_file, "\t\t%s\n", rrd.ds_def[i].dst); if (dst_conv(rrd.ds_def[i].dst) != DST_CDEF) { fprintf(out_file, - "\t\t %lu \n", + "\t\t%lu\n", rrd.ds_def[i].par[DS_mrhb_cnt].u_cnt); if (isnan(rrd.ds_def[i].par[DS_min_val].u_val)) { - fprintf(out_file, "\t\t NaN \n"); + fprintf(out_file, "\t\tNaN\n"); } else { - fprintf(out_file, "\t\t %0.10e \n", + fprintf(out_file, "\t\t%0.10e\n", rrd.ds_def[i].par[DS_min_val].u_val); } if (isnan(rrd.ds_def[i].par[DS_max_val].u_val)) { - fprintf(out_file, "\t\t NaN \n"); + fprintf(out_file, "\t\tNaN\n"); } else { - fprintf(out_file, "\t\t %0.10e \n", + fprintf(out_file, "\t\t%0.10e\n", rrd.ds_def[i].par[DS_max_val].u_val); } } else { /* DST_CDEF */ @@ -144,25 +138,25 @@ int rrd_dump_r( rpn_compact2str((rpn_cdefds_t *) &(rrd.ds_def[i].par[DS_cdef]), rrd.ds_def, &str); - fprintf(out_file, "\t\t %s \n", str); + fprintf(out_file, "\t\t%s\n", str); free(str); } fprintf(out_file, "\n\t\t\n"); - fprintf(out_file, "\t\t %s \n", + fprintf(out_file, "\t\t%s\n", rrd.pdp_prep[i].last_ds); if (isnan(rrd.pdp_prep[i].scratch[PDP_val].u_val)) { - fprintf(out_file, "\t\t NaN \n"); + fprintf(out_file, "\t\tNaN\n"); } else { - fprintf(out_file, "\t\t %0.10e \n", + fprintf(out_file, "\t\t%0.10e\n", rrd.pdp_prep[i].scratch[PDP_val].u_val); } - fprintf(out_file, "\t\t %lu \n", + fprintf(out_file, "\t\t%lu\n", rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt); fprintf(out_file, "\t\n\n"); } - fputs("", out_file); + fputs("\n", out_file); rra_base = rrd_file->header_len; rra_next = rra_base; @@ -175,9 +169,9 @@ int rrd_dump_r( rra_next += (rrd.stat_head->ds_cnt * rrd.rra_def[i].row_cnt * sizeof(rrd_value_t)); fprintf(out_file, "\t\n"); - fprintf(out_file, "\t\t %s \n", rrd.rra_def[i].cf_nam); + fprintf(out_file, "\t\t%s\n", rrd.rra_def[i].cf_nam); fprintf(out_file, - "\t\t %lu \n\n", + "\t\t%lu \n\n", rrd.rra_def[i].pdp_cnt, rrd.rra_def[i].pdp_cnt * rrd.stat_head->pdp_step); /* support for RRA parameters */ @@ -185,46 +179,46 @@ int rrd_dump_r( switch (cf_conv(rrd.rra_def[i].cf_nam)) { case CF_HWPREDICT: case CF_MHWPREDICT: - fprintf(out_file, "\t\t %0.10e \n", + fprintf(out_file, "\t\t%0.10e\n", rrd.rra_def[i].par[RRA_hw_alpha].u_val); - fprintf(out_file, "\t\t %0.10e \n", + fprintf(out_file, "\t\t%0.10e\n", rrd.rra_def[i].par[RRA_hw_beta].u_val); fprintf(out_file, - "\t\t %lu \n", + "\t\t%lu\n", rrd.rra_def[i].par[RRA_dependent_rra_idx].u_cnt); break; case CF_SEASONAL: case CF_DEVSEASONAL: fprintf(out_file, - "\t\t %0.10e \n", + "\t\t%0.10e\n", rrd.rra_def[i].par[RRA_seasonal_gamma].u_val); fprintf(out_file, - "\t\t %lu \n", + "\t\t%lu\n", rrd.rra_def[i].par[RRA_seasonal_smooth_idx].u_cnt); if (atoi(rrd.stat_head->version) >= 4) { fprintf(out_file, - "\t\t %0.10e \n", + "\t\t%0.10e\n", rrd.rra_def[i].par[RRA_seasonal_smoothing_window]. u_val); } fprintf(out_file, - "\t\t %lu \n", + "\t\t%lu\n", rrd.rra_def[i].par[RRA_dependent_rra_idx].u_cnt); break; case CF_FAILURES: - fprintf(out_file, "\t\t %0.10e \n", + fprintf(out_file, "\t\t%0.10e\n", rrd.rra_def[i].par[RRA_delta_pos].u_val); - fprintf(out_file, "\t\t %0.10e \n", + fprintf(out_file, "\t\t%0.10e\n", rrd.rra_def[i].par[RRA_delta_neg].u_val); - fprintf(out_file, "\t\t %lu \n", + fprintf(out_file, "\t\t%lu\n", rrd.rra_def[i].par[RRA_window_len].u_cnt); fprintf(out_file, - "\t\t %lu \n", + "\t\t%lu\n", rrd.rra_def[i].par[RRA_failure_threshold].u_cnt); /* fall thru */ case CF_DEVPREDICT: fprintf(out_file, - "\t\t %lu \n", + "\t\t%lu\n", rrd.rra_def[i].par[RRA_dependent_rra_idx].u_cnt); break; case CF_AVERAGE: @@ -232,7 +226,7 @@ int rrd_dump_r( case CF_MINIMUM: case CF_LAST: default: - fprintf(out_file, "\t\t %0.10e \n", + fprintf(out_file, "\t\t%0.10e\n", rrd.rra_def[i].par[RRA_cdp_xff_val].u_val); break; } @@ -251,10 +245,10 @@ int rrd_dump_r( + ii].scratch[CDP_primary_val].u_val; if (isnan(value)) { fprintf(out_file, - "\t\t\t NaN \n"); + "\t\t\tNaN\n"); } else { fprintf(out_file, - "\t\t\t %0.10e \n", + "\t\t\t%0.10e\n", value); } value = @@ -262,10 +256,10 @@ int rrd_dump_r( ii].scratch[CDP_secondary_val].u_val; if (isnan(value)) { fprintf(out_file, - "\t\t\t NaN \n"); + "\t\t\tNaN\n"); } else { fprintf(out_file, - "\t\t\t %0.10e \n", + "\t\t\t%0.10e\n", value); } switch (cf_conv(rrd.rra_def[i].cf_nam)) { @@ -275,29 +269,29 @@ int rrd_dump_r( rrd.cdp_prep[i * rrd.stat_head->ds_cnt + ii].scratch[CDP_hw_intercept].u_val; if (isnan(value)) { - fprintf(out_file, "\t\t\t NaN \n"); + fprintf(out_file, "\t\t\tNaN\n"); } else { fprintf(out_file, - "\t\t\t %0.10e \n", value); + "\t\t\t%0.10e\n", value); } value = rrd.cdp_prep[i * rrd.stat_head->ds_cnt + ii].scratch[CDP_hw_last_intercept].u_val; if (isnan(value)) { fprintf(out_file, - "\t\t\t NaN \n"); + "\t\t\tNaN\n"); } else { fprintf(out_file, - "\t\t\t %0.10e \n", + "\t\t\t%0.10e\n", value); } value = rrd.cdp_prep[i * rrd.stat_head->ds_cnt + ii].scratch[CDP_hw_slope].u_val; if (isnan(value)) { - fprintf(out_file, "\t\t\t NaN \n"); + fprintf(out_file, "\t\t\tNaN\n"); } else { - fprintf(out_file, "\t\t\t %0.10e \n", + fprintf(out_file, "\t\t\t%0.10e\n", value); } value = @@ -305,22 +299,22 @@ int rrd_dump_r( ii].scratch[CDP_hw_last_slope].u_val; if (isnan(value)) { fprintf(out_file, - "\t\t\t NaN \n"); + "\t\t\tNaN\n"); } else { fprintf(out_file, - "\t\t\t %0.10e \n", + "\t\t\t%0.10e\n", value); } ivalue = rrd.cdp_prep[i * rrd.stat_head->ds_cnt + ii].scratch[CDP_null_count].u_cnt; - fprintf(out_file, "\t\t\t %lu \n", + fprintf(out_file, "\t\t\t%lu\n", ivalue); ivalue = rrd.cdp_prep[i * rrd.stat_head->ds_cnt + ii].scratch[CDP_last_null_count].u_cnt; fprintf(out_file, - "\t\t\t %lu \n", + "\t\t\t%lu\n", ivalue); break; case CF_SEASONAL: @@ -329,9 +323,9 @@ int rrd_dump_r( rrd.cdp_prep[i * rrd.stat_head->ds_cnt + ii].scratch[CDP_hw_seasonal].u_val; if (isnan(value)) { - fprintf(out_file, "\t\t\t NaN \n"); + fprintf(out_file, "\t\t\tNaN\n"); } else { - fprintf(out_file, "\t\t\t %0.10e \n", + fprintf(out_file, "\t\t\t%0.10e\n", value); } value = @@ -339,16 +333,16 @@ int rrd_dump_r( ii].scratch[CDP_hw_last_seasonal].u_val; if (isnan(value)) { fprintf(out_file, - "\t\t\t NaN \n"); + "\t\t\tNaN\n"); } else { fprintf(out_file, - "\t\t\t %0.10e \n", + "\t\t\t%0.10e\n", value); } ivalue = rrd.cdp_prep[i * rrd.stat_head->ds_cnt + ii].scratch[CDP_init_seasonal].u_cnt; - fprintf(out_file, "\t\t\t %lu \n", + fprintf(out_file, "\t\t\t%lu\n", ivalue); break; case CF_DEVPREDICT: @@ -381,13 +375,13 @@ int rrd_dump_r( rrd.cdp_prep[i * rrd.stat_head->ds_cnt + ii].scratch[CDP_val].u_val; if (isnan(value)) { - fprintf(out_file, "\t\t\t NaN \n"); + fprintf(out_file, "\t\t\tNaN\n"); } else { - fprintf(out_file, "\t\t\t %0.10e \n", + fprintf(out_file, "\t\t\t%0.10e\n", value); } fprintf(out_file, - "\t\t\t %lu \n", + "\t\t\t%lu\n", rrd.cdp_prep[i * rrd.stat_head->ds_cnt + ii].scratch[CDP_unkn_pdp_cnt].u_cnt); break; @@ -400,7 +394,7 @@ int rrd_dump_r( rrd_seek(rrd_file, (rra_start + (rrd.rra_ptr[i].cur_row + 1) * rrd.stat_head->ds_cnt * sizeof(rrd_value_t)), SEEK_SET); - timer = -(rrd.rra_def[i].row_cnt - 1); + timer = -(long)(rrd.rra_def[i].row_cnt - 1); ii = rrd.rra_ptr[i].cur_row; for (ix = 0; ix < rrd.rra_def[i].row_cnt; ix++) { ii++; @@ -420,14 +414,14 @@ int rrd_dump_r( #else # error "Need strftime" #endif - fprintf(out_file, "\t\t\t ", somestring, - (int) now); + fprintf(out_file, "\t\t\t ", somestring, + (long long) now); for (iii = 0; iii < rrd.stat_head->ds_cnt; iii++) { rrd_read(rrd_file, &my_cdp, sizeof(rrd_value_t) * 1); if (isnan(my_cdp)) { - fprintf(out_file, " NaN "); + fprintf(out_file, "NaN"); } else { - fprintf(out_file, " %0.10e ", my_cdp); + fprintf(out_file, "%0.10e", my_cdp); }; } fprintf(out_file, "\n"); @@ -442,3 +436,97 @@ int rrd_dump_r( } return rrd_close(rrd_file); } + +/* backward compatibility with 1.2.x */ +int rrd_dump_r( + const char *filename, + char *outname) +{ + return rrd_dump_opt_r(filename, outname, 0); +} + +int rrd_dump( + int argc, + char **argv) +{ + int rc; + /** + * 0 = no header + * 1 = dtd header + * 2 = xsd header + */ + int opt_header = 1; + char *opt_daemon = NULL; + + /* init rrd clean */ + + optind = 0; + opterr = 0; /* initialize getopt */ + + while (42) {/* ha ha */ + int opt; + int option_index = 0; + static struct option long_options[] = { + {"daemon", required_argument, 0, 'd'}, + {"header", required_argument, 0, 'h'}, + {"no-header", no_argument, 0, 'n'}, + {0, 0, 0, 0} + }; + + opt = getopt_long(argc, argv, "d:h:n", long_options, &option_index); + + if (opt == EOF) + break; + + switch (opt) { + case 'd': + if (opt_daemon != NULL) + free (opt_daemon); + opt_daemon = strdup (optarg); + if (opt_daemon == NULL) + { + rrd_set_error ("strdup failed."); + return (-1); + } + break; + + case 'n': + opt_header = 0; + break; + + case 'h': + if (strcmp(optarg, "dtd") == 0) { + opt_header = 1; + } else if (strcmp(optarg, "xsd") == 0) { + opt_header = 2; + } else if (strcmp(optarg, "none") == 0) { + opt_header = 0; + } + break; + + default: + rrd_set_error("usage rrdtool %s [--header|-h {none,xsd,dtd}] [--no-header]" + "file.rrd [file.xml]", argv[0]); + return (-1); + break; + } + } /* while (42) */ + + if ((argc - optind) < 1 || (argc - optind) > 2) { + rrd_set_error("usage rrdtool %s [--header|-h {none,xsd,dtd}] [--no-header]" + "file.rrd [file.xml]", argv[0]); + return (-1); + } + + rc = rrdc_flush_if_daemon(opt_daemon, argv[optind]); + if (opt_daemon) free(opt_daemon); + if (rc) return (rc); + + if ((argc - optind) == 2) { + rc = rrd_dump_opt_r(argv[optind], argv[optind + 1], opt_header); + } else { + rc = rrd_dump_opt_r(argv[optind], NULL, opt_header); + } + + return rc; +}