X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Frrd_first.c;h=0bd3f459ab9d7ac22945c1f2a1e13e5abf17f00f;hb=3b98cbd3871a5f445c56c14f73805a14ea31dd7a;hp=86175102db69676e9ab64b816dad54b8ccc00092;hpb=9e6db622e8756105c1322481b34650ecbe15da1a;p=rrdtool.git

diff --git a/src/rrd_first.c b/src/rrd_first.c
index 8617510..0bd3f45 100644
--- a/src/rrd_first.c
+++ b/src/rrd_first.c
@@ -1,5 +1,5 @@
 /*****************************************************************************
- * RRDtool 1.2.14  Copyright by Tobi Oetiker, 1997-2006
+ * RRDtool 1.2.23  Copyright by Tobi Oetiker, 1997-2007
  *****************************************************************************
  * rrd_first Return
  *****************************************************************************
@@ -9,90 +9,91 @@
 #include "rrd_tool.h"
 
 
-time_t
-rrd_first(int argc, char **argv)
+time_t rrd_first(
+    int argc,
+    char **argv)
 {
-    int target_rraindex=0;
-    char *endptr;
-    optind = 0; opterr = 0;  /* initialize getopt */
+    int       target_rraindex = 0;
+    char     *endptr;
 
-    while (1){
-        static struct option long_options[] =
-        {
+    optind = 0;
+    opterr = 0;         /* initialize getopt */
+
+    while (1) {
+        static struct option long_options[] = {
             {"rraindex", required_argument, 0, 129},
-            {0,0,0,0}
+            {0, 0, 0, 0}
         };
-        int option_index = 0;
-        int opt;
+        int       option_index = 0;
+        int       opt;
+
         opt = getopt_long(argc, argv, "", long_options, &option_index);
 
-        if(opt == EOF)
+        if (opt == EOF)
             break;
 
-        switch(opt) {
-          case 129:
-            target_rraindex=strtol(optarg,&endptr,0);
-            if(target_rraindex < 0) {
+        switch (opt) {
+        case 129:
+            target_rraindex = strtol(optarg, &endptr, 0);
+            if (target_rraindex < 0) {
                 rrd_set_error("invalid rraindex number");
-                return(-1);
+                return (-1);
             }
             break;
-          default:
-            rrd_set_error("usage rrdtool %s [--rraindex number] file.rrd", argv[0]);
-            return(-1);
+        default:
+            rrd_set_error("usage rrdtool %s [--rraindex number] file.rrd",
+                          argv[0]);
+            return (-1);
         }
     }
 
-    if(optind >= argc){
+    if (optind >= argc) {
         rrd_set_error("not enough arguments");
-        return -1;       
-    }     
+        return -1;
+    }
 
-    return(rrd_first_r(argv[optind], target_rraindex));
+    return (rrd_first_r(argv[optind], target_rraindex));
 }
 
 
-time_t
-rrd_first_r(const char *filename, const int rraindex)
+time_t rrd_first_r(
+    const char *filename,
+    const int rraindex)
 {
-    long rra_start,
-         timer;
-    time_t then;
-    FILE *in_file;
-    rrd_t rrd;
+    off_t     rra_start, timer;
+    time_t    then;
+    rrd_t     rrd;
+    rrd_file_t *rrd_file;
 
-    if(rrd_open(filename,&in_file,&rrd, RRD_READONLY)==-1){
+    rrd_file = rrd_open(filename, &rrd, RRD_READONLY);
+    if (rrd_file == NULL) {
         rrd_set_error("could not open RRD");
-        return(-1);
+        return (-1);
     }
 
-    if((rraindex < 0) || (rraindex >= (int)rrd.stat_head->rra_cnt)) {
+    if ((rraindex < 0) || (rraindex >= (int) rrd.stat_head->rra_cnt)) {
         rrd_set_error("invalid rraindex number");
-        return(-1);
+        rrd_free(&rrd);
+        close(rrd_file->fd);
+        return (-1);
     }
 
-    rra_start = ftell(in_file);    
-    fseek(in_file,
-          (rra_start +
-           (rrd.rra_ptr[rraindex].cur_row+1) *
-           rrd.stat_head->ds_cnt *
-           sizeof(rrd_value_t)),
-          SEEK_SET);
-    timer = - (rrd.rra_def[rraindex].row_cnt-1);
+    rra_start = rrd_file->header_len;
+    rrd_seek(rrd_file,
+             (rra_start +
+              (rrd.rra_ptr[rraindex].cur_row + 1) *
+              rrd.stat_head->ds_cnt * sizeof(rrd_value_t)), SEEK_SET);
+    timer = -(rrd.rra_def[rraindex].row_cnt - 1);
     if (rrd.rra_ptr[rraindex].cur_row + 1 > rrd.rra_def[rraindex].row_cnt) {
-      fseek(in_file,rra_start,SEEK_SET);
+        rrd_seek(rrd_file, rra_start, SEEK_SET);
     }
     then = (rrd.live_head->last_up -
             rrd.live_head->last_up %
-            (rrd.rra_def[rraindex].pdp_cnt*rrd.stat_head->pdp_step)) +
-           (timer * 
-            rrd.rra_def[rraindex].pdp_cnt*rrd.stat_head->pdp_step);
+            (rrd.rra_def[rraindex].pdp_cnt * rrd.stat_head->pdp_step)) +
+        (timer * rrd.rra_def[rraindex].pdp_cnt * rrd.stat_head->pdp_step);
 
     rrd_free(&rrd);
-    fclose(in_file);
-    return(then);
+    close(rrd_file->fd);
+    rrd_close(rrd_file);
+    return (then);
 }
-
-
-
-