Class MaxConnectionIdleManager

java.lang.Object

io.grpc.internal.MaxConnectionIdleManager

public final class MaxConnectionIdleManager
extends Object

Monitors connection idle time; shutdowns the connection if the max connection idle is reached.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MaxConnectionIdleManager.Ticker

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	isActive
private final long	maxConnectionIdleInNanos
private long	nextIdleMonitorTime
private ScheduledExecutorService	scheduler
private boolean	shutdownDelayed
private ScheduledFuture<?>	shutdownFuture
private Runnable	shutdownTask
private static final MaxConnectionIdleManager.Ticker	systemTicker
private final MaxConnectionIdleManager.Ticker	ticker

Constructor Summary

Constructors

Constructor	Description
MaxConnectionIdleManager(long maxConnectionIdleInNanos)
MaxConnectionIdleManager(long maxConnectionIdleInNanos, MaxConnectionIdleManager.Ticker ticker)

Method Summary

Modifier and Type	Method	Description
void	onTransportActive()	There are outstanding RPCs on the transport.
void	onTransportIdle()	There are no outstanding RPCs on the transport.
void	onTransportTermination()	Transport is being terminated.
void	start(Runnable closeJob, ScheduledExecutorService scheduler)	Start the initial scheduled shutdown given the transport status reaches max connection idle.

Methods inherited from class Object

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

Field Details

systemTicker

private static final MaxConnectionIdleManager.Ticker systemTicker

maxConnectionIdleInNanos

private final long maxConnectionIdleInNanos

ticker

private final MaxConnectionIdleManager.Ticker ticker

shutdownFuture

@CheckForNull
private ScheduledFuture<?> shutdownFuture

shutdownTask

private Runnable shutdownTask

scheduler

private ScheduledExecutorService scheduler

nextIdleMonitorTime

private long nextIdleMonitorTime

shutdownDelayed

private boolean shutdownDelayed

isActive

private boolean isActive

Constructor Details

MaxConnectionIdleManager

public MaxConnectionIdleManager(long maxConnectionIdleInNanos)

MaxConnectionIdleManager

public MaxConnectionIdleManager(long maxConnectionIdleInNanos,
 MaxConnectionIdleManager.Ticker ticker)

Method Details

start

public void start(Runnable closeJob,
 ScheduledExecutorService scheduler)

Start the initial scheduled shutdown given the transport status reaches max connection idle.

Parameters:

closeJob - Closes the connection by sending GO_AWAY with status code NO_ERROR and ASCII debug data max_idle and then doing the graceful connection termination.

onTransportActive

public void onTransportActive()

There are outstanding RPCs on the transport.

onTransportIdle

public void onTransportIdle()

There are no outstanding RPCs on the transport.

onTransportTermination

public void onTransportTermination()

Transport is being terminated.