- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for workerLease (0.13 sec)
-
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
private void awaitCompletion(WorkSource<?> workSource, WorkerLease workerLease, Collection<? super Throwable> failures) { coordinationService.withStateLock(resourceLockState -> { if (workSource.allExecutionComplete()) { // Need to hold a worker lease in order to finish up if (!workerLease.isLockedByCurrentThread()) { if (!workerLease.tryLock()) { return RETRY;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
start { def workerLease = workerLeaseService.newWorkerLease() coordinationService.withStateLock(lock(workerLease)) try { instant.worker2Executed } finally { coordinationService.withStateLock(unlock(workerLease)) } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java
private void releaseWorkerLeaseAndWaitFor(Collection<? extends ResourceLock> locks) { Collection<? extends ResourceLock> workerLeases = workerLeaseLockRegistry.getResourceLocksByCurrentThread(); List<ResourceLock> allLocks = new ArrayList<ResourceLock>(locks.size() + workerLeases.size()); allLocks.addAll(workerLeases); allLocks.addAll(locks);
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/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceWorkerLeaseTest.groovy
registry?.stop() } def "can use worker lease as resource lock"() { def registry = workerLeaseService(1) when: def workerLease = registry.newWorkerLease() coordinationService.withStateLock(lock(workerLease)) then: noExceptionThrown() } def "acquire lease as resource lock blocks when there are no leases available"() {
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/extensibility/unit-test-fixtures/src/main/java/org/gradle/testfixtures/internal/ProjectBuilderImpl.java
WorkerLeaseService workerLeaseService = buildServices.get(WorkerLeaseService.class); WorkerLeaseRegistry.WorkerLeaseCompletion workerLease = workerLeaseService.maybeStartWorker(); buildServices.get(ProjectParallelExecutionController.class).startProjectExecution(false); GradleInternal gradle = build.getMutableModel();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:36 UTC 2024 - 15.7K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/taskgraph/DefaultTaskExecutionGraphSpec.groovy
def buildOperationRunner = new TestBuildOperationRunner() def listenerBuildOperationDecorator = new TestListenerBuildOperationDecorator() def workerLimits = new DefaultWorkerLimits(1) def workerLeases = new DefaultWorkerLeaseService(coordinator, workerLimits) def executorFactory = Mock(ExecutorFactory) def accessHierarchies = new ExecutionNodeAccessHierarchies(CASE_SENSITIVE, Stub(Stat))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 20.6K bytes - Viewed (0)