- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 63 for resourceLock (0.23 sec)
-
pkg/scheduler/apis/config/v1/defaults_test.go
LeaseDuration: metav1.Duration{Duration: 15 * time.Second}, RenewDeadline: metav1.Duration{Duration: 10 * time.Second}, RetryPeriod: metav1.Duration{Duration: 2 * time.Second}, ResourceLock: "leases", ResourceNamespace: "kube-system", ResourceName: "kube-scheduler", }, ClientConnection: componentbaseconfig.ClientConnectionConfiguration{ QPS: 50,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 15:03:04 UTC 2024 - 27.9K 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/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceWorkerLeaseTest.groovy
} def "does not release worker lease when replacing locks and locks can be acquired without blocking"() { def registry = workerLeaseService(1) def resource1 = resourceLock("one") def resource2 = resourceLock("two") when: async { start { registry.runAsWorkerThread { instant.worker1Started
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 13.2K 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) -
subprojects/core/src/main/java/org/gradle/api/internal/project/DefaultProjectStateRegistry.java
private final IProjectFactory projectFactory; private final BuildState owner; private final Path identityPath; private final ResourceLock allProjectsLock; private final ResourceLock projectLock; private final ResourceLock taskLock; private final Set<Thread> canDoAnythingToThisProject = new CopyOnWriteArraySet<>(); private final ProjectLifecycleController controller;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 21K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/TaskInAnotherBuild.java
import org.gradle.composite.internal.IncludedBuildTaskResource; import org.gradle.composite.internal.TaskIdentifier; import org.gradle.internal.lazy.Lazy; import org.gradle.internal.resources.ResourceLock; import org.gradle.util.Path; import javax.annotation.Nullable; import java.util.Collections; import java.util.List; import java.util.Set;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 06 15:09:14 UTC 2023 - 7.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/ActionNode.java
import org.gradle.api.internal.tasks.NodeExecutionContext; import org.gradle.api.internal.tasks.TaskDependencyContainer; import org.gradle.api.internal.tasks.WorkNodeAction; import org.gradle.internal.resources.ResourceLock; import javax.annotation.Nullable; import java.util.List; import java.util.function.Consumer; public class ActionNode extends Node implements SelfExecutingNode { private WorkNodeAction action;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Aug 26 20:11:12 UTC 2022 - 3.9K bytes - Viewed (0)