- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 26 for ResourceLock (0.23 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/SharedResourceLeaseRegistry.java
*/ package org.gradle.internal.resources; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; public class SharedResourceLeaseRegistry extends AbstractResourceLockRegistry<String, ResourceLock> { private final Map<String, LeaseHolder> sharedResources = new ConcurrentHashMap<String, LeaseHolder>(); private final ResourceLockCoordinationService coordinationService;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ProjectLock.java
*/ package org.gradle.internal.resources; public class ProjectLock extends ExclusiveAccessResourceLock { private final ResourceLock allProjectsLock; public ProjectLock(String displayName, ResourceLockCoordinationService coordinationService, ResourceLockContainer owner, ResourceLock allProjectsLock) { super(displayName, coordinationService, owner); this.allProjectsLock = allProjectsLock; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/TaskExecutionLockRegistry.java
super(coordinationService); this.projectLockRegistry = projectLockRegistry; } public ResourceLock getTaskExecutionLock(Path buildIdentityPath, final Path projectIdentityPath) { if (projectLockRegistry.getAllowsParallelExecution()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/AbstractWorkerLeaseServiceTest.groovy
return service } TestTrackedResourceLock resourceLock(String displayName, boolean locked, boolean hasLock = false) { return new TestTrackedResourceLock(displayName, coordinationService, Mock(ResourceLockContainer), locked, hasLock) } TestTrackedResourceLock resourceLock(String displayName) { return resourceLock(displayName, false) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ProjectLeaseRegistry.java
*/ ResourceLock getAllProjectsLock(Path buildIdentityPath); /** * Get a lock for access to the specified project's state. */ ResourceLock getProjectLock(Path buildIdentityPath, Path projectIdentityPath); /** * Get a lock for non-isolated tasks for the specified project. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 5.4K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/SharedResourceLeaseRegistryTest.groovy
} boolean lockIsHeld(final ResourceLock resourceLock) { MutableBoolean held = new MutableBoolean() coordinationService.withStateLock(new InternalTransformer<ResourceLockState.Disposition, ResourceLockState>() { @Override ResourceLockState.Disposition transform(ResourceLockState resourceLockState) { held.set(resourceLock.locked && resourceLock.isLockedByCurrentThread())
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/AbstractResourceLockRegistryTest.groovy
static class TestRegistry extends AbstractResourceLockRegistry<String, ResourceLock> { TestRegistry(ResourceLockCoordinationService coordinationService) { super(coordinationService) } def getResourceLock(String displayName) { return getOrRegisterResourceLock(displayName, new AbstractResourceLockRegistry.ResourceLockProducer<String, ResourceLock>() { @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockCoordinationService.java
/** * Adds a listener that is notified when a lock is released. Called while the state lock is held. */ void addLockReleaseListener(Action<ResourceLock> listener); void removeLockReleaseListener(Action<ResourceLock> listener);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:18 UTC 2024 - 2.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/LockCache.java
import com.google.common.cache.CacheBuilder; import org.gradle.internal.UncheckedException; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; public class LockCache<K, T extends ResourceLock> { private final Cache<K, T> resourceLocks = CacheBuilder.newBuilder().weakValues().build(); private final ResourceLockCoordinationService coordinationService; private final ResourceLockContainer owner;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.1K bytes - Viewed (0) -
pkg/scheduler/apis/config/v1/defaults.go
obj.PercentageOfNodesToScore = ptr.To[int32](config.DefaultPercentageOfNodesToScore) } if len(obj.LeaderElection.ResourceLock) == 0 { // Use lease-based leader election to reduce cost. // We migrated for EndpointsLease lock in 1.17 and starting in 1.20 we // migrated to Lease lock. obj.LeaderElection.ResourceLock = "leases" } if len(obj.LeaderElection.ResourceNamespace) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 7.2K bytes - Viewed (0)