src/rrd_dump.c

   1 /*****************************************************************************
   2  * RRDtool 1.0.33  Copyright Tobias Oetiker, 1997 - 2000
   3  *****************************************************************************
   4  * rrd_dump  Display a RRD
   5  *****************************************************************************
   6  * $Id$
   7  * $Log$
   8  * Revision 1.2  2001/03/04 13:01:55  oetiker
   9  * Aberrant Behavior Detection support. A brief overview added to rrdtool.pod.
  10  * Major updates to rrd_update.c, rrd_create.c. Minor update to other core files.
  11  * This is backwards compatible! But new files using the Aberrant stuff are not readable
  12  * by old rrdtool versions. See http://cricket.sourceforge.net/aberrant/rrd_hw.htm
  13  * -- Jake Brutlag <jakeb@corp.webtv.net>
  14  *
  15  * Revision 1.1.1.1  2001/02/25 22:25:05  oetiker
  16  * checkin
  17  *
  18  *****************************************************************************/
  19
  20 #include "rrd_tool.h"
  21
  22 extern char *tzname[2];
  23
  24 int
  25 rrd_dump(int argc, char **argv)
  26 {
  27     int          i,ii,ix,iii=0;
  28     time_t       now;
  29     char         somestring[255];
  30     rrd_value_t  my_cdp;
  31     long         rra_base, rra_start, rra_next;
  32     FILE                  *in_file;
  33     rrd_t             rrd;
  34     unival value;
  35
  36     if(rrd_open(argv[1],&in_file,&rrd, RRD_READONLY)==-1){
  37         return(-1);
  38     }
  39
  40     puts("<!-- Round Robin Database Dump -->");
  41     puts("<rrd>");
  42     printf("\t<version> %s </version>\n",RRD_VERSION);
  43     printf("\t<step> %lu </step> <!-- Seconds -->\n",rrd.stat_head->pdp_step);
  44 #if HAVE_STRFTIME
  45     strftime(somestring,200,"%Y-%m-%d %H:%M:%S %Z",
  46              localtime(&rrd.live_head->last_up));
  47 #else
  48 # error "Need strftime"
  49 #endif
  50     printf("\t<lastupdate> %ld </lastupdate> <!-- %s -->\n\n",
  51            rrd.live_head->last_up,somestring);
  52     for(i=0;i<rrd.stat_head->ds_cnt;i++){
  53         printf("\t<ds>\n");
  54         printf("\t\t<name> %s </name>\n",rrd.ds_def[i].ds_nam);
  55         printf("\t\t<type> %s </type>\n",rrd.ds_def[i].dst);
  56         printf("\t\t<minimal_heartbeat> %lu </minimal_heartbeat>\n",rrd.ds_def[i].par[DS_mrhb_cnt].u_cnt);
  57         if (isnan(rrd.ds_def[i].par[DS_min_val].u_val)){
  58           printf("\t\t<min> NaN </min>\n");
  59         } else {
  60           printf("\t\t<min> %0.10e </min>\n",rrd.ds_def[i].par[DS_min_val].u_val);
  61         }
  62         if (isnan(rrd.ds_def[i].par[DS_max_val].u_val)){
  63           printf("\t\t<max> NaN </max>\n");
  64         } else {
  65           printf("\t\t<max> %0.10e </max>\n",rrd.ds_def[i].par[DS_max_val].u_val);
  66         }
  67         printf("\n\t\t<!-- PDP Status -->\n");
  68         printf("\t\t<last_ds> %s </last_ds>\n",rrd.pdp_prep[i].last_ds);
  69         if (isnan(rrd.pdp_prep[i].scratch[PDP_val].u_val)){
  70           printf("\t\t<value> NaN </value>\n");
  71         } else {
  72           printf("\t\t<value> %0.10e </value>\n",rrd.pdp_prep[i].scratch[PDP_val].u_val);
  73         }
  74         printf("\t\t<unknown_sec> %lu </unknown_sec>\n",
  75                rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt);
  76
  77         printf("\t</ds>\n\n");
  78     }
  79
  80     puts("<!-- Round Robin Archives -->");
  81
  82     rra_base=ftell(in_file);
  83     rra_next = rra_base;
  84
  85     for(i=0;i<rrd.stat_head->rra_cnt;i++){
  86
  87         long timer=0;
  88         rra_start= rra_next;
  89         rra_next +=  ( rrd.stat_head->ds_cnt
  90                       * rrd.rra_def[i].row_cnt
  91                       * sizeof(rrd_value_t));
  92         printf("\t<rra>\n");
  93         printf("\t\t<cf> %s </cf>\n",rrd.rra_def[i].cf_nam);
  94         printf("\t\t<pdp_per_row> %lu </pdp_per_row> <!-- %lu seconds -->\n\n",
  95                rrd.rra_def[i].pdp_cnt, rrd.rra_def[i].pdp_cnt
  96                *rrd.stat_head->pdp_step);
  97         /* added support for RRA parameters */
  98         printf("\t\t<params>");
  99         for (ii = 0; ii < MAX_RRA_PAR_EN; ii++)
 100         {
 101            value = rrd.rra_def[i].par[ii];
 102            if (ii == RRA_dependent_rra_idx ||
 103                    ii == RRA_seasonal_smooth_idx ||
 104                    ii == RRA_failure_threshold)
 105                   printf("<value> %lu </value>", value.u_cnt);
 106            else {
 107                   if (isnan(value.u_val)) {
 108                       printf("<value> NaN </value>");
 109                   } else {
 110                       printf("<value> %0.10e </value>", value.u_val);
 111                   }
 112            }
 113         }
 114         printf("\t\t</params>\n");
 115         printf("\t\t<cdp_prep>\n");
 116         for(ii=0;ii<rrd.stat_head->ds_cnt;ii++){
 117 #if 0
 118                 double value = rrd.cdp_prep[i*rrd.stat_head->ds_cnt+ii].scratch[CDP_val].u_val;
 119 #endif
 120                 printf("\t\t\t<ds>");
 121                 /* added support for exporting all CDP parameters */
 122                 for (iii=0; iii < MAX_CDP_PAR_EN ; iii++)
 123                 {
 124                    value = rrd.cdp_prep[i*rrd.stat_head->ds_cnt + ii].scratch[iii];
 125            /* handle integer values as a special case */
 126                    if (cf_conv(rrd.rra_def[i].cf_nam) == CF_FAILURES ||
 127                            iii == CDP_unkn_pdp_cnt ||
 128                        iii == CDP_null_count ||
 129                        iii == CDP_last_null_count)
 130                      printf("<value> %lu </value>", value.u_cnt);
 131                    else {
 132                      if (isnan(value.u_val)) {
 133                        printf("<value> NaN </value>");
 134                      } else {
 135                        printf("<value> %0.10e </value>", value.u_val);
 136                      }
 137                    }
 138                 }
 139 #if 0
 140                 printf("  <unknown_datapoints> %lu </unknown_datapoints>",
 141                        rrd.cdp_prep[i*rrd.stat_head->ds_cnt+ii].scratch[CDP_unkn_pdp_cnt].u_cnt);
 142 #endif
 143         printf("</ds>\n");
 144         }
 145         printf("\t\t</cdp_prep>\n");
 146
 147         printf("\t\t<database>\n");
 148         fseek(in_file,(rra_start
 149                        +(rrd.rra_ptr[i].cur_row+1)
 150                        * rrd.stat_head->ds_cnt
 151                        * sizeof(rrd_value_t)),SEEK_SET);
 152         timer = - (rrd.rra_def[i].row_cnt-1);
 153         ii=rrd.rra_ptr[i].cur_row;
 154         for(ix=0;ix<rrd.rra_def[i].row_cnt;ix++){
 155             ii++;
 156             if (ii>=rrd.rra_def[i].row_cnt) {
 157                 fseek(in_file,rra_start,SEEK_SET);
 158                 ii=0; /* wrap if max row cnt is reached */
 159             }
 160             now = (rrd.live_head->last_up
 161                    - rrd.live_head->last_up
 162                    % (rrd.rra_def[i].pdp_cnt*rrd.stat_head->pdp_step))
 163                 + (timer*rrd.rra_def[i].pdp_cnt*rrd.stat_head->pdp_step);
 164
 165             timer++;
 166 #if HAVE_STRFTIME
 167             strftime(somestring,200,"%Y-%m-%d %H:%M:%S %Z", localtime(&now));
 168 #else
 169 # error "Need strftime"
 170 #endif
 171             printf("\t\t\t<!-- %s / %d --> <row>",somestring,(int)now);
 172             for(iii=0;iii<rrd.stat_head->ds_cnt;iii++){
 173                 fread(&my_cdp,sizeof(rrd_value_t),1,in_file);
 174                 if (isnan(my_cdp)){
 175                   printf("<v> NaN </v>");
 176                 } else {
 177                   printf("<v> %0.10e </v>",my_cdp);
 178                 };
 179             }
 180             printf("</row>\n");
 181         }
 182         printf("\t\t</database>\n\t</rra>\n");
 183
 184     }
 185     printf("</rrd>\n");
 186     rrd_free(&rrd);
 187     fclose(in_file);
 188     return(0);
 189 }
 190
 191
 192
 193