| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/connection/ |
| H A D | remote_commands.c | 775 WaitEventSet *waitEventSet = NULL; in WaitForAllConnections() local
816 if (waitEventSet != NULL) in WaitForAllConnections()
818 FreeWaitEventSet(waitEventSet); in WaitForAllConnections()
828 int eventCount = WaitEventSetWait(waitEventSet, timeout, events, in WaitForAllConnections()
959 if (waitEventSet != NULL) in WaitForAllConnections()
961 FreeWaitEventSet(waitEventSet); in WaitForAllConnections()
962 waitEventSet = NULL; in WaitForAllConnections()
972 if (waitEventSet != NULL) in WaitForAllConnections()
974 FreeWaitEventSet(waitEventSet); in WaitForAllConnections()
975 waitEventSet = NULL; in WaitForAllConnections()
[all …]
|
| H A D | connection_management.c | 753 WaitEventSet *waitEventSet = CreateWaitEventSet(CurrentMemoryContext, eventSetSize); in WaitEventSetFromMultiConnectionStates() local
755 waitEventSet); in WaitEventSetFromMultiConnectionStates()
761 AddWaitEventToSet(waitEventSet, WL_POSTMASTER_DEATH, PGINVALID_SOCKET, NULL, NULL); in WaitEventSetFromMultiConnectionStates()
762 AddWaitEventToSet(waitEventSet, WL_LATCH_SET, PGINVALID_SOCKET, MyLatch, NULL); in WaitEventSetFromMultiConnectionStates()
784 AddWaitEventToSet(waitEventSet, eventMask, sock, NULL, connectionState); in WaitEventSetFromMultiConnectionStates()
793 return waitEventSet; in WaitEventSetFromMultiConnectionStates()
831 WaitEventSet *waitEventSet = NULL; in FinishConnectionListEstablishment() local
879 waitEventSet = WaitEventSetFromMultiConnectionStates(connectionStates, in FinishConnectionListEstablishment()
889 int eventCount = WaitEventSetWait(waitEventSet, timeout, events, waitCount, in FinishConnectionListEstablishment()
934 ModifyWaitEvent(waitEventSet, event->pos, eventMask, NULL); in FinishConnectionListEstablishment()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/ |
| H A D | adaptive_executor.c | 246 WaitEventSet *waitEventSet; member
2386 if (execution->waitEventSet != NULL) in RunDistributedExecution()
2388 FreeWaitEventSet(execution->waitEventSet); in RunDistributedExecution()
2389 execution->waitEventSet = NULL; in RunDistributedExecution()
2408 if (execution->waitEventSet != NULL) in RunDistributedExecution()
2411 execution->waitEventSet = NULL; in RunDistributedExecution()
2501 if (execution->waitEventSet != NULL) in RebuildWaitEventSet()
2503 FreeWaitEventSet(execution->waitEventSet); in RebuildWaitEventSet()
2504 execution->waitEventSet = NULL; in RebuildWaitEventSet()
5112 WaitEventSet *waitEventSet = in BuildWaitEventSet() local
[all …]
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/virtualMachine/ |
| H A D | virtualmachine001.java | 116 eventSet = waitEventSet(brkp, waitTime); in execTest()
137 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in virtualmachine001
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/toString/ |
| H A D | tostring001.java | 126 eventSet = waitEventSet(brkp, waitTime); in execTest()
144 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in tostring001
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/virtualMachine/ |
| H A D | virtualmachine001.java | 116 eventSet = waitEventSet(brkp, waitTime); in execTest()
137 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in virtualmachine001
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/virtualMachine/ |
| H A D | virtualmachine001.java | 116 eventSet = waitEventSet(brkp, waitTime); in execTest()
137 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in virtualmachine001
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/toString/ |
| H A D | tostring001.java | 126 eventSet = waitEventSet(brkp, waitTime); in execTest()
144 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in tostring001
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/toString/ |
| H A D | tostring001.java | 126 eventSet = waitEventSet(brkp, waitTime); in execTest()
144 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in tostring001
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/virtualMachine/ |
| H A D | virtualmachine001.java | 116 eventSet = waitEventSet(brkp, waitTime); in execTest()
137 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in virtualmachine001
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/toString/ |
| H A D | tostring001.java | 126 eventSet = waitEventSet(brkp, waitTime); in execTest()
144 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in tostring001
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/toString/ |
| H A D | tostring001.java | 126 eventSet = waitEventSet(brkp, waitTime); in execTest()
144 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in tostring001
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/virtualMachine/ |
| H A D | virtualmachine001.java | 116 eventSet = waitEventSet(brkp, waitTime); in execTest()
137 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in virtualmachine001
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/virtualMachine/ |
| H A D | virtualmachine001.java | 116 eventSet = waitEventSet(brkp, waitTime); in execTest()
137 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in virtualmachine001
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/toString/ |
| H A D | tostring001.java | 126 eventSet = waitEventSet(brkp, waitTime); in execTest()
144 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in tostring001
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/virtualMachine/ |
| H A D | virtualmachine001.java | 116 eventSet = waitEventSet(brkp, waitTime); in execTest()
137 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in virtualmachine001
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/toString/ |
| H A D | tostring001.java | 126 eventSet = waitEventSet(brkp, waitTime); in execTest()
144 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in tostring001
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/toString/ |
| H A D | tostring001.java | 126 eventSet = waitEventSet(brkp, waitTime); in execTest()
144 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in tostring001
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/hotspot/jtreg/vmTestbase/nsk/jdi/EventSet/virtualMachine/ |
| H A D | virtualmachine001.java | 116 eventSet = waitEventSet(brkp, waitTime); in execTest()
137 private static EventSet waitEventSet(EventRequest request, long timeout) in waitEventSet() method in virtualmachine001
|