@Override
@CheckReturnValue
@Internal
protected ClientTransportFactory buildTransportFactory() {
  ProtocolNegotiator negotiator;
  if (protocolNegotiatorFactory != null) {
    negotiator = protocolNegotiatorFactory.buildProtocolNegotiator();
  } else {
    SslContext localSslContext = sslContext;
    if (negotiationType == NegotiationType.TLS && localSslContext == null) {
      try {
        localSslContext = GrpcSslContexts.forClient().build();
      } catch (SSLException ex) {
        throw new RuntimeException(ex);
      }
    }
    negotiator = createProtocolNegotiatorByType(negotiationType, localSslContext);
  }
  return new NettyTransportFactory(
      negotiator, channelType, channelOptions,
      eventLoopGroup, flowControlWindow, maxInboundMessageSize(),
      maxHeaderListSize, keepAliveTimeNanos, keepAliveTimeoutNanos, keepAliveWithoutCalls,
      transportTracerFactory.create(), localSocketPicker);
}
 

@Override
@Internal
protected final ClientTransportFactory buildTransportFactory() {
  boolean enableKeepAlive = keepAliveTimeNanos != KEEPALIVE_TIME_NANOS_DISABLED;
  return new OkHttpTransportFactory(
      transportExecutor,
      scheduledExecutorService,
      socketFactory,
      createSslSocketFactory(),
      hostnameVerifier,
      connectionSpec,
      maxInboundMessageSize(),
      enableKeepAlive,
      keepAliveTimeNanos,
      keepAliveTimeoutNanos,
      flowControlWindow,
      keepAliveWithoutCalls,
      maxInboundMetadataSize,
      transportTracerFactory,
      useGetForSafeMethods);
}
 

/**
 * Creates a new InProcessTransport.
 *
 * <p>When started, the transport will be registered with the given
 * {@link ServerListener}.
 */
@Internal
public static ConnectionClientTransport createInProcessTransport(
    String name,
    int maxInboundMetadataSize,
    String authority,
    String userAgent,
    Attributes eagAttrs,
    ObjectPool<ScheduledExecutorService> serverSchedulerPool,
    List<ServerStreamTracer.Factory> serverStreamTracerFactories,
    ServerListener serverListener) {
  return new InProcessTransport(
      name,
      maxInboundMetadataSize,
      authority,
      userAgent,
      eagAttrs,
      serverSchedulerPool,
      serverStreamTracerFactories,
      serverListener);
}
 

@Override
@Internal
protected final ClientTransportFactory buildTransportFactory() {
  boolean enableKeepAlive = keepAliveTimeNanos != KEEPALIVE_TIME_NANOS_DISABLED;
  return new OkHttpTransportFactory(transportExecutor, scheduledExecutorService,
      createSocketFactory(), hostnameVerifier, connectionSpec, maxInboundMessageSize(),
      enableKeepAlive, keepAliveTimeNanos, keepAliveTimeoutNanos, flowControlWindow,
      keepAliveWithoutCalls, maxInboundMetadataSize, transportTracerFactory);
}
 

@Override
@CheckReturnValue
@Internal
protected String checkAuthority(String authority) {
  if (authorityChecker != null) {
    return authorityChecker.checkAuthority(authority);
  }
  return super.checkAuthority(authority);
}
 

@Override
@CheckReturnValue
@Internal
protected ClientTransportFactory buildTransportFactory() {
  assertEventLoopAndChannelType();

  ProtocolNegotiator negotiator;
  if (protocolNegotiatorFactory != null) {
    negotiator = protocolNegotiatorFactory.buildProtocolNegotiator();
  } else {
    SslContext localSslContext = sslContext;
    if (negotiationType == NegotiationType.TLS && localSslContext == null) {
      try {
        localSslContext = GrpcSslContexts.forClient().build();
      } catch (SSLException ex) {
        throw new RuntimeException(ex);
      }
    }
    negotiator = createProtocolNegotiatorByType(negotiationType, localSslContext,
        this.getOffloadExecutorPool());
  }

  return new NettyTransportFactory(
      negotiator, channelFactory, channelOptions,
      eventLoopGroupPool, autoFlowControl, flowControlWindow, maxInboundMessageSize(),
      maxHeaderListSize, keepAliveTimeNanos, keepAliveTimeoutNanos, keepAliveWithoutCalls,
      transportTracerFactory, localSocketPicker, useGetForSafeMethods);
}
 

@Override
@CheckReturnValue
@Internal
protected String checkAuthority(String authority) {
  if (authorityChecker != null) {
    return authorityChecker.checkAuthority(authority);
  }
  return super.checkAuthority(authority);
}
 

@Override
@Internal
protected ClientTransportFactory buildTransportFactory() {
  return new InProcessClientTransportFactory(
      name, scheduledExecutorService, maxInboundMetadataSize);
}
 

@Override
@Internal
protected ClientTransportFactory buildTransportFactory() {
  return new InProcessClientTransportFactory(
      name, scheduledExecutorService, maxInboundMetadataSize, transportIncludeStatusCause);
}
 

/**
 * Children of AbstractServerBuilder should override this method to provide transport specific
 * information for the server.  This method is mean for Transport implementors and should not be
 * used by normal users.
 *
 * @param streamTracerFactories an immutable list of stream tracer factories
 */
@Internal
protected abstract io.grpc.internal.InternalServer buildTransportServer(
    List<ServerStreamTracer.Factory> streamTracerFactories);