]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/dird/dird_conf.h
Print block errors once + add RunAfterFailedJob + improve db_find_job_start_time...
[bacula/bacula] / bacula / src / dird / dird_conf.h
index d72a1b6319a240cccd55e1306a2249aee542fe46..5eee0c5da3daec27397ea0b30011aa17450b80eb 100644 (file)
@@ -6,7 +6,7 @@
  *    Version $Id$
  */
 /*
-   Copyright (C) 2000, 2001, 2002 Kern Sibbald and John Walker
+   Copyright (C) 2000-2003 2002 Kern Sibbald and John Walker
 
    This program is free software; you can redistribute it and/or
    modify it under the terms of the GNU General Public License as
 /*
  * Resource codes -- they must be sequential for indexing   
  */
-#define R_FIRST                       1001
-
-#define R_DIRECTOR                    1001
-#define R_CLIENT                      1002
-#define R_JOB                         1003
-#define R_STORAGE                     1004
-#define R_CATALOG                     1005
-#define R_SCHEDULE                    1006
-#define R_FILESET                     1007
-#define R_GROUP                       1008
-#define R_POOL                        1009
-#define R_MSGS                        1010
-#define R_COUNTER                     1011
-#define R_FILEOPTIONS                 1012
-
-#define R_LAST                        R_FILEOPTIONS
+#define R_FIRST              1001
+
+#define R_DIRECTOR           1001
+#define R_CLIENT             1002
+#define R_JOB                1003
+#define R_STORAGE            1004
+#define R_CATALOG            1005
+#define R_SCHEDULE           1006
+#define R_FILESET            1007
+#define R_GROUP              1008
+#define R_POOL               1009
+#define R_MSGS               1010
+#define R_COUNTER            1011
+#define R_CONSOLE            1012
+
+#define R_LAST               R_CONSOLE
 
 /*
  * Some resource attributes
  */
-#define R_NAME                        1020
-#define R_ADDRESS                     1021
-#define R_PASSWORD                    1022
-#define R_TYPE                        1023
-#define R_BACKUP                      1024
+#define R_NAME               1020
+#define R_ADDRESS            1021
+#define R_PASSWORD           1022
+#define R_TYPE               1023
+#define R_BACKUP             1024
 
 
 /* Used for certain KeyWord tables */
