def repo = newRepo()
        def same = newRepo()
        def different = newRepo()

        given:
        repo.url = new URI("http://localhost")
        same.url = new URI("http://localhost")
        different.url = new URI("http://localhost/repo")

        and:
        _ * fileResolver.resolveUri(_) >> { URI uri -> uri }

        expect:

        fromString()       | "command.execute(new String[] {'FOOBAR=foobar'}, file('$pwd'))"                       | pwd               | "foobar"
        fromGroovyString() | "command.execute(new String[] {'FOOBAR=foobar'}, file('$pwd'))"                       | pwd               | "foobar"
        fromStringArray()  | "command.execute(new String[] {'FOOBAR=foobar'}, file('$pwd'))"                       | pwd               | "foobar"

    @Rule TestNameTestDirectoryProvider workspace = new TestNameTestDirectoryProvider(getClass())
    GradleDistribution distribution = new UnderDevelopmentGradleDistribution()
    @Rule StressHttpServer server = new StressHttpServer()
    @Rule ConcurrentTestUtil concurrent = new ConcurrentTestUtil()

    def setup() {
        concurrent.shortTimeout = 180000
    }

    def cleanup() {

        0 * client1.stop()
        1 * client2.stop()
    }

    def "can stop session-scoped clients"() {
        listenerManager = new DefaultListenerManager(Scope.BuildSession)
        manager = new WorkerDaemonClientsManager(starter, listenerManager, loggingManager, memoryManager, new MBeanOsMemoryInfo(new DefaultMBeanAttributeProvider()))
        def client1 = Mock(WorkerDaemonClient)
        def client2 = Mock(WorkerDaemonClient)

        "T = T"                                         | "MyObject" | 'new MyObject("hello")'                  | "hello"
        "T = Provider<T>"                               | "MyObject" | 'provider { new MyObject("hello") }'     | unsupportedWithCause("Cannot cast object")
        "String = Object"                               | "String"   | 'new MyObject("hello")'                  | "hello"

        def file1 = new File("/src/Person.java")
        def file2 = new File("Computer.java")
        spec.sourceFiles = [file1, file2]

        expect:
        builder.build() == defaultOptions
    }

    def "generates -sourcepath option"() {
        def file1 = new File("/lib/lib1.jar")
        def file2 = new File("/lib/lib2.jar")
        def fc = [file1, file2]

        expect:
        byteBuffer.readAsByteArray() == testbuffer
    }

    def "reads source InputStream fully"() {
        given:
        def byteBuffer = new StreamByteBuffer()
        def byteArrayInputStream = new ByteArrayInputStream(testbuffer)

        when:
        byteBuffer.readFully(byteArrayInputStream)

        then:
        byteBuffer.totalBytesUnread() == testbuffer.length

    }

    def "visits content of tree of collections"() {
        def child1 = new TestCollection() {
            @Override
            protected void visitChildren(Consumer<FileCollectionInternal> visitor) {
                visitor.accept(TestFiles.fileCollectionFactory().fixed(new File("1").absoluteFile))
            }
        }
        def child2 = new TestCollection() {
            @Override

                new TestSftpSubsystem(channel, this)
            }
        }))
        sshServer.setCommandFactory(new ScpCommandFactory())
        sshServer.setKeyPairProvider(new GeneratingKeyPairProvider())

        if (passwordAuthenticationEnabled) {
            sshServer.setPasswordAuthenticator(new DummyPasswordAuthenticator())
        }

        sshServer.setPublickeyAuthenticator(new PublickeyAuthenticator() {

        run "someTask"

        then:
        skipped(":someTask")

        // Change the values of the property
        when:
        buildFile.replace("[new CustomType('123'), new ScriptType('abc'), pluginValue] as $type", "[new CustomType('abc'), new ScriptType('123'), pluginValue] as $type")

        and:
        executer.withArgument("-i")
        run "someTask"

        then: