/*
- Bacula® - The Network Backup Solution
-
- Copyright (C) 2000-2007 Free Software Foundation Europe e.V.
-
- The main author of Bacula is Kern Sibbald, with contributions from
- many others, a complete list can be found in the file AUTHORS.
- This program is Free Software; you can redistribute it and/or
- modify it under the terms of version two of the GNU General Public
- License as published by the Free Software Foundation and included
- in the file LICENSE.
-
- This program is distributed in the hope that it will be useful, but
- WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- General Public License for more details.
-
- You should have received a copy of the GNU General Public License
- along with this program; if not, write to the Free Software
- Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
- 02110-1301, USA.
-
- Bacula® is a registered trademark of John Walker.
- The licensor of Bacula is the Free Software Foundation Europe
- (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich,
- Switzerland, email:ftf@fsfeurope.org.
+ Bacula(R) - The Network Backup Solution
+
+ Copyright (C) 2000-2015 Kern Sibbald
+ Copyright (C) 2000-2014 Free Software Foundation Europe e.V.
+
+ The original author of Bacula is Kern Sibbald, with contributions
+ from many others, a complete list can be found in the file AUTHORS.
+
+ You may use this file and others of this release according to the
+ license defined in the LICENSE file, which includes the Affero General
+ Public License, v3.0 ("AGPLv3") and some additional permissions and
+ terms pursuant to its AGPLv3 Section 7.
+
+ This notice must be preserved when any source code is
+ conveyed and/or propagated.
+
+ Bacula(R) is a registered trademark of Kern Sibbald.
*/
/*
* Director specific configuration and defines
*
* Kern Sibbald, Feb MM
*
- * Version $Id$
*/
/* NOTE: #includes at the end of this file */
R_COUNTER,
R_CONSOLE,
R_JOBDEFS,
- R_DEVICE,
+ R_DEVICE, /* This is the real last device class */
+
R_FIRST = R_DIRECTOR,
R_LAST = R_DEVICE /* keep this updated */
};
R_BACKUP
};
-
-/* Used for certain KeyWord tables */
-struct s_kw {
+/* Options for FileSet keywords */
+struct s_fs_opt {
const char *name;
- int token;
+ int keyword;
+ const char *option;
};
/* Job Level keyword structure */
struct s_jl {
- const char *level_name; /* level keyword */
- int level; /* level */
- int job_type; /* JobType permitting this level */
+ const char *level_name; /* level keyword */
+ int32_t level; /* level */
+ int32_t job_type; /* JobType permitting this level */
};
/* Job Type keyword structure */
struct s_jt {
const char *type_name;
- int job_type;
+ int32_t job_type;
};
/* Definition of the contents of each Resource */
public:
RES hdr;
dlist *DIRaddrs;
+ dlist *DIRsrc_addr; /* address to source connections from */
char *password; /* Password for UA access */
char *query_file; /* SQL query file */
char *working_directory; /* WorkingDirectory */
const char *scripts_directory; /* ScriptsDirectory */
+ const char *plugin_directory; /* Plugin Directory */
char *pid_directory; /* PidDirectory */
char *subsys_directory; /* SubsysDirectory */
MSGS *messages; /* Daemon message handler */
uint32_t MaxConcurrentJobs; /* Max concurrent jobs for whole director */
+ uint32_t MaxSpawnedJobs; /* Max Jobs that can be started by Migration/Copy */
+ uint32_t MaxConsoleConnect; /* Max concurrent console session */
+ uint32_t MaxReload; /* Maximum reload requests */
utime_t FDConnectTimeout; /* timeout for connect in seconds */
utime_t SDConnectTimeout; /* timeout in seconds */
utime_t heartbeat_interval; /* Interval to send heartbeats */
char *tls_dhfile; /* TLS Diffie-Hellman Parameters */
alist *tls_allowed_cns; /* TLS Allowed Clients */
TLS_CONTEXT *tls_ctx; /* Shared TLS Context */
+ utime_t stats_retention; /* Stats retention period in seconds */
+ bool tls_authenticate; /* Authenticated with TLS */
bool tls_enable; /* Enable TLS */
bool tls_require; /* Require TLS */
bool tls_verify_peer; /* TLS Verify Client Certificate */
-
+ char *verid; /* Custom Id to print in version command */
/* Methods */
char *name() const;
};
/*
* Device Resource
* This resource is a bit different from the other resources
- * because it is not defined in the Director
+ * because it is not defined in the Director
* by DEVICE { ... }, but rather by a "reference" such as
* DEVICE = xxx; Then when the Director connects to the
* SD, it requests the information about the device.
RES hdr;
bool found; /* found with SD */
- int num_writers; /* number of writers */
- int max_writers; /* = 1 for files */
- int reserved; /* number of reserves */
- int num_drives; /* for autochanger */
+ int32_t num_writers; /* number of writers */
+ int32_t max_writers; /* = 1 for files */
+ int32_t reserved; /* number of reserves */
+ int32_t num_drives; /* for autochanger */
bool autochanger; /* set if device is autochanger */
bool open; /* drive open */
bool append; /* in append mode */
FileSet_ACL,
Catalog_ACL,
Where_ACL,
+ PluginOptions_ACL,
Num_ACL /* keep last */
};
char *tls_dhfile; /* TLS Diffie-Hellman Parameters */
alist *tls_allowed_cns; /* TLS Allowed Clients */
TLS_CONTEXT *tls_ctx; /* Shared TLS Context */
+ bool tls_authenticate; /* Authenticated with TLS */
bool tls_enable; /* Enable TLS */
bool tls_require; /* Require TLS */
bool tls_verify_peer; /* TLS Verify Client Certificate */
public:
RES hdr;
- int db_port; /* Port */
+ uint32_t db_port; /* Port */
char *db_address; /* host name for remote access */
char *db_socket; /* Socket for local access */
char *db_password;
char *db_user;
char *db_name;
- int mult_db_connections; /* set if multiple connections wanted */
+ char *db_driver; /* Select appropriate driver */
+ uint32_t mult_db_connections; /* set for multiple db connections */
+ bool disable_batch_insert; /* set to disable batch inserts */
/* Methods */
char *name() const;
+ char *display(POOLMEM *dst); /* Get catalog information */
};
inline char *CAT::name() const { return hdr.name; }
public:
RES hdr;
- int FDport; /* Where File daemon listens */
+ uint32_t FDport; /* Where File daemon listens */
utime_t FileRetention; /* file retention period in seconds */
utime_t JobRetention; /* job retention period in seconds */
+ utime_t SnapRetention; /* Snapshot retention period in seconds */
utime_t heartbeat_interval; /* Interval to send heartbeats */
char *address;
+ char *fd_storage_address; /* Storage address to use from FD side */
char *password;
CAT *catalog; /* Catalog resource */
- uint32_t MaxConcurrentJobs; /* Maximume concurrent jobs */
- uint32_t NumConcurrentJobs; /* number of concurrent jobs running */
+ int32_t MaxConcurrentJobs; /* Maximum concurrent jobs */
+ int32_t NumConcurrentJobs; /* number of concurrent jobs running */
char *tls_ca_certfile; /* TLS CA Certificate File */
char *tls_ca_certdir; /* TLS CA Certificate Directory */
char *tls_certfile; /* TLS Client Certificate File */
char *tls_keyfile; /* TLS Client Key File */
alist *tls_allowed_cns; /* TLS Allowed Clients */
TLS_CONTEXT *tls_ctx; /* Shared TLS Context */
+ bool tls_authenticate; /* Authenticated with TLS */
bool tls_enable; /* Enable TLS */
bool tls_require; /* Require TLS */
+ bool enabled; /* Set if client enabled */
bool AutoPrune; /* Do automatic pruning? */
+ bool sd_calls_client; /* SD calls the client */
+ int64_t max_bandwidth; /* Limit speed on this client */
/* Methods */
char *name() const;
public:
RES hdr;
- int SDport; /* port where Directors connect */
- int SDDport; /* data port for File daemon */
+ uint32_t SDport; /* port where Directors connect */
+ uint32_t SDDport; /* data port for File daemon */
char *address;
+ char *fd_storage_address; /* Storage address to use from FD side */
char *password;
char *media_type;
alist *device; /* Alternate devices for this Storage */
- uint32_t MaxConcurrentJobs; /* Maximume concurrent jobs */
- uint32_t NumConcurrentJobs; /* number of concurrent jobs running */
+ int32_t MaxConcurrentJobs; /* Maximum concurrent jobs */
+ int32_t MaxConcurrentReadJobs; /* Maximum concurrent jobs reading */
+ int32_t NumConcurrentJobs; /* number of concurrent jobs running */
+ int32_t NumConcurrentReadJobs; /* number of jobs reading */
char *tls_ca_certfile; /* TLS CA Certificate File */
char *tls_ca_certdir; /* TLS CA Certificate Directory */
char *tls_certfile; /* TLS Client Certificate File */
char *tls_keyfile; /* TLS Client Key File */
TLS_CONTEXT *tls_ctx; /* Shared TLS Context */
+ bool tls_authenticate; /* Authenticated with TLS */
bool tls_enable; /* Enable TLS */
bool tls_require; /* Require TLS */
bool enabled; /* Set if device is enabled */
- bool autochanger; /* set if autochanger */
+ bool AllowCompress; /* set if this Storage should allow jobs to enable compression */
+ bool autochanger; /* set if we are part of an autochanger */
int64_t StorageId; /* Set from Storage DB record */
utime_t heartbeat_interval; /* Interval to send heartbeats */
- int drives; /* number of drives in autochanger */
+ uint32_t drives; /* number of drives in autochanger */
/* Methods */
char *dev_name() const;
};
inline char *STORE::dev_name() const
-{
+{
DEVICE *dev = (DEVICE *)device->first();
- return dev->hdr.name;
+ return dev->name();
}
inline char *STORE::name() const { return hdr.name; }
POOLMEM *store_source;
/* Methods */
- USTORE() { store = NULL; store_source = get_pool_memory(PM_MESSAGE);
+ USTORE() { store = NULL; store_source = get_pool_memory(PM_MESSAGE);
*store_source = 0; };
- ~USTORE() { destroy(); }
+ ~USTORE() { destroy(); }
void set_source(const char *where);
void destroy();
};
public:
RES hdr;
- int JobType; /* job type (backup, verify, restore */
- int JobLevel; /* default backup/verify level */
- int Priority; /* Job priority */
- int RestoreJobId; /* What -- JobId to restore */
+ uint32_t JobType; /* job type (backup, verify, restore */
+ uint32_t JobLevel; /* default backup/verify level */
+ uint32_t RestoreJobId; /* What -- JobId to restore */
+ uint32_t replace; /* How (overwrite, ..) */
+ uint32_t selection_type;
+
+ int32_t Priority; /* Job priority */
+ int32_t RescheduleTimes; /* Number of times to reschedule job */
+
char *RestoreWhere; /* Where on disk to restore -- directory */
char *RegexWhere; /* RegexWhere option */
char *strip_prefix; /* remove prefix from filename */
char *add_prefix; /* add prefix to filename */
char *add_suffix; /* add suffix to filename -- .old */
- bool where_use_regexp; /* true if RestoreWhere is a BREGEXP */
char *RestoreBootstrap; /* Bootstrap file */
- alist *RunScripts; /* Run {client} program {after|before} Job */
+ char *PluginOptions; /* Options to pass to plugin */
union {
char *WriteBootstrap; /* Where to write bootstrap Job updates */
char *WriteVerifyList; /* List of changed files */
};
- int replace; /* How (overwrite, ..) */
utime_t MaxRunTime; /* max run time in seconds */
utime_t MaxWaitTime; /* max blocking time in seconds */
- utime_t FullMaxWaitTime; /* Max Full job wait time */
- utime_t DiffMaxWaitTime; /* Max Differential job wait time */
- utime_t IncMaxWaitTime; /* Max Incremental job wait time */
+ utime_t FullMaxRunTime; /* Max Full job run time */
+ utime_t DiffMaxRunTime; /* Max Differential job run time */
+ utime_t IncMaxRunTime; /* Max Incremental job run time */
utime_t MaxStartDelay; /* max start delay in seconds */
+ utime_t MaxRunSchedTime; /* max run time in seconds from Scheduled time*/
utime_t RescheduleInterval; /* Reschedule interval */
- utime_t JobRetention; /* job retention period in seconds */
- uint32_t MaxConcurrentJobs; /* Maximum concurrent jobs */
+ utime_t MaxFullInterval; /* Maximum time interval between Fulls */
+ utime_t MaxDiffInterval; /* Maximum time interval between Diffs */
+ utime_t DuplicateJobProximity; /* Permitted time between duplicicates */
+ utime_t SnapRetention; /* Snapshot retention period in seconds */
int64_t spool_size; /* Size of spool file for this job */
- int RescheduleTimes; /* Number of times to reschedule job */
- bool RescheduleOnError; /* Set to reschedule on error */
- bool PrefixLinks; /* prefix soft links with Where path */
- bool PruneJobs; /* Force pruning of Jobs */
- bool PruneFiles; /* Force pruning of Files */
- bool PruneVolumes; /* Force pruning of Volumes */
- bool SpoolAttributes; /* Set to spool attributes in SD */
- bool spool_data; /* Set to spool data in SD */
- bool rerun_failed_levels; /* Upgrade to rerun failed levels */
- bool PreferMountedVolumes; /* Prefer vols mounted rather than new one */
- bool write_part_after_job; /* Set to write part after job in SD */
- bool enabled; /* Set if job enabled */
- bool OptimizeJobScheduling; /* Set if we should optimize Job scheduling */
-
+ int32_t MaxConcurrentJobs; /* Maximum concurrent jobs */
+ int32_t NumConcurrentJobs; /* number of concurrent jobs running */
+ uint32_t MaxSpawnedJobs; /* Max Jobs that can be started by Migration/Copy */
+ bool allow_mixed_priority; /* Allow jobs with higher priority concurrently with this */
+
MSGS *messages; /* How and where to send messages */
SCHED *schedule; /* When -- Automatic schedule */
CLIENT *client; /* Who to backup */
FILESET *fileset; /* What to backup -- Fileset */
alist *storage; /* Where is device -- list of Storage to be used */
POOL *pool; /* Where is media -- Media Pool */
+ POOL *next_pool; /* Next Pool for Copy/Migrate/VirtualFull */
POOL *full_pool; /* Pool for Full backups */
POOL *inc_pool; /* Pool for Incremental backups */
POOL *diff_pool; /* Pool for Differental backups */
char *selection_pattern;
- int selection_type;
union {
- JOB *verify_job; /* Job name to verify */
+ JOB *verify_job; /* Job name to verify */
};
JOB *jobdefs; /* Job defaults */
alist *run_cmds; /* Run commands */
- uint32_t NumConcurrentJobs; /* number of concurrent jobs running */
+ alist *RunScripts; /* Run {client} program {after|before} Job */
+
+ bool where_use_regexp; /* true if RestoreWhere is a BREGEXP */
+ bool RescheduleOnError; /* Set to reschedule on error */
+ bool RescheduleIncompleteJobs; /* Set to reschedule incomplete Jobs */
+ bool PrefixLinks; /* prefix soft links with Where path */
+ bool PruneJobs; /* Force pruning of Jobs */
+ bool PruneFiles; /* Force pruning of Files */
+ bool PruneVolumes; /* Force pruning of Volumes */
+ bool SpoolAttributes; /* Set to spool attributes in SD */
+ bool spool_data; /* Set to spool data in SD */
+ bool rerun_failed_levels; /* Upgrade to rerun failed levels */
+ bool PreferMountedVolumes; /* Prefer vols mounted rather than new one */
+ bool write_part_after_job; /* Set to write part after job in SD */
+ bool enabled; /* Set if job enabled */
+ bool accurate; /* Set if it is an accurate backup job */
+ bool AllowDuplicateJobs; /* Allow duplicate jobs */
+ bool AllowHigherDuplicates; /* Permit Higher Level */
+ bool CancelLowerLevelDuplicates; /* Cancel lower level backup jobs */
+ bool CancelQueuedDuplicates; /* Cancel queued jobs */
+ bool CancelRunningDuplicates; /* Cancel Running jobs */
+ bool PurgeMigrateJob; /* Purges source job on completion */
+ bool IgnoreDuplicateJobChecking; /* Set to ignore Duplicate Job Checking */
+
+ alist *base; /* Base jobs */
+ int64_t max_bandwidth; /* Speed limit on this job */
/* Methods */
char *name() const;
inline char *JOB::name() const { return hdr.name; }
+/* Define FileSet Options keyword values */
+enum {
+ INC_KW_NONE,
+ INC_KW_COMPRESSION,
+ INC_KW_DIGEST,
+ INC_KW_ENCRYPTION,
+ INC_KW_VERIFY,
+ INC_KW_BASEJOB,
+ INC_KW_ACCURATE,
+ INC_KW_ONEFS,
+ INC_KW_RECURSE,
+ INC_KW_SPARSE,
+ INC_KW_HARDLINK,
+ 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,
+ INC_KW_IGNORECASE,
+ INC_KW_HFSPLUS,
+ INC_KW_NOATIME,
+ INC_KW_ENHANCEDWILD,
+ INC_KW_CHKCHANGES,
+ INC_KW_STRIPPATH,
+ INC_KW_HONOR_NODUMP,
+ INC_KW_XATTR,
+ INC_KW_MAX /* Keep this last */
+};
+
+
#undef MAX_FOPTS
-#define MAX_FOPTS 34
+#define MAX_FOPTS 50
/* File options structure */
struct FOPTS {
alist drivetype; /* drive type limitation */
char *reader; /* reader program */
char *writer; /* writer program */
+ char *plugin; /* plugin program */
};
/* This is either an include item or an exclude item */
struct INCEXE {
+ char opt_present[INC_KW_MAX+1]; /* set if option is present in conf file */
FOPTS *current_opts; /* points to current options structure */
FOPTS **opts_list; /* options list */
- int num_opts; /* number of options items */
+ int32_t num_opts; /* number of options items */
alist name_list; /* filename list -- holds char * */
+ alist plugin_list; /* filename list for plugins */
+ char *ignoredir; /* ignoredir string */
};
/*
bool new_include; /* Set if new include used */
INCEXE **include_items; /* array of incexe structures */
- int num_includes; /* number in array */
+ int32_t num_includes; /* number in array */
INCEXE **exclude_items;
- int num_excludes;
+ int32_t num_excludes;
bool have_MD5; /* set if MD5 initialized */
struct MD5Context md5c; /* MD5 of include/exclude */
char MD5[30]; /* base 64 representation of MD5 */
bool ignore_fs_changes; /* Don't force Full if FS changed */
bool enable_vss; /* Enable Volume Shadow Copy */
+ bool enable_snapshot; /* Enable Snapshot */
/* Methods */
char *name() const;
RES hdr;
RUN *run;
+ bool enabled; /* set if enabled */
+ /* Methods */
+ char *name() const;
};
+inline char *SCHED::name() const { return hdr.name; }
+
/*
* Counter Resource
*/
bool recycle_current_volume; /* attempt recycle of current volume */
bool AutoPrune; /* default for pool auto prune */
bool Recycle; /* default for media recycle yes/no */
+ uint32_t action_on_purge; /* action on purge, e.g. truncate the disk volume */
POOL *RecyclePool; /* RecyclePool destination when media is purged */
+ POOL *ScratchPool; /* ScratchPool source when requesting media */
alist *CopyPool; /* List of copy pools */
- CAT *Catalog; /* Catalog to be used */
+ CAT *catalog; /* Catalog to be used */
+ utime_t FileRetention; /* file retention period in seconds */
+ utime_t JobRetention; /* job retention period in seconds */
+
/* Methods */
char *name() const;
};
inline char *POOL::name() const { return hdr.name; }
-
-
/* Define the Union of all the above
* resource structure definitions.
*/
class RUN {
public:
RUN *next; /* points to next run record */
- int level; /* level override */
- int Priority; /* priority override */
- int job_type;
+ uint32_t level; /* level override */
+ int32_t Priority; /* priority override */
+ uint32_t job_type;
+ utime_t MaxRunSchedTime; /* max run time in sec from Sched time */
+ bool MaxRunSchedTime_set; /* MaxRunSchedTime given */
bool spool_data; /* Data spooling override */
bool spool_data_set; /* Data spooling override given */
+ bool accurate; /* accurate */
+ bool accurate_set; /* accurate given */
bool write_part_after_job; /* Write part after job override */
bool write_part_after_job_set; /* Write part after job override given */
-
+ bool priority_set; /* priority override given */
+ bool level_set; /* level override given */
+
POOL *pool; /* Pool override */
+ POOL *next_pool; /* Next pool override */
POOL *full_pool; /* Pool override */
POOL *inc_pool; /* Pool override */
POOL *diff_pool; /* Pool override */
STORE *storage; /* Storage override */
MSGS *msgs; /* Messages override */
char *since;
- int level_no;
- int minute; /* minute to run job */
+ uint32_t level_no;
+ uint32_t minute; /* minute to run job */
time_t last_run; /* last time run */
time_t next_run; /* next time to run */
+ bool last_day_set; /* set if last_day is used */
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 mday[nbytes_for_bits(32)]; /* 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 wom[nbytes_for_bits(5)]; /* week of month */
+ char wom[nbytes_for_bits(6)]; /* week of month */
char woy[nbytes_for_bits(54)]; /* week of year */
};
#define GetJobResWithName(x) ((JOB *)GetResWithName(R_JOB, (x)))
#define GetFileSetResWithName(x) ((FILESET *)GetResWithName(R_FILESET, (x)))
#define GetCatalogResWithName(x) ((CAT *)GetResWithName(R_CATALOG, (x)))
+
+/* Imported subroutines */
+void store_jobtype(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_level(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_replace(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_migtype(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_acl(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_ac_res(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_actiononpurge(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_inc(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_regex(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_wild(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_fstype(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_drivetype(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_opts(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_lopts(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_base(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_plugin(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_run(LEX *lc, RES_ITEM *item, int index, int pass);
+void store_runscript(LEX *lc, RES_ITEM *item, int index, int pass);
projects / bacula / bacula / blobdiff