]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/dird/inc_conf.c
Pool + label cleanups from bug reports
[bacula/bacula] / bacula / src / dird / inc_conf.c
index 2c1413217ef0673124b582fbbf8ae7ec47164b47..d3df0b8fd4f5b15a6c023c6eee4df49203c0f30b 100644 (file)
 
 #include "bacula.h"
 #include "dird.h"
+#ifdef HAVE_REGEX_H
+#include <regex.h>
+#endif
 
 /* Forward referenced subroutines */
 
 void store_inc(LEX *lc, RES_ITEM *item, int index, int pass);
 
 static void store_newinc(LEX *lc, RES_ITEM *item, int index, int pass);
-static void store_match(LEX *lc, RES_ITEM *item, int index, int pass);
+static void store_regex(LEX *lc, RES_ITEM *item, int index, int pass);
+static void store_wild(LEX *lc, RES_ITEM *item, int index, int pass);
 static void store_opts(LEX *lc, RES_ITEM *item, int index, int pass);
 static void store_fname(LEX *lc, RES_ITEM *item, int index, int pass);
 static void options_res(LEX *lc, RES_ITEM *item, int index, int pass);
@@ -76,29 +80,39 @@ static RES_ITEM options_items[] = {
    {"readfifo",        store_opts,    NULL,     0, 0, 0},
    {"replace",         store_opts,    NULL,     0, 0, 0},
    {"portable",        store_opts,    NULL,     0, 0, 0},
-   {"match",           store_match,   NULL,     0, 0, 0},
+   {"mtimeonly",       store_opts,    NULL,     0, 0, 0},
+   {"keepatime",       store_opts,    NULL,     0, 0, 0},
+   {"regex",           store_regex,   NULL,     0, 0, 0},
    {"base",            store_base,    NULL,     0, 0, 0},
+   {"wild",            store_wild,    NULL,     0, 0, 0},
+   {"exclude",         store_opts,    NULL,     0, 0, 0},
+   {"aclsupport",      store_opts,    NULL,     0, 0, 0},
    {NULL, NULL, NULL, 0, 0, 0} 
 };
 
 
 /* Define FileSet KeyWord values */
 
-#define INC_KW_NONE        0
-#define INC_KW_COMPRESSION  1
-#define INC_KW_SIGNATURE    2
-#define INC_KW_ENCRYPTION   3
-#define INC_KW_VERIFY      4
-#define INC_KW_ONEFS       5
-#define INC_KW_RECURSE     6
-#define INC_KW_SPARSE      7
-#define INC_KW_REPLACE     8         /* restore options */
-#define INC_KW_READFIFO     9        /* Causes fifo data to be read */
-#define INC_KW_PORTABLE    10
-#define INC_KW_MTIMEONLY   11
-#define INC_KW_KEEPATIME   12
-
-/* Include keywords -- these are keywords that can appear
+enum {
+   INC_KW_NONE,
+   INC_KW_COMPRESSION,
+   INC_KW_SIGNATURE,
+   INC_KW_ENCRYPTION,
+   INC_KW_VERIFY,
+   INC_KW_ONEFS,
+   INC_KW_RECURSE,
+   INC_KW_SPARSE,
+   INC_KW_REPLACE,              /* restore options */
+   INC_KW_READFIFO,             /* Causes fifo data to be read */
+   INC_KW_PORTABLE,
+   INC_KW_MTIMEONLY,
+   INC_KW_KEEPATIME,
+   INC_KW_EXCLUDE,
+   INC_KW_ACL
+};
+
+/*
+ * Include keywords -- these are keywords that can appear
  *    in the options lists of an old include ( Include = compression= ...)
  */
 static struct s_kw FS_option_kw[] = {
@@ -114,15 +128,17 @@ static struct s_kw FS_option_kw[] = {
    {"portable",    INC_KW_PORTABLE},
    {"mtimeonly",   INC_KW_MTIMEONLY},
    {"keepatime",   INC_KW_KEEPATIME},
+   {"exclude",     INC_KW_EXCLUDE},
+   {"aclsupport",  INC_KW_ACL},
    {NULL,         0}
 };
 
 /* Options for FileSet keywords */
 
 struct s_fs_opt {
-   char *name;
+   const char *name;
    int keyword;
-   char *option;
+   const char *option;
 };
 
 /*
@@ -163,7 +179,11 @@ static struct s_fs_opt FS_options[] = {
    {"no",       INC_KW_MTIMEONLY,     "0"},
    {"yes",      INC_KW_KEEPATIME,     "k"},
    {"no",       INC_KW_KEEPATIME,     "0"},
-   {NULL,      0,                   0}
+   {"yes",      INC_KW_EXCLUDE,       "e"},
+   {"no",       INC_KW_EXCLUDE,       "0"},
+   {"yes",      INC_KW_ACL,           "A"},
+   {"no",       INC_KW_ACL,           "0"},
+   {NULL,      0,                      0}
 };
 
 
@@ -187,7 +207,7 @@ static void scan_include_options(LEX *lc, int keyword, char *opts, int optlen)
       bstrncat(opts, "V", optlen);         /* indicate Verify */
       bstrncat(opts, lc->str, optlen);
       bstrncat(opts, ":", optlen);         /* terminate it */
-      Dmsg3(100, "Catopts=%s option=%s optlen=%d\n", opts, option,optlen);
+      Dmsg3(900, "Catopts=%s option=%s optlen=%d\n", opts, option,optlen);
 
    /*
     * Standard keyword options for Include/Exclude 
@@ -206,7 +226,7 @@ static void scan_include_options(LEX *lc, int keyword, char *opts, int optlen)
          scan_err1(lc, "Expected a FileSet option keyword, got:%s:", lc->str);
       } else { /* add option */
         bstrncat(opts, option, optlen);
-         Dmsg3(100, "Catopts=%s option=%s optlen=%d\n", opts, option,optlen);
+         Dmsg3(900, "Catopts=%s option=%s optlen=%d\n", opts, option,optlen);
       }
    }
 
