Package io.grpc.internal

Class ConnectivityStateManager

java.lang.Object

io.grpc.internal.ConnectivityStateManager

@NotThreadSafe
final class ConnectivityStateManager
extends Object

Manages connectivity states of the channel. Used for ManagedChannel.getState(boolean) to read the current state of the channel, for ManagedChannel.notifyWhenStateChanged(io.grpc.ConnectivityState, java.lang.Runnable) to add listeners to state change events, and for LoadBalancer.Helper#updateBalancingState to update the state and run the gotoState(io.grpc.ConnectivityState)s.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	ConnectivityStateManager.Listener

Field Summary

Fields

Modifier and Type	Field	Description
private ArrayList<ConnectivityStateManager.Listener>	listeners
private ConnectivityState	state

Constructor Summary

Constructors

Constructor	Description
ConnectivityStateManager()

Method Summary

Modifier and Type	Method	Description
(package private) ConnectivityState	getState()	Gets the current connectivity state of the channel.
(package private) void	gotoState(ConnectivityState newState)	Connectivity state is changed to the specified value.
(package private) void	notifyWhenStateChanged(Runnable callback, Executor executor, ConnectivityState source)	Adds a listener for state change event.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

listeners

private ArrayList<ConnectivityStateManager.Listener> listeners

state

private volatile ConnectivityState state

Constructor Details

ConnectivityStateManager

ConnectivityStateManager()

Method Details

notifyWhenStateChanged

void notifyWhenStateChanged(Runnable callback,
 Executor executor,
 ConnectivityState source)

Adds a listener for state change event.

The executor must be one that can run RPC call listeners.

gotoState

void gotoState(@Nonnull
 ConnectivityState newState)

Connectivity state is changed to the specified value. Will trigger some notifications that have been registered earlier by ManagedChannel.notifyWhenStateChanged(io.grpc.ConnectivityState, java.lang.Runnable).

getState

ConnectivityState getState()

Gets the current connectivity state of the channel. This method is threadsafe.