Rather than calling "FLUSH" for each RRD file needed for drawing a

graph and then accessing the file directly, use the "FLUSH" command to
receive the data required for drawing a graph.

The daemon can now be specified in one of three ways:

  * A new option has been added to the "DEF" option. If the "DEF" command
    includes the option "daemon=...", then the given daemon is used for
    accessing that file only. This option takes precedence over all
    other options. The value given follows the same syntax as other ways
    to specify a daemon address, thouh colons need to be escaped from
    rrdgraph(1).

    Example:
      'DEF:v1=path/to/example.rrd:value:AVERAGE:daemon=collect1.octo.cx'

  * The "--daemon" option can be given to the overall "rrdtool graph"
    command. When given, this address is used for all file accesses
    except those which explicitely contain a "daemon=..." option.

  * If the "RRDCACHED_ADDRESS" environment variable is set, it's value
    is used as the daemon address. This is the lowest priority option
    and only used if no other option is given.

One nice detail is that with ":daemon=...", the cache address can be
specified for each "DEF:" definition. It is therefore possible to graph
values stored on several servers in one graph ? even if several RRD
files have the same name. -- Florian

git-svn-id: svn://svn.oetiker.ch/rrdtool/trunk@2062 a5681a0c-68f1-0310-ab6d-d61299d08faa

diff --git a/program/NEWS b/program/NEWS
index 6d889f86fbc42cd64f7176b9eaac59c2cd6511f7..af022721ac2ded96c740168f75f51a5459cb7fb7 100644 (file)
--- a/program/NEWS
+++ b/program/NEWS
@@ -10,6 +10,14 @@ RRD Graph
   create a gradient from one color to the next
   by Rian Shelley
 
+* RRDcached awareness. Instead of just flushing the file, data can now
+  be pulled in from remote RRDcached instances.
+
+RRDcached
+----------
+* New FETCH command allowing rrd_fetch to operate through the daemon and
+  thus work remotely. By Florian Forster
+
 
 
 

diff --git a/program/doc/rrdgraph_data.pod b/program/doc/rrdgraph_data.pod
index d5ceddbfb68ffa6ed1d658bd14f995818c74b610..57b9d0a70da66212ae590d37018d40f1241c066d 100644 (file)
--- a/program/doc/rrdgraph_data.pod
+++ b/program/doc/rrdgraph_data.pod
@@ -4,7 +4,7 @@ rrdgraph_data - preparing data for graphing in rrdtool graph
 
 =head1 SYNOPSIS
 
-B<DEF:>I<E<lt>vnameE<gt>>=I<E<lt>rrdfileE<gt>>:I<E<lt>ds-nameE<gt>>:I<E<lt>CFE<gt>>[:step=I<E<lt>stepE<gt>>][:start=I<E<lt>timeE<gt>>][:end=I<E<lt>timeE<gt>>][:reduce=I<E<lt>B<CF>E<gt>>]
+B<DEF:>I<E<lt>vnameE<gt>>=I<E<lt>rrdfileE<gt>>:I<E<lt>ds-nameE<gt>>:I<E<lt>CFE<gt>>[:step=I<E<lt>stepE<gt>>][:start=I<E<lt>timeE<gt>>][:end=I<E<lt>timeE<gt>>][:reduce=I<E<lt>B<CF>E<gt>>][:daemon=I<E<lt>addressE<gt>>]
 
 B<VDEF>:I<vname>=I<RPN expression>
 
@@ -28,7 +28,7 @@ mixed case names for variables since operators will always be in uppercase.
 
 =head1 DEF
 
-B<DEF:>I<E<lt>vnameE<gt>>=I<E<lt>rrdfileE<gt>>:I<E<lt>ds-nameE<gt>>:I<E<lt>CFE<gt>>[:step=I<E<lt>stepE<gt>>][:start=I<E<lt>timeE<gt>>][:end=I<E<lt>timeE<gt>>][:reduce=I<E<lt>B<CF>E<gt>>]
+B<DEF:>I<E<lt>vnameE<gt>>=I<E<lt>rrdfileE<gt>>:I<E<lt>ds-nameE<gt>>:I<E<lt>CFE<gt>>[:step=I<E<lt>stepE<gt>>][:start=I<E<lt>timeE<gt>>][:end=I<E<lt>timeE<gt>>][:reduce=I<E<lt>B<CF>E<gt>>][:daemon=I<E<lt>addressE<gt>>]
 
 This command fetches data from an B<RRD> file.  The virtual name
 I<vname> can then be used throughout the rest of the script. By
@@ -54,12 +54,20 @@ B<DEF> itself will be used to reduce the data density. This behavior can
 be changed using C<:reduce=I<E<lt>B<CF>E<gt>>>.  This optional parameter
 specifies the B<CF> to use during the data reduction phase.
 
+It is possible to request single data sources from a specific I<RRDCacheD>, see
+L<rrdcached(1)>, using the C<:daemon=I<E<lt>addressE<gt>>> parameter. The
+value given to this parameter follows the same syntax as other means to specify
+the address of the caching daemon. It is described in detail in the
+L<rrdcached(1)> manual page. Beware, however, that colons (in IPv6 addresses
+and as a port separator, for example) need to be escaped using a backslash.
+
 Example:
 
         DEF:ds0=router.rrd:ds0:AVERAGE
         DEF:ds0weekly=router.rrd:ds0:AVERAGE:step=7200
         DEF:ds0weekly=router.rrd:ds0:AVERAGE:start=end-1h
         DEF:ds0weekly=router.rrd:ds0:AVERAGE:start=11\:00:end=start+1h
+        DEF:ds0weekly=router.rrd:ds0:AVERAGE:daemon=collect1.example.com
 
 =head1 VDEF
 

