diff options
| author | Robert Haas <rhaas@postgresql.org> | 2016-02-03 12:46:18 -0500 |
|---|---|---|
| committer | Robert Haas <rhaas@postgresql.org> | 2016-02-03 12:49:46 -0500 |
| commit | 69d34408e5e7adcef8ef2f4e9c4f2919637e9a06 (patch) | |
| tree | bce5efdc1891f9a86505228090b8838fba710833 /src/include/executor | |
| parent | 25e44518c16461d66fb6cec2063035d591db1def (diff) | |
| download | postgresql-69d34408e5e7adcef8ef2f4e9c4f2919637e9a06.tar.gz postgresql-69d34408e5e7adcef8ef2f4e9c4f2919637e9a06.zip | |
Allow parallel custom and foreign scans.
This patch doesn't put the new infrastructure to use anywhere, and
indeed it's not clear how it could ever be used for something like
postgres_fdw which has to send an SQL query and wait for a reply,
but there might be FDWs or custom scan providers that are CPU-bound,
so let's give them a way to join club parallel.
KaiGai Kohei, reviewed by me.
Diffstat (limited to 'src/include/executor')
| -rw-r--r-- | src/include/executor/nodeCustom.h | 11 | ||||
| -rw-r--r-- | src/include/executor/nodeForeignscan.h | 8 |
2 files changed, 19 insertions, 0 deletions
diff --git a/src/include/executor/nodeCustom.h b/src/include/executor/nodeCustom.h index e244942d79a..410a3ad14db 100644 --- a/src/include/executor/nodeCustom.h +++ b/src/include/executor/nodeCustom.h @@ -12,6 +12,7 @@ #ifndef NODECUSTOM_H #define NODECUSTOM_H +#include "access/parallel.h" #include "nodes/execnodes.h" /* @@ -26,4 +27,14 @@ extern void ExecReScanCustomScan(CustomScanState *node); extern void ExecCustomMarkPos(CustomScanState *node); extern void ExecCustomRestrPos(CustomScanState *node); +/* + * Parallel execution support + */ +extern void ExecCustomScanEstimate(CustomScanState *node, + ParallelContext *pcxt); +extern void ExecCustomScanInitializeDSM(CustomScanState *node, + ParallelContext *pcxt); +extern void ExecCustomScanInitializeWorker(CustomScanState *node, + shm_toc *toc); + #endif /* NODECUSTOM_H */ diff --git a/src/include/executor/nodeForeignscan.h b/src/include/executor/nodeForeignscan.h index a92ce5c22a3..c2553295fab 100644 --- a/src/include/executor/nodeForeignscan.h +++ b/src/include/executor/nodeForeignscan.h @@ -14,6 +14,7 @@ #ifndef NODEFOREIGNSCAN_H #define NODEFOREIGNSCAN_H +#include "access/parallel.h" #include "nodes/execnodes.h" extern ForeignScanState *ExecInitForeignScan(ForeignScan *node, EState *estate, int eflags); @@ -21,4 +22,11 @@ extern TupleTableSlot *ExecForeignScan(ForeignScanState *node); extern void ExecEndForeignScan(ForeignScanState *node); extern void ExecReScanForeignScan(ForeignScanState *node); +extern void ExecForeignScanEstimate(ForeignScanState *node, + ParallelContext *pcxt); +extern void ExecForeignScanInitializeDSM(ForeignScanState *node, + ParallelContext *pcxt); +extern void ExecForeignScanInitializeWorker(ForeignScanState *node, + shm_toc *toc); + #endif /* NODEFOREIGNSCAN_H */ |