- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for workerLease (0.18 sec)
-
subprojects/core/src/test/groovy/org/gradle/execution/plan/DefaultPlanExecutorTest.groovy
def cancellationHandler = Mock(BuildCancellationToken) def coordinationService = new DefaultResourceLockCoordinationService() def workerLeaseService = Mock(WorkerLeaseService) def workerLease = Mock(WorkerLeaseRegistry.WorkerLease) def executor = new DefaultPlanExecutor(new DefaultWorkerLimits(1), executorFactory, workerLeaseService, cancellationHandler, coordinationService, new DefaultInternalOptions([:]))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 4.3K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/work/TestWorkerLeaseService.groovy
return factory.create() } @Override boolean isAllowedUncontrolledAccessToAnyProject() { return false } private WorkerLease workerLease() { return new WorkerLease() { @Override boolean isLocked() { return false } @Override boolean isLockedByCurrentThread() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K 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/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/internal/operations/DefaultBuildOperationExecutorParallelExecutionTest.groovy
WorkerLeaseService workerRegistry BuildOperationExecutor buildOperationExecutor WorkerLeaseRegistry.WorkerLeaseCompletion outerOperationCompletion WorkerLeaseRegistry.WorkerLease outerOperation def setupBuildOperationExecutor(int maxThreads) { def workerLimits = new DefaultWorkerLimits(maxThreads)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 9.6K 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)