On 13-03-2015 PM 01:37, Amit Langote wrote: > By the way, is it right that TupleQueueFunnel.queue has one shm_mq_handle per > initialized parallel worker? If so, how does TupleQueueFunnel.maxqueues relate > to ParallelContext.nworkers (of the corresponding parallel context)? > > Why I asked this is because in CreateTupleQueueFunnel(): > > funnel->maxqueues = 8; > funnel->queue = palloc(funnel->maxqueues * sizeof(shm_mq_handle *)); > > So, is the hardcoded "8" intentional or an oversight? >
Oh, I see that in RegisterTupleQueueOnFunnel(), the TupleQueueFunnel.queue is expanded (repalloc'd) if needed as per corresponding pcxt->nworkers. Thanks, Amit -- Sent via pgsql-hackers mailing list (pgsql-hackers@postgresql.org) To make changes to your subscription: http://www.postgresql.org/mailpref/pgsql-hackers
