- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 517 for STARTED (0.12 sec)
-
src/cmd/go/internal/par/queue_test.go
var wg sync.WaitGroup wg.Add(totalWork) started := make([]chan struct{}, totalWork) unblock := make(chan struct{}) for i := range started { started[i] = make(chan struct{}) i := i q.Add(func() { close(started[i]) <-unblock wg.Done() }) } for i, c := range started { if i < maxActive { <-c // Work item i should be started immediately. } else { select { case <-c:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 24 21:08:46 UTC 2020 - 1.4K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/testng/TestNGClassIntegrationTest.groovy
""" when: succeeds 'test' then: containsEvent(STARTED, DefaultTestSuiteDescriptor, 'TestSuite > LightTest') containsEvent(STARTED, DefaultTestClassDescriptor, 'TestSuite > LightTest > org.company.SystemOutTest') containsEvent(STARTED, DefaultTestMethodDescriptor, 'TestSuite > LightTest > org.company.SystemOutTest > testOut')
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 7.2K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/test/groovy/org/gradle/api/internal/tasks/testing/results/AttachParentTestResultProcessorTest.groovy
TestStartEvent suiteStartEvent = new TestStartEvent(100L) when: processor.started(suite, suiteStartEvent) processor.started(test, new TestStartEvent(200L)) then: 1 * target.started(suite, suiteStartEvent) 1 * target.started(test, { it.parentId == 'suite' }) } def canHaveMoreThanOneRootSuite() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 20:33:30 UTC 2024 - 2.8K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkQueueIntegrationTest.groovy
} """ def started = blockingHttpServer.expectConcurrentAndBlock("item1", "item2", "item3", "submitted") def finished = blockingHttpServer.expectConcurrentAndBlock("finished") when: def gradle = executer.withTasks("runWork").start() then: started.waitForAllPendingCalls() then: started.release("submitted") started.release("item1")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 8.7K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/test/groovy/org/gradle/api/internal/tasks/testing/processors/CaptureTestOutputTestResultProcessorTest.groovy
def testEvent = new TestStartEvent(2, "1") processor.started(new DefaultTestSuiteDescriptor("1", "Foo"), new TestStartEvent(1)) when: processor.started(test, testEvent) then: 1 * target.started(test, testEvent) 1 * redirector.setOutputOwner("2") 0 * _ } def "when test completes its parent will be the owner of output"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 3.5K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/internal/operations/notify/BuildOperationNotificationFixture.groovy
return op.detailsType == detailsClass.name && op.details.subMap(details.keySet()) == details } return found } void started(Class<?> type, Predicate<? super Map<String, ?>> payloadTest) { has(true, type, payloadTest) } void started(Class<?> type, Map<String, ?> payload = null) { has(true, type, (Map) payload) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 20 11:47:00 UTC 2022 - 7.5K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/bindm.go
var ( mutex = sync.Mutex{} cThreadToM = map[uintptr]uintptr{} started = atomic.Uint32{} ) // same as CTHREADS in C, make sure all the C threads are actually started. const cThreadNum = 2 func init() { register("EnsureBindM", EnsureBindM) } //export GoCheckBindM func GoCheckBindM(thread uintptr) { // Wait all threads start if started.Load() != cThreadNum {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 17 21:53:11 UTC 2023 - 1.2K bytes - Viewed (0) -
platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/logging/AbstractTestLoggerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 7.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/logging/DefaultBuildOperationLogger.java
private boolean started; private int numberOfFailedOperationsSeen; DefaultBuildOperationLogger(BuildOperationLogInfo configuration, Logger logger, File outputFile) { this.configuration = configuration; this.logger = logger; this.outputFile = outputFile; this.numberOfFailedOperationsSeen = 0; this.started = false; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 17 10:39:11 UTC 2019 - 3.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonTcpServerConnector.java
try { if (stopped) { throw new IllegalStateException("server connector cannot be started as it is either stopping or has been stopped"); } if (started) { throw new IllegalStateException("server connector cannot be started as it has already been started"); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 4.1K bytes - Viewed (0)