- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for workerLease (0.29 sec)
-
subprojects/core/src/test/groovy/org/gradle/internal/work/DefaultAsyncWorkTrackerTest.groovy
_ * workerLeaseService.currentWorkerLease >> workerLease 1 * workerLeaseService.withoutLock(workerLease, _) >> { locks, Runnable runnable -> runnable.run() } 0 * workerLeaseService._ } def "does not temporarily release a project lock before waiting on async work when no work is registered"() { def workerLease = Mock(WorkerLeaseRegistry.WorkerLease) def workerLeaseService = Mock(WorkerLeaseService)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 06 04:53:10 UTC 2023 - 14.9K bytes - Viewed (0) -
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/main/java/org/gradle/execution/plan/DefaultFinalizedExecutionPlan.java
runningNodes.clear(); reachableCache.clear(); } private void resourceUnlocked(ResourceLock resourceLock) { if (!(resourceLock instanceof WorkerLeaseRegistry.WorkerLease) && !readyNodes.isEmpty()) { maybeNodesSelectable = true; } } @Override public State executionState() { lockCoordinator.assertHasStateLock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Dec 28 21:49:39 UTC 2022 - 28.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
DefaultBuildOperationQueue(boolean allowAccessToProjectState, WorkerLeaseService workerLeases, Executor executor, QueueWorker<T> queueWorker) { this.allowAccessToProjectState = allowAccessToProjectState; this.workerLeases = workerLeases; this.executor = executor; this.queueWorker = queueWorker; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K 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)