Home
last modified time | relevance | path

Searched refs:known_attached_workers (Results 1 – 25 of 56) sorted by relevance

123

/dports/databases/postgresql11-client/postgresql-11.14/src/backend/access/transam/
H A Dparallel.c459 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
461 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
462 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
574 pcxt->known_attached_workers = in LaunchParallelWorkers()
639 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
648 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
661 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
678 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
748 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1069 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/access/transam/
H A Dparallel.c459 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
461 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
462 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
574 pcxt->known_attached_workers = in LaunchParallelWorkers()
639 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
648 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
661 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
678 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
748 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1069 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/access/transam/
H A Dparallel.c459 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
461 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
462 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
574 pcxt->known_attached_workers = in LaunchParallelWorkers()
639 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
648 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
661 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
678 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
748 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1069 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql11-docs/postgresql-11.14/src/backend/access/transam/
H A Dparallel.c459 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
461 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
462 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
574 pcxt->known_attached_workers = in LaunchParallelWorkers()
639 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
648 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
661 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
678 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
748 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1069 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/access/transam/
H A Dparallel.c459 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
461 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
462 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
574 pcxt->known_attached_workers = in LaunchParallelWorkers()
639 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
648 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
661 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
678 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
748 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1069 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql11-server/postgresql-11.14/src/backend/access/transam/
H A Dparallel.c459 if (pcxt->known_attached_workers)
461 pfree(pcxt->known_attached_workers);
462 pcxt->known_attached_workers = NULL;
574 pcxt->known_attached_workers =
639 if (pcxt->known_attached_workers[i])
648 pcxt->known_attached_workers[i] = true;
661 pcxt->known_attached_workers[i] = true;
678 pcxt->known_attached_workers[i] = true;
748 else if (pcxt->known_attached_workers[i])
1069 !pcxt->known_attached_workers[i])
[all …]
/dports/databases/postgresql12-client/postgresql-12.9/src/backend/access/transam/
H A Dparallel.c468 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
470 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
471 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
583 pcxt->known_attached_workers = in LaunchParallelWorkers()
648 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
657 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
670 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
687 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
753 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1074 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/access/transam/
H A Dparallel.c459 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
461 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
462 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
574 pcxt->known_attached_workers = in LaunchParallelWorkers()
639 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
648 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
661 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
678 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
748 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1069 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/access/transam/
H A Dparallel.c485 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
487 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
488 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
617 pcxt->known_attached_workers = in LaunchParallelWorkers()
682 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
691 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
704 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
721 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
787 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1108 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql14-server/postgresql-14.1/src/backend/access/transam/
H A Dparallel.c485 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
487 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
488 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
617 pcxt->known_attached_workers = in LaunchParallelWorkers()
682 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
691 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
704 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
721 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
787 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1108 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/access/transam/
H A Dparallel.c485 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
487 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
488 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
617 pcxt->known_attached_workers = in LaunchParallelWorkers()
682 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
691 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
704 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
721 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
787 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1108 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/access/transam/
H A Dparallel.c485 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
487 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
488 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
617 pcxt->known_attached_workers = in LaunchParallelWorkers()
682 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
691 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
704 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
721 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
787 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1108 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/access/transam/
H A Dparallel.c485 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
487 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
488 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
617 pcxt->known_attached_workers = in LaunchParallelWorkers()
682 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
691 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
704 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
721 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
787 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1108 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql14-client/postgresql-14.1/src/backend/access/transam/
H A Dparallel.c485 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
487 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
488 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
617 pcxt->known_attached_workers = in LaunchParallelWorkers()
682 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
691 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
704 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
721 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
787 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1108 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql13-server/postgresql-13.5/src/backend/access/transam/
H A Dparallel.c484 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
486 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
487 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
616 pcxt->known_attached_workers = in LaunchParallelWorkers()
681 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
690 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
703 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
720 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
786 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1107 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql14-docs/postgresql-14.1/src/backend/access/transam/
H A Dparallel.c485 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
487 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
488 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
617 pcxt->known_attached_workers = in LaunchParallelWorkers()
682 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
691 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
704 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
721 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
787 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1108 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/access/transam/
H A Dparallel.c484 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
486 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
487 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
616 pcxt->known_attached_workers = in LaunchParallelWorkers()
681 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
690 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
703 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
720 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
786 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1107 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql12-server/postgresql-12.9/src/backend/access/transam/
H A Dparallel.c468 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
470 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
471 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
583 pcxt->known_attached_workers = in LaunchParallelWorkers()
648 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
657 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
670 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
687 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
753 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1074 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql13-docs/postgresql-13.5/src/backend/access/transam/
H A Dparallel.c484 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
486 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
487 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
616 pcxt->known_attached_workers = in LaunchParallelWorkers()
681 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
690 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
703 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
720 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
786 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1107 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/access/transam/
H A Dparallel.c468 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
470 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
471 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
583 pcxt->known_attached_workers = in LaunchParallelWorkers()
648 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
657 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
670 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
687 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
753 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1074 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/access/transam/
H A Dparallel.c468 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
470 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
471 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
583 pcxt->known_attached_workers = in LaunchParallelWorkers()
648 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
657 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
670 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
687 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
753 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1074 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql13-client/postgresql-13.5/src/backend/access/transam/
H A Dparallel.c484 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
486 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
487 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
616 pcxt->known_attached_workers = in LaunchParallelWorkers()
681 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
690 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
703 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
720 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
786 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1107 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/access/transam/
H A Dparallel.c484 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
486 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
487 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
616 pcxt->known_attached_workers = in LaunchParallelWorkers()
681 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
690 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
703 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
720 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
786 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1107 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/access/transam/
H A Dparallel.c468 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
470 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
471 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
583 pcxt->known_attached_workers = in LaunchParallelWorkers()
648 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
657 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
670 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
687 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
753 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1074 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]
/dports/databases/postgresql12-pltcl/postgresql-12.9/src/backend/access/transam/
H A Dparallel.c468 if (pcxt->known_attached_workers) in ReinitializeParallelDSM()
470 pfree(pcxt->known_attached_workers); in ReinitializeParallelDSM()
471 pcxt->known_attached_workers = NULL; in ReinitializeParallelDSM()
583 pcxt->known_attached_workers = in LaunchParallelWorkers()
648 if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToAttach()
657 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
670 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
687 pcxt->known_attached_workers[i] = true; in WaitForParallelWorkersToAttach()
753 else if (pcxt->known_attached_workers[i]) in WaitForParallelWorkersToFinish()
1074 !pcxt->known_attached_workers[i]) in HandleParallelMessage()
[all …]

123