STARTED - Code Search

platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/logging/TestWorkerProgressListenerTest.groovy

        def testDescriptor1 = createTestDescriptor(testEvent1)
        def testDescriptor2 = createTestDescriptor(testEvent2)

        when:
        testWorkerProgressListener.started(testDescriptor1, createTestStartEvent())
        testWorkerProgressListener.started(testDescriptor2, createTestStartEvent())

        then:

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon Sep 18 20:52:40 UTC 2023

- 10.3K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core/src/test/groovy/org/gradle/util/ConcurrentSpecificationTest.groovy

        Runnable action = Mock()
        def started = new CountDownLatch(1)
        def operation = waitsForAsyncActionToComplete()

        when:
        operation.start {
            start { action.run() }
            started.await()
        }
        finished()

        then:
        1 * action.run() >> { started.countDown(); operation.done() }

        cleanup:

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Wed Apr 07 08:18:50 UTC 2021

- 10.5K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandle.java

 * <h3>State flows</h3>
 *
 * <ul>
 *   <li>INIT -&gt; STARTED -&gt; [SUCCEEDED|FAILED|ABORTED|DETACHED]</li>
 *   <li>INIT -&gt; FAILED</li>
 *   <li>INIT -&gt; STARTED -&gt; DETACHED -&gt; ABORTED</li>
 * </ul>
 *
 * State is controlled on all control methods:
 * <ul>
 * <li>{@link #start()} allowed when state is INIT</li>
 * <li>{@link #abort()} allowed when state is STARTED or DETACHED</li>
 * </ul>
 */

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri Jan 26 14:58:23 UTC 2024

- 15.2K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core/src/main/java/org/gradle/internal/operations/notify/BuildOperationNotificationBridge.java

                return;
            }

            active.put(id, "");

            Started notification = new Started(startEvent.getStartTime(), id, parentId, buildOperation.getDetails());

            try {
                notificationListener.started(notification);
            } catch (Throwable e) {

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Tue Apr 09 04:43:28 UTC 2024

- 15.8K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/jvm/testing-jvm/src/test/groovy/org/gradle/api/tasks/testing/TestTaskSpec.groovy

            processor.started(suiteDescriptor, suiteStartEvent)
            processor.started(testDescriptor, testStartEvent)
            processor.completed("test", finishEvent)
            processor.completed("suite", finishEvent)

            processor.started(suiteDescriptor, suiteStartEvent)
            processor.completed("suite", finishEvent)
        }

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon Sep 18 20:52:40 UTC 2023

- 10.1K bytes

- Viewed (0)

github.com/golang/go

src/testing/sub_test.go

			{typ: add1, running: 3, waiting: 3, started: false},
			{typ: done, running: 3, waiting: 2, started: true},
			{typ: add1, running: 3, waiting: 3, started: false},
			{typ: done, running: 3, waiting: 2, started: true},
			{typ: done, running: 3, waiting: 1, started: true},
			{typ: done, running: 3, waiting: 0, started: true},
			{typ: done, running: 2, waiting: 0, started: false},
			{typ: done, running: 1, waiting: 0, started: false},

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri Dec 01 21:27:08 UTC 2023

- 23.8K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy

    }

    def "multiple threads can coordinate locking of a project"() {
        def threadCount = 10
        def started = new CountDownLatch(threadCount)

        when:
        async {
            threadCount.times {
                start {
                    started.countDown()
                    thread.blockUntil.releaseAll

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri Apr 05 16:29:26 UTC 2024

- 25.6K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/parameters/BuildProgressListenerAdapterForTransformOperationsTest.groovy

        _ * startEvent.getDisplayName() >> 'Transform started'
        _ * startEvent.getDescriptor() >> transformDescriptor

        adapter.onEvent(startEvent)

        then:
        1 * listener.statusChanged(_ as TransformStartEvent) >> { TransformStartEvent event ->
            assertTrue event.eventTime == 999
            assertTrue event.displayName == "Transform started"

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Tue Sep 26 14:49:20 UTC 2023

- 10.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/prober/prober_manager.go

	// started.
	if _, exists := m.getWorker(pod.UID, containerStatus.Name, startup); exists {
		return false
	}

	// there is no startup probe, so the container is started.
	return true
}

func (m *manager) UpdatePodStatus(pod *v1.Pod, podStatus *v1.PodStatus) {
	for i, c := range podStatus.ContainerStatuses {
		started := m.isContainerStarted(pod, &podStatus.ContainerStatuses[i])

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Fri Jul 07 22:26:12 UTC 2023

- 11K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/services/DefaultLoggingManagerTest.groovy

        1 * javaUtilLoggingSystem.restore(javaUtilSnapshot)
        0 * loggingRouter._
        0 * slf4jLoggingSystem._
        0 * javaUtilLoggingSystem._
    }

    public void "can change capture level while started"() {
        final LoggingSystem.Snapshot stdOutSnapshot = Mock(LoggingSystem.Snapshot.class)
        final LoggingSystem.Snapshot stdErrSnapshot = Mock(LoggingSystem.Snapshot.class)

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri Sep 22 09:05:18 UTC 2023

- 15.8K bytes

- Viewed (0)

Search Options