Class NettyServerHandler.GracefulShutdown

java.lang.Object

io.grpc.netty.NettyServerHandler.GracefulShutdown

Enclosing class:

NettyServerHandler

private final class NettyServerHandler.GracefulShutdown
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
(package private) String	goAwayMessage
(package private) Long	graceTimeInNanos	The grace time between starting graceful shutdown and closing the netty channel, null is unspecified.
(package private) boolean	pingAckedOrTimeout	True if ping is Acked or ping is timeout.
(package private) Future<?>	pingFuture

Constructor Summary

Constructors

Constructor	Description
GracefulShutdown(String goAwayMessage, Long graceTimeInNanos)

Method Summary

Modifier and Type	Method	Description
private long	graceTimeOverrideMillis(long originalMillis)
(package private) void	secondGoAwayAndClose(io.netty.channel.ChannelHandlerContext ctx)
(package private) void	start(io.netty.channel.ChannelHandlerContext ctx)	Sends out first GOAWAY and ping, and schedules second GOAWAY and close.

Methods inherited from class Object

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

Field Details

goAwayMessage

String goAwayMessage

graceTimeInNanos

@CheckForNull
Long graceTimeInNanos

The grace time between starting graceful shutdown and closing the netty channel, null is unspecified.

pingAckedOrTimeout

boolean pingAckedOrTimeout

True if ping is Acked or ping is timeout.

pingFuture

Future<?> pingFuture

Constructor Details

GracefulShutdown

GracefulShutdown(String goAwayMessage,
 @Nullable
 Long graceTimeInNanos)

Method Details

start

void start(io.netty.channel.ChannelHandlerContext ctx)

Sends out first GOAWAY and ping, and schedules second GOAWAY and close.

secondGoAwayAndClose

void secondGoAwayAndClose(io.netty.channel.ChannelHandlerContext ctx)

graceTimeOverrideMillis

private long graceTimeOverrideMillis(long originalMillis)