GRPCServer:      grpc.NewServer(opts...),
		faultInjectLock: &sync.Mutex{},
	}
	// Register CA service at gRPC server.
	pb.RegisterIstioCertificateServiceServer(server.GRPCServer, server)
	ghc.RegisterHealthServer(server.GRPCServer, server)
	return server, server.start(port)
}

func (s *CAServer) start(port int) error {
	listener, err := net.Listen("tcp", fmt.Sprintf("127.0.0.1:%d", port))
	if err != nil {

	"istio.io/istio/pkg/h2c"
)

func NewServer() *http.Server {
	// Need to set this to allow timeout on the read header
	h1 := &http.Transport{
		ExpectContinueTimeout: 3 * time.Second,
	}
	h2, _ := http2.ConfigureTransports(h1)
	h2.ReadIdleTimeout = 10 * time.Minute // TODO: much larger to support long-lived connections
	h2.AllowHTTP = true
	h2Server := &http2.Server{}

    public int getPort() {
        return port;
    }

    public void setPort(int port) {
        this.port = port;
    }

    public boolean isServer() {
        return server;
    }

    public void setServer(boolean server) {
        this.server = server;
    }

    public boolean isSuspend() {
        return suspend;
    }

    public void setSuspend(boolean suspend) {
        this.suspend = suspend;

import org.gradle.integtests.resource.s3.fixtures.S3Server
import org.junit.Rule

abstract class AbstractS3DependencyResolutionTest extends AbstractDependencyResolutionTest {

    @Rule
    public final S3Server server = new S3Server(temporaryFolder)

    def setup() {
        executer.withArgument('-i')
        executer.withArgument("-Dorg.gradle.s3.endpoint=${server.uri}")
    }

    String getBucket() {

class MavenS3Repository implements MavenRepository {
    private final S3Server server
    private final MavenFileRepository backingRepository
    private final String bucket
    private final String repositoryPath

    MavenS3Repository(S3Server server, File repoDir, String repositoryPath, String bucket) {
        assert !bucket.startsWith('/')
        this.server = server
        this.bucket = bucket

import org.gradle.integtests.resource.s3.fixtures.S3Server
import org.gradle.test.precondition.Requires
import org.gradle.test.preconditions.IntegTestPreconditions
import org.junit.Rule

@Requires(IntegTestPreconditions.CanPublishToS3)
class IvyPublishS3IntegrationTest extends AbstractIvyPublishIntegTest {
    @Rule
    public S3Server server = new S3Server(temporaryFolder)

    def setup() {

import org.gradle.integtests.resource.s3.fixtures.S3Server
import org.gradle.test.fixtures.server.RepositoryServer
import org.junit.Rule

class IvyS3RepoResolveIntegrationTest extends AbstractIvyRemoteRepoResolveIntegrationTest {

    @Rule
    S3Server server = new S3Server(temporaryFolder)

    @Override
    RepositoryServer getServer() {
        return server
    }

    MavenFileModule backingModule
    S3Server server
    String bucket
    String repositoryPath

    MavenS3Module(S3Server server, MavenFileModule backingModule, String repositoryPath, String bucket) {
        super(backingModule)
        this.bucket = bucket
        this.server = server
        this.backingModule = backingModule
        this.repositoryPath = repositoryPath
    }

class S3Resource implements RemoteResource {
    S3Server server
    TestFile file
    String bucket
    String repositoryPath

    S3Resource(S3Server server, TestFile file, String repositoryPath, String bucket) {
        this.repositoryPath = repositoryPath
        this.bucket = bucket
        this.server = server
        this.file = file
    }

    String getPath() {

class S3DirectoryResource implements RemoteResource {

    private final S3Server server
    private final TestFile directory
    private String bucket
    private final String path

    S3DirectoryResource(S3Server server, String bucket, TestFile directory) {
        this.bucket = bucket
        this.directory = directory
        this.server = server
        def directoryUri = directory.toURI().toString()