Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for waitForAllPendingCalls (0.2 sec)

  1. platforms/core-runtime/logging/src/integTest/groovy/org/gradle/internal/logging/console/AbstractConsoleBuildPhaseFunctionalTest.groovy

            expect:
            settings.waitForAllPendingCalls()
            assertHasBuildPhase("0% INITIALIZING")
            settings.releaseAll()
    
            and:
            rootBuildScript.waitForAllPendingCalls()
            assertHasBuildPhase("0% CONFIGURING")
            rootBuildScript.releaseAll()
    
            and:
            bBuildScript.waitForAllPendingCalls()
            assertHasBuildPhase("40% CONFIGURING")
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 15 07:25:15 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  2. platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r65/ToolingApiShutdownCrossVersionSpec.groovy

            def build = connection.newBuild()
            build.forTasks('hang')
            build.run(resultHandler)
            sync.waitForAllPendingCalls(resultHandler)
            connector.disconnect()
            resultHandler.finished()
    
            then:
            assertNoRunningDaemons()
        }
    
        @Timeout(30)
        @TargetGradleVersion(">=6.8")
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 16 10:10:39 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  3. testing/internal-integ-testing/src/test/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServerTest.groovy

                }
                start { succeeds("c") }
                handle.waitForAllPendingCalls()
                handle.release("a")
                handle.waitForAllPendingCalls()
                handle.releaseAll()
                handle.waitForAllPendingCalls()
                handle.releaseAll()
                handle.waitForAllPendingCalls()
            }
            server.stop()
    
            then:
            noExceptionThrown()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 46.1K bytes
    - Viewed (0)
  4. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/ParallelDownloadsIntegrationTest.groovy

            def build = executer.withTasks("resolve").start()
    
            metadataRequests.waitForAllPendingCalls()
            metadataRequests.release(2)
    
            metadataRequests.waitForAllPendingCalls()
            metadataRequests.release(2)
    
            requests.waitForAllPendingCalls()
            requests.release(2)
    
            requests.waitForAllPendingCalls()
            requests.release(2)
    
            build.waitForFinish()
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 17:10:15 UTC 2024
    - 13K bytes
    - Viewed (0)
  5. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequests.java

            condition.signalAll();
        }
    
    
        @Override
        public void waitForAllPendingCalls() {
            waitForAllPendingCalls(BlockingHttpServer.FailureTracker.NO_FAILURE_TRACKER);
        }
    
        @Override
        public void waitForAllPendingCalls(BlockingHttpServer.FailureTracker failureTracker) {
            lock.lock();
            try {
                previous.assertCanWait();
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
Back to top