Package io.grpc.xds

Class XdsServerWrapper


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

      • logger

        private static final java.util.logging.Logger logger
      • syncContext

        private final io.grpc.SynchronizationContext syncContext
      • ATTR_SERVER_ROUTING_CONFIG

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

        static final long RETRY_DELAY_NANOS
      • listenerAddress

        private final java.lang.String listenerAddress
      • delegateBuilder

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

        private boolean sharedTimeService
      • timeService

        private final java.util.concurrent.ScheduledExecutorService timeService
      • started

        private final java.util.concurrent.atomic.AtomicBoolean started
      • shutdown

        private final java.util.concurrent.atomic.AtomicBoolean shutdown
      • isServing

        private boolean isServing
      • internalTerminationLatch

        private final java.util.concurrent.CountDownLatch internalTerminationLatch
      • initialStartFuture

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

        private boolean initialStarted
      • restartTimer

        private io.grpc.SynchronizationContext.ScheduledHandle restartTimer
      • xdsClientPool

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

        private volatile io.grpc.Server delegate
    • Method Detail

      • start

        public io.grpc.Server start()
                             throws java.io.IOException
        Specified by:
        start in class io.grpc.Server
        Throws:
        java.io.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,
                                        java.util.concurrent.TimeUnit unit)
                                 throws java.lang.InterruptedException
        Specified by:
        awaitTermination in class io.grpc.Server
        Throws:
        java.lang.InterruptedException
      • awaitTermination

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

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

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

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

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

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

        private void startDelegateServer()