- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for resourceLock (0.36 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java
Registries registries = this.registries.get(); Collection<? extends ResourceLock> projectLocks = registries.getProjectLockRegistry().getResourceLocksByCurrentThread(); Collection<? extends ResourceLock> taskLocks = registries.getTaskExecutionLockRegistry().getResourceLocksByCurrentThread(); List<ResourceLock> locks = new ArrayList<ResourceLock>(projectLocks.size() + taskLocks.size()); locks.addAll(projectLocks);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 04:43:28 UTC 2024 - 20.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/DefaultResourceLockCoordinationService.java
private final Iterable<? extends ResourceLock> resourceLocks; ReleaseLocks(Iterable<? extends ResourceLock> resourceLocks) { this.resourceLocks = resourceLocks; } @Override public ResourceLockState.Disposition transform(ResourceLockState resourceLockState) { for (ResourceLock resourceLock : resourceLocks) { resourceLock.unlock(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 11.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/DefaultResourceLockCoordinationServiceTest.groovy
then: lock1.lockedState } def "can nest multiple calls to withStateLock"() { def lock = [ resourceLock("lock1"), resourceLock("lock2"), resourceLock("lock3"), resourceLock("lock4") ] given: def innerAction = new InternalTransformer<ResourceLockState.Disposition, ResourceLockState>() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 15.4K bytes - Viewed (0) -
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/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) -
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) -
pkg/scheduler/apis/config/validation/validation.go
// TODO: This can be removed when ResourceLock is not available // Only ResourceLock values with leases are allowed if cc.LeaderElection.LeaderElect && cc.LeaderElection.ResourceLock != "leases" { leaderElectionPath := field.NewPath("leaderElection") errs = append(errs, field.Invalid(leaderElectionPath.Child("resourceLock"), cc.LeaderElection.ResourceLock, `resourceLock value must be "leases"`)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 06:27:01 UTC 2024 - 11.5K bytes - Viewed (0) -
cmd/kube-scheduler/app/options/options.go
} // add a uniquifier so that two processes on the same host don't accidentally both become active id := hostname + "_" + string(uuid.NewUUID()) rl, err := resourcelock.NewFromKubeconfig(config.ResourceLock, config.ResourceNamespace, config.ResourceName, resourcelock.ResourceLockConfig{ Identity: id, EventRecorder: recorder, }, kubeConfig, config.RenewDeadline.Duration) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 17 17:06:29 UTC 2024 - 13.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/services/internal/DefaultBuildServicesRegistry.java
}); } @Override public List<ResourceLock> getSharedResources(Set<Provider<? extends BuildService<?>>> services) { if (services.isEmpty()) { return Collections.emptyList(); } ImmutableList.Builder<ResourceLock> locks = ImmutableList.builder(); for (Provider<? extends BuildService<?>> service : services) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 19:15:45 UTC 2024 - 16.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.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 Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0)