-struct s_kw {       
+struct s_kw {      
    char *name;
-   int token;   
+   int token;  
 };
 
 /* Job Level keyword structure */
 struct s_jl {
-   char *level_name;                  /* level keyword */
-   int  level;                        /* level */
-   int  job_type;                     /* JobType permitting this level */
+   char *level_name;                 /* level keyword */
+   int level;                        /* level */
+   int job_type;                     /* JobType permitting this level */
 };
 
 /* Job Type keyword structure */
@@ -77,238 +77,275 @@ struct s_jt {
 };
 
 /* Definition of the contents of each Resource */
+/* Needed for forward references */
+struct SCHED;
+struct CLIENT;
+struct FILESET;
+struct POOL;
+struct RUN;
 
 /* 
- *   Director Resource  
+ *   Director Resource 
  *
  */
-struct s_res_dir {
-   RES   hdr;
-   int   DIRport;                     /* where we listen -- UA port server port */
-   char *DIRaddr;                     /* bind address */
-   char *password;                    /* Password for UA access */
-   char *query_file;                  /* SQL query file */
-   char *working_directory;           /* WorkingDirectory */
-   char *pid_directory;               /* PidDirectory */
-   char *subsys_directory;            /* SubsysDirectory */
-   struct s_res_msgs *messages;       /* Daemon message handler */
-   int   MaxConcurrentJobs;
-   utime_t FDConnectTimeout;          /* timeout for connect in seconds */
-   utime_t SDConnectTimeout;          /* timeout in seconds */
+struct DIRRES {
+   RES  hdr;
+   int  DIRport;                     /* where we listen -- UA port server port */
+   char *DIRaddr;                    /* bind address */
+   char *password;                   /* Password for UA access */
+   int enable_ssl;                   /* Use SSL for UA */
+   char *query_file;                 /* SQL query file */
+   char *working_directory;          /* WorkingDirectory */
+   char *pid_directory;              /* PidDirectory */
+   char *subsys_directory;           /* SubsysDirectory */
+   int require_ssl;                  /* Require SSL for all connections */
+   MSGS *messages;                   /* Daemon message handler */
+   uint32_t MaxConcurrentJobs;       /* Max concurrent jobs for whole director */
+   utime_t FDConnectTimeout;         /* timeout for connect in seconds */
+   utime_t SDConnectTimeout;         /* timeout in seconds */
 };
-typedef struct s_res_dir DIRRES;
+
+/* 
+ *    Console Resource
+ */
+struct CONRES {
+   RES  hdr;
+   char *password;                   /* UA server password */
+   int enable_ssl;                   /* Use SSL */
+};
+
+
+/*
+ *   Catalog Resource
+ *
+ */
+struct CAT {
+   RES  hdr;
+
+   int  db_port;                     /* Port -- not yet implemented */
+   char *db_address;                 /* host name for remote access */
+   char *db_socket;                  /* Socket for local access */
+   char *db_password;
+   char *db_user;
+   char *db_name;
+};
+
 
 /*
  *   Client Resource
  *
  */
-struct s_res_client {
-   RES   hdr;
+struct CLIENT {
+   RES  hdr;
 
-   int   FDport;                      /* Where File daemon listens */
-   int   AutoPrune;                   /* Do automatic pruning? */
-   utime_t FileRetention;             /* file retention period in seconds */
-   utime_t JobRetention;              /* job retention period in seconds */
+   int  FDport;                      /* Where File daemon listens */
+   int  AutoPrune;                   /* Do automatic pruning? */
+   utime_t FileRetention;            /* file retention period in seconds */
+   utime_t JobRetention;             /* job retention period in seconds */
    char *address;
    char *password;
-   struct s_res_cat    *catalog;       /* Catalog resource */
+   CAT *catalog;                     /* Catalog resource */
+   uint32_t MaxConcurrentJobs;       /* Maximume concurrent jobs */
+   uint32_t NumConcurrentJobs;       /* number of concurrent jobs running */
+   int enable_ssl;                   /* Use SSL */
 };
-typedef struct s_res_client CLIENT;
 
 /*
  *   Store Resource
  * 
  */
-struct s_res_store {
-   RES   hdr;
+struct STORE {
+   RES  hdr;
 
-   int   SDport;                      /* port where Directors connect */
-   int   SDDport;                     /* data port for File daemon */
+   int  SDport;                      /* port where Directors connect */
+   int  SDDport;                     /* data port for File daemon */
    char *address;
    char *password;
    char *media_type;
    char *dev_name;   
-   int  autochanger;                  /* set if autochanger */
+   int autochanger;                  /* set if autochanger */
+   uint32_t MaxConcurrentJobs;       /* Maximume concurrent jobs */
+   uint32_t NumConcurrentJobs;       /* number of concurrent jobs running */
+   int enable_ssl;                   /* Use SSL */
 };
-typedef struct s_res_store STORE;
+
 
 /*
- *   Catalog Resource
+ *   Job Resource
  *
  */
-struct s_res_cat {
-   RES   hdr;
+struct JOB {
+   RES  hdr;
+
+   int  JobType;                     /* job type (backup, verify, restore */
+   int  level;                       /* default backup/verify level */
+   int  Priority;                    /* Job priority */
+   int  RestoreJobId;                /* What -- JobId to restore */
+   char *RestoreWhere;               /* Where on disk to restore -- directory */
+   char *RestoreBootstrap;           /* Bootstrap file */
+   char *RunBeforeJob;               /* Run program before Job */
+   char *RunAfterJob;                /* Run program after Job */
+   char *RunAfterFailedJob;          /* Run program after Job that errs */
+   char *ClientRunBeforeJob;         /* Run client program before Job */
+   char *ClientRunAfterJob;          /* Run client program after Job */
+   char *WriteBootstrap;             /* Where to write bootstrap Job updates */
+   int  replace;                     /* How (overwrite, ..) */
+   utime_t MaxRunTime;               /* max run time in seconds */
+   utime_t MaxStartDelay;            /* max start delay in seconds */
+   int PrefixLinks;                  /* prefix soft links with Where path */
+   int PruneJobs;                    /* Force pruning of Jobs */
+   int PruneFiles;                   /* Force pruning of Files */
+   int PruneVolumes;                 /* Force pruning of Volumes */
+   int SpoolAttributes;              /* Set to spool attributes in SD */
+   uint32_t MaxConcurrentJobs;       /* Maximume concurrent jobs */
+   int RescheduleOnError;            /* Set to reschedule on error */
+   int RescheduleTimes;              /* Number of times to reschedule job */
+   utime_t RescheduleInterval;       /* Reschedule interval */
+  
+   MSGS      *messages;              /* How and where to send messages */
+   SCHED     *schedule;              /* When -- Automatic schedule */
+   CLIENT    *client;                /* Who to backup */
+   FILESET   *fileset;               /* What to backup -- Fileset */
+   STORE     *storage;               /* Where is device -- Storage daemon */
+   POOL      *pool;                  /* Where is media -- Media Pool */
+   JOB      *verify_job;             /* Job name to verify */
+   uint32_t NumConcurrentJobs;       /* number of concurrent jobs running */
+};
 
-   int   DBport;                      /* Port -- not yet implemented */
-   char *address;
-   char *db_password;
-   char *db_user;
-   char *db_name;
+#define MAX_FOPTS 30
+
+/* File options structure */
+struct FOPTS {
+   char opts[MAX_FOPTS];             /* options string */
+   alist match;                      /* match string(s) */
+   alist base_list;                  /* list of base names */
 };
-typedef struct s_res_cat CAT;
 
-/*
- *   Job Resource
- *
- */
-struct s_res_job {
-   RES   hdr;
-
-   int   JobType;                     /* job type (backup, verify, restore */
-   int   level;                       /* default backup/verify level */
-   int   RestoreJobId;                /* What -- JobId to restore */
-   char *RestoreWhere;                /* Where on disk to restore -- directory */
-   char *RestoreBootstrap;            /* Bootstrap file */
-   char *RunBeforeJob;                /* Run program before Job */
-   char *RunAfterJob;                 /* Run program after Job */
-   char *WriteBootstrap;              /* Where to write bootstrap Job updates */
-   int   replace;                     /* How (overwrite, ..) */
-   utime_t MaxRunTime;                /* max run time in seconds */
-   utime_t MaxStartDelay;             /* max start delay in seconds */
-   int PrefixLinks;                   /* prefix soft links with Where path */
-   int PruneJobs;                     /* Force pruning of Jobs */
-   int PruneFiles;                    /* Force pruning of Files */
-   int PruneVolumes;                  /* Force pruning of Volumes */
-   int SpoolAttributes;               /* Set to spool attributes in SD */
-
-   struct s_res_msgs   *messages;     /* How and where to send messages */
-   struct s_res_sch    *schedule;     /* When -- Automatic schedule */
-   struct s_res_client *client;       /* Who to backup */
-   struct s_res_fs     *fileset;      /* What to backup -- Fileset */
-   struct s_res_store  *storage;      /* Where is device -- Storage daemon */
-   struct s_res_pool   *pool;         /* Where is media -- Media Pool */
+
+/* This is either an include item or an exclude item */
+struct INCEXE {
+   FOPTS *current_opts;              /* points to current options structure */
+   FOPTS **opts_list;                /* options list */
+   int num_opts;                     /* number of options items */
+   alist name_list;                  /* filename list -- holds char * */
 };
-typedef struct s_res_job JOB;
 
 /* 
  *   FileSet Resource
  *
  */
-struct s_res_fs {
-   RES   hdr;
+struct FILESET {
+   RES  hdr;
 
-   char **include_array;
-   int num_includes;
-   int include_size;
-   char **exclude_array;
+   int new_include;                  /* Set if new include used */
+   INCEXE **include_items;           /* array of incexe structures */
+   int num_includes;                 /* number in array */
+   INCEXE **exclude_items;
    int num_excludes;
-   int exclude_size;
-   int have_MD5;                      /* set if MD5 initialized */
-   struct MD5Context md5c;            /* MD5 of include/exclude */
-   char MD5[50];                      /* base 64 representation of MD5 */
+   int have_MD5;                     /* set if MD5 initialized */
+   struct MD5Context md5c;           /* MD5 of include/exclude */
+   char MD5[30];                     /* base 64 representation of MD5 */
 };
-typedef struct s_res_fs FILESET;
-
-/*
- * FileOptions Resource (options for Includes)
- */
-struct s_res_fo {
-   RES  hdr;
 
-   char opts[50];                     /* Options string */
-   struct s_applyto *applyto;         /* applyto strings */
-}; 
-typedef struct s_res_fo FILEOPTIONS;
  
-
 /* 
  *   Schedule Resource
  *
  */
-struct s_res_sch {
-   RES   hdr;
+struct SCHED {
+   RES  hdr;
 
-   struct s_run *run;
+   RUN *run;
 };
-typedef struct s_res_sch SCHED;
 
 /*
  *   Group Resource (not used)
  *
  */
-struct s_res_group {
-   RES   hdr;
+struct GROUP {
+   RES  hdr;
 };
-typedef struct s_res_group GROUP;
 
 /*
  *   Counter Resource
  */
-struct s_res_counter {
-   RES   hdr;
-
-   int32_t MinValue;                  /* Minimum value */
-   int32_t MaxValue;                  /* Maximum value */
-   int     Global;                    /* global/local */
-   char  *WrapCounter;                /* Wrap counter name */
+struct COUNTER {
+   RES  hdr;
+
+   int32_t  MinValue;                /* Minimum value */
+   int32_t  MaxValue;                /* Maximum value */
+   int32_t  CurrentValue;            /* Current value */
+   COUNTER *WrapCounter;             /* Wrap counter name */
+   CAT    *Catalog;                  /* Where to store */
+   bool     created;                 /* Created in DB */
 };
-typedef struct s_res_counter COUNTER;
 
 /*
  *   Pool Resource   
  *
  */
-struct s_res_pool {
-   RES   hdr;
-
-   struct s_res_counter counter;      /* Counter resources */
-   char *pool_type;                   /* Pool type */
-   char *label_format;                /* Label format string */
-   int   use_catalog;                 /* maintain catalog for media */
-   int   catalog_files;               /* maintain file entries in catalog */
-   int   use_volume_once;             /* write on volume only once */
-   int   accept_any_volume;           /* accept any volume */
-   uint32_t max_volumes;              /* max number of volumes */
-   utime_t VolRetention;              /* volume retention period in seconds */
-   utime_t VolUseDuration;            /* duration volume can be used */
-   uint32_t MaxVolJobs;               /* Maximum jobs on the Volume */
-   uint32_t MaxVolFiles;              /* Maximum files on the Volume */
-   uint64_t MaxVolBytes;              /* Maximum bytes on the Volume */
-   int   AutoPrune;                   /* default for pool auto prune */
-   int   Recycle;                     /* default for media recycle yes/no */
+struct POOL {
+   RES  hdr;
+
+   char *pool_type;                  /* Pool type */
+   char *label_format;               /* Label format string */
+   char *cleaning_prefix;            /* Cleaning label prefix */
+   int  use_catalog;                 /* maintain catalog for media */
+   int  catalog_files;               /* maintain file entries in catalog */
+   int  use_volume_once;             /* write on volume only once */
+   int  accept_any_volume;           /* accept any volume */
+   int  purge_oldest_volume;         /* purge oldest volume */
+   int  recycle_oldest_volume;       /* attempt to recycle oldest volume */
+   int  recycle_current_volume;      /* attempt recycle of current volume */
+   uint32_t max_volumes;             /* max number of volumes */
+   utime_t VolRetention;             /* volume retention period in seconds */
+   utime_t VolUseDuration;           /* duration volume can be used */
+   uint32_t MaxVolJobs;              /* Maximum jobs on the Volume */
+   uint32_t MaxVolFiles;             /* Maximum files on the Volume */
+   uint64_t MaxVolBytes;             /* Maximum bytes on the Volume */
+   int  AutoPrune;                   /* default for pool auto prune */
+   int  Recycle;                     /* default for media recycle yes/no */
 };
-typedef struct s_res_pool POOL;
 
 
 /* Define the Union of all the above
  * resource structure definitions.
  */
-union u_res {
-   struct s_res_dir     res_dir;
-   struct s_res_client  res_client;
-   struct s_res_store   res_store;
-   struct s_res_cat     res_cat;
-   struct s_res_job     res_job;
-   struct s_res_fs      res_fs;
-   struct s_res_sch     res_sch;
-   struct s_res_group   res_group;
-   struct s_res_pool    res_pool;
-   struct s_res_msgs    res_msgs;
-   struct s_res_counter res_counter;
-   struct s_res_fo      res_fo;
-   RES hdr;
+union URES {
+   DIRRES     res_dir;
+   CONRES     res_con;
+   CLIENT     res_client;
+   STORE      res_store;
+   CAT       res_cat;
+   JOB       res_job;
+   FILESET    res_fs;
+   SCHED      res_sch;
+   GROUP      res_group;
+   POOL       res_pool;
+   MSGS       res_msgs;
+   COUNTER    res_counter;
+   RES       hdr;
 };
 
-typedef union u_res URES;
 
 
 /* Run structure contained in Schedule Resource */
-struct s_run {
-   struct s_run *next;                /* points to next run record */
-   int level;                         /* level override */
+struct RUN {
+   RUN *next;                        /* points to next run record */
+   int level;                        /* level override */
+   int Priority;                     /* priority override */
    int job_type;  
-   POOL *pool;                        /* Pool override */
-   STORE *storage;                    /* Storage override */
-   MSGS *msgs;                        /* Messages override */
+   POOL *pool;                       /* Pool override */
+   STORE *storage;                   /* Storage override */
+   MSGS *msgs;                       /* Messages override */
    char *since;
    int level_no;
-   int minute;                        /* minute to run job */
-   time_t last_run;                   /* last time run */
-   time_t next_run;                   /* next time to run */
+   int minute;                       /* minute to run job */
+   time_t last_run;                  /* last time run */
+   time_t next_run;                  /* next time to run */
    char hour[nbytes_for_bits(24)];    /* bit set for each hour */
    char mday[nbytes_for_bits(31)];    /* bit set for each day of month */
    char month[nbytes_for_bits(12)];   /* bit set for each month */
    char wday[nbytes_for_bits(7)];     /* bit set for each day of the week */
    char wpos[nbytes_for_bits(5)];     /* week position */
 };
-typedef struct s_run RUN;