grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

cronet: CronetChannelBuilder extends a public API class

This commit is contained in:
Sergii Tkachenko 2020-09-01 19:33:45 -04:00 committed by Sergii Tkachenko
parent c7f876d016
commit a429b9767c
1 changed files with 26 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
cronet/src/main/java/io/grpc/cronet/CronetChannelBuilder.java
View File

@ -26,10 +26,14 @@ import com.google.common.base.Preconditions;
import com.google.common.util.concurrent.MoreExecutors; import com.google.common.util.concurrent.MoreExecutors;
import io.grpc.ChannelLogger; import io.grpc.ChannelLogger;
import io.grpc.ExperimentalApi; import io.grpc.ExperimentalApi;
import io.grpc.internal.AbstractManagedChannelImplBuilder; import io.grpc.ForwardingChannelBuilder;
import io.grpc.Internal;
import io.grpc.ManagedChannelBuilder;
import io.grpc.internal.ClientTransportFactory; import io.grpc.internal.ClientTransportFactory;
import io.grpc.internal.ConnectionClientTransport; import io.grpc.internal.ConnectionClientTransport;
import io.grpc.internal.GrpcUtil; import io.grpc.internal.GrpcUtil;
import io.grpc.internal.ManagedChannelImplBuilder;
import io.grpc.internal.ManagedChannelImplBuilder.ClientTransportFactoryBuilder;
import io.grpc.internal.SharedResourceHolder; import io.grpc.internal.SharedResourceHolder;
import io.grpc.internal.TransportTracer; import io.grpc.internal.TransportTracer;
import java.lang.reflect.InvocationTargetException; import java.lang.reflect.InvocationTargetException;
@ -46,8 +50,7 @@ import org.chromium.net.ExperimentalCronetEngine;
/** Convenience class for building channels with the cronet transport. */ /** Convenience class for building channels with the cronet transport. */
@ExperimentalApi("There is no plan to make this API stable, given transport API instability") @ExperimentalApi("There is no plan to make this API stable, given transport API instability")
public final class CronetChannelBuilder extends public final class CronetChannelBuilder extends ForwardingChannelBuilder<CronetChannelBuilder> {
AbstractManagedChannelImplBuilder<CronetChannelBuilder> {
private static final String LOG_TAG = "CronetChannelBuilder"; private static final String LOG_TAG = "CronetChannelBuilder";
@ -81,6 +84,8 @@ public final class CronetChannelBuilder extends
private ScheduledExecutorService scheduledExecutorService; private ScheduledExecutorService scheduledExecutorService;
private final CronetEngine cronetEngine; private final CronetEngine cronetEngine;
private final ManagedChannelImplBuilder managedChannelImplBuilder;
private TransportTracer.Factory transportTracerFactory = TransportTracer.getDefaultFactory();
private boolean alwaysUsePut = false; private boolean alwaysUsePut = false;
@ -103,12 +108,27 @@ public final class CronetChannelBuilder extends
private int trafficStatsUid; private int trafficStatsUid;
private CronetChannelBuilder(String host, int port, CronetEngine cronetEngine) { private CronetChannelBuilder(String host, int port, CronetEngine cronetEngine) {
super( final class CronetChannelTransportFactoryBuilder implements ClientTransportFactoryBuilder {
@Override
public ClientTransportFactory buildClientTransportFactory() {
return buildTransportFactory();
}
}
managedChannelImplBuilder = new ManagedChannelImplBuilder(
InetSocketAddress.createUnresolved(host, port), InetSocketAddress.createUnresolved(host, port),
GrpcUtil.authorityFromHostAndPort(host, port)); GrpcUtil.authorityFromHostAndPort(host, port),
new CronetChannelTransportFactoryBuilder(),
null);
this.cronetEngine = Preconditions.checkNotNull(cronetEngine, "cronetEngine"); this.cronetEngine = Preconditions.checkNotNull(cronetEngine, "cronetEngine");
} }
@Internal
@Override
protected ManagedChannelBuilder<?> delegate() {
return managedChannelImplBuilder;
}
/** /**
* Sets the maximum message size allowed to be received on the channel. If not called, * Sets the maximum message size allowed to be received on the channel. If not called,
* defaults to {@link io.grpc.internal.GrpcUtil#DEFAULT_MAX_MESSAGE_SIZE}. * defaults to {@link io.grpc.internal.GrpcUtil#DEFAULT_MAX_MESSAGE_SIZE}.
@ -188,8 +208,7 @@ public final class CronetChannelBuilder extends
return this; return this;
} }
@Override ClientTransportFactory buildTransportFactory() {
protected final ClientTransportFactory buildTransportFactory() {
return new CronetTransportFactory( return new CronetTransportFactory(
new TaggingStreamFactory( new TaggingStreamFactory(
cronetEngine, trafficStatsTagSet, trafficStatsTag, trafficStatsUidSet, trafficStatsUid), cronetEngine, trafficStatsTagSet, trafficStatsTag, trafficStatsUidSet, trafficStatsUid),