Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,100 for actioned (0.15 sec)

  1. testing/internal-testing/src/test/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpecTest.groovy

            given:
            def action1 = {
                instant.action1Start
                thread.block()
                instant.action1End
            }
            def action2 = {
                instant.action2Start
            }
    
            when:
            start {
                synchronizer.runNow(action1)
            }
            async {
                thread.blockUntil.action1Start
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. platforms/ide/tooling-api-builders/src/test/groovy/org/gradle/tooling/internal/provider/runner/DefaultBuildControllerTest.groovy

            then:
            result.getModel() == model
        }
    
        def "runs supplied actions"() {
            def action1 = Mock(Supplier)
            def action2 = Mock(Supplier)
            def action3 = Mock(Supplier)
    
            when:
            def result = controller.run([action1, action2, action3])
    
            then:
            result == ["one", "two", "three"]
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Jun 05 08:56:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. fess-crawler-es/src/test/java/org/codelibs/fess/crawler/service/impl/EsUrlQueueServiceTest.java

                    .execute().actionGet().getHits().getTotalHits().value > 0);
    
            urlQueueService.delete("sessionId");
            assertFalse(fesenClient.prepareSearch("fess_crawler.queue").setQuery(QueryBuilders.termQuery("sessionId", "sessionId")).setSize(0)
                    .execute().actionGet().getHits().getTotalHits().value > 0);
    
        }
    
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  4. platforms/ide/problems-api/src/test/groovy/org/gradle/internal/code/DefaultUserCodeApplicationContextTest.groovy

            def action2 = Mock(Action)
            def id1
    
            when:
            context.apply(source, action)
    
            then:
            1 * action.execute(_) >> { UserCodeApplicationId id ->
                id1 = id
                context.apply(source2, action2)
                assert context.current().id == id
                assert context.current().source == source
            }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Sep 27 13:19:04 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  5. platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/connection/LazyConsumerActionExecutorTest.groovy

            1 * action.run(consumerConnection)
            0 * _._
        }
    
        def reusesConnection() {
            def action2 = Mock(ConsumerAction)
    
            when:
            connection.run(action)
            connection.run(action2)
    
            then:
            1 * loggingProvider.getProgressLoggerFactory() >> progressLoggerFactory
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  6. src/cmd/go/internal/work/cover.go

    // run actions. Note that this function has to be called A) after the
    // build actions are complete for all packages being tested, and B)
    // before any of the "run test" actions for those packages happen.
    // This requirement is enforced by adding making this action ("a")
    // dependent on all test package build actions, and making all test
    // run actions dependent on this action.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 19:09:38 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  7. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy

            client?.stop()
        }
    
        def "manages contention for multiple locks"() {
            def action1 = new AtomicBoolean()
            def action2 = new AtomicBoolean()
    
            when:
            int port = handler.reservePort()
            handler.start(10, { action1.set(true) })
            handler.start(11, { action2.set(true) })
    
            client.maybePingOwner(port, 10, "lock 1", 50000, null)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/async/ServiceLifecycleTest.groovy

        def "can use service when not stopped"() {
            def action = Mock(Runnable)
    
            when:
            lifecycle.use(action)
    
            then:
            1 * action.run()
            0 * _._
        }
    
        def "can use service concurrently from multiple threads"() {
            given:
            def action1 = {
                instant.action1Started
                thread.blockUntil.action2Done
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 19:07:55 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java

                        }
                        response = builder.execute().actionGet(settings.getSearchTimeout());
                    } else {
                        response = client.prepareSearchScroll(scrollId).setScroll(settings.getScrollTimeout()).execute()
                                .actionGet(settings.getSearchTimeout());
                        if (!scrollId.equals(response.getScrollId())) {
    Registered: Wed Jun 12 15:38:08 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  10. src/cmd/buildid/buildid.go

    	if err != nil {
    		log.Fatal(err)
    	}
    	matches, hash, err := buildid.FindAndHash(f, id, 0)
    	f.Close()
    	if err != nil {
    		log.Fatal(err)
    	}
    
    	// <= go 1.7 doesn't embed the contentID or actionID, so no slash is present
    	if !strings.Contains(id, "/") {
    		log.Fatalf("%s: build ID is a legacy format...binary too old for this tool", file)
    	}
    
    	newID := id[:strings.LastIndex(id, "/")] + "/" + buildid.HashToString(hash)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 1.7K bytes
    - Viewed (0)
Back to top