Re: Parallel Seq Scan

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