blob: fb459b2106441eae5756ccf7b2b369feece9f555 (
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
|
/*
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_STORED_STORED_JCR_IMPL_H_
#define BAREOS_STORED_STORED_JCR_IMPL_H_
#include "stored/read_ctx.h"
#include "stored/stored_conf.h"
#define SD_APPEND 1
#define SD_READ 0
template <typename T> class alist;
namespace storagedaemon {
struct VolumeList;
class DeviceControlRecord;
class DirectorResource;
struct BootStrapRecord;
class DirectorStorage;
struct ReadSession {
READ_CTX* rctx{};
BootStrapRecord* bsr{};
bool mount_next_volume{};
uint32_t read_VolSessionId{};
uint32_t read_VolSessionTime{};
uint32_t read_StartFile{};
uint32_t read_EndFile{};
uint32_t read_StartBlock{};
uint32_t read_EndBlock{};
};
struct DeviceWaitTimes {
int32_t min_wait{};
int32_t max_wait{};
int32_t max_num_wait{};
int32_t wait_sec{};
int32_t rem_wait_sec{};
int32_t num_wait{};
};
} // namespace storagedaemon
/* clang-format off */
struct StoredJcrImpl {
JobControlRecord* next_dev{}; /**< Next JobControlRecord attached to device */
JobControlRecord* prev_dev{}; /**< Previous JobControlRecord attached to device */
pthread_cond_t job_start_wait = PTHREAD_COND_INITIALIZER; /**< Wait for FD to start Job */
pthread_cond_t job_end_wait = PTHREAD_COND_INITIALIZER; /**< Wait for Job to end */
storagedaemon::DeviceControlRecord* read_dcr{}; /**< Device context for reading */
storagedaemon::DeviceControlRecord* dcr{}; /**< Device context record */
POOLMEM* job_name{}; /**< Base Job name (not unique) */
POOLMEM* fileset_name{}; /**< FileSet */
POOLMEM* fileset_md5{}; /**< MD5 for FileSet */
POOLMEM* backup_format{}; /**< Backup format used when doing a NDMP backup */
storagedaemon::VolumeList* VolList{}; /**< List to read */
int32_t NumWriteVolumes{}; /**< Number of volumes written */
int32_t NumReadVolumes{}; /**< Total number of volumes to read */
int32_t CurReadVolume{}; /**< Current read volume number */
int32_t label_errors{}; /**< Count of label errors */
bool session_opened{};
bool remote_replicate{}; /**< Replicate data to remote SD */
int32_t Ticket{}; /**< Ticket for this job */
bool ignore_label_errors{}; /**< Ignore Volume label errors */
bool spool_attributes{}; /**< Set if spooling attributes */
bool no_attributes{}; /**< Set if no attributes wanted */
int64_t spool_size{}; /**< Spool size for this job */
bool spool_data{}; /**< Set to spool data */
storagedaemon::DirectorResource* director{}; /**< Director resource */
alist<const char*>* plugin_options{}; /**< Specific Plugin Options sent by DIR */
alist<storagedaemon::DirectorStorage*>* write_store{}; /**< List of write storage devices sent by DIR */
alist<storagedaemon::DirectorStorage*>* read_store{}; /**< List of read devices sent by DIR */
alist<const char*>* reserve_msgs{}; /**< Reserve fail messages */
bool acquired_storage{}; /**< Did we acquire our reserved storage already or not */
bool PreferMountedVols{}; /**< Prefer mounted vols rather than new */
bool insert_jobmedia_records{}; /**< Need to insert job media records */
uint64_t RemainingQuota{}; /**< Available bytes to use as quota */
storagedaemon::ReadSession read_session;
storagedaemon::DeviceWaitTimes device_wait_times;
};
/* clang-format on */
#endif // BAREOS_STORED_STORED_JCR_IMPL_H_
|
