diff options
Diffstat (limited to 'src/bin/pg_dump/parallel.h')
| -rw-r--r-- | src/bin/pg_dump/parallel.h | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/src/bin/pg_dump/parallel.h b/src/bin/pg_dump/parallel.h index 7422f12db4e..a7caa6cdbef 100644 --- a/src/bin/pg_dump/parallel.h +++ b/src/bin/pg_dump/parallel.h @@ -16,6 +16,9 @@ *------------------------------------------------------------------------- */ +#ifndef PG_DUMP_PARALLEL_H +#define PG_DUMP_PARALLEL_H + #include "pg_backup_db.h" struct _archiveHandle; @@ -62,6 +65,13 @@ typedef struct ParallelState ParallelSlot *parallelSlot; } ParallelState; +#ifdef WIN32 +extern bool parallel_init_done; +extern DWORD mainThreadId; +#endif + +extern void init_parallel_dump_utils(void); + extern int GetIdleWorker(ParallelState *pstate); extern bool IsEveryWorkerIdle(ParallelState *pstate); extern void ListenToWorkers(struct _archiveHandle * AH, ParallelState *pstate, bool do_wait); @@ -77,3 +87,9 @@ extern void DispatchJobForTocEntry(struct _archiveHandle * AH, extern void ParallelBackupEnd(struct _archiveHandle * AH, ParallelState *pstate); extern void checkAborting(struct _archiveHandle * AH); + +extern void +exit_horribly(const char *modulename, const char *fmt,...) +__attribute__((format(PG_PRINTF_ATTRIBUTE, 2, 3), noreturn)); + +#endif /* PG_DUMP_PARALLEL_H */ |