@@ -230,7 +250,7 @@ void store_inc(LEX *lc, RES_ITEM *item, int index, int pass)
 
    /*
     * Decide if we are doing a new Include or an old include. The
-    *  new Include is followed immediately by {, whereas the
+    *  new Include is followed immediately by open brace, whereas the
     *  old include has options following the Include.
     */
    token = lex_get_token(lc, T_ALL);           
@@ -283,10 +303,10 @@ void store_inc(LEX *lc, RES_ITEM *item, int index, int pass)
       }
       setup_current_opts();
       bstrncpy(res_incexe.current_opts->opts, inc_opts, MAX_FOPTS);
-      Dmsg2(100, "old pass=%d incexe opts=%s\n", pass, res_incexe.current_opts->opts);
+      Dmsg2(900, "old pass=%d incexe opts=%s\n", pass, res_incexe.current_opts->opts);
 
       /* Create incexe structure */
-      Dmsg0(200, "Create INCEXE structure\n");
+      Dmsg0(900, "Create INCEXE structure\n");
       incexe = (INCEXE *)malloc(sizeof(INCEXE));
       memcpy(incexe, &res_incexe, sizeof(INCEXE));
       memset(&res_incexe, 0, sizeof(INCEXE));
@@ -298,7 +318,7 @@ void store_inc(LEX *lc, RES_ITEM *item, int index, int pass)
                           sizeof(INCEXE *) * (res_all.res_fs.num_includes + 1));
          }
          res_all.res_fs.include_items[res_all.res_fs.num_includes++] = incexe;
-          Dmsg1(200, "num_includes=%d\n", res_all.res_fs.num_includes);
+          Dmsg1(900, "num_includes=%d\n", res_all.res_fs.num_includes);
       } else {   /* exclude */
         if (res_all.res_fs.num_excludes == 0) {
            res_all.res_fs.exclude_items = (INCEXE **)malloc(sizeof(INCEXE *));
@@ -307,7 +327,7 @@ void store_inc(LEX *lc, RES_ITEM *item, int index, int pass)
                           sizeof(INCEXE *) * (res_all.res_fs.num_excludes + 1));
          }
          res_all.res_fs.exclude_items[res_all.res_fs.num_excludes++] = incexe;
