mirror of
https://github.com/postgres/postgres.git
synced 2026-02-16 09:08:23 -05:00
51daa7bdb3
Move the responsibility for creating/destroying TupleQueueReaders into execParallel.c, to avoid duplicative coding in nodeGather.c and nodeGatherMerge.c. Also, instead of having DestroyTupleQueueReader do shm_mq_detach, do it in the caller (which is now only ExecParallelFinish). This means execParallel.c does both the attaching and detaching of the tuple-queue-reader shm_mqs, which seems less weird than the previous arrangement. These changes also eliminate a vestigial memory leak (of the pei->tqueue array). It's now demonstrable that rescans of Gather or GatherMerge don't leak memory. Discussion: https://postgr.es/m/8670.1504192177@sss.pgh.pa.us
48 lines
1.8 KiB
C
48 lines
1.8 KiB
C
/*--------------------------------------------------------------------
|
|
* execParallel.h
|
|
* POSTGRES parallel execution interface
|
|
*
|
|
* Portions Copyright (c) 1996-2017, PostgreSQL Global Development Group
|
|
* Portions Copyright (c) 1994, Regents of the University of California
|
|
*
|
|
* IDENTIFICATION
|
|
* src/include/executor/execParallel.h
|
|
*--------------------------------------------------------------------
|
|
*/
|
|
|
|
#ifndef EXECPARALLEL_H
|
|
#define EXECPARALLEL_H
|
|
|
|
#include "access/parallel.h"
|
|
#include "nodes/execnodes.h"
|
|
#include "nodes/parsenodes.h"
|
|
#include "nodes/plannodes.h"
|
|
#include "utils/dsa.h"
|
|
|
|
typedef struct SharedExecutorInstrumentation SharedExecutorInstrumentation;
|
|
|
|
typedef struct ParallelExecutorInfo
|
|
{
|
|
PlanState *planstate; /* plan subtree we're running in parallel */
|
|
ParallelContext *pcxt; /* parallel context we're using */
|
|
BufferUsage *buffer_usage; /* points to bufusage area in DSM */
|
|
SharedExecutorInstrumentation *instrumentation; /* optional */
|
|
dsa_area *area; /* points to DSA area in DSM */
|
|
bool finished; /* set true by ExecParallelFinish */
|
|
/* These two arrays have pcxt->nworkers_launched entries: */
|
|
shm_mq_handle **tqueue; /* tuple queues for worker output */
|
|
struct TupleQueueReader **reader; /* tuple reader/writer support */
|
|
} ParallelExecutorInfo;
|
|
|
|
extern ParallelExecutorInfo *ExecInitParallelPlan(PlanState *planstate,
|
|
EState *estate, int nworkers, int64 tuples_needed);
|
|
extern void ExecParallelCreateReaders(ParallelExecutorInfo *pei,
|
|
TupleDesc tupDesc);
|
|
extern void ExecParallelFinish(ParallelExecutorInfo *pei);
|
|
extern void ExecParallelCleanup(ParallelExecutorInfo *pei);
|
|
extern void ExecParallelReinitialize(PlanState *planstate,
|
|
ParallelExecutorInfo *pei);
|
|
|
|
extern void ParallelQueryMain(dsm_segment *seg, shm_toc *toc);
|
|
|
|
#endif /* EXECPARALLEL_H */
|