Code

d50e6081059cc14bed4d0b0e36ed8015188f886a
[rrdtool.git] / src / rrd_tool.c
1 /*****************************************************************************
2  * RRDtool 1.3.2  Copyright by Tobi Oetiker, 1997-2008
3  *****************************************************************************
4  * rrd_tool.c  Startup wrapper
5  *****************************************************************************/
7 #if defined(_WIN32) && !defined(__CYGWIN__) && !defined(__CYGWIN32__) && !defined(HAVE_CONFIG_H)
8 #include "../win32/config.h"
9 #else
10 #ifdef HAVE_CONFIG_H
11 #include "../rrd_config.h"
12 #endif
13 #endif
15 #include "rrd_tool.h"
16 #include "rrd_xport.h"
17 #include "rrd_i18n.h"
19 #ifdef HAVE_LOCALE_H
20 #include <locale.h>
21 #endif
23 void      PrintUsage(
24     char *cmd);
25 int       CountArgs(
26     char *aLine);
27 int       CreateArgs(
28     char *,
29     char *,
30     int,
31     char **);
32 int       HandleInputLine(
33     int,
34     char **,
35     FILE *);
36 int       RemoteMode = 0;
37 int       ChangeRoot = 0;
39 #define TRUE            1
40 #define FALSE           0
41 #define MAX_LENGTH      10000
44 void PrintUsage(
45     char *cmd)
46 {
48     const char *help_main =
49         N_("RRDtool %s"
50            "  Copyright 1997-2008 by Tobias Oetiker <tobi@oetiker.ch>\n"
51            "               Compiled %s %s\n\n"
52            "Usage: rrdtool [options] command command_options\n\n");
54     const char *help_list =
55         N_
56         ("Valid commands: create, update, updatev, graph, graphv,  dump, restore,\n"
57          "\t\tlast, lastupdate, first, info, fetch, tune,\n"
58          "\t\tresize, xport\n\n");
60     const char *help_listremote =
61         N_("Valid remote commands: quit, ls, cd, mkdir, pwd\n\n");
64     const char *help_create =
65         N_("* create - create a new RRD\n\n"
66            "\trrdtool create filename [--start|-b start time]\n"
67            "\t\t[--step|-s step]\n"
68            "\t\t[DS:ds-name:DST:dst arguments]\n"
69            "\t\t[RRA:CF:cf arguments]\n\n");
71     const char *help_dump =
72         N_("* dump - dump an RRD to XML\n\n"
73            "\trrdtool dump filename.rrd >filename.xml\n\n");
75     const char *help_info =
76         N_("* info - returns the configuration and status of the RRD\n\n"
77            "\trrdtool info filename.rrd\n\n");
79     const char *help_restore =
80         N_("* restore - restore an RRD file from its XML form\n\n"
81            "\trrdtool restore [--range-check|-r] [--force-overwrite|-f] filename.xml filename.rrd\n\n");
83     const char *help_last =
84         N_("* last - show last update time for RRD\n\n"
85            "\trrdtool last filename.rrd\n\n");
87     const char *help_lastupdate =
88         N_("* lastupdate - returns the most recent datum stored for\n"
89            "  each DS in an RRD\n\n" "\trrdtool lastupdate filename.rrd\n\n");
91     const char *help_first =
92         N_("* first - show first update time for RRA within an RRD\n\n"
93            "\trrdtool first filename.rrd [--rraindex number]\n\n");
95     const char *help_update =
96         N_("* update - update an RRD\n\n"
97            "\trrdtool update filename\n"
98            "\t\t--template|-t ds-name:ds-name:...\n"
99            "\t\ttime|N:value[:value...]\n\n"
100            "\t\tat-time@value[:value...]\n\n"
101            "\t\t[ time:value[:value...] ..]\n\n");
103     const char *help_updatev =
104         N_("* updatev - a verbose version of update\n"
105            "\treturns information about values, RRAs, and datasources updated\n\n"
106            "\trrdtool updatev filename\n"
107            "\t\t--template|-t ds-name:ds-name:...\n"
108            "\t\ttime|N:value[:value...]\n\n"
109            "\t\tat-time@value[:value...]\n\n"
110            "\t\t[ time:value[:value...] ..]\n\n");
112     const char *help_fetch =
113         N_("* fetch - fetch data out of an RRD\n\n"
114            "\trrdtool fetch filename.rrd CF\n"
115            "\t\t[-r|--resolution resolution]\n"
116            "\t\t[-s|--start start] [-e|--end end]\n\n");
118 /* break up very large strings (help_graph, help_tune) for ISO C89 compliance*/
120     const char *help_graph0 =
121         N_("* graph - generate a graph from one or several RRD\n\n"
122            "\trrdtool graph filename [-s|--start seconds] [-e|--end seconds]\n");
123     const char *help_graphv0 =
124         N_("* graphv - generate a graph from one or several RRD\n"
125            "           with meta data printed before the graph\n\n"
126            "\trrdtool graphv filename [-s|--start seconds] [-e|--end seconds]\n");
127     const char *help_graph1 =
128         N_("\t\t[-x|--x-grid x-axis grid and label]\n"
129            "\t\t[-Y|--alt-y-grid]\n"
130            "\t\t[-y|--y-grid y-axis grid and label]\n"
131            "\t\t[-v|--vertical-label string] [-w|--width pixels]\n"
132            "\t\t[-h|--height pixels] [-o|--logarithmic]\n"
133            "\t\t[-u|--upper-limit value] [-z|--lazy]\n"
134            "\t\t[-l|--lower-limit value] [-r|--rigid]\n"
135            "\t\t[-g|--no-legend]\n"
136            "\t\t[-F|--force-rules-legend]\n" "\t\t[-j|--only-graph]\n");
137     const char *help_graph2 =
138         N_("\t\t[-n|--font FONTTAG:size:font]\n"
139            "\t\t[-m|--zoom factor]\n"
140            "\t\t[-A|--alt-autoscale]\n"
141            "\t\t[-M|--alt-autoscale-max]\n"
142            "\t\t[-R|--font-render-mode {normal,light,mono}]\n"
143            "\t\t[-B|--font-smoothing-threshold size]\n"
144            "\t\t[-T|--tabwidth width]\n"
145            "\t\t[-E|--slope-mode]\n"
146            "\t\t[-N|--no-gridfit]\n"
147            "\t\t[-X|--units-exponent value]\n"
148            "\t\t[-L|--units-length value]\n"
149            "\t\t[-S|--step seconds]\n"
150            "\t\t[-f|--imginfo printfstr]\n"
151            "\t\t[-a|--imgformat PNG]\n"
152            "\t\t[-c|--color COLORTAG#rrggbb[aa]] [-t|--title string]\n"
153            "\t\t[-W|--watermark string]\n"
154            "\t\t[DEF:vname=rrd:ds-name:CF]\n");
155     const char *help_graph3 =
156         N_("\t\t[CDEF:vname=rpn-expression]\n"
157            "\t\t[VDEF:vdefname=rpn-expression]\n"
158            "\t\t[PRINT:vdefname:format]\n"
159            "\t\t[GPRINT:vdefname:format]\n" "\t\t[COMMENT:text]\n"
160            "\t\t[SHIFT:vname:offset]\n"
161            "\t\t[TICK:vname#rrggbb[aa][:[fraction][:legend]]]\n"
162            "\t\t[HRULE:value#rrggbb[aa][:legend]]\n"
163            "\t\t[VRULE:value#rrggbb[aa][:legend]]\n"
164            "\t\t[LINE[width]:vname[#rrggbb[aa][:[legend][:STACK]]]]\n"
165            "\t\t[AREA:vname[#rrggbb[aa][:[legend][:STACK]]]]\n"
166            "\t\t[PRINT:vname:CF:format] (deprecated)\n"
167            "\t\t[GPRINT:vname:CF:format] (deprecated)\n"
168            "\t\t[STACK:vname[#rrggbb[aa][:legend]]] (deprecated)\n\n");
169     const char *help_tune1 =
170         N_(" * tune -  Modify some basic properties of an RRD\n\n"
171            "\trrdtool tune filename\n"
172            "\t\t[--heartbeat|-h ds-name:heartbeat]\n"
173            "\t\t[--data-source-type|-d ds-name:DST]\n"
174            "\t\t[--data-source-rename|-r old-name:new-name]\n"
175            "\t\t[--minimum|-i ds-name:min] [--maximum|-a ds-name:max]\n"
176            "\t\t[--deltapos scale-value] [--deltaneg scale-value]\n"
177            "\t\t[--failure-threshold integer]\n"
178            "\t\t[--window-length integer]\n"
179            "\t\t[--alpha adaptation-parameter]\n");
180     const char *help_tune2 =
181         N_(" * tune -  Modify some basic properties of an RRD\n\n"
182            "\t\t[--beta adaptation-parameter]\n"
183            "\t\t[--gamma adaptation-parameter]\n"
184            "\t\t[--gamma-deviation adaptation-parameter]\n"
185            "\t\t[--aberrant-reset ds-name]\n\n");
186     const char *help_resize =
187         N_
188         (" * resize - alter the length of one of the RRAs in an RRD\n\n"
189          "\trrdtool resize filename rranum GROW|SHRINK rows\n\n");
190     const char *help_xport =
191         N_("* xport - generate XML dump from one or several RRD\n\n"
192            "\trrdtool xport [-s|--start seconds] [-e|--end seconds]\n"
193            "\t\t[-m|--maxrows rows]\n" "\t\t[--step seconds]\n"
194            "\t\t[--enumds]\n" "\t\t[DEF:vname=rrd:ds-name:CF]\n"
195            "\t\t[CDEF:vname=rpn-expression]\n"
196            "\t\t[XPORT:vname:legend]\n\n");
197     const char *help_quit =
198         N_(" * quit - closing a session in remote mode\n\n"
199            "\trrdtool quit\n\n");
200     const char *help_ls =
201         N_(" * ls - lists all *.rrd files in current directory\n\n"
202            "\trrdtool ls\n\n");
203     const char *help_cd =
204         N_(" * cd - changes the current directory\n\n"
205            "\trrdtool cd new directory\n\n");
206     const char *help_mkdir =
207         N_(" * mkdir - creates a new directory\n\n"
208            "\trrdtool mkdir newdirectoryname\n\n");
209     const char *help_pwd =
210         N_(" * pwd - returns the current working directory\n\n"
211            "\trrdtool pwd\n\n");
212     const char *help_lic =
213         N_("RRDtool is distributed under the Terms of the GNU General\n"
214            "Public License Version 2. (www.gnu.org/copyleft/gpl.html)\n\n"
215            "For more information read the RRD manpages\n\n");
216     enum { C_NONE, C_CREATE, C_DUMP, C_INFO, C_RESTORE, C_LAST,
217         C_LASTUPDATE, C_FIRST, C_UPDATE, C_FETCH, C_GRAPH, C_GRAPHV,
218         C_TUNE,
219         C_RESIZE, C_XPORT, C_QUIT, C_LS, C_CD, C_MKDIR, C_PWD,
220         C_UPDATEV
221     };
222     int       help_cmd = C_NONE;
224     if (cmd) {
225         if (!strcmp(cmd, "create"))
226             help_cmd = C_CREATE;
227         else if (!strcmp(cmd, "dump"))
228             help_cmd = C_DUMP;
229         else if (!strcmp(cmd, "info"))
230             help_cmd = C_INFO;
231         else if (!strcmp(cmd, "restore"))
232             help_cmd = C_RESTORE;
233         else if (!strcmp(cmd, "last"))
234             help_cmd = C_LAST;
235         else if (!strcmp(cmd, "lastupdate"))
236             help_cmd = C_LASTUPDATE;
237         else if (!strcmp(cmd, "first"))
238             help_cmd = C_FIRST;
239         else if (!strcmp(cmd, "update"))
240             help_cmd = C_UPDATE;
241         else if (!strcmp(cmd, "updatev"))
242             help_cmd = C_UPDATEV;
243         else if (!strcmp(cmd, "fetch"))
244             help_cmd = C_FETCH;
245         else if (!strcmp(cmd, "graph"))
246             help_cmd = C_GRAPH;
247         else if (!strcmp(cmd, "graphv"))
248             help_cmd = C_GRAPHV;
249         else if (!strcmp(cmd, "tune"))
250             help_cmd = C_TUNE;
251         else if (!strcmp(cmd, "resize"))
252             help_cmd = C_RESIZE;
253         else if (!strcmp(cmd, "xport"))
254             help_cmd = C_XPORT;
255         else if (!strcmp(cmd, "quit"))
256             help_cmd = C_QUIT;
257         else if (!strcmp(cmd, "ls"))
258             help_cmd = C_LS;
259         else if (!strcmp(cmd, "cd"))
260             help_cmd = C_CD;
261         else if (!strcmp(cmd, "mkdir"))
262             help_cmd = C_MKDIR;
263         else if (!strcmp(cmd, "pwd"))
264             help_cmd = C_PWD;
265     }
266     fprintf(stdout, _(help_main), PACKAGE_VERSION, __DATE__, __TIME__);
267     fflush(stdout);
268     switch (help_cmd) {
269     case C_NONE:
270         fputs(_(help_list), stdout);
271         if (RemoteMode) {
272             fputs(_(help_listremote), stdout);
273         }
274         break;
275     case C_CREATE:
276         fputs(_(help_create), stdout);
277         break;
278     case C_DUMP:
279         fputs(_(help_dump), stdout);
280         break;
281     case C_INFO:
282         fputs(_(help_info), stdout);
283         break;
284     case C_RESTORE:
285         fputs(_(help_restore), stdout);
286         break;
287     case C_LAST:
288         fputs(_(help_last), stdout);
289         break;
290     case C_LASTUPDATE:
291         fputs(_(help_lastupdate), stdout);
292         break;
293     case C_FIRST:
294         fputs(_(help_first), stdout);
295         break;
296     case C_UPDATE:
297         fputs(_(help_update), stdout);
298         break;
299     case C_UPDATEV:
300         fputs(_(help_updatev), stdout);
301         break;
302     case C_FETCH:
303         fputs(_(help_fetch), stdout);
304         break;
305     case C_GRAPH:
306         fputs(_(help_graph0), stdout);
307         fputs(_(help_graph1), stdout);
308         fputs(_(help_graph2), stdout);
309         fputs(_(help_graph3), stdout);
310         break;
311     case C_GRAPHV:
312         fputs(_(help_graphv0), stdout);
313         fputs(_(help_graph1), stdout);
314         fputs(_(help_graph2), stdout);
315         fputs(_(help_graph3), stdout);
316         break;
317     case C_TUNE:
318         fputs(_(help_tune1), stdout);
319         fputs(_(help_tune2), stdout);
320         break;
321     case C_RESIZE:
322         fputs(_(help_resize), stdout);
323         break;
324     case C_XPORT:
325         fputs(_(help_xport), stdout);
326         break;
327     case C_QUIT:
328         fputs(_(help_quit), stdout);
329         break;
330     case C_LS:
331         fputs(_(help_ls), stdout);
332         break;
333     case C_CD:
334         fputs(_(help_cd), stdout);
335         break;
336     case C_MKDIR:
337         fputs(_(help_mkdir), stdout);
338         break;
339     case C_PWD:
340         fputs(_(help_pwd), stdout);
341         break;
342     }
343     fputs(_(help_lic), stdout);
346 static char *fgetslong(
347     char **aLinePtr,
348     FILE * stream)
350     char     *linebuf;
351     size_t    bufsize = MAX_LENGTH;
352     int       eolpos = 0;
354     if (feof(stream))
355         return *aLinePtr = 0;
356     if (!(linebuf = malloc(bufsize))) {
357         perror("fgetslong: malloc");
358         exit(1);
359     }
360     linebuf[0] = '\0';
361     while (fgets(linebuf + eolpos, MAX_LENGTH, stream)) {
362         eolpos += strlen(linebuf + eolpos);
363         if (linebuf[eolpos - 1] == '\n')
364             return *aLinePtr = linebuf;
365         bufsize += MAX_LENGTH;
366         if (!(linebuf = realloc(linebuf, bufsize))) {
367             free(linebuf);
368             perror("fgetslong: realloc");
369             exit(1);
370         }
371     }
372     if (linebuf[0]){
373         return  *aLinePtr = linebuf;
374     }
375     free(linebuf);
376     return *aLinePtr = 0;
379 int main(
380     int argc,
381     char *argv[])
383     char    **myargv;
384     char     *aLine;
385     char     *firstdir = "";
387 #ifdef MUST_DISABLE_SIGFPE
388     signal(SIGFPE, SIG_IGN);
389 #endif
390 #ifdef MUST_DISABLE_FPMASK
391     fpsetmask(0);
392 #endif
393 #ifdef HAVE_LOCALE_H
394     setlocale(LC_ALL, "");
395 #endif
397 #if defined(HAVE_LIBINTL_H) && defined(BUILD_LIBINTL)
398     bindtextdomain(GETTEXT_PACKAGE, LOCALEDIR);
399     bind_textdomain_codeset(GETTEXT_PACKAGE, "UTF-8");
400     textdomain(GETTEXT_PACKAGE);
401 #endif
402     if (argc == 1) {
403         PrintUsage("");
404         return 0;
405     }
407     if (((argc == 2) || (argc == 3)) && !strcmp("-", argv[1])) {
408 #if HAVE_GETRUSAGE
409         struct rusage myusage;
410         struct timeval starttime;
411         struct timeval currenttime;
413         gettimeofday(&starttime, NULL);
414 #endif
415         RemoteMode = 1;
416         if ((argc == 3) && strcmp("", argv[2])) {
418             if (
419 #ifdef HAVE_GETUID
420                    getuid()
421 #else
422                    1
423 #endif
424                    == 0) {
426 #ifdef HAVE_CHROOT
427                 if (chroot(argv[2]) != 0){
428                     fprintf(stderr, "ERROR: chroot %s: %s\n", argv[2],rrd_strerror(errno));
429                     exit(errno);
430                 }
431                 ChangeRoot = 1;
432                 firstdir = "/";
433 #else
434                 fprintf(stderr,
435                         "ERROR: change root is not supported by your OS "
436                         "or at least by this copy of rrdtool\n");
437                 exit(1);
438 #endif
439             } else {
440                 firstdir = argv[2];
441             }
442         }
443         if (strcmp(firstdir, "")) {
444             if (chdir(firstdir) != 0){
445                 fprintf(stderr, "ERROR: chdir %s %s\n", firstdir,rrd_strerror(errno));
446                 exit(errno);
447             }
448         }
450         while (fgetslong(&aLine, stdin)) {
451             if ((argc = CountArgs(aLine)) == 0) {
452                 free(aLine);
453                 printf("ERROR: not enough arguments\n");
454             }
455             if ((myargv = (char **) malloc((argc + 1) *
456                                            sizeof(char *))) == NULL) {
457                 perror("malloc");
458                 exit(1);
459             }
460             if ((argc = CreateArgs(argv[0], aLine, argc, myargv)) < 0) {
461                 free(aLine);
462                 free(myargv);
463                 printf("ERROR: creating arguments\n");
464             } else {
465                 int       ret = HandleInputLine(argc, myargv, stdout);
467                 free(myargv);
468                 if (ret == 0) {
469 #if HAVE_GETRUSAGE
470                     getrusage(RUSAGE_SELF, &myusage);
471                     gettimeofday(&currenttime, NULL);
472                     printf("OK u:%1.2f s:%1.2f r:%1.2f\n",
473                            (double) myusage.ru_utime.tv_sec +
474                            (double) myusage.ru_utime.tv_usec / 1000000.0,
475                            (double) myusage.ru_stime.tv_sec +
476                            (double) myusage.ru_stime.tv_usec / 1000000.0,
477                            (double) (currenttime.tv_sec - starttime.tv_sec)
478                            + (double) (currenttime.tv_usec -
479                                        starttime.tv_usec)
480                            / 1000000.0);
481 #else
482                     printf("OK\n");
483 #endif
484                 }
485             }
486             fflush(stdout); /* this is important for pipes to work */
487             free(aLine);
488         }
489     } else if (argc == 2) {
490         PrintUsage(argv[1]);
491         exit(0);
492     } else if (argc == 3 && !strcmp(argv[1], "help")) {
493         PrintUsage(argv[2]);
494         exit(0);
495     } else {
496         exit(HandleInputLine(argc, argv, stderr));
497     }
498     return 0;
501 /* HandleInputLine is NOT thread safe - due to readdir issues,
502    resolving them portably is not really simple. */
503 int HandleInputLine(
504     int argc,
505     char **argv,
506     FILE * out)
508 #if defined(HAVE_OPENDIR) && defined (HAVE_READDIR)
509     DIR      *curdir;   /* to read current dir with ls */
510     struct dirent *dent;
511 #endif
512 #if defined(HAVE_SYS_STAT_H)
513     struct stat st;
514 #endif
515     char     *cwd;      /* To hold current working dir on call to pwd */
517     /* Reset errno to 0 before we start.
518      */
519     if (RemoteMode) {
520         if (argc > 1 && strcmp("quit", argv[1]) == 0) {
521             if (argc > 2) {
522                 printf("ERROR: invalid parameter count for quit\n");
523                 return (1);
524             }
525             exit(0);
526         }
527 #if defined(HAVE_OPENDIR) && defined(HAVE_READDIR) && defined(HAVE_CHDIR)
528         if (argc > 1 && strcmp("cd", argv[1]) == 0) {
529             if (argc > 3) {
530                 printf("ERROR: invalid parameter count for cd\n");
531                 return (1);
532             }
533 #if ! defined(HAVE_CHROOT) || ! defined(HAVE_GETUID)
534             if (getuid() == 0 && !ChangeRoot) {
535                 printf
536                     ("ERROR: chdir security problem - rrdtool is running as "
537                      "root but not chroot!\n");
538                 return (1);
539             }
540 #endif
541             if (chdir(argv[2]) != 0){
542                 printf("ERROR: chdir %s %s\n", argv[2], rrd_strerror(errno));
543                 return (1);
544             }
545             return (0);
546         }
547         if (argc > 1 && strcmp("pwd", argv[1]) == 0) {
548             if (argc > 2) {
549                 printf("ERROR: invalid parameter count for pwd\n");
550                 return (1);
551             }
552             cwd = getcwd(NULL, MAXPATH);
553             if (cwd == NULL) {
554                 printf("ERROR: getcwd %s\n", rrd_strerror(errno));
555                 return (1);
556             }
557             printf("%s\n", cwd);
558             free(cwd);
559             return (0);
560         }
561         if (argc > 1 && strcmp("mkdir", argv[1]) == 0) {
562             if (argc > 3) {
563                 printf("ERROR: invalid parameter count for mkdir\n");
564                 return (1);
565             }
566 #if ! defined(HAVE_CHROOT) || ! defined(HAVE_GETUID)
567             if (getuid() == 0 && !ChangeRoot) {
568                 printf
569                     ("ERROR: mkdir security problem - rrdtool is running as "
570                      "root but not chroot!\n");
571                 return (1);
572             }
573 #endif
574             if(mkdir(argv[2], 0777)!=0){
575                 printf("ERROR: mkdir %s: %s\n", argv[2],rrd_strerror(errno));
576                 return (1);
577             }
578             return (0);
579         }
580         if (argc > 1 && strcmp("ls", argv[1]) == 0) {
581             if (argc > 2) {
582                 printf("ERROR: invalid parameter count for ls\n");
583                 return (1);
584             }
585             if ((curdir = opendir(".")) != NULL) {
586                 while ((dent = readdir(curdir)) != NULL) {
587                     if (!stat(dent->d_name, &st)) {
588                         if (S_ISDIR(st.st_mode)) {
589                             printf("d %s\n", dent->d_name);
590                         }
591                         if (strlen(dent->d_name) > 4 && S_ISREG(st.st_mode)) {
592                             if (!strcmp
593                                 (dent->d_name + NAMLEN(dent) - 4, ".rrd")
594                                 || !strcmp(dent->d_name + NAMLEN(dent) - 4,
595                                            ".RRD")) {
596                                 printf("- %s\n", dent->d_name);
597                             }
598                         }
599                     }
600                 }
601                 closedir(curdir);
602             } else {
603                 printf("ERROR: opendir .: %s\n", rrd_strerror(errno));
604                 return (errno);
605             }
606             return (0);
607         }
608 #endif                          /* opendir and readdir */
610     }
611     if (argc < 3
612         || strcmp("help", argv[1]) == 0
613         || strcmp("--help", argv[1]) == 0
614         || strcmp("-help", argv[1]) == 0
615         || strcmp("-?", argv[1]) == 0 || strcmp("-h", argv[1]) == 0) {
616         PrintUsage("");
617         return 0;
618     }
620     if (strcmp("create", argv[1]) == 0)
621         rrd_create(argc - 1, &argv[1]);
622     else if (strcmp("dump", argv[1]) == 0)
623         rrd_dump(argc - 1, &argv[1]);
624     else if (strcmp("info", argv[1]) == 0 || strcmp("updatev", argv[1]) == 0) {
625         rrd_info_t *data;
627         if (strcmp("info", argv[1]) == 0)
629             data = rrd_info(argc - 1, &argv[1]);
630         else
631             data = rrd_update_v(argc - 1, &argv[1]);
632         rrd_info_print(data);
633         rrd_info_free(data);
634     }
636     else if (strcmp("--version", argv[1]) == 0 ||
637              strcmp("version", argv[1]) == 0 ||
638              strcmp("v", argv[1]) == 0 ||
639              strcmp("-v", argv[1]) == 0 || strcmp("-version", argv[1]) == 0)
640         printf("RRDtool " PACKAGE_VERSION
641                "  Copyright by Tobi Oetiker, 1997-2008 (%f)\n",
642                rrd_version());
643     else if (strcmp("restore", argv[1]) == 0)
644         rrd_restore(argc - 1, &argv[1]);
645     else if (strcmp("resize", argv[1]) == 0)
646         rrd_resize(argc - 1, &argv[1]);
647     else if (strcmp("last", argv[1]) == 0)
648         printf("%ld\n", rrd_last(argc - 1, &argv[1]));
649     else if (strcmp("lastupdate", argv[1]) == 0) {
650         time_t    last_update;
651         char    **ds_namv;
652         char    **last_ds;
653         unsigned long ds_cnt, i;
655         if (rrd_lastupdate(argc - 1, &argv[1], &last_update,
656                            &ds_cnt, &ds_namv, &last_ds) == 0) {
657             for (i = 0; i < ds_cnt; i++)
658                 printf(" %s", ds_namv[i]);
659             printf("\n\n");
660             printf("%10lu:", last_update);
661             for (i = 0; i < ds_cnt; i++) {
662                 printf(" %s", last_ds[i]);
663                 free(last_ds[i]);
664                 free(ds_namv[i]);
665             }
666             printf("\n");
667             free(last_ds);
668             free(ds_namv);
669         }
670     } else if (strcmp("first", argv[1]) == 0)
671         printf("%ld\n", rrd_first(argc - 1, &argv[1]));
672     else if (strcmp("update", argv[1]) == 0)
673         rrd_update(argc - 1, &argv[1]);
674     else if (strcmp("fetch", argv[1]) == 0) {
675         time_t    start, end, ti;
676         unsigned long step, ds_cnt, i, ii;
677         rrd_value_t *data, *datai;
678         char    **ds_namv;
680         if (rrd_fetch
681             (argc - 1, &argv[1], &start, &end, &step, &ds_cnt, &ds_namv,
682              &data) != -1) {
683             datai = data;
684             printf("           ");
685             for (i = 0; i < ds_cnt; i++)
686                 printf("%20s", ds_namv[i]);
687             printf("\n\n");
688             for (ti = start + step; ti <= end; ti += step) {
689                 printf("%10lu:", ti);
690                 for (ii = 0; ii < ds_cnt; ii++)
691                     printf(" %0.10e", *(datai++));
692                 printf("\n");
693             }
694             for (i = 0; i < ds_cnt; i++)
695                 free(ds_namv[i]);
696             free(ds_namv);
697             free(data);
698         }
699     } else if (strcmp("xport", argv[1]) == 0) {
700         int       xxsize;
701         unsigned long int j = 0;
702         time_t    start, end, ti;
703         unsigned long step, col_cnt, row_cnt;
704         rrd_value_t *data, *ptr;
705         char    **legend_v;
706         int       enumds = 0;
707         int       i;
708         size_t    vtag_s = strlen(COL_DATA_TAG) + 10;
709         char     *vtag = malloc(vtag_s);
711         for (i = 2; i < argc; i++) {
712             if (strcmp("--enumds", argv[i]) == 0)
713                 enumds = 1;
714         }
716         if (rrd_xport
717             (argc - 1, &argv[1], &xxsize, &start, &end, &step, &col_cnt,
718              &legend_v, &data) != -1) {
719             row_cnt = (end - start) / step;
720             ptr = data;
721             printf("<?xml version=\"1.0\" encoding=\"%s\"?>\n\n",
722                    XML_ENCODING);
723             printf("<%s>\n", ROOT_TAG);
724             printf("  <%s>\n", META_TAG);
725             printf("    <%s>%lu</%s>\n", META_START_TAG,
726                    (unsigned long) start + step, META_START_TAG);
727             printf("    <%s>%lu</%s>\n", META_STEP_TAG, step, META_STEP_TAG);
728             printf("    <%s>%lu</%s>\n", META_END_TAG, (unsigned long) end,
729                    META_END_TAG);
730             printf("    <%s>%lu</%s>\n", META_ROWS_TAG, row_cnt,
731                    META_ROWS_TAG);
732             printf("    <%s>%lu</%s>\n", META_COLS_TAG, col_cnt,
733                    META_COLS_TAG);
734             printf("    <%s>\n", LEGEND_TAG);
735             for (j = 0; j < col_cnt; j++) {
736                 char     *entry = NULL;
738                 entry = legend_v[j];
739                 printf("      <%s>%s</%s>\n", LEGEND_ENTRY_TAG, entry,
740                        LEGEND_ENTRY_TAG);
741                 free(entry);
742             }
743             free(legend_v);
744             printf("    </%s>\n", LEGEND_TAG);
745             printf("  </%s>\n", META_TAG);
746             printf("  <%s>\n", DATA_TAG);
747             for (ti = start + step; ti <= end; ti += step) {
748                 printf("    <%s>", DATA_ROW_TAG);
749                 printf("<%s>%lu</%s>", COL_TIME_TAG, ti, COL_TIME_TAG);
750                 for (j = 0; j < col_cnt; j++) {
751                     rrd_value_t newval = DNAN;
753                     if (enumds == 1)
755                         snprintf(vtag, vtag_s, "%s%lu", COL_DATA_TAG, j);
756                     else
757                         snprintf(vtag, vtag_s, "%s", COL_DATA_TAG);
758                     newval = *ptr;
759                     if (isnan(newval)) {
760                         printf("<%s>NaN</%s>", vtag, vtag);
761                     } else {
762                         printf("<%s>%0.10e</%s>", vtag, newval, vtag);
763                     };
764                     ptr++;
765                 }
766                 printf("</%s>\n", DATA_ROW_TAG);
767             }
768             free(data);
769             printf("  </%s>\n", DATA_TAG);
770             printf("</%s>\n", ROOT_TAG);
771         }
772         free(vtag);
773     } else if (strcmp("graph", argv[1]) == 0) {
774         char    **calcpr;
776 #ifdef notused /*XXX*/
777         const char *imgfile = argv[2];  /* rrd_graph changes argv pointer */
778 #endif
779         int       xsize, ysize;
780         double    ymin, ymax;
781         int       i;
782         int       tostdout = (strcmp(argv[2], "-") == 0);
783         int       imginfo = 0;
785         for (i = 2; i < argc; i++) {
786             if (strcmp(argv[i], "--imginfo") == 0
787                 || strcmp(argv[i], "-f") == 0) {
788                 imginfo = 1;
789                 break;
790             }
791         }
792         if (rrd_graph
793             (argc - 1, &argv[1], &calcpr, &xsize, &ysize, NULL, &ymin,
794              &ymax) != -1) {
795             if (!tostdout && !imginfo)
796                 printf("%dx%d\n", xsize, ysize);
797             if (calcpr) {
798                 for (i = 0; calcpr[i]; i++) {
799                     if (!tostdout)
800                         printf("%s\n", calcpr[i]);
801                     free(calcpr[i]);
802                 }
803                 free(calcpr);
804             }
805         }
807     } else if (strcmp("graphv", argv[1]) == 0) {
808         rrd_info_t *grinfo = NULL;  /* 1 to distinguish it from the NULL that rrd_graph sends in */
810         grinfo = rrd_graph_v(argc - 1, &argv[1]);
811         if (grinfo) {
812             rrd_info_print(grinfo);
813             rrd_info_free(grinfo);
814         }
816     } else if (strcmp("tune", argv[1]) == 0)
817         rrd_tune(argc - 1, &argv[1]);
818     else {
819         rrd_set_error("unknown function '%s'", argv[1]);
820     }
821     if (rrd_test_error()) {
822         fprintf(out, "ERROR: %s\n", rrd_get_error());
823         rrd_clear_error();
824         return 1;
825     }
826     return (0);
829 int CountArgs(
830     char *aLine)
832     int       i = 0;
833     int       aCount = 0;
834     int       inarg = 0;
836     while (aLine[i] == ' ')
837         i++;
838     while (aLine[i] != 0) {
839         if ((aLine[i] == ' ') && inarg) {
840             inarg = 0;
841         }
842         if ((aLine[i] != ' ') && !inarg) {
843             inarg = 1;
844             aCount++;
845         }
846         i++;
847     }
848     return aCount;
851 /*
852  * CreateArgs - take a string (aLine) and tokenize
853  */
854 int CreateArgs(
855     char *pName,
856     char *aLine,
857     int argc,
858     char **argv)
860     char     *getP, *putP;
861     char    **pargv = argv;
862     char      Quote = 0;
863     int       inArg = 0;
864     int       len;
866     len = strlen(aLine);
867     /* remove trailing space and newlines */
868     while (len && aLine[len] <= ' ') {
869         aLine[len] = 0;
870         len--;
871     }
872     /* sikp leading blanks */
873     while (*aLine && *aLine <= ' ')
874         aLine++;
875     pargv[0] = pName;
876     argc = 1;
877     getP = aLine;
878     putP = aLine;
879     while (*getP) {
880         switch (*getP) {
881         case ' ':
882             if (Quote) {
883                 *(putP++) = *getP;
884             } else if (inArg) {
885                 *(putP++) = 0;
886                 inArg = 0;
887             }
888             break;
889         case '"':
890         case '\'':
891             if (Quote != 0) {
892                 if (Quote == *getP)
893                     Quote = 0;
894                 else {
895                     *(putP++) = *getP;
896                 }
897             } else {
898                 if (!inArg) {
899                     pargv[argc++] = putP;
900                     inArg = 1;
901                 }
902                 Quote = *getP;
903             }
904             break;
905         default:
906             if (!inArg) {
907                 pargv[argc++] = putP;
908                 inArg = 1;
909             }
910             *(putP++) = *getP;
911             break;
912         }
913         getP++;
914     }
916     *putP = '\0';
917     if (Quote)
918         return -1;
919     else
920         return argc;