Package io.grpc.netty

Class NettyServer

java.lang.Object
io.grpc.netty.NettyServer
All Implemented Interfaces:
InternalServer, InternalWithLogId

class NettyServer extends Object implements InternalServer, InternalWithLogId
Netty-based server implementation.
  • Field Details

    • log

      private static final Logger log
    • logId

      private final InternalLogId logId
    • addresses

      private final List<? extends SocketAddress> addresses
    • channelFactory

      private final io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel> channelFactory
    • channelOptions

      private final Map<io.netty.channel.ChannelOption<?>,?> channelOptions
    • childChannelOptions

      private final Map<io.netty.channel.ChannelOption<?>,?> childChannelOptions
    • protocolNegotiator

      private final ProtocolNegotiator protocolNegotiator
    • maxStreamsPerConnection

      private final int maxStreamsPerConnection
    • bossGroupPool

      private final ObjectPool<? extends io.netty.channel.EventLoopGroup> bossGroupPool
    • workerGroupPool

      private final ObjectPool<? extends io.netty.channel.EventLoopGroup> workerGroupPool
    • forceHeapBuffer

      private final boolean forceHeapBuffer
    • bossGroup

      private io.netty.channel.EventLoopGroup bossGroup
    • workerGroup

      private io.netty.channel.EventLoopGroup workerGroup
    • listener

      private ServerListener listener
    • channelGroup

      private final io.netty.channel.group.ChannelGroup channelGroup
    • autoFlowControl

      private final boolean autoFlowControl
    • flowControlWindow

      private final int flowControlWindow
    • maxMessageSize

      private final int maxMessageSize
    • maxHeaderListSize

      private final int maxHeaderListSize
    • keepAliveTimeInNanos

      private final long keepAliveTimeInNanos
    • keepAliveTimeoutInNanos

      private final long keepAliveTimeoutInNanos
    • maxConnectionIdleInNanos

      private final long maxConnectionIdleInNanos
    • maxConnectionAgeInNanos

      private final long maxConnectionAgeInNanos
    • maxConnectionAgeGraceInNanos

      private final long maxConnectionAgeGraceInNanos
    • permitKeepAliveWithoutCalls

      private final boolean permitKeepAliveWithoutCalls
    • permitKeepAliveTimeInNanos

      private final long permitKeepAliveTimeInNanos
    • maxRstCount

      private final int maxRstCount
    • maxRstPeriodNanos

      private final long maxRstPeriodNanos
    • eagAttributes

      private final Attributes eagAttributes
    • sharedResourceReferenceCounter

      private final io.netty.util.ReferenceCounted sharedResourceReferenceCounter
    • streamTracerFactories

      private final List<? extends ServerStreamTracer.Factory> streamTracerFactories
    • transportTracerFactory

      private final TransportTracer.Factory transportTracerFactory
    • channelz

      private final InternalChannelz channelz
    • listenSocketStatsList

      private volatile List<InternalInstrumented<InternalChannelz.SocketStats>> listenSocketStatsList
    • terminated

      private volatile boolean terminated
    • bossExecutor

      private final io.netty.channel.EventLoop bossExecutor
  • Constructor Details

    • NettyServer

      NettyServer(List<? extends SocketAddress> addresses, io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel> channelFactory, Map<io.netty.channel.ChannelOption<?>,?> channelOptions, Map<io.netty.channel.ChannelOption<?>,?> childChannelOptions, ObjectPool<? extends io.netty.channel.EventLoopGroup> bossGroupPool, ObjectPool<? extends io.netty.channel.EventLoopGroup> workerGroupPool, boolean forceHeapBuffer, ProtocolNegotiator protocolNegotiator, List<? extends ServerStreamTracer.Factory> streamTracerFactories, TransportTracer.Factory transportTracerFactory, int maxStreamsPerConnection, boolean autoFlowControl, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, long maxConnectionIdleInNanos, long maxConnectionAgeInNanos, long maxConnectionAgeGraceInNanos, boolean permitKeepAliveWithoutCalls, long permitKeepAliveTimeInNanos, int maxRstCount, long maxRstPeriodNanos, Attributes eagAttributes, InternalChannelz channelz)
  • Method Details