Package io.grpc.netty

Class GracefulServerCloseCommand

java.lang.Object

io.grpc.netty.WriteQueue.AbstractQueuedCommand

io.grpc.netty.GracefulServerCloseCommand

All Implemented Interfaces:

WriteQueue.QueuedCommand

class GracefulServerCloseCommand
extends WriteQueue.AbstractQueuedCommand

A command to trigger close and allow streams naturally close.

Field Summary

Fields

Modifier and Type	Field	Description
private java.lang.String	goAwayDebugString
private long	graceTime
private java.util.concurrent.TimeUnit	graceTimeUnit

Constructor Summary

Constructors

Constructor	Description
GracefulServerCloseCommand(java.lang.String goAwayDebugString)
GracefulServerCloseCommand(java.lang.String goAwayDebugString, long graceTime, java.util.concurrent.TimeUnit graceTimeUnit)

Method Summary

Modifier and Type	Method	Description
java.lang.String	getGoAwayDebugString()
long	getGraceTime()	Has no meaning if getGraceTimeUnit() == null.
java.util.concurrent.TimeUnit	getGraceTimeUnit()

Methods inherited from class io.grpc.netty.WriteQueue.AbstractQueuedCommand

getLink, promise, promise, run

Methods inherited from class java.lang.Object

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

Field Detail

goAwayDebugString

private final java.lang.String goAwayDebugString

graceTime

private final long graceTime

graceTimeUnit

private final java.util.concurrent.TimeUnit graceTimeUnit

Constructor Detail

GracefulServerCloseCommand

public GracefulServerCloseCommand(java.lang.String goAwayDebugString)

GracefulServerCloseCommand

public GracefulServerCloseCommand(java.lang.String goAwayDebugString,
                                  long graceTime,
                                  java.util.concurrent.TimeUnit graceTimeUnit)

Method Detail

getGoAwayDebugString

public java.lang.String getGoAwayDebugString()

getGraceTime

public long getGraceTime()

Has no meaning if getGraceTimeUnit() == null.

getGraceTimeUnit

public java.util.concurrent.TimeUnit getGraceTimeUnit()