- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for waitUntilBlocked (0.18 sec)
-
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/RemoteDependencyResolveConsoleIntegrationTest.groovy
"> one-1.2.pom", "> two-1.2.pom" ) } when: metaData.releaseAll() getM1Pom.waitUntilBlocked() getM2Pom.waitUntilBlocked() then: ConcurrentTestUtil.poll { outputContainsProgress(build, "> :resolve > Resolve dependencies of :compile",
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun Jan 14 00:59:27 UTC 2024 - 5.2K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java
} } finally { lock.unlock(); } exchange.getResponseBody().write(content, 1024, content.length - 1024); } @Override public void waitUntilBlocked() { lock.lock(); try { precondition.assertCanWait(); if (released) { throw new IllegalStateException("Response has already been released."); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMethod.java
this.precondition = precondition; return this; } @Override public void waitUntilBlocked() { if (blockingRequest == null) { throw new IllegalStateException("This request is not expected to block."); } blockingRequest.waitUntilBlocked(); } @Override public void release() { if (blockingRequest == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 6.6K bytes - Viewed (0) -
testing/internal-integ-testing/src/test/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 46.1K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
} } public interface ThreadHandle { ThreadHandle waitFor(); boolean waitUntil(Date expiry); boolean isCurrentThread(); void waitUntilBlocked(); } public interface ClockTick { ClockTick hasParticipants(int count); } private static class ClockTickImpl implements ClockTick { private final int number;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/integTest/groovy/org/gradle/integtests/tooling/ToolingApiRemoteIntegrationTest.groovy
.forTasks("help") .withCancellationToken(tokenSource.token()) .addProgressListener(events) .run(handler) downloadHandle.waitUntilBlocked() tokenSource.cancel() handler.finished() downloadHandle.release() } then: handler.assertFailedWith(BuildCancelledException)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 10.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
*/ public interface BlockingRequest extends ExpectedRequest { /** * Waits for the request to be received and blocked. */ void waitUntilBlocked(); /** * Unblock the request. */ void release(); } /** * Allows the test to synchronise with and unblock requests. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0)