* limitations under the License.
 */

package org.gradle.workers.fixtures

import org.gradle.test.fixtures.file.TestNameTestDirectoryProvider
import org.gradle.util.internal.TextUtil

class WorkerExecutorFixture {

    enum IsolationMode {
        NO_ISOLATION("no"),
        CLASSLOADER_ISOLATION("classLoader"),
        PROCESS_ISOLATION("process");

        private final String prefix

import org.gradle.test.precondition.TestPrecondition
import org.gradle.test.preconditions.UnitTestPreconditions
import org.gradle.workers.fixtures.OptionsVerifier
import org.gradle.workers.fixtures.WorkerExecutorFixture
import org.junit.Assume

import static org.gradle.api.internal.file.TestFiles.systemSpecificAbsolutePath
import static org.gradle.util.internal.TextUtil.normaliseFileSeparators

@IntegrationTestTimeout(180)

import org.gradle.integtests.fixtures.AbstractIntegrationSpec
import org.gradle.test.fixtures.file.TestFile
import org.gradle.workers.fixtures.WorkerExecutorFixture

abstract class AbstractWorkerExecutorIntegrationTest extends AbstractIntegrationSpec {

    def fixture = new WorkerExecutorFixture(temporaryFolder)

    def setup() {
        fixture.prepareTaskTypeUsingWorker()
    }

    void assertWorkerExecuted(String taskName) {

import org.gradle.workers.fixtures.WorkerExecutorFixture
import org.junit.Rule

import static org.gradle.workers.fixtures.WorkerExecutorFixture.ISOLATION_MODES

class WorkQueueIntegrationTest extends AbstractWorkerExecutorIntegrationTest {
    @Rule BlockingHttpServer blockingHttpServer = new BlockingHttpServer()
    WorkerExecutorFixture.WorkParameterClass parallelParameterType

import org.gradle.workers.fixtures.WorkerExecutorFixture

import static org.gradle.workers.fixtures.WorkerExecutorFixture.ISOLATION_MODES

@IntegrationTestTimeout(120)
class WorkerExecutorErrorHandlingIntegrationTest extends AbstractWorkerExecutorIntegrationTest {
    WorkerExecutorFixture.WorkActionClass actionThatFailsInstantiation
    WorkerExecutorFixture.WorkActionClass actionThatThrowsUnserializableMemberException

 * limitations under the License.
 */

package org.gradle.workers.internal

import org.gradle.workers.fixtures.WorkerExecutorFixture.WorkActionClass
import spock.lang.Timeout

import static org.gradle.workers.fixtures.WorkerExecutorFixture.ISOLATION_MODES

@Timeout(120)
class WorkerExecutorLoggingIntegrationTest extends AbstractWorkerExecutorIntegrationTest {
    WorkActionClass executionWithLogging

import org.gradle.internal.work.DefaultConditionalExecutionQueue
import org.gradle.workers.WorkerExecutor
import org.gradle.workers.fixtures.WorkerExecutorFixture

import static org.gradle.workers.fixtures.WorkerExecutorFixture.ISOLATION_MODES

@IntegrationTestTimeout(120)
class WorkerExecutorNestingIntegrationTest extends AbstractWorkerExecutorIntegrationTest {

    @Rule
    BlockingHttpServer blockingHttpServer = new BlockingHttpServer()
    def buildOperations = new BuildOperationsFixture(executer, temporaryFolder)
    WorkerExecutorFixture.WorkParameterClass parallelParameterType
    WorkerExecutorFixture.WorkActionClass parallelWorkAction


    def setup() {
        blockingHttpServer.start()

        buildFile << """
            task slowTask {
                doLast {

 * limitations under the License.
 */

package org.gradle.workers.internal

import org.gradle.integtests.fixtures.AbstractIntegrationSpec
import org.gradle.workers.fixtures.WorkerExecutorFixture

/**
 * Verifies that we can spawn large amounts of workers without running out of memory, because the old ones will be killed
 * if necessary.
 *
 * <p>

 */

package org.gradle.workers.internal


import org.gradle.integtests.fixtures.AbstractIntegrationSpec
import org.gradle.internal.jvm.Jvm
import org.gradle.workers.fixtures.WorkerExecutorFixture

class WorkerExecutorProblemsApiIntegrationTest extends AbstractIntegrationSpec {

    // Worker-written file containing the build operation id