- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for getCurrent (0.15 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/DefaultResourceLockCoordinationService.java
} } } @Override public void assertHasStateLock() { synchronized (lock) { if (getCurrent() == null) { throw new IllegalStateException(); } } } @Override public void addLockReleaseListener(Action<ResourceLock> listener) { synchronized (lock) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/kubelet/pleg/generic.go
// update running pod and container count updateRunningPodAndContainerMetrics(pods) g.podRecords.setCurrent(pods) // Compare the old and the current pods, and generate events. eventsByPodID := map[types.UID][]*PodLifecycleEvent{} for pid := range g.podRecords { oldPod := g.podRecords.getOld(pid) pod := g.podRecords.getCurrent(pid) // Get all containers in the old and the new pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/DefaultResourceLockCoordinationServiceTest.groovy
@Override ResourceLockState.Disposition transform(ResourceLockState resourcesLockState) { assert coordinationService.getCurrent() == resourcesLockState return FINISHED } }) then: noExceptionThrown() } def "locks are rolled back when an exception is thrown"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 15.4K bytes - Viewed (0)