aboutsummaryrefslogtreecommitdiff
path: root/src/include
diff options
context:
space:
mode:
Diffstat (limited to 'src/include')
-rw-r--r--src/include/executor/execParallel.h1
-rw-r--r--src/include/nodes/execnodes.h2
2 files changed, 2 insertions, 1 deletions
diff --git a/src/include/executor/execParallel.h b/src/include/executor/execParallel.h
index 4fc797ad982..505500e76b5 100644
--- a/src/include/executor/execParallel.h
+++ b/src/include/executor/execParallel.h
@@ -32,5 +32,6 @@ typedef struct ParallelExecutorInfo
extern ParallelExecutorInfo *ExecInitParallelPlan(PlanState *planstate,
EState *estate, int nworkers);
extern void ExecParallelFinish(ParallelExecutorInfo *pei);
+extern void ExecParallelCleanup(ParallelExecutorInfo *pei);
#endif /* EXECPARALLEL_H */
diff --git a/src/include/nodes/execnodes.h b/src/include/nodes/execnodes.h
index 23670e1ff9b..4fcdcc4067a 100644
--- a/src/include/nodes/execnodes.h
+++ b/src/include/nodes/execnodes.h
@@ -1961,9 +1961,9 @@ typedef struct UniqueState
typedef struct GatherState
{
PlanState ps; /* its first field is NodeTag */
+ bool initialized;
struct ParallelExecutorInfo *pei;
struct TupleQueueFunnel *funnel;
- bool need_to_scan_workers;
bool need_to_scan_locally;
} GatherState;