diff --git a/program/src/rrd_graph.c b/program/src/rrd_graph.c
index 5dd332861bfe5074f394f22481ea10ee0c6765b0..f5a63c320f105643b1a91f9526a9d21be5e38b4c 100644 (file)
--- a/program/src/rrd_graph.c
+++ b/program/src/rrd_graph.c
@@ -846,46 +846,48 @@ int data_fetch(
         }
         if (!skip) {
             unsigned long ft_step = im->gdes[i].step;   /* ft_step will record what we got from fetch */
+            const char *daemon;
+            int status;
 
-            /* Flush the file if
-             * - a connection to the daemon has been established
-             * - this is the first occurrence of that RRD file
-             */
-            if (rrdc_is_connected(im->daemon_addr))
+            if (im->gdes[i].daemon[0] != 0)
+                daemon = im->gdes[i].daemon;
+            else
+                daemon = im->daemon_addr;
+
+            /* "daemon" may be NULL. ENV_RRDCACHED_ADDRESS is evaluated in that
+             * case. If "daemon" holds the same value as in the previous
+             * iteration, no actual new connection is established - the
+             * existing connection is re-used. */
+            rrdc_connect (daemon);
+
+            /* If connecting was successfull, use the daemon to query the data.
+             * If there is no connection, for example because no daemon address
+             * was specified, (try to) use the local file directly. */
+            if (rrdc_is_connected (daemon))
             {
-                int status;
-
-                status = 0;
-                for (ii = 0; ii < i; ii++)
-                {
-                    if (strcmp (im->gdes[i].rrd, im->gdes[ii].rrd) == 0)
-                    {
-                        status = 1;
-                        break;
-                    }
-                }
-
-                if (status == 0)
-                {
-                    status = rrdc_flush (im->gdes[i].rrd);
-                    if (status != 0)
-                    {
-                        rrd_set_error ("rrdc_flush (%s) failed with status %i.",
-                                im->gdes[i].rrd, status);
-                        return (-1);
-                    }
+                status = rrdc_fetch (im->gdes[i].rrd,
+                        cf_to_string (im->gdes[i].cf),
+                        &im->gdes[i].start,
+                        &im->gdes[i].end,
+                        &ft_step,
+                        &im->gdes[i].ds_cnt,
+                        &im->gdes[i].ds_namv,
+                        &im->gdes[i].data);
+                if (status != 0)
+                    return (status);
+            }
+            else
+            {
+                if ((rrd_fetch_fn(im->gdes[i].rrd,
+                                im->gdes[i].cf,
+                                &im->gdes[i].start,
+                                &im->gdes[i].end,
+                                &ft_step,
+                                &im->gdes[i].ds_cnt,
+                                &im->gdes[i].ds_namv,
+                                &im->gdes[i].data)) == -1) {
+                    return -1;
                 }
-            } /* if (rrdc_is_connected()) */
-
-            if ((rrd_fetch_fn(im->gdes[i].rrd,
-                              im->gdes[i].cf,
-                              &im->gdes[i].start,
-                              &im->gdes[i].end,
-                              &ft_step,
-                              &im->gdes[i].ds_cnt,
-                              &im->gdes[i].ds_namv,
-                              &im->gdes[i].data)) == -1) {
-                return -1;
             }
             im->gdes[i].data_first = 1;
 
@@ -3853,6 +3855,7 @@ int gdes_alloc(
     im->gdes[im->gdes_c - 1].cf = CF_AVERAGE;
     im->gdes[im->gdes_c - 1].yrule = DNAN;
     im->gdes[im->gdes_c - 1].xrule = 0;
+    im->gdes[im->gdes_c - 1].daemon[0] = 0;
     return 0;
 }
 
@@ -4690,11 +4693,6 @@ void rrd_graph_options(
         }
     } /* while (1) */
 
-    {   /* try to connect to rrdcached */
-        int status = rrdc_connect(im->daemon_addr);
-        if (status != 0) return;
-    }
-
     pango_cairo_context_set_font_options(pango_layout_get_context(im->layout), im->font_options);
     pango_layout_context_changed(im->layout);
 

diff --git a/program/src/rrd_graph.h b/program/src/rrd_graph.h
index 6058a4f54e0e6908e0f03028db2e332041169b8f..fa0915289c7df6ec1422f230f786d36e176b9320 100644 (file)
--- a/program/src/rrd_graph.h
+++ b/program/src/rrd_graph.h
@@ -158,6 +158,7 @@ typedef struct graph_desc_t {
     char      rrd[1024];    /* name of the rrd_file containing data */
     char      ds_nam[DS_NAM_SIZE];  /* data source name */
     long      ds;       /* data source number */
+    char      daemon[256];
     enum cf_en cf;      /* consolidation function */
     enum cf_en cf_reduce;   /* consolidation function for reduce_data() */
     struct gfx_color_t col, col2; /* graph color */

diff --git a/program/src/rrd_graph_helper.c b/program/src/rrd_graph_helper.c
index 5c604877df8c69b21a6e872860d77afb8950927a..25943a272cc385a63677e9432842fe1bf0f03f88 100644 (file)
--- a/program/src/rrd_graph_helper.c
+++ b/program/src/rrd_graph_helper.c
@@ -1003,6 +1003,11 @@ int rrd_parse_def(
                 return 1;
             }
             dprintf("- done parsing:  '%s'\n", &line[*eaten]);
+        } else if (!strcmp("daemon", command)) {
+            i = scan_for_col(&line[*eaten],
+                    sizeof (gdp->daemon), gdp->daemon);
+            (*eaten) += i;
+            dprintf("- using daemon '%s'\n", gdp->daemon);
         } else {
             rrd_set_error("Parse error in '%s'", line);
             return 1;