- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for waitForAllPendingCalls (0.33 sec)
-
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerDaemonProcessFailureIntegrationTest.groovy
""" def handler = blockingHttpServer.expectAndBlock("between") when: def gradle = executer.withTasks("compileJava").start() then: handler.waitForAllPendingCalls() and: pidFile('other').exists() def pid1 = pidFile('other').text.strip() as long kill(pid1) when: handler.releaseAll()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Mar 07 18:43:14 UTC 2024 - 9.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/artifactreuse/ArtifactResolutionQueryIntegrationTest.groovy
} """ executer.requireOwnGradleUserHomeDir().requireIsolatedDaemons() expect: def build = executer.withArguments('query:query', ':resolve:resolve', '--parallel').start() handler.waitForAllPendingCalls() handler.release('/sync') Thread.sleep(1000) handler.release(module.pom.path) build.waitForFinish() } @Issue('https://github.com/gradle/gradle/issues/11247')
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 00:21:07 UTC 2024 - 5.8K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/bundling/ConcurrentArchiveIntegrationTest.groovy
// Wait for all extracters to be ready waiting.waitForAllPendingCalls() def firstExtracter = server.expectAndBlock("extract") // release the extracters so they start trying to extract concurrently waiting.releaseAll() // wait for the first extracter to start extracting firstExtracter.waitForAllPendingCalls()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 17:32:21 UTC 2024 - 28.6K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/FixedSharedModeCrossProcessCacheAccessIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jan 10 15:52:52 UTC 2024 - 4.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r86/StreamingBuildActionCrossVersionTest.groovy
collectOutputs(builder) builder.setStreamedValueListener(listener) builder.run(handler) modelReceived.await() request.waitForAllPendingCalls() request.releaseAll() finished.await() } then: models.size() == 2 models[0] instanceof GradleProject
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Mar 07 03:20:59 UTC 2024 - 6.9K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/integTest/groovy/org/gradle/internal/watch/ChangesDuringTheBuildFileSystemWatchingIntegrationTest.groovy
def handle = withWatchFs().executer.withTasks(task).start() def userInput = server.expectAndBlock(expectedCall) userInput.waitForAllPendingCalls() action() userInput.releaseAll() result = handle.waitForFinish() } int getProjectFilesInVfs() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 13:50:33 UTC 2024 - 8K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
*/ void waitForAllPendingCalls(); /** * Waits for the expected number of concurrent requests to be received or until the given {@link FailureTracker} provides a * failure captured during execution which should be reported without waiting further. */ void waitForAllPendingCalls(FailureTracker failureTracker); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/CrossBuildScriptCachingIntegrationSpec.groovy
} """) def handle = server.expectAndBlock("running") when: def longRunning = executer.withTasks("someLongRunningTask").start() handle.waitForAllPendingCalls() then: def before ConcurrentTestUtil.poll { // Output is delivered asynchronously, so wait until the details are available
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 17:32:21 UTC 2024 - 24.2K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformCachingIntegrationTest.groovy
cleaningBarrier.waitForAllPendingCalls() when: 'transforming build is started' def transformBarrier = blockingHttpServer.expectAndBlock("transform") def transformingBuild = executer.withTasks("waitForTransformBarrier").start() then: 'transforming build starts artifact transform' transformBarrier.waitForAllPendingCalls() def cachedTransform = null
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 11:52:44 UTC 2024 - 97.8K bytes - Viewed (0)