Package io.grpc.xds

Class XdsServerWrapper

java.lang.Object
io.grpc.Server
io.grpc.xds.XdsServerWrapper

final class XdsServerWrapper extends io.grpc.Server
  • Field Details

    • logger

      private static final Logger logger
    • syncContext

      private final io.grpc.SynchronizationContext syncContext
    • ATTR_SERVER_ROUTING_CONFIG

      public static final io.grpc.Attributes.Key<AtomicReference<XdsServerWrapper.ServerRoutingConfig>> ATTR_SERVER_ROUTING_CONFIG
    • RETRY_DELAY_NANOS

      static final long RETRY_DELAY_NANOS
    • listenerAddress

      private final String listenerAddress
    • delegateBuilder

      private final io.grpc.ServerBuilder<?> delegateBuilder
    • sharedTimeService

      private boolean sharedTimeService
    • timeService

      private final ScheduledExecutorService timeService
    • filterRegistry

      private final FilterRegistry filterRegistry
    • random

      private final ThreadSafeRandom random
    • xdsClientPoolFactory

      private final XdsClientPoolFactory xdsClientPoolFactory
    • listener

    • filterChainSelectorManager

      private final FilterChainSelectorManager filterChainSelectorManager
    • started

      private final AtomicBoolean started
    • shutdown

      private final AtomicBoolean shutdown
    • isServing

      private boolean isServing
    • internalTerminationLatch

      private final CountDownLatch internalTerminationLatch
    • initialStartFuture

      private final com.google.common.util.concurrent.SettableFuture<Exception> initialStartFuture
    • initialStarted

      private boolean initialStarted
    • restartTimer

      private io.grpc.SynchronizationContext.ScheduledHandle restartTimer
    • xdsClientPool

      private io.grpc.internal.ObjectPool<XdsClient> xdsClientPool
    • xdsClient

      private XdsClient xdsClient
    • discoveryState

      private XdsServerWrapper.DiscoveryState discoveryState
    • delegate

      private volatile io.grpc.Server delegate
  • Constructor Details

  • Method Details

    • start

      public io.grpc.Server start() throws IOException
      Specified by:
      start in class io.grpc.Server
      Throws:
      IOException
    • internalStart

      private void internalStart()
    • shutdown

      public io.grpc.Server shutdown()
      Specified by:
      shutdown in class io.grpc.Server
    • shutdownNow

      public io.grpc.Server shutdownNow()
      Specified by:
      shutdownNow in class io.grpc.Server
    • internalShutdown

      private void internalShutdown()
    • isShutdown

      public boolean isShutdown()
      Specified by:
      isShutdown in class io.grpc.Server
    • isTerminated

      public boolean isTerminated()
      Specified by:
      isTerminated in class io.grpc.Server
    • awaitTermination

      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException
      Specified by:
      awaitTermination in class io.grpc.Server
      Throws:
      InterruptedException
    • awaitTermination

      public void awaitTermination() throws InterruptedException
      Specified by:
      awaitTermination in class io.grpc.Server
      Throws:
      InterruptedException
    • getPort

      public int getPort()
      Overrides:
      getPort in class io.grpc.Server
    • getListenSockets

      public List<? extends SocketAddress> getListenSockets()
      Overrides:
      getListenSockets in class io.grpc.Server
    • getServices

      public List<io.grpc.ServerServiceDefinition> getServices()
      Overrides:
      getServices in class io.grpc.Server
    • getImmutableServices

      public List<io.grpc.ServerServiceDefinition> getImmutableServices()
      Overrides:
      getImmutableServices in class io.grpc.Server
    • getMutableServices

      public List<io.grpc.ServerServiceDefinition> getMutableServices()
      Overrides:
      getMutableServices in class io.grpc.Server
    • startDelegateServer

      private void startDelegateServer()