-          Dmsg1(200, "num_excludes=%d\n", res_all.res_fs.num_excludes);
+          Dmsg1(900, "num_excludes=%d\n", res_all.res_fs.num_excludes);
       }
 
       /* Pickup include/exclude names. They are stored in INCEXE
@@ -329,7 +349,7 @@ void store_inc(LEX *lc, RES_ITEM *item, int index, int pass)
               incexe->name_list.init(10, true);
            }
            incexe->name_list.append(bstrdup(lc->str));
-            Dmsg1(200, "Add to name_list %s\n", lc->str);
+            Dmsg1(900, "Add to name_list %s\n", lc->str);
            break;
         default:
             scan_err1(lc, "Expected a filename, got: %s", lc->str);
@@ -349,7 +369,7 @@ void store_inc(LEX *lc, RES_ITEM *item, int index, int pass)
 /*
  * Store FileSet FInclude/FExclude info   
  *  Note, when this routine is called, we are inside a FileSet
- *  resource.  We treat the Finclude/Fexeclude like a sort of
+ *  resource.  We treat the Include/Execlude like a sort of
  *  mini-resource within the FileSet resource.
  */
 static void store_newinc(LEX *lc, RES_ITEM *item, int index, int pass)
@@ -363,7 +383,7 @@ static void store_newinc(LEX *lc, RES_ITEM *item, int index, int pass)
       res_all.res_fs.have_MD5 = TRUE;
    }
    memset(&res_incexe, 0, sizeof(INCEXE));
-   res_all.res_fs.new_include = TRUE;
+   res_all.res_fs.new_include = true;
    while ((token = lex_get_token(lc, T_ALL)) != T_EOF) {
       if (token == T_EOL) {
         continue;
@@ -405,7 +425,7 @@ static void store_newinc(LEX *lc, RES_ITEM *item, int index, int pass)
                           sizeof(INCEXE *) * (res_all.res_fs.num_includes + 1));
         }
         res_all.res_fs.include_items[res_all.res_fs.num_includes++] = incexe;
-         Dmsg1(200, "num_includes=%d\n", res_all.res_fs.num_includes);
+         Dmsg1(900, "num_includes=%d\n", res_all.res_fs.num_includes);
       } else {   /* exclude */
         if (res_all.res_fs.num_excludes == 0) {
            res_all.res_fs.exclude_items = (INCEXE **)malloc(sizeof(INCEXE *));
@@ -414,7 +434,7 @@ static void store_newinc(LEX *lc, RES_ITEM *item, int index, int pass)
                           sizeof(INCEXE *) * (res_all.res_fs.num_excludes + 1));
         }
         res_all.res_fs.exclude_items[res_all.res_fs.num_excludes++] = incexe;
-         Dmsg1(200, "num_excludes=%d\n", res_all.res_fs.num_excludes);
+         Dmsg1(900, "num_excludes=%d\n", res_all.res_fs.num_excludes);
       }
    }
    scan_to_eol(lc);
@@ -422,24 +442,35 @@ static void store_newinc(LEX *lc, RES_ITEM *item, int index, int pass)
 }
 
 
