61 #define IsParallelWorker() (ParallelWorkerNumber >= 0) 64 const char *function_name,
int nworkers);
void ReinitializeParallelWorkers(ParallelContext *pcxt, int nworkers_to_launch)
struct ParallelContext ParallelContext
shm_toc_estimator estimator
int nknown_attached_workers
void AtEOSubXact_Parallel(bool isCommit, SubTransactionId mySubId)
bool ParallelContextActive(void)
void HandleParallelMessages(void)
volatile bool ParallelMessagePending
ParallelWorkerInfo * worker
shm_mq_handle * error_mqh
PGDLLIMPORT bool InitializingParallelWorker
BackgroundWorkerHandle * bgwhandle
bool * known_attached_workers
void ParallelWorkerReportLastRecEnd(XLogRecPtr last_xlog_end)
void AtEOXact_Parallel(bool isCommit)
struct ParallelWorkerContext ParallelWorkerContext
void LaunchParallelWorkers(ParallelContext *pcxt)
void InitializeParallelDSM(ParallelContext *pcxt)
struct ParallelWorkerInfo ParallelWorkerInfo
ErrorContextCallback * error_context_stack
void WaitForParallelWorkersToAttach(ParallelContext *pcxt)
void(* parallel_worker_main_type)(dsm_segment *seg, shm_toc *toc)
void HandleParallelMessageInterrupt(void)
void ReinitializeParallelDSM(ParallelContext *pcxt)
ParallelContext * CreateParallelContext(const char *library_name, const char *function_name, int nworkers)
void WaitForParallelWorkersToFinish(ParallelContext *pcxt)
void DestroyParallelContext(ParallelContext *pcxt)
PGDLLIMPORT int ParallelWorkerNumber
void ParallelWorkerMain(Datum main_arg)