src/rrd_info.c

   1 /*****************************************************************************
   2  * RRDtool 1.0.33  Copyright Tobias Oetiker, 1997 - 2000
   3  *****************************************************************************
   4  * rrd_info  Get Information about the configuration of an RRD
   5  *****************************************************************************/
   6
   7 #include "rrd_tool.h"
   8 #include <stdarg.h>
   9
  10 /* proto */
  11 static char * sprintf_alloc(char *, ...);
  12 static info_t *push(info_t *, char *, enum info_type, infoval);
  13 info_t *rrd_info(int, char **);
  14
  15 /* allocate memory for string */
  16 static char *
  17 sprintf_alloc(char *fmt, ...) {
  18 #ifdef HAVE_VSNPRINTF
  19     int maxlen = 50;
  20 #else
  21     int maxlen = 1000;
  22 #endif
  23     char *str = NULL;
  24     va_list argp;
  25     str = malloc(sizeof(char)*(strlen(fmt)+maxlen));
  26     if (str != NULL) {
  27         va_start(argp, fmt);
  28 #ifdef HAVE_VSNPRINTF
  29         vsnprintf(str, maxlen-1, fmt, argp);
  30 #else
  31         vsprintf(str, fmt, argp);
  32 #endif
  33     }
  34     va_end(argp);
  35     return str;
  36 }
  37
  38 static info_t
  39 *push(info_t *info, char *key, enum info_type type, infoval value){
  40     info_t *next;
  41     next = malloc(sizeof(*next));
  42     next->next = (info_t *) 0;
  43     if( info )
  44         info->next = next;
  45     next->type = type;
  46     next->key  = key;
  47     switch (type) {
  48     case RD_I_VAL:
  49         next->value.u_val = value.u_val;
  50         break;
  51     case RD_I_CNT:
  52         next->value.u_cnt = value.u_cnt;
  53         break;
  54     case RD_I_STR:
  55         next->value.u_str = malloc(sizeof(char)*(strlen(value.u_str)+1));
  56         strcpy(next->value.u_str,value.u_str);
  57         break;
  58     }
  59     return(next);
  60 }
  61
  62
  63 info_t *
  64 rrd_info(int argc, char **argv) {
  65     int          i,ii=0;
  66     FILE         *in_file;
  67     rrd_t        rrd;
  68     info_t       *data,*cd;
  69     infoval      info;
  70         enum cf_en   current_cf;
  71
  72     if(rrd_open(argv[1],&in_file,&rrd, RRD_READONLY)==-1){
  73         return(NULL);
  74     }
  75     fclose(in_file);
  76
  77     info.u_str=argv[1];
  78     cd=push(NULL,sprintf_alloc("filename"),    RD_I_STR, info);
  79     data=cd;
  80
  81     info.u_str=rrd.stat_head->version;
  82     cd=push(cd,sprintf_alloc("rrd_version"),    RD_I_STR, info);
  83
  84     info.u_cnt=rrd.stat_head->pdp_step;
  85     cd=push(cd,sprintf_alloc("step"),       RD_I_CNT, info);
  86
  87     info.u_cnt=rrd.live_head->last_up;
  88     cd=push(cd,sprintf_alloc("last_update"), RD_I_CNT, info);
  89
  90     for(i=0;i<rrd.stat_head->ds_cnt;i++){
  91
  92         info.u_str=rrd.ds_def[i].dst;
  93         cd=push(cd,sprintf_alloc("ds[%s].type",             rrd.ds_def[i].ds_nam), RD_I_STR, info);
  94
  95         info.u_cnt=rrd.ds_def[i].par[DS_mrhb_cnt].u_cnt;
  96         cd=push(cd,sprintf_alloc("ds[%s].minimal_heartbeat",rrd.ds_def[i].ds_nam), RD_I_CNT, info);
  97
  98         info.u_val=rrd.ds_def[i].par[DS_min_val].u_val;
  99         cd=push(cd,sprintf_alloc("ds[%s].min",              rrd.ds_def[i].ds_nam), RD_I_VAL, info);
 100
 101         info.u_val=rrd.ds_def[i].par[DS_max_val].u_val;
 102         cd=push(cd,sprintf_alloc("ds[%s].max",              rrd.ds_def[i].ds_nam), RD_I_VAL, info);
 103
 104         info.u_str=rrd.pdp_prep[i].last_ds;
 105         cd=push(cd,sprintf_alloc("ds[%s].last_ds",          rrd.ds_def[i].ds_nam), RD_I_STR, info);
 106
 107         info.u_val=rrd.pdp_prep[i].scratch[PDP_val].u_val;
 108         cd=push(cd,sprintf_alloc("ds[%s].value",            rrd.ds_def[i].ds_nam), RD_I_VAL, info);
 109
 110         info.u_cnt=rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt;
 111         cd=push(cd,sprintf_alloc("ds[%s].unknown_sec",      rrd.ds_def[i].ds_nam), RD_I_CNT, info);
 112     }
 113
 114     for(i=0;i<rrd.stat_head->rra_cnt;i++){
 115         info.u_str=rrd.rra_def[i].cf_nam;
 116         cd=push(cd,sprintf_alloc("rra[%d].cf",         i),  RD_I_STR,   info);
 117         current_cf = cf_conv(rrd.rra_def[i].cf_nam);
 118
 119         info.u_cnt=rrd.rra_def[i].row_cnt;
 120         cd=push(cd,sprintf_alloc("rra[%d].rows",i),  RD_I_CNT,   info);
 121
 122         info.u_cnt=rrd.rra_def[i].pdp_cnt;
 123         cd=push(cd,sprintf_alloc("rra[%d].pdp_per_row",i),  RD_I_CNT,   info);
 124
 125         switch(current_cf)
 126         {
 127            case CF_HWPREDICT:
 128                   info.u_val=rrd.rra_def[i].par[RRA_hw_alpha].u_val;
 129                   cd=push(cd,sprintf_alloc("rra[%d].alpha",i),RD_I_VAL,info);
 130                   info.u_val=rrd.rra_def[i].par[RRA_hw_beta].u_val;
 131                   cd=push(cd,sprintf_alloc("rra[%d].beta",i),RD_I_VAL,info);
 132                   break;
 133            case CF_SEASONAL:
 134            case CF_DEVSEASONAL:
 135                   info.u_val=rrd.rra_def[i].par[RRA_seasonal_gamma].u_val;
 136                   cd=push(cd,sprintf_alloc("rra[%d].gamma",i),RD_I_VAL,info);
 137                   break;
 138            case CF_FAILURES:
 139                   info.u_val=rrd.rra_def[i].par[RRA_delta_pos].u_val;
 140                   cd=push(cd,sprintf_alloc("rra[%d].delta_pos",i),RD_I_VAL,info);
 141                   info.u_val=rrd.rra_def[i].par[RRA_delta_neg].u_val;
 142                   cd=push(cd,sprintf_alloc("rra[%d].delta_neg",i),RD_I_VAL,info);
 143                   info.u_cnt=rrd.rra_def[i].par[RRA_failure_threshold].u_cnt;
 144                   cd=push(cd,sprintf_alloc("rra[%d].failure_threshold",i),RD_I_CNT,info);
 145                   info.u_cnt=rrd.rra_def[i].par[RRA_window_len].u_cnt;
 146                   cd=push(cd,sprintf_alloc("rra[%d].window_length",i),RD_I_CNT,info);
 147                   break;
 148            case CF_DEVPREDICT:
 149                   break;
 150            default:
 151                   info.u_val=rrd.rra_def[i].par[RRA_cdp_xff_val].u_val;
 152                   cd=push(cd,sprintf_alloc("rra[%d].xff",i),RD_I_VAL,info);
 153                   break;
 154         }
 155
 156         for(ii=0;ii<rrd.stat_head->ds_cnt;ii++){
 157             info.u_val=rrd.cdp_prep[i*rrd.stat_head->ds_cnt+ii].scratch[CDP_val].u_val;
 158             cd=push(cd,sprintf_alloc("rra[%d].cdp_prep[%d].value",i,ii), RD_I_VAL, info);
 159         switch(current_cf)
 160                 {
 161                 case CF_HWPREDICT:
 162             info.u_val=rrd.cdp_prep[i*rrd.stat_head->ds_cnt+ii].scratch[CDP_hw_intercept].u_val;
 163             cd=push(cd,sprintf_alloc("rra[%d].cdp_prep[%d].intercept",i,ii), RD_I_VAL, info);
 164             info.u_val=rrd.cdp_prep[i*rrd.stat_head->ds_cnt+ii].scratch[CDP_hw_slope].u_val;
 165             cd=push(cd,sprintf_alloc("rra[%d].cdp_prep[%d].slope",i,ii), RD_I_VAL, info);
 166             info.u_cnt=rrd.cdp_prep[i*rrd.stat_head->ds_cnt+ii].scratch[CDP_null_count].u_cnt;
 167             cd=push(cd,sprintf_alloc("rra[%d].cdp_prep[%d].NaN_count",i,ii), RD_I_CNT, info);
 168                    break;
 169                 case CF_SEASONAL:
 170             info.u_val=rrd.cdp_prep[i*rrd.stat_head->ds_cnt+ii].scratch[CDP_hw_seasonal].u_val;
 171             cd=push(cd,sprintf_alloc("rra[%d].cdp_prep[%d].seasonal",i,ii), RD_I_VAL, info);
 172                    break;
 173                 case CF_DEVSEASONAL:
 174             info.u_val=rrd.cdp_prep[i*rrd.stat_head->ds_cnt+ii].scratch[CDP_seasonal_deviation].u_val;
 175             cd=push(cd,sprintf_alloc("rra[%d].cdp_prep[%d].deviation",i,ii), RD_I_VAL, info);
 176                    break;
 177                 case CF_DEVPREDICT:
 178                 case CF_FAILURES:
 179                    break;
 180                 default:
 181             info.u_cnt=rrd.cdp_prep[i*rrd.stat_head->ds_cnt+ii].scratch[CDP_unkn_pdp_cnt].u_cnt;
 182             cd=push(cd,sprintf_alloc("rra[%d].cdp_prep[%d].unknown_datapoints",i,ii), RD_I_CNT, info);
 183                    break;
 184         }
 185     }
 186         }
 187         rrd_free(&rrd);
 188     return(data);
 189
 190 }