From d1b7c1ffe72e86932b5395f29e006c3f503bc53d Mon Sep 17 00:00:00 2001 From: Robert Haas Date: Mon, 28 Sep 2015 21:55:57 -0400 Subject: Parallel executor support. This code provides infrastructure for a parallel leader to start up parallel workers to execute subtrees of the plan tree being executed in the master. User-supplied parameters from ParamListInfo are passed down, but PARAM_EXEC parameters are not. Various other constructs, such as initplans, subplans, and CTEs, are also not currently shared. Nevertheless, there's enough here to support a basic implementation of parallel query, and we can lift some of the current restrictions as needed. Amit Kapila and Robert Haas --- src/backend/executor/tqueue.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'src/backend/executor/tqueue.c') diff --git a/src/backend/executor/tqueue.c b/src/backend/executor/tqueue.c index d0edf4e5595..67143d33da6 100644 --- a/src/backend/executor/tqueue.c +++ b/src/backend/executor/tqueue.c @@ -66,7 +66,9 @@ tqueueStartupReceiver(DestReceiver *self, int operation, TupleDesc typeinfo) static void tqueueShutdownReceiver(DestReceiver *self) { - /* do nothing */ + TQueueDestReceiver *tqueue = (TQueueDestReceiver *) self; + + shm_mq_detach(shm_mq_get_queue(tqueue->handle)); } /* -- cgit v1.2.3