| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
447 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
513 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
547 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
742 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
744 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
885 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
951 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
447 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
513 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
547 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
742 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
744 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
885 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
951 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
447 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
513 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
547 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
742 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
744 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
885 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
951 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
447 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
513 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
547 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
742 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
744 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
885 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
951 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
447 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
513 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
547 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
742 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
744 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
885 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
951 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql14-client/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
447 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
513 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
547 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
742 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
744 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
885 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
951 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
446 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
512 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
546 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
741 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
743 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
884 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
950 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql14-docs/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
447 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
513 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
547 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
742 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
744 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
885 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
951 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
446 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
512 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
546 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
741 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
743 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
884 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
950 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
446 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
512 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
546 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
741 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
743 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
884 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
950 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
446 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
512 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
546 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
741 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
743 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
884 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
950 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
446 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
512 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
546 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
741 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
743 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
884 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
950 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql13-plperl/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
446 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
512 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
546 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
741 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
743 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
884 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
950 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql13-plpython/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 193 return pcxt; in CreateParallelContext()
288 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
315 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
446 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
512 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
546 if (pcxt->nworkers == 0 || pcxt->nworkers_to_launch == 0) in LaunchParallelWorkers()
741 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
743 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
884 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
950 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql12-client/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 187 return pcxt; in CreateParallelContext()
279 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
306 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
409 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers); in InitializeParallelDSM()
430 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
496 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
708 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
710 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
851 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
917 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql12-server/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 187 return pcxt; in CreateParallelContext()
279 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
306 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
409 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers); in InitializeParallelDSM()
430 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
496 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
708 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
710 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
851 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
917 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 187 return pcxt; in CreateParallelContext()
279 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
306 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
409 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers); in InitializeParallelDSM()
430 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
496 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
708 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
710 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
851 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
917 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 187 return pcxt; in CreateParallelContext()
279 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
306 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
409 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers); in InitializeParallelDSM()
430 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
496 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
708 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
710 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
851 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
917 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 187 return pcxt; in CreateParallelContext()
279 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
306 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
409 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers); in InitializeParallelDSM()
430 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
496 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
708 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
710 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
851 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
917 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql12-pltcl/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 187 return pcxt; in CreateParallelContext()
279 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
306 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
409 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers); in InitializeParallelDSM()
430 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
496 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
708 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
710 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
851 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
917 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql12-docs/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 187 return pcxt;
279 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) +
306 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory,
409 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers);
430 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL);
496 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL);
708 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched)
710 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched);
851 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL)
917 pcxt->seg = NULL;
[all …]
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 199 return pcxt; in CreateParallelContext()
285 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
312 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
400 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers); in InitializeParallelDSM()
421 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
487 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
703 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
705 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
846 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
912 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 199 return pcxt; in CreateParallelContext()
285 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
312 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
400 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers); in InitializeParallelDSM()
421 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
487 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
703 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
705 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
846 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
912 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 199 return pcxt; in CreateParallelContext()
285 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
312 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
400 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers); in InitializeParallelDSM()
421 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
487 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
703 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
705 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
846 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
912 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 199 return pcxt; in CreateParallelContext()
285 shm_toc_estimate_chunk(&pcxt->estimator, strlen(pcxt->library_name) + in InitializeParallelDSM()
312 pcxt->toc = shm_toc_create(PARALLEL_MAGIC, pcxt->private_memory, in InitializeParallelDSM()
400 pcxt->worker = palloc0(sizeof(ParallelWorkerInfo) * pcxt->nworkers); in InitializeParallelDSM()
421 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in InitializeParallelDSM()
487 pcxt->worker[i].error_mqh = shm_mq_attach(mq, pcxt->seg, NULL); in ReinitializeParallelDSM()
703 if (pcxt->nknown_attached_workers >= pcxt->nworkers_launched) in WaitForParallelWorkersToAttach()
705 Assert(pcxt->nknown_attached_workers == pcxt->nworkers_launched); in WaitForParallelWorkersToAttach()
846 if (pcxt->worker == NULL || pcxt->worker[i].bgwhandle == NULL) in WaitForParallelWorkersToExit()
912 pcxt->seg = NULL; in DestroyParallelContext()
[all …]
|