PostgreSQL Source Code  git master
 All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros
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 it's 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 
28 #include <time.h>
29 
30 #include "pg_backup.h"
31 
32 #include "libpq-fe.h"
33 #include "pqexpbuffer.h"
34 
35 #define LOBBUFSIZE 16384
36 
37 /*
38  * Note: zlib.h must be included *after* libpq-fe.h, because the latter may
39  * include ssl.h, which has a naming conflict with zlib.h.
40  */
41 #ifdef HAVE_LIBZ
42 #include <zlib.h>
43 #define GZCLOSE(fh) gzclose(fh)
44 #define GZWRITE(p, s, n, fh) gzwrite(fh, p, (n) * (s))
45 #define GZREAD(p, s, n, fh) gzread(fh, p, (n) * (s))
46 #define GZEOF(fh) gzeof(fh)
47 #else
48 #define GZCLOSE(fh) fclose(fh)
49 #define GZWRITE(p, s, n, fh) (fwrite(p, s, n, fh) * (s))
50 #define GZREAD(p, s, n, fh) fread(p, s, n, fh)
51 #define GZEOF(fh) feof(fh)
52 /* this is just the redefinition of a libz constant */
53 #define Z_DEFAULT_COMPRESSION (-1)
54 
55 typedef struct _z_stream
56 {
57  void *next_in;
58  void *next_out;
59  size_t avail_in;
60  size_t avail_out;
61 } z_stream;
63 #endif
64 
65 /* Data block types */
66 #define BLK_DATA 1
67 #define BLK_BLOBS 3
68 
69 /* Encode version components into a convenient integer <maj><min><rev> */
70 #define MAKE_ARCHIVE_VERSION(major, minor, rev) (((major) * 256 + (minor)) * 256 + (rev))
71 
72 #define ARCHIVE_MAJOR(version) (((version) >> 16) & 255)
73 #define ARCHIVE_MINOR(version) (((version) >> 8) & 255)
74 #define ARCHIVE_REV(version) (((version) ) & 255)
75 
76 /* Historical version numbers (checked in code) */
77 #define K_VERS_1_0 MAKE_ARCHIVE_VERSION(1, 0, 0)
78 #define K_VERS_1_2 MAKE_ARCHIVE_VERSION(1, 2, 0) /* Allow No ZLIB */
79 #define K_VERS_1_3 MAKE_ARCHIVE_VERSION(1, 3, 0) /* BLOBs */
80 #define K_VERS_1_4 MAKE_ARCHIVE_VERSION(1, 4, 0) /* Date & name in header */
81 #define K_VERS_1_5 MAKE_ARCHIVE_VERSION(1, 5, 0) /* Handle dependencies */
82 #define K_VERS_1_6 MAKE_ARCHIVE_VERSION(1, 6, 0) /* Schema field in TOCs */
83 #define K_VERS_1_7 MAKE_ARCHIVE_VERSION(1, 7, 0) /* File Offset size in
84  * header */
85 #define K_VERS_1_8 MAKE_ARCHIVE_VERSION(1, 8, 0) /* change interpretation
86  * of ID numbers and
87  * dependencies */
88 #define K_VERS_1_9 MAKE_ARCHIVE_VERSION(1, 9, 0) /* add default_with_oids
89  * tracking */
90 #define K_VERS_1_10 MAKE_ARCHIVE_VERSION(1, 10, 0) /* add tablespace */
91 #define K_VERS_1_11 MAKE_ARCHIVE_VERSION(1, 11, 0) /* add toc section
92  * indicator */
93 #define K_VERS_1_12 MAKE_ARCHIVE_VERSION(1, 12, 0) /* add separate BLOB
94  * entries */
95 
96 /* Current archive version number (the format we can output) */
97 #define K_VERS_MAJOR 1
98 #define K_VERS_MINOR 12
99 #define K_VERS_REV 0
100 #define K_VERS_SELF MAKE_ARCHIVE_VERSION(K_VERS_MAJOR, K_VERS_MINOR, K_VERS_REV);
101 
102 /* Newest format we can read */
103 #define K_VERS_MAX MAKE_ARCHIVE_VERSION(K_VERS_MAJOR, K_VERS_MINOR, 255)
104 
105 
106 /* Flags to indicate disposition of offsets stored in files */
107 #define K_OFFSET_POS_NOT_SET 1
108 #define K_OFFSET_POS_SET 2
109 #define K_OFFSET_NO_DATA 3
110 
111 /*
112  * Special exit values from worker children. We reserve 0 for normal
113  * success; 1 and other small values should be interpreted as crashes.
114  */
115 #define WORKER_OK 0
116 #define WORKER_CREATE_DONE 10
117 #define WORKER_INHIBIT_DATA 11
118 #define WORKER_IGNORED_ERRORS 12
119 
121 typedef struct _tocEntry TocEntry;
122 struct ParallelState;
123 
124 #define READ_ERROR_EXIT(fd) \
125  do { \
126  if (feof(fd)) \
127  exit_horribly(modulename, \
128  "could not read from input file: end of file\n"); \
129  else \
130  exit_horribly(modulename, \
131  "could not read from input file: %s\n", strerror(errno)); \
132  } while (0)
133 
134 #define WRITE_ERROR_EXIT \
135  do { \
136  exit_horribly(modulename, "could not write to output file: %s\n", \
137  strerror(errno)); \
138  } while (0)
139 
140 typedef enum T_Action
141 {
144 } T_Action;
145 
146 typedef void (*ClosePtrType) (ArchiveHandle *AH);
147 typedef void (*ReopenPtrType) (ArchiveHandle *AH);
149 
150 typedef void (*StartDataPtrType) (ArchiveHandle *AH, TocEntry *te);
151 typedef void (*WriteDataPtrType) (ArchiveHandle *AH, const void *data, size_t dLen);
152 typedef void (*EndDataPtrType) (ArchiveHandle *AH, TocEntry *te);
153 
154 typedef void (*StartBlobsPtrType) (ArchiveHandle *AH, TocEntry *te);
155 typedef void (*StartBlobPtrType) (ArchiveHandle *AH, TocEntry *te, Oid oid);
156 typedef void (*EndBlobPtrType) (ArchiveHandle *AH, TocEntry *te, Oid oid);
157 typedef void (*EndBlobsPtrType) (ArchiveHandle *AH, TocEntry *te);
158 
159 typedef int (*WriteBytePtrType) (ArchiveHandle *AH, const int i);
160 typedef int (*ReadBytePtrType) (ArchiveHandle *AH);
161 typedef void (*WriteBufPtrType) (ArchiveHandle *AH, const void *c, size_t len);
162 typedef void (*ReadBufPtrType) (ArchiveHandle *AH, void *buf, size_t len);
163 typedef void (*SaveArchivePtrType) (ArchiveHandle *AH);
168 
169 typedef void (*ClonePtrType) (ArchiveHandle *AH);
170 typedef void (*DeClonePtrType) (ArchiveHandle *AH);
171 
174 
175 typedef size_t (*CustomOutPtrType) (ArchiveHandle *AH, const void *buf, size_t len);
176 
177 typedef enum
178 {
179  SQL_SCAN = 0, /* normal */
180  SQL_IN_SINGLE_QUOTE, /* '...' literal */
181  SQL_IN_DOUBLE_QUOTE /* "..." identifier */
182 } sqlparseState;
183 
184 typedef struct
185 {
186  sqlparseState state; /* see above */
187  bool backSlash; /* next char is backslash quoted? */
188  PQExpBuffer curCmd; /* incomplete line (NULL if not created) */
189 } sqlparseInfo;
190 
191 typedef enum
192 {
197 } ArchiverStage;
198 
199 typedef enum
200 {
201  OUTPUT_SQLCMDS = 0, /* emitting general SQL commands */
202  OUTPUT_COPYDATA, /* writing COPY data */
203  OUTPUT_OTHERDATA /* writing data as INSERT commands */
205 
206 typedef enum
207 {
208  REQ_SCHEMA = 0x01, /* want schema */
209  REQ_DATA = 0x02, /* want data */
210  REQ_SPECIAL = 0x04 /* for special TOC entries */
211 } teReqs;
212 
214 {
215  Archive public; /* Public part of archive */
216  int version; /* Version of file */
217 
218  char *archiveRemoteVersion; /* When reading an archive, the
219  * version of the dumped DB */
220  char *archiveDumpVersion; /* When reading an archive, the
221  * version of the dumper */
222 
223  int debugLevel; /* Used for logging (currently only by
224  * --verbose) */
225  size_t intSize; /* Size of an integer in the archive */
226  size_t offSize; /* Size of a file offset in the archive -
227  * Added V1.7 */
228  ArchiveFormat format; /* Archive format */
229 
230  sqlparseInfo sqlparse; /* state for parsing INSERT data */
231 
232  time_t createDate; /* Date archive created */
233 
234  /*
235  * Fields used when discovering header. A format can always get the
236  * previous read bytes from here...
237  */
238  int readHeader; /* Used if file header has been read already */
239  char *lookahead; /* Buffer used when reading header to discover
240  * format */
241  size_t lookaheadSize; /* Size of allocated buffer */
242  size_t lookaheadLen; /* Length of data in lookahead */
243  pgoff_t lookaheadPos; /* Current read position in lookahead buffer */
244 
245  ArchiveEntryPtrType ArchiveEntryPtr; /* Called for each metadata
246  * object */
247  StartDataPtrType StartDataPtr; /* Called when table data is about to
248  * be dumped */
249  WriteDataPtrType WriteDataPtr; /* Called to send some table data to
250  * the archive */
251  EndDataPtrType EndDataPtr; /* Called when table data dump is finished */
252  WriteBytePtrType WriteBytePtr; /* Write a byte to output */
253  ReadBytePtrType ReadBytePtr; /* Read a byte from an archive */
254  WriteBufPtrType WriteBufPtr; /* Write a buffer of output to the archive */
255  ReadBufPtrType ReadBufPtr; /* Read a buffer of input from the archive */
256  ClosePtrType ClosePtr; /* Close the archive */
257  ReopenPtrType ReopenPtr; /* Reopen the archive */
258  WriteExtraTocPtrType WriteExtraTocPtr; /* Write extra TOC entry data
259  * associated with the current
260  * archive format */
261  ReadExtraTocPtrType ReadExtraTocPtr; /* Read extra info associated
262  * with archive format */
263  PrintExtraTocPtrType PrintExtraTocPtr; /* Extra TOC info for format */
265 
270 
274 
275  ClonePtrType ClonePtr; /* Clone format-specific fields */
276  DeClonePtrType DeClonePtr; /* Clean up cloned fields */
277 
278  CustomOutPtrType CustomOutPtr; /* Alternative script output routine */
279 
280  /* Stuff for direct DB connection */
281  char *archdbname; /* DB name *read* from archive */
283  char *savedPassword; /* password for ropt->username, if known */
284  char *use_role;
286  /* If connCancel isn't NULL, SIGINT handler will send a cancel */
287  PGcancel *volatile connCancel;
288 
289  int connectToDB; /* Flag to indicate if direct DB connection is
290  * required */
291  ArchiverOutput outputKind; /* Flag for what we're currently writing */
292  bool pgCopyIn; /* Currently in libpq 'COPY IN' mode. */
293 
294  int loFd; /* BLOB fd */
295  int writingBlob; /* Flag */
296  int blobCount; /* # of blobs restored */
297 
298  char *fSpec; /* Archive File Spec */
299  FILE *FH; /* General purpose file handle */
300  void *OF;
301  int gzOut; /* Output file */
302 
303  struct _tocEntry *toc; /* Header of circular list of TOC entries */
304  int tocCount; /* Number of TOC entries */
305  DumpId maxDumpId; /* largest DumpId among all TOC entries */
306 
307  /* arrays created after the TOC list is complete: */
308  struct _tocEntry **tocsByDumpId; /* TOCs indexed by dumpId */
309  DumpId *tableDataId; /* TABLE DATA ids, indexed by table dumpId */
310 
311  struct _tocEntry *currToc; /* Used when dumping data */
312  int compression; /* Compression requested on open Possible
313  * values for compression: -1
314  * Z_DEFAULT_COMPRESSION 0 COMPRESSION_NONE
315  * 1-9 levels for gzip compression */
316  bool dosync; /* data requested to be synced on sight */
317  ArchiveMode mode; /* File mode - r or w */
318  void *formatData; /* Header data specific to file format */
319 
320  /* these vars track state to avoid sending redundant SET commands */
321  char *currUser; /* current username, or NULL if unknown */
322  char *currSchema; /* current schema, or NULL */
323  char *currTablespace; /* current tablespace, or NULL */
324  bool currWithOids; /* current default_with_oids setting */
325 
326  void *lo_buf;
327  size_t lo_buf_used;
328  size_t lo_buf_size;
329 
335 };
336 
337 struct _tocEntry
338 {
339  struct _tocEntry *prev;
340  struct _tocEntry *next;
344  bool hadDumper; /* Archiver was passed a dumper routine (used
345  * in restore) */
346  char *tag; /* index tag */
347  char *namespace; /* null or empty string if not in a schema */
348  char *tablespace; /* null if not in a tablespace; empty string
349  * means use database default */
350  char *owner;
351  bool withOids; /* Used only by "TABLE" tags */
352  char *desc;
353  char *defn;
354  char *dropStmt;
355  char *copyStmt;
356  DumpId *dependencies; /* dumpIds of objects this one depends on */
357  int nDeps; /* number of dependencies */
358 
359  DataDumperPtr dataDumper; /* Routine to dump data for object */
360  void *dataDumperArg; /* Arg for above routine */
361  void *formatData; /* TOC Entry data specific to file format */
362 
363  /* working state while dumping/restoring */
364  teReqs reqs; /* do we need schema and/or data of object */
365  bool created; /* set for DATA member if TABLE was created */
366 
367  /* working state (needed only for parallel restore) */
368  struct _tocEntry *par_prev; /* list links for pending/ready items; */
369  struct _tocEntry *par_next; /* these are NULL if not in either list */
370  int depCount; /* number of dependencies not yet restored */
371  DumpId *revDeps; /* dumpIds of objects depending on this one */
372  int nRevDeps; /* number of such dependencies */
373  DumpId *lockDeps; /* dumpIds of objects this one needs lock on */
374  int nLockDeps; /* number of such dependencies */
375 };
376 
377 extern int parallel_restore(ArchiveHandle *AH, TocEntry *te);
378 extern void on_exit_close_archive(Archive *AHX);
379 
380 extern void warn_or_exit_horribly(ArchiveHandle *AH, const char *modulename, const char *fmt,...) pg_attribute_printf(3, 4);
381 
382 extern void WriteTOC(ArchiveHandle *AH);
383 extern void ReadTOC(ArchiveHandle *AH);
384 extern void WriteHead(ArchiveHandle *AH);
385 extern void ReadHead(ArchiveHandle *AH);
386 extern void WriteToc(ArchiveHandle *AH);
387 extern void ReadToc(ArchiveHandle *AH);
388 extern void WriteDataChunks(ArchiveHandle *AH, struct ParallelState *pstate);
391 extern void DeCloneArchive(ArchiveHandle *AH);
392 
393 extern teReqs TocIDRequired(ArchiveHandle *AH, DumpId id);
395 extern bool checkSeek(FILE *fp);
396 
397 #define appendStringLiteralAHX(buf,str,AH) \
398  appendStringLiteral(buf, str, (AH)->public.encoding, (AH)->public.std_strings)
399 
400 #define appendByteaLiteralAHX(buf,str,len,AH) \
401  appendByteaLiteral(buf, str, len, (AH)->public.std_strings)
402 
403 /*
404  * Mandatory routines for each supported format
405  */
406 
407 extern size_t WriteInt(ArchiveHandle *AH, int i);
408 extern int ReadInt(ArchiveHandle *AH);
409 extern char *ReadStr(ArchiveHandle *AH);
410 extern size_t WriteStr(ArchiveHandle *AH, const char *s);
411 
413 size_t WriteOffset(ArchiveHandle *, pgoff_t, int);
414 
415 extern void StartRestoreBlobs(ArchiveHandle *AH);
416 extern void StartRestoreBlob(ArchiveHandle *AH, Oid oid, bool drop);
417 extern void EndRestoreBlob(ArchiveHandle *AH, Oid oid);
418 extern void EndRestoreBlobs(ArchiveHandle *AH);
419 
420 extern void InitArchiveFmt_Custom(ArchiveHandle *AH);
421 extern void InitArchiveFmt_Null(ArchiveHandle *AH);
422 extern void InitArchiveFmt_Directory(ArchiveHandle *AH);
423 extern void InitArchiveFmt_Tar(ArchiveHandle *AH);
424 
425 extern bool isValidTarHeader(char *header);
426 
427 extern int ReconnectToServer(ArchiveHandle *AH, const char *dbname, const char *newUser);
428 extern void DropBlobIfExists(ArchiveHandle *AH, Oid oid);
429 
430 void ahwrite(const void *ptr, size_t size, size_t nmemb, ArchiveHandle *AH);
431 int ahprintf(ArchiveHandle *AH, const char *fmt,...) pg_attribute_printf(2, 3);
432 
433 void ahlog(ArchiveHandle *AH, int level, const char *fmt,...) pg_attribute_printf(3, 4);
434 
435 #endif
struct _tocEntry * next
int(* WorkerJobDumpPtrType)(ArchiveHandle *AH, TocEntry *te)
ReopenPtrType ReopenPtr
void ahwrite(const void *ptr, size_t size, size_t nmemb, ArchiveHandle *AH)
ReadBufPtrType ReadBufPtr
PQExpBuffer curCmd
void(* ReopenPtrType)(ArchiveHandle *AH)
int DumpId
Definition: pg_backup.h:230
sqlparseState state
void(* WriteExtraTocPtrType)(ArchiveHandle *AH, TocEntry *te)
DeClonePtrType DeClonePtr
struct _tocEntry * currentTE
static const char * modulename
Definition: compress_io.c:78
int ReconnectToServer(ArchiveHandle *AH, const char *dbname, const char *newUser)
Definition: pg_backup_db.c:86
int(* WorkerJobRestorePtrType)(ArchiveHandle *AH, TocEntry *te)
void DropBlobIfExists(ArchiveHandle *AH, Oid oid)
Definition: pg_backup_db.c:663
int void ahlog(ArchiveHandle *AH, int level, const char *fmt,...) pg_attribute_printf(3
int ReadInt(ArchiveHandle *AH)
WriteBufPtrType WriteBufPtr
CatalogId catalogId
void * dataDumperArg
size_t WriteInt(ArchiveHandle *AH, int i)
void on_exit_close_archive(Archive *AHX)
Definition: parallel.c:345
int parallel_restore(ArchiveHandle *AH, TocEntry *te)
int(* DataDumperPtr)(Archive *AH, void *userArg)
Definition: pg_backup.h:232
StartBlobPtrType StartBlobPtr
EndDataPtrType EndDataPtr
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)
DumpId * lockDeps
void(* ReadExtraTocPtrType)(ArchiveHandle *AH, TocEntry *te)
bool checkSeek(FILE *fp)
void DeCloneArchive(ArchiveHandle *AH)
SetupWorkerPtrType SetupWorkerPtr
struct _tocEntry * currToc
ReadBytePtrType ReadBytePtr
sqlparseState
#define pg_attribute_printf(f, a)
Definition: c.h:638
teSection section
void(* WriteBufPtrType)(ArchiveHandle *AH, const void *c, size_t len)
EndBlobPtrType EndBlobPtr
void EndRestoreBlobs(ArchiveHandle *AH)
void WriteDataChunksForTocEntry(ArchiveHandle *AH, TocEntry *te)
void(* DeClonePtrType)(ArchiveHandle *AH)
void EndRestoreBlob(ArchiveHandle *AH, Oid oid)
int ahprintf(ArchiveHandle *AH, const char *fmt,...) pg_attribute_printf(2
void(* EndBlobPtrType)(ArchiveHandle *AH, TocEntry *te, Oid oid)
char * c
struct _tocEntry * toc
static char * buf
Definition: pg_test_fsync.c:66
DumpId * dependencies
StartDataPtrType StartDataPtr
void(* SaveArchivePtrType)(ArchiveHandle *AH)
size_t(* CustomOutPtrType)(ArchiveHandle *AH, const void *buf, size_t len)
struct _tocEntry * par_prev
z_stream * z_streamp
sqlparseInfo sqlparse
WriteBytePtrType WriteBytePtr
void WriteDataChunks(ArchiveHandle *AH, struct ParallelState *pstate)
void(* ReadBufPtrType)(ArchiveHandle *AH, void *buf, size_t len)
struct _tocEntry * par_next
trivalue
Definition: vacuumlo.c:31
void ReadTOC(ArchiveHandle *AH)
struct _tocEntry * prev
int(* WriteBytePtrType)(ArchiveHandle *AH, const int i)
void(* ClonePtrType)(ArchiveHandle *AH)
TocEntry * getTocEntryByDumpId(ArchiveHandle *AH, DumpId id)
#define pgoff_t
Definition: win32.h:231
ArchiveFormat format
size_t WriteOffset(ArchiveHandle *, pgoff_t, int)
ArchiverStage stage
PrintTocDataPtrType PrintTocDataPtr
size_t WriteStr(ArchiveHandle *AH, const char *s)
ArchiverStage
void StartRestoreBlob(ArchiveHandle *AH, Oid oid, bool drop)
WriteDataPtrType WriteDataPtr
void InitArchiveFmt_Directory(ArchiveHandle *AH)
enum _archiveFormat ArchiveFormat
int ReadOffset(ArchiveHandle *, pgoff_t *)
void InitArchiveFmt_Null(ArchiveHandle *AH)
void warn_or_exit_horribly(ArchiveHandle *AH, const char *modulename, const char *fmt,...) pg_attribute_printf(3
void(* StartBlobsPtrType)(ArchiveHandle *AH, TocEntry *te)
enum _teSection teSection
void InitArchiveFmt_Custom(ArchiveHandle *AH)
void(* PrintTocDataPtrType)(ArchiveHandle *AH, TocEntry *te)
void StartRestoreBlobs(ArchiveHandle *AH)
void void WriteTOC(ArchiveHandle *AH)
ArchiveHandle * CloneArchive(ArchiveHandle *AH)
CustomOutPtrType CustomOutPtr
void(* StartDataPtrType)(ArchiveHandle *AH, TocEntry *te)
TocEntry ** te
Definition: parallel.h:44
EndBlobsPtrType EndBlobsPtr
ArchiveMode
Definition: xlog.h:115
char * dbname
Definition: streamutil.c:38
ArchiveEntryPtrType ArchiveEntryPtr
DumpId * revDeps
ArchiverOutput outputKind
static void header(const char *fmt,...) pg_attribute_printf(1
Definition: pg_regress.c:207
int(* ReadBytePtrType)(ArchiveHandle *AH)
struct _tocEntry ** tocsByDumpId
ClonePtrType ClonePtr
void WriteToc(ArchiveHandle *AH)
void(* ClosePtrType)(ArchiveHandle *AH)
void(* SetupWorkerPtrType)(Archive *AH)
Definition: pg_backup.h:234
ArchiverOutput
void(* EndDataPtrType)(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
ClosePtrType ClosePtr
PrintExtraTocPtrType PrintExtraTocPtr
void(* PrintExtraTocPtrType)(ArchiveHandle *AH, TocEntry *te)
struct _tocEntry * lastErrorTE
void(* WriteDataPtrType)(ArchiveHandle *AH, const void *data, size_t dLen)
void(* ArchiveEntryPtrType)(ArchiveHandle *AH, TocEntry *te)
void(* EndBlobsPtrType)(ArchiveHandle *AH, TocEntry *te)
WriteExtraTocPtrType WriteExtraTocPtr
void WriteHead(ArchiveHandle *AH)
void(* StartBlobPtrType)(ArchiveHandle *AH, TocEntry *te, Oid oid)
ReadExtraTocPtrType ReadExtraTocPtr
void ReadToc(ArchiveHandle *AH)
WorkerJobDumpPtrType WorkerJobDumpPtr