blob: 00f22b50bd9981734183dd8d01d0e96dd650d7a0 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
|
/*
BAREOS® - Backup Archiving REcovery Open Sourced
Copyright (C) 2000-2012 Free Software Foundation Europe e.V.
Copyright (C) 2011-2012 Planets Communications B.V.
Copyright (C) 2013-2022 Bareos GmbH & Co. KG
This program is Free Software; you can redistribute it and/or
modify it under the terms of version three of the GNU Affero 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
Affero General Public License for more details.
You should have received a copy of the GNU Affero 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.
*/
#ifndef BAREOS_DIRD_JCR_PRIVATE_H_
#define BAREOS_DIRD_JCR_PRIVATE_H_
#include "cats/cats.h"
#include "dird/client_connection_handshake_mode.h"
#include "dird/job_trigger.h"
typedef struct s_tree_root TREE_ROOT;
class ConfigResourcesContainer;
namespace directordaemon {
class JobResource;
class StorageResource;
class ClientResource;
class PoolResource;
class FilesetResource;
class CatalogResource;
} // namespace directordaemon
namespace storagedaemon {
struct BootStrapRecord;
} // namespace storagedaemon
#define JobWaiting(jcr) \
(jcr->job_started \
&& (jcr->getJobStatus() == JS_WaitFD || jcr->getJobStatus() == JS_WaitSD \
|| jcr->getJobStatus() == JS_WaitMedia \
|| jcr->getJobStatus() == JS_WaitMount \
|| jcr->getJobStatus() == JS_WaitStoreRes \
|| jcr->getJobStatus() == JS_WaitJobRes \
|| jcr->getJobStatus() == JS_WaitClientRes \
|| jcr->getJobStatus() == JS_WaitMaxJobs \
|| jcr->getJobStatus() == JS_WaitPriority \
|| jcr->impl->SDJobStatus == JS_WaitMedia \
|| jcr->impl->SDJobStatus == JS_WaitMount \
|| jcr->impl->SDJobStatus == JS_WaitDevice \
|| jcr->impl->SDJobStatus == JS_WaitMaxJobs))
/* clang-format off */
struct Resources {
directordaemon::JobResource* job{}; /**< Job resource */
directordaemon::JobResource* verify_job{}; /**< Job resource of verify previous job */
directordaemon::JobResource* previous_job{}; /**< Job resource of migration previous job */
directordaemon::StorageResource* read_storage{}; /**< Selected read storage */
directordaemon::StorageResource* write_storage{}; /**< Selected write storage */
directordaemon::StorageResource* paired_read_write_storage{}; /*< Selected paired storage (savedwrite_storage or read_storage)*/
directordaemon::ClientResource* client{}; /**< Client resource */
directordaemon::PoolResource* pool{}; /**< Pool resource = write for migration */
directordaemon::PoolResource* rpool{}; /**< Read pool. Used only in migration */
directordaemon::PoolResource* full_pool{}; /**< Full backup pool resource */
directordaemon::PoolResource* vfull_pool{}; /**< Virtual Full backup pool resource */
directordaemon::PoolResource* inc_pool{}; /**< Incremental backup pool resource */
directordaemon::PoolResource* diff_pool{}; /**< Differential backup pool resource */
directordaemon::PoolResource* next_pool{}; /**< Next Pool used for migration/copy and virtual backup */
directordaemon::FilesetResource* fileset{}; /**< FileSet resource */
directordaemon::CatalogResource* catalog{}; /**< Catalog resource */
MessagesResource* messages{}; /**< Default message handler */
POOLMEM* pool_source{}; /**< Where pool came from */
POOLMEM* npool_source{}; /**< Where next pool came from */
POOLMEM* rpool_source{}; /**< Where migrate read pool came from */
POOLMEM* rstore_source{}; /**< Where read storage came from */
POOLMEM* wstore_source{}; /**< Where write storage came from */
POOLMEM* catalog_source{}; /**< Where catalog came from */
alist<directordaemon::StorageResource*>* read_storage_list{}; /**< Read storage possibilities */
alist<directordaemon::StorageResource*>* write_storage_list{}; /**< Write storage possibilities */
alist<directordaemon::StorageResource*>* paired_read_write_storage_list{}; /**< Paired storage possibilities (saved write_storage_list or read_storage_list) */
bool run_pool_override{}; /**< Pool override was given on run cmdline */
bool run_full_pool_override{}; /**< Full pool override was given on run cmdline */
bool run_vfull_pool_override{}; /**< Virtual Full pool override was given on run cmdline */
bool run_inc_pool_override{}; /**< Incremental pool override was given on run cmdline */
bool run_diff_pool_override{}; /**< Differential pool override was given on run cmdline */
bool run_next_pool_override{}; /**< Next pool override was given on run cmdline */
};
struct JobControlRecordPrivate {
JobControlRecordPrivate( std::shared_ptr<ConfigResourcesContainer> configuration_resources_container) : job_config_resources_container_(configuration_resources_container) {
RestoreJobId = 0; MigrateJobId = 0; VerifyJobId = 0;
}
std::shared_ptr<ConfigResourcesContainer> job_config_resources_container_;
pthread_t SD_msg_chan{}; /**< Message channel thread id */
bool SD_msg_chan_started{}; /**< Message channel thread started */
pthread_cond_t term_wait = PTHREAD_COND_INITIALIZER; /**< Wait for job termination */
pthread_cond_t nextrun_ready = PTHREAD_COND_INITIALIZER; /**< Wait for job next run to become ready */
Resources res; /**< Resources assigned */
TREE_ROOT* restore_tree_root{}; /**< Selected files to restore (some protocols need this info) */
storagedaemon::BootStrapRecord* bsr{}; /**< Bootstrap record -- has everything */
char* backup_format{}; /**< Backup format used when doing a NDMP backup */
char* plugin_options{}; /**< User set options for plugin */
uint32_t SDJobFiles{}; /**< Number of files written, this job */
uint64_t SDJobBytes{}; /**< Number of bytes processed this job */
uint32_t SDErrors{}; /**< Number of non-fatal errors */
std::atomic<int32_t> SDJobStatus{}; /**< Storage Job Status */
std::atomic<int32_t> FDJobStatus{}; /**< File daemon Job Status */
uint32_t DumpLevel{}; /**< Dump level when doing a NDMP backup */
uint32_t ExpectedFiles{}; /**< Expected restore files */
uint32_t MediaId{}; /**< DB record IDs associated with this job */
uint32_t FileIndex{}; /**< Last FileIndex processed */
utime_t MaxRunSchedTime{}; /**< Max run time in seconds from Initial Scheduled time */
JobDbRecord jr; /**< Job DB record for current job */
JobDbRecord previous_jr; /**< Previous job database record */
JobControlRecord* mig_jcr{}; /**< JobControlRecord for migration/copy job */
char FSCreateTime[MAX_TIME_LENGTH]{}; /**< FileSet CreateTime as returned from DB */
char since[MAX_TIME_LENGTH]{}; /**< Since time */
char PrevJob[MAX_NAME_LENGTH]{}; /**< Previous job name assiciated with since time */
union {
JobId_t RestoreJobId; /**< Restore JobId specified by UA */
JobId_t MigrateJobId; /**< Migration JobId specified by UA */
JobId_t VerifyJobId; /**< Verify JobId specified by UA */
};
POOLMEM* fname{}; /**< Name to put into catalog */
POOLMEM* client_uname{}; /**< Client uname */
POOLMEM* FDSecureEraseCmd{}; /**< Report: Secure Erase Command */
POOLMEM* SDSecureEraseCmd{}; /**< Report: Secure Erase Command */
POOLMEM* vf_jobids{}; /**< JobIds to use for Virtual Full */
uint32_t replace{}; /**< Replace option */
int32_t NumVols{}; /**< Number of Volume used in pool */
int32_t reschedule_count{}; /**< Number of times rescheduled */
int32_t FDVersion{}; /**< File daemon version number */
int64_t spool_size{}; /**< Spool size for this job */
std::atomic<bool> sd_msg_thread_done{}; /**< Set when Storage message thread done */
bool IgnoreDuplicateJobChecking{}; /**< Set in migration jobs */
bool IgnoreLevelPoolOverrides{}; /**< Set if a cmdline pool was specified */
bool IgnoreClientConcurrency{}; /**< Set in migration jobs */
bool IgnoreStorageConcurrency{}; /**< Set in migration jobs */
bool spool_data{}; /**< Spool data in SD */
bool acquired_resource_locks{}; /**< Set if resource locks acquired */
bool term_wait_inited{}; /**< Set when cond var inited */
bool nextrun_ready_inited{}; /**< Set when cond var inited */
bool fn_printed{}; /**< Printed filename */
bool needs_sd{}; /**< Set if SD needed by Job */
bool cloned{}; /**< Set if cloned */
bool unlink_bsr{}; /**< Unlink bsr file created */
bool VSS{}; /**< VSS used by FD */
bool Encrypt{}; /**< Encryption used by FD */
bool no_maxtime{}; /**< Don't check Max*Time for this JobControlRecord */
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 */
bool sd_canceled{}; /**< Set if SD canceled */
bool remote_replicate{}; /**< Replicate data to remote SD */
bool HasQuota{}; /**< Client has quota limits */
bool HasSelectedJobs{}; /**< Migration/Copy Job did actually select some JobIds */
directordaemon::ClientConnectionHandshakeMode connection_handshake_try_{
directordaemon::ClientConnectionHandshakeMode::kUndefined};
JobTrigger job_trigger{JobTrigger::kUndefined};
};
/* clang-format on */
#endif // BAREOS_DIRD_JCR_PRIVATE_H_
|
