SpeedCash v6.5.1482 - InProcessServerBuilder.java 源代码

package io.grpc.inprocess;

import com.google.android.gms.common.api.Api;
import com.google.common.base.Preconditions;
import com.google.errorprone.annotations.DoNotCall;
import defpackage.h22;
import io.grpc.Deadline;
import io.grpc.ExperimentalApi;
import io.grpc.Internal;
import io.grpc.ServerBuilder;
import io.grpc.ServerStreamTracer;
import io.grpc.internal.AbstractServerImplBuilder;
import io.grpc.internal.FixedObjectPool;
import io.grpc.internal.GrpcUtil;
import io.grpc.internal.InternalServer;
import io.grpc.internal.ObjectPool;
import io.grpc.internal.ServerImplBuilder;
import io.grpc.internal.SharedResourcePool;
import java.io.File;
import java.net.SocketAddress;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/1783")
public final class InProcessServerBuilder extends AbstractServerImplBuilder<InProcessServerBuilder> {
    public final ServerImplBuilder a;
    public final SocketAddress b;
    public int c = Api.BaseClientBuilder.API_PRIORITY_OTHER;
    public ObjectPool<ScheduledExecutorService> d = SharedResourcePool.forResource(GrpcUtil.TIMER_SERVICE);

    public final class a implements ServerImplBuilder.ClientTransportServersBuilder {
        public a() {
        }

        public InternalServer buildClientTransportServers(List<? extends ServerStreamTracer.Factory> list) {
            return InProcessServerBuilder.this.b(list);
        }
    }

    public InProcessServerBuilder(SocketAddress socketAddress) {
        this.b = (SocketAddress) Preconditions.checkNotNull(socketAddress, "listenAddress");
        ServerImplBuilder serverImplBuilder = new ServerImplBuilder(new a());
        this.a = serverImplBuilder;
        serverImplBuilder.setStatsRecordStartedRpcs(false);
        serverImplBuilder.setStatsRecordFinishedRpcs(false);
        handshakeTimeout(Long.MAX_VALUE, TimeUnit.SECONDS);
    }

    public static InProcessServerBuilder forAddress(SocketAddress socketAddress) {
        return new InProcessServerBuilder(socketAddress);
    }

    public static InProcessServerBuilder forName(String str) {
        return forAddress(new InProcessSocketAddress((String) Preconditions.checkNotNull(str, "name")));
    }

    @DoNotCall("Unsupported. Use forName() instead")
    public static InProcessServerBuilder forPort(int i) {
        throw new UnsupportedOperationException("call forName() instead");
    }

    public static String generateName() {
        return UUID.randomUUID().toString();
    }

    public h22 b(List<? extends ServerStreamTracer.Factory> list) {
        return new h22(this, list);
    }

    public InProcessServerBuilder deadlineTicker(Deadline.Ticker ticker) {
        this.a.setDeadlineTicker(ticker);
        return this;
    }

    @Internal
    public ServerBuilder<?> delegate() {
        return this.a;
    }

    public InProcessServerBuilder scheduledExecutorService(ScheduledExecutorService scheduledExecutorService) {
        this.d = new FixedObjectPool((ScheduledExecutorService) Preconditions.checkNotNull(scheduledExecutorService, "scheduledExecutorService"));
        return this;
    }

    public void setStatsEnabled(boolean z) {
        this.a.setStatsEnabled(z);
    }

    public InProcessServerBuilder m77maxInboundMetadataSize(int i) {
        Preconditions.checkArgument(i > 0, "maxInboundMetadataSize must be > 0");
        this.c = i;
        return this;
    }

    public InProcessServerBuilder m79useTransportSecurity(File file, File file2) {
        throw new UnsupportedOperationException("TLS not supported in InProcessServer");
    }
}