PostgreSQL Source Code: src/include/backup/basebackup_sink.h Source File (original) (raw)
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#ifndef BASEBACKUP_SINK_H
27#define BASEBACKUP_SINK_H
28
32
33
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
67{
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
100{
106};
107
108
109
110
111
112
113
114
115
116
117
119{
120
121
122
123
124
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
144
145
146
147
148
149
150
151
152
153
157
158
159
160
161
163
164
165
166
167
168
169
171};
172
173
174static inline void
176{
177 Assert(sink != NULL);
178
179 Assert(buffer_length > 0);
180
184
187}
188
189
190static inline void
192{
193 Assert(sink != NULL);
194
196}
197
198
199static inline void
201{
202 Assert(sink != NULL);
203
204
205
206
207
208
209 Assert(len > 0 && len <= sink->bbs_buffer_length);
210
212}
213
214
215static inline void
217{
218 Assert(sink != NULL);
219
221}
222
223
224static inline void
226{
227 Assert(sink != NULL);
228
230}
231
232
233static inline void
235{
236 Assert(sink != NULL);
237
238
239 Assert(len > 0 && len <= sink->bbs_buffer_length);
240
242}
243
244
245static inline void
247{
248 Assert(sink != NULL);
249
251}
252
253
254static inline void
256{
257 Assert(sink != NULL);
259
261}
262
263
264static inline void
266{
267 Assert(sink != NULL);
268
270}
271
272
275 const char *archive_name);
284
285
293
294
300
301#endif
static void bbsink_begin_backup(bbsink *sink, bbsink_state *state, int buffer_length)
bbsink * bbsink_zstd_new(bbsink *next, pg_compress_specification *)
void basebackup_progress_wait_checkpoint(void)
bbsink * bbsink_gzip_new(bbsink *next, pg_compress_specification *)
void bbsink_forward_begin_backup(bbsink *sink)
void bbsink_forward_begin_manifest(bbsink *sink)
bbsink * bbsink_progress_new(bbsink *next, bool estimate_backup_size)
bbsink * bbsink_copystream_new(bool send_to_client)
void bbsink_forward_end_backup(bbsink *sink, XLogRecPtr endptr, TimeLineID endtli)
bbsink * bbsink_throttle_new(bbsink *next, uint32 maxrate)
bbsink * bbsink_lz4_new(bbsink *next, pg_compress_specification *)
static void bbsink_begin_archive(bbsink *sink, const char *archive_name)
void bbsink_forward_cleanup(bbsink *sink)
void bbsink_forward_manifest_contents(bbsink *sink, size_t len)
static void bbsink_end_archive(bbsink *sink)
static void bbsink_begin_manifest(bbsink *sink)
struct bbsink_state bbsink_state
static void bbsink_end_backup(bbsink *sink, XLogRecPtr endptr, TimeLineID endtli)
void bbsink_forward_end_archive(bbsink *sink)
void bbsink_forward_archive_contents(bbsink *sink, size_t len)
static void bbsink_cleanup(bbsink *sink)
void basebackup_progress_wait_wal_archive(bbsink_state *)
void bbsink_forward_begin_archive(bbsink *sink, const char *archive_name)
static void bbsink_end_manifest(bbsink *sink)
void bbsink_forward_end_manifest(bbsink *sink)
static void bbsink_archive_contents(bbsink *sink, size_t len)
static void bbsink_manifest_contents(bbsink *sink, size_t len)
void basebackup_progress_done(void)
void basebackup_progress_transfer_wal(void)
void basebackup_progress_estimate_backup_size(void)
bbsink * bbsink_server_new(bbsink *next, char *pathname)
Assert(PointerIsAligned(start, uint64))
static int list_length(const List *l)
void(* begin_manifest)(bbsink *sink)
void(* cleanup)(bbsink *sink)
void(* end_manifest)(bbsink *sink)
void(* end_archive)(bbsink *sink)
void(* manifest_contents)(bbsink *sink, size_t len)
void(* begin_backup)(bbsink *sink)
void(* end_backup)(bbsink *sink, XLogRecPtr endptr, TimeLineID endtli)
void(* archive_contents)(bbsink *sink, size_t len)
void(* begin_archive)(bbsink *sink, const char *archive_name)
bool bytes_total_is_valid
const bbsink_ops * bbs_ops