Class OobChannel

    • Field Detail

      • log

        private static final java.util.logging.Logger log
      • authority

        private final java.lang.String authority
      • executorPool

        private final ObjectPool<? extends java.util.concurrent.Executor> executorPool
      • executor

        private final java.util.concurrent.Executor executor
      • deadlineCancellationExecutor

        private final java.util.concurrent.ScheduledExecutorService deadlineCancellationExecutor
      • terminatedLatch

        private final java.util.concurrent.CountDownLatch terminatedLatch
      • shutdown

        private volatile boolean shutdown
      • channelCallsTracer

        private final CallTracer channelCallsTracer
    • Method Detail

      • authority

        public java.lang.String authority()
        Description copied from class: Channel
        The authority of the destination this channel connects to. Typically this is in the format host:port.
        Specified by:
        authority in class Channel
      • awaitTermination

        public boolean awaitTermination​(long time,
                                        java.util.concurrent.TimeUnit unit)
                                 throws java.lang.InterruptedException
        Description copied from class: ManagedChannel
        Waits for the channel to become terminated, giving up if the timeout is reached.
        Specified by:
        awaitTermination in class ManagedChannel
        Returns:
        whether the channel is terminated, as would be done by ManagedChannel.isTerminated().
        Throws:
        java.lang.InterruptedException
      • getState

        public ConnectivityState getState​(boolean requestConnectionIgnored)
        Description copied from class: ManagedChannel
        Gets the current connectivity state. Note the result may soon become outdated.

        Note that the core library did not provide an implementation of this method until v1.6.1.

        Overrides:
        getState in class ManagedChannel
        Parameters:
        requestConnectionIgnored - if true, the channel will try to make a connection if it is currently IDLE
      • shutdown

        public ManagedChannel shutdown()
        Description copied from class: ManagedChannel
        Initiates an orderly shutdown in which preexisting calls continue but new calls are immediately cancelled.
        Specified by:
        shutdown in class ManagedChannel
        Returns:
        this
      • handleSubchannelTerminated

        void handleSubchannelTerminated()
      • getLogId

        public InternalLogId getLogId()
        Description copied from interface: InternalWithLogId
        Returns an ID that is primarily used in debug logs. It usually contains the class name and a numeric ID that is unique among the instances.

        The subclasses of this interface usually want to include the log ID in their Object.toString() results.

        Specified by:
        getLogId in interface InternalWithLogId
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • resetConnectBackoff

        public void resetConnectBackoff()
        Description copied from class: ManagedChannel
        For subchannels that are in TRANSIENT_FAILURE state, short-circuit the backoff timer and make them reconnect immediately. May also attempt to invoke NameResolver.refresh().

        This is primarily intended for Android users, where the network may experience frequent temporary drops. Rather than waiting for gRPC's name resolution and reconnect timers to elapse before reconnecting, the app may use this method as a mechanism to notify gRPC that the network is now available and a reconnection attempt may occur immediately.

        No-op if not supported by the implementation.

        Overrides:
        resetConnectBackoff in class ManagedChannel