-/* Store Match info */
-static void store_match(LEX *lc, RES_ITEM *item, int index, int pass)
+/* Store regex info */
+static void store_regex(LEX *lc, RES_ITEM *item, int index, int pass)
 {
-   int token;
+   int token, rc;
+   regex_t preg;
+   char prbuf[500];
 
    if (pass == 1) {
-      /* Pickup Match string
+      /* Pickup regex string
        */
       token = lex_get_token(lc, T_ALL);           
       switch (token) {
       case T_IDENTIFIER:
       case T_UNQUOTED_STRING:
       case T_QUOTED_STRING:
-        setup_current_opts();
-        res_incexe.current_opts->match.append(bstrdup(lc->str));
+        rc = regcomp(&preg, lc->str, REG_EXTENDED);
+        if (rc != 0) {
+           regerror(rc, &preg, prbuf, sizeof(prbuf));
+           regfree(&preg);
+            scan_err1(lc, _("Regex compile error. ERR=%s\n"), prbuf);
+           break;
+        }
+        regfree(&preg);
+        res_incexe.current_opts->regex.append(bstrdup(lc->str));
+         Dmsg3(900, "set regex %p size=%d %s\n", 
+           res_incexe.current_opts, res_incexe.current_opts->regex.size(),lc->str);
         break;
       default:
-         scan_err1(lc, _("Expected a filename, got: %s\n"), lc->str);
+         scan_err1(lc, _("Expected a regex string, got: %s\n"), lc->str);
       }                                
    } else { /* pass 2 */
       lex_get_token(lc, T_ALL);         
@@ -453,17 +484,46 @@ static void store_base(LEX *lc, RES_ITEM *item, int index, int pass)
    int token;
 
    if (pass == 1) {
-      setup_current_opts();
       /*
        * Pickup Base Job Name
        */
       token = lex_get_token(lc, T_NAME);          
-      res_incexe.current_opts->base_list.append(bstrdup(lc->str));
+      res_incexe.current_opts->base.append(bstrdup(lc->str));
+   } else { /* pass 2 */
+      lex_get_token(lc, T_ALL);         
+   }
+   scan_to_eol(lc);
+}
+
+
+/* Store Wild-card info */
+static void store_wild(LEX *lc, RES_ITEM *item, int index, int pass)
+{
+   int token;
+
+   if (pass == 1) {
+      /*
+       * Pickup Wild-card string
+       */
+      token = lex_get_token(lc, T_ALL);           
+      switch (token) {
+      case T_IDENTIFIER:
+      case T_UNQUOTED_STRING:
+      case T_QUOTED_STRING:
+        res_incexe.current_opts->wild.append(bstrdup(lc->str));
+         Dmsg3(900, "set wild %p size=%d %s\n", 
+           res_incexe.current_opts, res_incexe.current_opts->wild.size(),lc->str);
+        break;
+      default:
+         scan_err1(lc, _("Expected a wild-card string, got: %s\n"), lc->str);
+      }                                
    } else { /* pass 2 */
       lex_get_token(lc, T_ALL);         
    }
    scan_to_eol(lc);
 }
+
+
 /*
  * Store Filename info. Note, for minor efficiency reasons, we
  * always increase the name buffer by 10 items because we expect
@@ -490,7 +550,7 @@ static void store_fname(LEX *lc, RES_ITEM *item, int index, int pass)
               incexe->name_list.init(10, true);
            }
            incexe->name_list.append(bstrdup(lc->str));
-            Dmsg1(200, "Add to name_list %s\n", lc->str);
+            Dmsg1(900, "Add to name_list %s\n", lc->str);
            break;
         default:
             scan_err1(lc, _("Expected a filename, got: %s"), lc->str);
@@ -513,6 +573,10 @@ static void options_res(LEX *lc, RES_ITEM *item, int index, int pass)
       scan_err1(lc, "Expecting open brace. Got %s", lc->str);
    }
 
+   if (pass == 1) {
+      setup_current_opts();
+   }
+        
    while ((token = lex_get_token(lc, T_ALL)) != T_EOF) {
       if (token == T_EOL) {
         continue;
@@ -567,9 +631,8 @@ static void store_opts(LEX *lc, RES_ITEM *item, int index, int pass)
    /* Now scan for the value */
    scan_include_options(lc, keyword, inc_opts, sizeof(inc_opts));
    if (pass == 1) {
-      setup_current_opts();
       bstrncat(res_incexe.current_opts->opts, inc_opts, MAX_FOPTS);
-      Dmsg2(100, "new pass=%d incexe opts=%s\n", pass, res_incexe.current_opts->opts);
+      Dmsg2(900, "new pass=%d incexe opts=%s\n", pass, res_incexe.current_opts->opts);
    }
    scan_to_eol(lc);
 }
@@ -579,13 +642,17 @@ static void store_opts(LEX *lc, RES_ITEM *item, int index, int pass)
 /* If current_opts not defined, create first entry */
 static void setup_current_opts(void)
 {
-   if (res_incexe.current_opts == NULL) {
-      res_incexe.current_opts = (FOPTS *)malloc(sizeof(FOPTS));
-      memset(res_incexe.current_opts, 0, sizeof(FOPTS));
-      res_incexe.current_opts->match.init(1, true);
-      res_incexe.current_opts->base_list.init(1, true);
-      res_incexe.num_opts = 1;
+   FOPTS *fo = (FOPTS *)malloc(sizeof(FOPTS));
+   memset(fo, 0, sizeof(FOPTS));
+   fo->regex.init(1, true);
+   fo->wild.init(1, true);
+   fo->base.init(1, true);
+   res_incexe.current_opts = fo;
+   if (res_incexe.num_opts == 0) {
       res_incexe.opts_list = (FOPTS **)malloc(sizeof(FOPTS *));
-      res_incexe.opts_list[0] = res_incexe.current_opts;
+   } else {
+      res_incexe.opts_list = (FOPTS **)realloc(res_incexe.opts_list,
+                    sizeof(FOPTS *) * (res_incexe.num_opts + 1));
    }
+   res_incexe.opts_list[res_incexe.num_opts++] = fo;
 }