- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for workItem2 (0.13 sec)
-
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/DefaultWorkerExecutor.java
private void await(List<AsyncWorkCompletion> workItems) throws WorkExecutionException { BuildOperationRef currentOperation = buildOperationRunner.getCurrentOperation(); try { if (CollectionUtils.any(workItems, workItem -> !workItem.isComplete())) { executionQueue.expand(); } asyncWorkTracker.waitForCompletion(currentOperation, workItems, RETAIN_PROJECT_LOCKS);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:17:07 UTC 2024 - 15.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
WorkItem workItem = getNextItem(workerLease); if (workItem == null) { break; } Object selected = workItem.selection.getItem(); LOGGER.info("{} ({}) started.", selected, Thread.currentThread()); execute(selected, workItem.plan, workItem.executor); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
if err != nil { autoRegistrationErrors.Increment() return err } if !changed { return nil } log.Infof("updated auto-registered WorkloadEntry %s/%s as disconnected", workItem.proxy.Metadata.Namespace, workItem.entryName) if workItem.autoCreated { autoRegistrationUnregistrations.Increment() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0)