- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for awaitCompletion (0.12 sec)
-
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ChainingHttpHandler.java
long completionTimeout = clock.getCurrentTime() + timeoutMs; for (RequestOutcome outcome : outcomes) { long waitTime = completionTimeout - clock.getCurrentTime(); outcome.awaitCompletion(waitTime); } } @Override public void handle(HttpExchange httpExchange) { try { int id = counter.incrementAndGet();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 10.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
new ExecutorWorker(thisPlanOnly, currentWorkerLease, cancellationToken, coordinationService, workerLeaseService, stats).run(); List<Throwable> failures = new ArrayList<>(); awaitCompletion(workSource, currentWorkerLease, failures); return ExecutionResult.maybeFailed(failures); } @Override public void assertHealthy() { // Wait until execution state is healthy.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0)