PostgreSQL Source Code  git master
pg_backup_archiver.h
Go to the documentation of this file.
1 /*-------------------------------------------------------------------------
2  *
3  * pg_backup_archiver.h
4  *
5  * Private interface to the pg_dump archiver routines.
6  * It is NOT intended that these routines be called by any
7  * dumper directly.
8  *
9  * See the headers to pg_restore for more details.
10  *
11  * Copyright (c) 2000, Philip Warner
12  * Rights are granted to use this software in any way so long
13  * as this notice is not removed.
14  *
15  * The author is not responsible for loss or damages that may
16  * result from its use.
17  *
18  *
19  * IDENTIFICATION
20  * src/bin/pg_dump/pg_backup_archiver.h
21  *
22  *-------------------------------------------------------------------------
23  */
24 #ifndef __PG_BACKUP_ARCHIVE__
25 #define __PG_BACKUP_ARCHIVE__
26 
27 #include <time.h>
28 
29 #include "libpq-fe.h"
30 #include "pg_backup.h"
31 #include "pqexpbuffer.h"
32 
33 #define LOBBUFSIZE 16384
34 
35 /*
36  * Note: zlib.h must be included *after* libpq-fe.h, because the latter may
37  * include ssl.h, which has a naming conflict with zlib.h.
38  */
39 #ifdef HAVE_LIBZ
40 #include <zlib.h>
41 #define GZCLOSE(fh) gzclose(fh)
42 #define GZWRITE(p, s, n, fh) gzwrite(fh, p, (n) * (s))
43 #define GZREAD(p, s, n, fh) gzread(fh, p, (n) * (s))
44 #define GZEOF(fh) gzeof(fh)
45 #else
46 #define GZCLOSE(fh) fclose(fh)
47 #define GZWRITE(p, s, n, fh) (fwrite(p, s, n, fh) * (s))
48 #define GZREAD(p, s, n, fh) fread(p, s, n, fh)
49 #define GZEOF(fh) feof(fh)
50 /* this is just the redefinition of a libz constant */
51 #define Z_DEFAULT_COMPRESSION (-1)
52 
53 typedef struct _z_stream
54 {
55  void *next_in;
56  void *next_out;
57  size_t avail_in;
58  size_t avail_out;
59 } z_stream;
61 #endif
62 
63 /* Data block types */
64 #define BLK_DATA 1
65 #define BLK_BLOBS 3
66 
67 /* Encode version components into a convenient integer <maj><min><rev> */
68 #define MAKE_ARCHIVE_VERSION(major, minor, rev) (((major) * 256 + (minor)) * 256 + (rev))
69 
70 #define ARCHIVE_MAJOR(version) (((version) >> 16) & 255)
71 #define ARCHIVE_MINOR(version) (((version) >> 8) & 255)
72 #define ARCHIVE_REV(version) (((version) ) & 255)
73 
74 /* Historical version numbers (checked in code) */
75 #define K_VERS_1_0 MAKE_ARCHIVE_VERSION(1, 0, 0)
76 #define K_VERS_1_2 MAKE_ARCHIVE_VERSION(1, 2, 0) /* Allow No ZLIB */
77 #define K_VERS_1_3 MAKE_ARCHIVE_VERSION(1, 3, 0) /* BLOBs */
78 #define K_VERS_1_4 MAKE_ARCHIVE_VERSION(1, 4, 0) /* Date & name in header */
79 #define K_VERS_1_5 MAKE_ARCHIVE_VERSION(1, 5, 0) /* Handle dependencies */
80 #define K_VERS_1_6 MAKE_ARCHIVE_VERSION(1, 6, 0) /* Schema field in TOCs */
81 #define K_VERS_1_7 MAKE_ARCHIVE_VERSION(1, 7, 0) /* File Offset size in
82  * header */
83 #define K_VERS_1_8 MAKE_ARCHIVE_VERSION(1, 8, 0) /* change interpretation
84  * of ID numbers and
85  * dependencies */
86 #define K_VERS_1_9 MAKE_ARCHIVE_VERSION(1, 9, 0) /* add default_with_oids
87  * tracking */
88 #define K_VERS_1_10 MAKE_ARCHIVE_VERSION(1, 10, 0) /* add tablespace */
89 #define K_VERS_1_11 MAKE_ARCHIVE_VERSION(1, 11, 0) /* add toc section
90  * indicator */
91 #define K_VERS_1_12 MAKE_ARCHIVE_VERSION(1, 12, 0) /* add separate BLOB
92  * entries */
93 #define K_VERS_1_13 MAKE_ARCHIVE_VERSION(1, 13, 0) /* change search_path
94  * behavior */
95 #define K_VERS_1_14 MAKE_ARCHIVE_VERSION(1, 14, 0) /* add tableam */
96 
97 /* Current archive version number (the format we can output) */
98 #define K_VERS_MAJOR 1
99 #define K_VERS_MINOR 14
100 #define K_VERS_REV 0
101 #define K_VERS_SELF MAKE_ARCHIVE_VERSION(K_VERS_MAJOR, K_VERS_MINOR, K_VERS_REV)
102 
103 /* Newest format we can read */
104 #define K_VERS_MAX MAKE_ARCHIVE_VERSION(K_VERS_MAJOR, K_VERS_MINOR, 255)
105 
106 
107 /* Flags to indicate disposition of offsets stored in files */
108 #define K_OFFSET_POS_NOT_SET 1
109 #define K_OFFSET_POS_SET 2
110 #define K_OFFSET_NO_DATA 3
111 
112 /*
113  * Special exit values from worker children. We reserve 0 for normal
114  * success; 1 and other small values should be interpreted as crashes.
115  */
116 #define WORKER_OK 0
117 #define WORKER_CREATE_DONE 10
118 #define WORKER_INHIBIT_DATA 11
119 #define WORKER_IGNORED_ERRORS 12
120 
122 typedef struct _tocEntry TocEntry;
123 struct ParallelState;
124 
125 #define READ_ERROR_EXIT(fd) \
126  do { \
127  if (feof(fd)) \
128  fatal("could not read from input file: end of file"); \
129  else \
130  fatal("could not read from input file: %m"); \
131  } while (0)
132 
133 #define WRITE_ERROR_EXIT \
134  do { \
135  fatal("could not write to output file: %m"); \
136  } while (0)
137 
138 typedef enum T_Action
139 {
142 } T_Action;
143 
144 typedef void (*ClosePtrType) (ArchiveHandle *AH);
145 typedef void (*ReopenPtrType) (ArchiveHandle *AH);
147 
148 typedef void (*StartDataPtrType) (ArchiveHandle *AH, TocEntry *te);
149 typedef void (*WriteDataPtrType) (ArchiveHandle *AH, const void *data, size_t dLen);
150 typedef void (*EndDataPtrType) (ArchiveHandle *AH, TocEntry *te);
151 
152 typedef void (*StartBlobsPtrType) (ArchiveHandle *AH, TocEntry *te);
153 typedef void (*StartBlobPtrType) (ArchiveHandle *AH, TocEntry *te, Oid oid);
154 typedef void (*EndBlobPtrType) (ArchiveHandle *AH, TocEntry *te, Oid oid);
155 typedef void (*EndBlobsPtrType) (ArchiveHandle *AH, TocEntry *te);
156 
157 typedef int (*WriteBytePtrType) (ArchiveHandle *AH, const int i);
158 typedef int (*ReadBytePtrType) (ArchiveHandle *AH);
159 typedef void (*WriteBufPtrType) (ArchiveHandle *AH, const void *c, size_t len);
160 typedef void (*ReadBufPtrType) (ArchiveHandle *AH, void *buf, size_t len);
165 
167 typedef void (*ClonePtrType) (ArchiveHandle *AH);
168 typedef void (*DeClonePtrType) (ArchiveHandle *AH);
169 
172 
173 typedef size_t (*CustomOutPtrType) (ArchiveHandle *AH, const void *buf, size_t len);
174 
175 typedef enum
176 {
177  SQL_SCAN = 0, /* normal */
178  SQL_IN_SINGLE_QUOTE, /* '...' literal */
179  SQL_IN_DOUBLE_QUOTE /* "..." identifier */
180 } sqlparseState;
181 
182 typedef struct
183 {
184  sqlparseState state; /* see above */
185  bool backSlash; /* next char is backslash quoted? */
186  PQExpBuffer curCmd; /* incomplete line (NULL if not created) */
187 } sqlparseInfo;
188 
189 typedef enum
190 {
195 } ArchiverStage;
196 
197 typedef enum
198 {
199  OUTPUT_SQLCMDS = 0, /* emitting general SQL commands */
200  OUTPUT_COPYDATA, /* writing COPY data */
201  OUTPUT_OTHERDATA /* writing data as INSERT commands */
203 
204 /*
205  * For historical reasons, ACL items are interspersed with everything else in
206  * a dump file's TOC; typically they're right after the object they're for.
207  * However, we need to restore data before ACLs, as otherwise a read-only
208  * table (ie one where the owner has revoked her own INSERT privilege) causes
209  * data restore failures. On the other hand, matview REFRESH commands should
210  * come out after ACLs, as otherwise non-superuser-owned matviews might not
211  * be able to execute. (If the permissions at the time of dumping would not
212  * allow a REFRESH, too bad; we won't fix that for you.) We also want event
213  * triggers to be restored after ACLs, so that they can't mess those up.
214  *
215  * These considerations force us to make three passes over the TOC,
216  * restoring the appropriate subset of items in each pass. We assume that
217  * the dependency sort resulted in an appropriate ordering of items within
218  * each subset.
219  *
220  * XXX This mechanism should be superseded by tracking dependencies on ACLs
221  * properly; but we'll still need it for old dump files even after that.
222  */
223 typedef enum
224 {
225  RESTORE_PASS_MAIN = 0, /* Main pass (most TOC item types) */
226  RESTORE_PASS_ACL, /* ACL item types */
227  RESTORE_PASS_POST_ACL /* Event trigger and matview refresh items */
228 
229 #define RESTORE_PASS_LAST RESTORE_PASS_POST_ACL
230 } RestorePass;
231 
232 typedef enum
233 {
234  REQ_SCHEMA = 0x01, /* want schema */
235  REQ_DATA = 0x02, /* want data */
236  REQ_SPECIAL = 0x04 /* for special TOC entries */
237 } teReqs;
238 
240 {
241  Archive public; /* Public part of archive */
242  int version; /* Version of file */
243 
244  char *archiveRemoteVersion; /* When reading an archive, the
245  * version of the dumped DB */
246  char *archiveDumpVersion; /* When reading an archive, the version of
247  * the dumper */
248 
249  size_t intSize; /* Size of an integer in the archive */
250  size_t offSize; /* Size of a file offset in the archive -
251  * Added V1.7 */
252  ArchiveFormat format; /* Archive format */
253 
254  sqlparseInfo sqlparse; /* state for parsing INSERT data */
255 
256  time_t createDate; /* Date archive created */
257 
258  /*
259  * Fields used when discovering header. A format can always get the
260  * previous read bytes from here...
261  */
262  int readHeader; /* Used if file header has been read already */
263  char *lookahead; /* Buffer used when reading header to discover
264  * format */
265  size_t lookaheadSize; /* Size of allocated buffer */
266  size_t lookaheadLen; /* Length of data in lookahead */
267  pgoff_t lookaheadPos; /* Current read position in lookahead buffer */
268 
269  ArchiveEntryPtrType ArchiveEntryPtr; /* Called for each metadata object */
270  StartDataPtrType StartDataPtr; /* Called when table data is about to be
271  * dumped */
272  WriteDataPtrType WriteDataPtr; /* Called to send some table data to the
273  * archive */
274  EndDataPtrType EndDataPtr; /* Called when table data dump is finished */
275  WriteBytePtrType WriteBytePtr; /* Write a byte to output */
276  ReadBytePtrType ReadBytePtr; /* Read a byte from an archive */
277  WriteBufPtrType WriteBufPtr; /* Write a buffer of output to the archive */
278  ReadBufPtrType ReadBufPtr; /* Read a buffer of input from the archive */
279  ClosePtrType ClosePtr; /* Close the archive */
280  ReopenPtrType ReopenPtr; /* Reopen the archive */
281  WriteExtraTocPtrType WriteExtraTocPtr; /* Write extra TOC entry data
282  * associated with the current
283  * archive format */
284  ReadExtraTocPtrType ReadExtraTocPtr; /* Read extra info associated with
285  * archive format */
286  PrintExtraTocPtrType PrintExtraTocPtr; /* Extra TOC info for format */
288 
293 
297 
299  ClonePtrType ClonePtr; /* Clone format-specific fields */
300  DeClonePtrType DeClonePtr; /* Clean up cloned fields */
301 
302  CustomOutPtrType CustomOutPtr; /* Alternative script output routine */
303 
304  /* Stuff for direct DB connection */
305  char *archdbname; /* DB name *read* from archive */
306  char *savedPassword; /* password for ropt->username, if known */
307  char *use_role;
309  /* If connCancel isn't NULL, SIGINT handler will send a cancel */
310  PGcancel *volatile connCancel;
311 
312  int connectToDB; /* Flag to indicate if direct DB connection is
313  * required */
314  ArchiverOutput outputKind; /* Flag for what we're currently writing */
315  bool pgCopyIn; /* Currently in libpq 'COPY IN' mode. */
316 
317  int loFd; /* BLOB fd */
318  int writingBlob; /* Flag */
319  int blobCount; /* # of blobs restored */
320 
321  char *fSpec; /* Archive File Spec */
322  FILE *FH; /* General purpose file handle */
323  void *OF;
324  int gzOut; /* Output file */
325 
326  struct _tocEntry *toc; /* Header of circular list of TOC entries */
327  int tocCount; /* Number of TOC entries */
328  DumpId maxDumpId; /* largest DumpId among all TOC entries */
329 
330  /* arrays created after the TOC list is complete: */
331  struct _tocEntry **tocsByDumpId; /* TOCs indexed by dumpId */
332  DumpId *tableDataId; /* TABLE DATA ids, indexed by table dumpId */
333 
334  struct _tocEntry *currToc; /* Used when dumping data */
335  int compression; /* Compression requested on open Possible
336  * values for compression: -1
337  * Z_DEFAULT_COMPRESSION 0 COMPRESSION_NONE
338  * 1-9 levels for gzip compression */
339  bool dosync; /* data requested to be synced on sight */
340  ArchiveMode mode; /* File mode - r or w */
341  void *formatData; /* Header data specific to file format */
342 
343  /* these vars track state to avoid sending redundant SET commands */
344  char *currUser; /* current username, or NULL if unknown */
345  char *currSchema; /* current schema, or NULL */
346  char *currTablespace; /* current tablespace, or NULL */
347  char *currTableAm; /* current table access method, or NULL */
348 
349  void *lo_buf;
350  size_t lo_buf_used;
351  size_t lo_buf_size;
352 
356  RestorePass restorePass; /* used only during parallel restore */
359 };
360 
361 struct _tocEntry
362 {
363  struct _tocEntry *prev;
364  struct _tocEntry *next;
368  bool hadDumper; /* Archiver was passed a dumper routine (used
369  * in restore) */
370  char *tag; /* index tag */
371  char *namespace; /* null or empty string if not in a schema */
372  char *tablespace; /* null if not in a tablespace; empty string
373  * means use database default */
374  char *tableam; /* table access method, only for TABLE tags */
375  char *owner;
376  char *desc;
377  char *defn;
378  char *dropStmt;
379  char *copyStmt;
380  DumpId *dependencies; /* dumpIds of objects this one depends on */
381  int nDeps; /* number of dependencies */
382 
383  DataDumperPtr dataDumper; /* Routine to dump data for object */
384  void *dataDumperArg; /* Arg for above routine */
385  void *formatData; /* TOC Entry data specific to file format */
386 
387  /* working state while dumping/restoring */
388  pgoff_t dataLength; /* item's data size; 0 if none or unknown */
389  teReqs reqs; /* do we need schema and/or data of object */
390  bool created; /* set for DATA member if TABLE was created */
391 
392  /* working state (needed only for parallel restore) */
393  struct _tocEntry *pending_prev; /* list links for pending-items list; */
394  struct _tocEntry *pending_next; /* NULL if not in that list */
395  int depCount; /* number of dependencies not yet restored */
396  DumpId *revDeps; /* dumpIds of objects depending on this one */
397  int nRevDeps; /* number of such dependencies */
398  DumpId *lockDeps; /* dumpIds of objects this one needs lock on */
399  int nLockDeps; /* number of such dependencies */
400 };
401 
402 extern int parallel_restore(ArchiveHandle *AH, TocEntry *te);
403 extern void on_exit_close_archive(Archive *AHX);
404 
405 extern void warn_or_exit_horribly(ArchiveHandle *AH, const char *fmt,...) pg_attribute_printf(2, 3);
406 
407 /* Options for ArchiveEntry */
408 typedef struct _archiveOpts
409 {
410  const char *tag;
411  const char *namespace;
412  const char *tablespace;
413  const char *tableam;
414  const char *owner;
415  const char *description;
417  const char *createStmt;
418  const char *dropStmt;
419  const char *copyStmt;
420  const DumpId *deps;
421  int nDeps;
423  void *dumpArg;
424 } ArchiveOpts;
425 #define ARCHIVE_OPTS(...) &(ArchiveOpts){__VA_ARGS__}
426 /* Called to add a TOC entry */
428  DumpId dumpId, ArchiveOpts *opts);
429 
430 extern void WriteHead(ArchiveHandle *AH);
431 extern void ReadHead(ArchiveHandle *AH);
432 extern void WriteToc(ArchiveHandle *AH);
433 extern void ReadToc(ArchiveHandle *AH);
434 extern void WriteDataChunks(ArchiveHandle *AH, struct ParallelState *pstate);
437 extern void DeCloneArchive(ArchiveHandle *AH);
438 
439 extern teReqs TocIDRequired(ArchiveHandle *AH, DumpId id);
441 extern bool checkSeek(FILE *fp);
442 
443 #define appendStringLiteralAHX(buf,str,AH) \
444  appendStringLiteral(buf, str, (AH)->public.encoding, (AH)->public.std_strings)
445 
446 #define appendByteaLiteralAHX(buf,str,len,AH) \
447  appendByteaLiteral(buf, str, len, (AH)->public.std_strings)
448 
449 /*
450  * Mandatory routines for each supported format
451  */
452 
453 extern size_t WriteInt(ArchiveHandle *AH, int i);
454 extern int ReadInt(ArchiveHandle *AH);
455 extern char *ReadStr(ArchiveHandle *AH);
456 extern size_t WriteStr(ArchiveHandle *AH, const char *s);
457 
459 size_t WriteOffset(ArchiveHandle *, pgoff_t, int);
460 
461 extern void StartRestoreBlobs(ArchiveHandle *AH);
462 extern void StartRestoreBlob(ArchiveHandle *AH, Oid oid, bool drop);
463 extern void EndRestoreBlob(ArchiveHandle *AH, Oid oid);
464 extern void EndRestoreBlobs(ArchiveHandle *AH);
465 
466 extern void InitArchiveFmt_Custom(ArchiveHandle *AH);
467 extern void InitArchiveFmt_Null(ArchiveHandle *AH);
468 extern void InitArchiveFmt_Directory(ArchiveHandle *AH);
469 extern void InitArchiveFmt_Tar(ArchiveHandle *AH);
470 
471 extern bool isValidTarHeader(char *header);
472 
473 extern void ReconnectToServer(ArchiveHandle *AH, const char *dbname);
474 extern void DropBlobIfExists(ArchiveHandle *AH, Oid oid);
475 
476 void ahwrite(const void *ptr, size_t size, size_t nmemb, ArchiveHandle *AH);
477 int ahprintf(ArchiveHandle *AH, const char *fmt,...) pg_attribute_printf(2, 3);
478 
479 #endif
struct _tocEntry * next
ReopenPtrType ReopenPtr
void ahwrite(const void *ptr, size_t size, size_t nmemb, ArchiveHandle *AH)
ReadBufPtrType ReadBufPtr
PQExpBuffer curCmd
int DumpId
Definition: pg_backup.h:242
sqlparseState state
DeClonePtrType DeClonePtr
void(* PrepParallelRestorePtrType)(ArchiveHandle *AH)
struct _tocEntry * currentTE
int(* ReadBytePtrType)(ArchiveHandle *AH)
const DumpId * deps
void DropBlobIfExists(ArchiveHandle *AH, Oid oid)
Definition: pg_backup_db.c:551
void(* ClosePtrType)(ArchiveHandle *AH)
int ReadInt(ArchiveHandle *AH)
WriteBufPtrType WriteBufPtr
CatalogId catalogId
int(* WorkerJobDumpPtrType)(ArchiveHandle *AH, TocEntry *te)
void * dataDumperArg
size_t WriteInt(ArchiveHandle *AH, int i)
void(* DeClonePtrType)(ArchiveHandle *AH)
void on_exit_close_archive(Archive *AHX)
Definition: parallel.c:347
int parallel_restore(ArchiveHandle *AH, TocEntry *te)
StartBlobPtrType StartBlobPtr
struct _tocEntry * pending_prev
int(* WriteBytePtrType)(ArchiveHandle *AH, const int i)
EndDataPtrType EndDataPtr
const char * dropStmt
void InitArchiveFmt_Tar(ArchiveHandle *AH)
DataDumperPtr dataDumper
StartBlobsPtrType StartBlobsPtr
PGcancel *volatile connCancel
unsigned int Oid
Definition: postgres_ext.h:31
void ReadHead(ArchiveHandle *AH)
bool isValidTarHeader(char *header)
void(* PrintTocDataPtrType)(ArchiveHandle *AH, TocEntry *te)
DumpId * lockDeps
bool checkSeek(FILE *fp)
void DeCloneArchive(ArchiveHandle *AH)
SetupWorkerPtrType SetupWorkerPtr
struct _tocEntry * currToc
ReadBytePtrType ReadBytePtr
RestorePass restorePass
sqlparseState
#define pg_attribute_printf(f, a)
Definition: c.h:130
teSection section
struct _tocEntry * pending_next
#define pgoff_t
Definition: win32_port.h:194
EndBlobPtrType EndBlobPtr
void EndRestoreBlobs(ArchiveHandle *AH)
void struct _archiveOpts ArchiveOpts
void WriteDataChunksForTocEntry(ArchiveHandle *AH, TocEntry *te)
void(* EndBlobPtrType)(ArchiveHandle *AH, TocEntry *te, Oid oid)
const char * description
void EndRestoreBlob(ArchiveHandle *AH, Oid oid)
int ahprintf(ArchiveHandle *AH, const char *fmt,...) pg_attribute_printf(2
char * c
struct _tocEntry * toc
static char * buf
Definition: pg_test_fsync.c:68
DumpId * dependencies
StartDataPtrType StartDataPtr
void warn_or_exit_horribly(ArchiveHandle *AH, const char *fmt,...) pg_attribute_printf(2
TocEntry * ArchiveEntry(Archive *AHX, CatalogId catalogId, DumpId dumpId, ArchiveOpts *opts)
void ReconnectToServer(ArchiveHandle *AH, const char *dbname)
Definition: pg_backup_db.c:78
pgoff_t dataLength
z_stream * z_streamp
sqlparseInfo sqlparse
WriteBytePtrType WriteBytePtr
void WriteDataChunks(ArchiveHandle *AH, struct ParallelState *pstate)
void(* ReadExtraTocPtrType)(ArchiveHandle *AH, TocEntry *te)
void(* ArchiveEntryPtrType)(ArchiveHandle *AH, TocEntry *te)
const char * tag
struct _tocEntry * prev
TocEntry * getTocEntryByDumpId(ArchiveHandle *AH, DumpId id)
void(* StartDataPtrType)(ArchiveHandle *AH, TocEntry *te)
ArchiveFormat format
size_t WriteOffset(ArchiveHandle *, pgoff_t, int)
ArchiverStage stage
void(* StartBlobPtrType)(ArchiveHandle *AH, TocEntry *te, Oid oid)
PrintTocDataPtrType PrintTocDataPtr
size_t WriteStr(ArchiveHandle *AH, const char *s)
ArchiverStage
void StartRestoreBlob(ArchiveHandle *AH, Oid oid, bool drop)
WriteDataPtrType WriteDataPtr
void(* EndBlobsPtrType)(ArchiveHandle *AH, TocEntry *te)
void InitArchiveFmt_Directory(ArchiveHandle *AH)
enum _archiveFormat ArchiveFormat
const char * copyStmt
int ReadOffset(ArchiveHandle *, pgoff_t *)
void(* WriteDataPtrType)(ArchiveHandle *AH, const void *data, size_t dLen)
void InitArchiveFmt_Null(ArchiveHandle *AH)
void(* StartBlobsPtrType)(ArchiveHandle *AH, TocEntry *te)
enum _teSection teSection
const char * tablespace
void InitArchiveFmt_Custom(ArchiveHandle *AH)
void(* WriteBufPtrType)(ArchiveHandle *AH, const void *c, size_t len)
void StartRestoreBlobs(ArchiveHandle *AH)
ArchiveHandle * CloneArchive(ArchiveHandle *AH)
CustomOutPtrType CustomOutPtr
void(* ReopenPtrType)(ArchiveHandle *AH)
TocEntry ** te
Definition: parallel.h:44
void(* EndDataPtrType)(ArchiveHandle *AH, TocEntry *te)
PrepParallelRestorePtrType PrepParallelRestorePtr
void(* WriteExtraTocPtrType)(ArchiveHandle *AH, TocEntry *te)
EndBlobsPtrType EndBlobsPtr
ArchiveMode
Definition: xlog.h:153
char * dbname
Definition: streamutil.c:51
ArchiveEntryPtrType ArchiveEntryPtr
DumpId * revDeps
const char * createStmt
const char * tableam
ArchiverOutput outputKind
static void header(const char *fmt,...) pg_attribute_printf(1
Definition: pg_regress.c:210
void(* PrintExtraTocPtrType)(ArchiveHandle *AH, TocEntry *te)
int(* DataDumperPtr)(Archive *AH, void *userArg)
Definition: pg_backup.h:250
void(* ClonePtrType)(ArchiveHandle *AH)
DataDumperPtr dumpFn
struct _tocEntry ** tocsByDumpId
ClonePtrType ClonePtr
void WriteToc(ArchiveHandle *AH)
ArchiverOutput
int(* WorkerJobRestorePtrType)(ArchiveHandle *AH, TocEntry *te)
char * ReadStr(ArchiveHandle *AH)
int i
WorkerJobRestorePtrType WorkerJobRestorePtr
teReqs TocIDRequired(ArchiveHandle *AH, DumpId id)
ArchiverStage lastErrorStage
struct _z_stream z_stream
const char * owner
ClosePtrType ClosePtr
PrintExtraTocPtrType PrintExtraTocPtr
struct _tocEntry * lastErrorTE
size_t(* CustomOutPtrType)(ArchiveHandle *AH, const void *buf, size_t len)
void(* SetupWorkerPtrType)(Archive *AH)
Definition: pg_backup.h:252
WriteExtraTocPtrType WriteExtraTocPtr
void WriteHead(ArchiveHandle *AH)
ReadExtraTocPtrType ReadExtraTocPtr
void ReadToc(ArchiveHandle *AH)
WorkerJobDumpPtrType WorkerJobDumpPtr
void(* ReadBufPtrType)(ArchiveHandle *AH, void *buf, size_t len)