Java 类io.grpc.Internal 实例源码

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

@Override
@CheckReturnValue
@Internal
protected ClientTransportFactory buildTransportFactory() {
  return new NettyTransportFactory(dynamicParamsFactory, channelType, channelOptions,
      negotiationType, sslContext, eventLoopGroup, flowControlWindow, maxInboundMessageSize(),
      maxHeaderListSize, keepAliveTimeNanos, keepAliveTimeoutNanos, keepAliveWithoutCalls,
      transportTracerFactory.create());
}

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

/**
 * Obtains the number of uncommitted events.
 */
@Internal
@VisibleForTesting
protected int uncommittedEventsCount() {
    return uncommittedEvents.size();
}

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

/**
 * 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);