| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 563 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
564 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
646 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
746 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
780 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
894 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
898 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
899 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1025 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1154 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 563 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
564 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
646 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
746 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
780 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
894 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
898 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
899 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1025 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1154 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 563 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
564 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
646 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
746 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
780 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
894 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
898 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
899 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1025 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1154 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 563 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
564 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
646 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
746 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
780 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
894 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
898 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
899 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1025 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1154 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 563 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
564 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
646 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
746 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
780 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
894 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
898 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
899 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1025 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1154 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql11-server/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 563 shm_mq_detach(pcxt->worker[i].error_mqh);
564 pcxt->worker[i].error_mqh = NULL;
646 if (pcxt->worker[i].error_mqh == NULL)
746 if (pcxt->worker[i].error_mqh == NULL)
780 if (pcxt->worker[i].error_mqh == NULL ||
894 if (pcxt->worker[i].error_mqh != NULL)
898 shm_mq_detach(pcxt->worker[i].error_mqh);
899 pcxt->worker[i].error_mqh = NULL;
1025 while (pcxt->worker[i].error_mqh != NULL)
1154 shm_mq_detach(pcxt->worker[i].error_mqh);
[all …]
|
| /dports/databases/postgresql12-client/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 572 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
573 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
655 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
751 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
785 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
899 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
903 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
904 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1030 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1159 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/access/transam/ |
| H A D | parallel.c | 563 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
564 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
646 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
746 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
780 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
894 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
898 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
899 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1025 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1154 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 606 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
607 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
689 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
785 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
819 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
933 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
937 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
938 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1064 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1193 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 606 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
607 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
689 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
785 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
819 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
933 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
937 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
938 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1064 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1193 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 606 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
607 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
689 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
785 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
819 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
933 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
937 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
938 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1064 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1193 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 606 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
607 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
689 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
785 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
819 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
933 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
937 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
938 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1064 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1193 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 606 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
607 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
689 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
785 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
819 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
933 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
937 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
938 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1064 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1193 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql14-client/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 606 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
607 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
689 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
785 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
819 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
933 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
937 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
938 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1064 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1193 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 605 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
606 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
688 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
784 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
818 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
932 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
936 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
937 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1063 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1192 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql14-docs/postgresql-14.1/src/backend/access/transam/ |
| H A D | parallel.c | 606 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
607 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
689 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
785 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
819 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
933 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
937 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
938 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1064 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1193 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 605 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
606 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
688 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
784 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
818 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
932 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
936 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
937 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1063 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1192 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql12-server/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 572 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
573 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
655 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
751 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
785 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
899 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
903 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
904 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1030 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1159 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 605 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
606 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
688 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
784 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
818 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
932 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
936 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
937 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1063 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1192 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 572 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
573 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
655 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
751 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
785 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
899 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
903 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
904 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1030 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1159 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 572 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
573 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
655 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
751 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
785 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
899 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
903 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
904 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1030 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1159 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 605 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
606 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
688 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
784 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
818 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
932 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
936 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
937 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1063 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1192 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/access/transam/ |
| H A D | parallel.c | 605 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
606 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
688 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
784 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
818 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
932 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
936 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
937 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1063 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1192 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 572 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
573 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
655 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
751 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
785 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
899 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
903 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
904 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1030 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1159 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|
| /dports/databases/postgresql12-pltcl/postgresql-12.9/src/backend/access/transam/ |
| H A D | parallel.c | 572 shm_mq_detach(pcxt->worker[i].error_mqh); in LaunchParallelWorkers()
573 pcxt->worker[i].error_mqh = NULL; in LaunchParallelWorkers()
655 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToAttach()
751 if (pcxt->worker[i].error_mqh == NULL) in WaitForParallelWorkersToFinish()
785 if (pcxt->worker[i].error_mqh == NULL || in WaitForParallelWorkersToFinish()
899 if (pcxt->worker[i].error_mqh != NULL) in DestroyParallelContext()
903 shm_mq_detach(pcxt->worker[i].error_mqh); in DestroyParallelContext()
904 pcxt->worker[i].error_mqh = NULL; in DestroyParallelContext()
1030 while (pcxt->worker[i].error_mqh != NULL) in HandleParallelMessages()
1159 shm_mq_detach(pcxt->worker[i].error_mqh); in HandleParallelMessage()
[all …]
|