diff options
| author | Robert Haas <rhaas@postgresql.org> | 2015-11-18 12:35:25 -0500 |
|---|---|---|
| committer | Robert Haas <rhaas@postgresql.org> | 2015-11-18 12:35:25 -0500 |
| commit | 166b61a88ef8e9fb97eba7b7ab8062e214c93af8 (patch) | |
| tree | 36456939ecfd844777a7f5fd4150a59d068d5547 /src/include/executor/execParallel.h | |
| parent | adeee974866085db84b860c1f397dd7c6b136a0a (diff) | |
| download | postgresql-166b61a88ef8e9fb97eba7b7ab8062e214c93af8.tar.gz postgresql-166b61a88ef8e9fb97eba7b7ab8062e214c93af8.zip | |
Avoid aggregating worker instrumentation multiple times.
Amit Kapila, per design ideas from me.
Diffstat (limited to 'src/include/executor/execParallel.h')
| -rw-r--r-- | src/include/executor/execParallel.h | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/include/executor/execParallel.h b/src/include/executor/execParallel.h index 23c29ebb902..b43af1dd2b3 100644 --- a/src/include/executor/execParallel.h +++ b/src/include/executor/execParallel.h @@ -27,12 +27,13 @@ typedef struct ParallelExecutorInfo BufferUsage *buffer_usage; SharedExecutorInstrumentation *instrumentation; shm_mq_handle **tqueue; + bool finished; } ParallelExecutorInfo; extern ParallelExecutorInfo *ExecInitParallelPlan(PlanState *planstate, EState *estate, int nworkers); extern void ExecParallelFinish(ParallelExecutorInfo *pei); extern void ExecParallelCleanup(ParallelExecutorInfo *pei); -extern shm_mq_handle **ExecParallelReinitializeTupleQueues(ParallelContext *pcxt); +extern void ExecParallelReinitialize(ParallelExecutorInfo *pei); #endif /* EXECPARALLEL_H */ |