/*
Bacula® - The Network Backup Solution
- Copyright (C) 2000-2009 Free Software Foundation Europe e.V.
+ Copyright (C) 2000-2010 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.
*
* Kern Sibbald, Nov MM
*
- * Version $Id$
*/
#define JT_SCAN 'S' /* Scan Job */
/* Job Status. Some of these are stored in the DB */
-#define JS_Created 'C' /* created but not yet running */
-#define JS_Running 'R' /* running */
+#define JS_Canceled 'A' /* canceled by user */
#define JS_Blocked 'B' /* blocked */
-#define JS_Terminated 'T' /* terminated normally */
-#define JS_Warnings 'W' /* Terminated normally with warnings */
-#define JS_ErrorTerminated 'E' /* Job terminated in error */
-#define JS_Error 'e' /* Non-fatal error */
-#define JS_FatalError 'f' /* Fatal error */
+#define JS_Created 'C' /* created but not yet running */
#define JS_Differences 'D' /* Verify differences */
-#define JS_Canceled 'A' /* canceled by user */
-#define JS_Incomplete 'I' /* Incomplete Job */
+#define JS_ErrorTerminated 'E' /* Job terminated in error */
#define JS_WaitFD 'F' /* waiting on File daemon */
-#define JS_WaitSD 'S' /* waiting on the Storage daemon */
-#define JS_WaitMedia 'm' /* waiting for new media */
+#define JS_Incomplete 'I' /* Incomplete Job */
+#define JS_DataCommitting 'L' /* Committing data (last despool) */
#define JS_WaitMount 'M' /* waiting for Mount */
-#define JS_WaitStoreRes 's' /* Waiting for storage resource */
-#define JS_WaitJobRes 'j' /* Waiting for job resource */
+#define JS_Running 'R' /* running */
+#define JS_WaitSD 'S' /* waiting on the Storage daemon */
+#define JS_Terminated 'T' /* terminated normally */
+#define JS_Warnings 'W' /* Terminated normally with warnings */
+
+#define JS_AttrDespooling 'a' /* SD despooling attributes */
#define JS_WaitClientRes 'c' /* Waiting for Client resource */
#define JS_WaitMaxJobs 'd' /* Waiting for maximum jobs */
-#define JS_WaitStartTime 't' /* Waiting for start time */
-#define JS_WaitPriority 'p' /* Waiting for higher priority jobs to finish */
-#define JS_AttrDespooling 'a' /* SD despooling attributes */
+#define JS_Error 'e' /* Non-fatal error */
+#define JS_FatalError 'f' /* Fatal error */
#define JS_AttrInserting 'i' /* Doing batch insert file records */
+#define JS_WaitJobRes 'j' /* Waiting for job resource */
#define JS_DataDespooling 'l' /* Doing data despooling */
-#define JS_DataCommitting 'L' /* Committing data (last despool) */
+#define JS_WaitMedia 'm' /* waiting for new media */
+#define JS_WaitPriority 'p' /* Waiting for higher priority jobs to finish */
+#define JS_WaitStoreRes 's' /* Waiting for storage resource */
+#define JS_WaitStartTime 't' /* Waiting for start time */
/* Migration selection types */
enum {
void unlock() {V(mutex); };
void inc_use_count(void) {lock(); _use_count++; unlock(); };
void dec_use_count(void) {lock(); _use_count--; unlock(); };
- int32_t use_count() { return _use_count; };
+ int32_t use_count() const { return _use_count; };
void init_mutex(void) {pthread_mutex_init(&mutex, NULL); };
void destroy_mutex(void) {pthread_mutex_destroy(&mutex); };
bool is_job_canceled() {return job_canceled(this); };
void setJobLevel(int32_t JobLevel) { m_JobLevel = JobLevel; };
void set_JobType(int32_t JobType) { m_JobType = JobType; };
void setJobType(int32_t JobType) { m_JobType = JobType; };
- int32_t get_JobType() { return m_JobType; };
- int32_t getJobType() { return m_JobType; };
- int32_t get_JobLevel() { return m_JobLevel; };
- int32_t getJobLevel() { return m_JobLevel; };
- bool no_client_used() {
+ int32_t getJobType() const { return m_JobType; };
+ int32_t getJobLevel() const { return m_JobLevel; };
+ int32_t getJobStatus() const { return JobStatus; };
+ bool no_client_used() const {
return (m_JobType == JT_MIGRATE || m_JobType == JT_COPY ||
m_JobLevel == L_VIRTUAL_FULL);
};
BSOCK *file_bsock; /* File daemon connection socket */
JCR_free_HANDLER *daemon_free_jcr; /* Local free routine */
dlist *msg_queue; /* Queued messages */
+ pthread_mutex_t msg_queue_mutex; /* message queue mutex */
+ bool dequeuing_msgs; /* Set when dequeuing messages */
alist job_end_push; /* Job end pushed calls */
- bool dequeuing; /* dequeuing messages */
POOLMEM *VolumeName; /* Volume name desired -- pool_memory */
POOLMEM *errmsg; /* edited error message */
char Job[MAX_NAME_LENGTH]; /* Unique name of this Job */
save_pkt *plugin_sp; /* plugin save packet */
char *plugin_options; /* user set options for plugin */
bool cmd_plugin; /* Set when processing a command Plugin = */
+ POOLMEM *comment; /* Comment for this Job */
/* Daemon specific part of JCR */
/* This should be empty in the library */
bool run_full_pool_override;
bool run_inc_pool_override;
bool run_diff_pool_override;
+ bool sd_canceled; /* set if SD canceled */
FILESET *fileset; /* FileSet resource */
CAT *catalog; /* Catalog resource */
MSGS *messages; /* Default message handler */
bool stats_enabled; /* Keep all job records in a table for long term statistics */
bool no_maxtime; /* Don't check Max*Time for this JCR */
bool keep_sd_auth_key; /* Clear or not the SD auth key after connection*/
+ bool use_accurate_chksum; /* Use or not checksum option in accurate code */
#endif /* DIRECTOR_DAEMON */
alist *reserve_msgs; /* reserve fail messages */
bool write_part_after_job; /* Set to write part after job */
bool PreferMountedVols; /* Prefer mounted vols rather than new */
+ bool Resched; /* Job may be rescheduled */
/* Parmaters for Open Read Session */
BSR *bsr; /* Bootstrap record -- has everything */
};
extern struct s_last_job last_job;
-extern DLL_IMP_EXP dlist * last_jobs;
+extern DLL_IMP_EXP dlist *last_jobs;
/* The following routines are found in lib/jcr.c */
projects / bacula / bacula / blobdiff