mirror of
https://git.postgresql.org/git/postgresql.git
synced 2024-09-13 17:49:43 +02:00
9af4159fce
This is the first run of the Perl-based pgindent script. Also update pgindent instructions.
96 lines
2.4 KiB
C
96 lines
2.4 KiB
C
/*-------------------------------------------------------------------------
|
|
*
|
|
* parallel.h
|
|
*
|
|
* Parallel support header file for the pg_dump archiver
|
|
*
|
|
* Portions Copyright (c) 1996-2011, PostgreSQL Global Development Group
|
|
* Portions Copyright (c) 1994, Regents of the University of California
|
|
*
|
|
* The author is not responsible for loss or damages that may
|
|
* result from its use.
|
|
*
|
|
* IDENTIFICATION
|
|
* src/bin/pg_dump/parallel.h
|
|
*
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
|
|
#ifndef PG_DUMP_PARALLEL_H
|
|
#define PG_DUMP_PARALLEL_H
|
|
|
|
#include "pg_backup_db.h"
|
|
|
|
struct _archiveHandle;
|
|
struct _tocEntry;
|
|
|
|
typedef enum
|
|
{
|
|
WRKR_TERMINATED = 0,
|
|
WRKR_IDLE,
|
|
WRKR_WORKING,
|
|
WRKR_FINISHED
|
|
} T_WorkerStatus;
|
|
|
|
/* Arguments needed for a worker process */
|
|
typedef struct ParallelArgs
|
|
{
|
|
struct _archiveHandle *AH;
|
|
struct _tocEntry *te;
|
|
} ParallelArgs;
|
|
|
|
/* State for each parallel activity slot */
|
|
typedef struct ParallelSlot
|
|
{
|
|
ParallelArgs *args;
|
|
T_WorkerStatus workerStatus;
|
|
int status;
|
|
int pipeRead;
|
|
int pipeWrite;
|
|
int pipeRevRead;
|
|
int pipeRevWrite;
|
|
#ifdef WIN32
|
|
uintptr_t hThread;
|
|
unsigned int threadId;
|
|
#else
|
|
pid_t pid;
|
|
#endif
|
|
} ParallelSlot;
|
|
|
|
#define NO_SLOT (-1)
|
|
|
|
typedef struct ParallelState
|
|
{
|
|
int numWorkers;
|
|
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);
|
|
extern int ReapWorkerStatus(ParallelState *pstate, int *status);
|
|
extern void EnsureIdleWorker(struct _archiveHandle * AH, ParallelState *pstate);
|
|
extern void EnsureWorkersFinished(struct _archiveHandle * AH, ParallelState *pstate);
|
|
|
|
extern ParallelState *ParallelBackupStart(struct _archiveHandle * AH,
|
|
RestoreOptions *ropt);
|
|
extern void DispatchJobForTocEntry(struct _archiveHandle * AH,
|
|
ParallelState *pstate,
|
|
struct _tocEntry * te, T_Action act);
|
|
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 */
|