Home
last modified time | relevance | path

Searched refs:maxConnectionIdleInNanos (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DMaxConnectionIdleManager.java38 private final long maxConnectionIdleInNanos; field in MaxConnectionIdleManager
49 MaxConnectionIdleManager(long maxConnectionIdleInNanos) { in MaxConnectionIdleManager() argument
50 this(maxConnectionIdleInNanos, systemTicker); in MaxConnectionIdleManager()
54 MaxConnectionIdleManager(long maxConnectionIdleInNanos, Ticker ticker) { in MaxConnectionIdleManager() argument
55 this.maxConnectionIdleInNanos = maxConnectionIdleInNanos; in MaxConnectionIdleManager()
67 nextIdleMonitorTime = ticker.nanoTime() + maxConnectionIdleInNanos; in start()
88 scheduler.schedule(shutdownTask, maxConnectionIdleInNanos, TimeUnit.NANOSECONDS); in start()
112 .schedule(shutdownTask, maxConnectionIdleInNanos, TimeUnit.NANOSECONDS); in onTransportIdle()
114 nextIdleMonitorTime = ticker.nanoTime() + maxConnectionIdleInNanos; in onTransportIdle()
DNettyServerBuilder.java86 private long maxConnectionIdleInNanos = MAX_CONNECTION_IDLE_NANOS_DISABLED; field in NettyServerBuilder
342 maxConnectionIdleInNanos = timeUnit.toNanos(maxConnectionIdle); in maxConnectionIdle()
343 if (maxConnectionIdleInNanos >= AS_LARGE_AS_INFINITE) { in maxConnectionIdle()
344 maxConnectionIdleInNanos = MAX_CONNECTION_IDLE_NANOS_DISABLED; in maxConnectionIdle()
346 if (maxConnectionIdleInNanos < MIN_MAX_CONNECTION_IDLE_NANO) { in maxConnectionIdle()
347 maxConnectionIdleInNanos = MIN_MAX_CONNECTION_IDLE_NANO; in maxConnectionIdle()
437 maxConnectionIdleInNanos, in buildTransportServer()
DNettyServerTransport.java72 private final long maxConnectionIdleInNanos; field in NettyServerTransport
92 long maxConnectionIdleInNanos, in NettyServerTransport() argument
109 this.maxConnectionIdleInNanos = maxConnectionIdleInNanos; in NettyServerTransport()
265 maxConnectionIdleInNanos, in createHandler()
DNettyServer.java87 private final long maxConnectionIdleInNanos; field in NettyServer
109 long maxConnectionIdleInNanos, in NettyServer() argument
130 this.maxConnectionIdleInNanos = maxConnectionIdleInNanos; in NettyServer()
204 maxConnectionIdleInNanos, in start()
DNettyServerHandler.java143 long maxConnectionIdleInNanos, in newHandler() argument
168 maxConnectionIdleInNanos, in newHandler()
189 long maxConnectionIdleInNanos, in newHandler() argument
230 maxConnectionIdleInNanos, in newHandler()
247 long maxConnectionIdleInNanos, in NettyServerHandler() argument
254 if (maxConnectionIdleInNanos == MAX_CONNECTION_IDLE_NANOS_DISABLED) { in NettyServerHandler()
257 maxConnectionIdleManager = new MaxConnectionIdleManager(maxConnectionIdleInNanos) { in NettyServerHandler()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerHandlerTest.java137 private long maxConnectionIdleInNanos = MAX_CONNECTION_IDLE_NANOS_DISABLED; field in NettyServerHandlerTest
687 maxConnectionIdleInNanos = TimeUnit.MINUTES.toNanos(30L); in noGoAwaySentBeforeMaxConnectionIdleReached()
701 maxConnectionIdleInNanos = TimeUnit.MILLISECONDS.toNanos(10L); in maxConnectionIdle_goAwaySent_pingAck()
705 fakeClock().forwardNanos(maxConnectionIdleInNanos); in maxConnectionIdle_goAwaySent_pingAck()
736 maxConnectionIdleInNanos = TimeUnit.MILLISECONDS.toNanos(10L); in maxConnectionIdle_goAwaySent_pingTimeout()
740 fakeClock().forwardNanos(maxConnectionIdleInNanos); in maxConnectionIdle_goAwaySent_pingTimeout()
766 maxConnectionIdleInNanos = TimeUnit.MILLISECONDS.toNanos(10L); in maxConnectionIdle_activeThenRst_pingAck()
770 fakeClock().forwardNanos(maxConnectionIdleInNanos); in maxConnectionIdle_activeThenRst_pingAck()
780 fakeClock().forwardNanos(maxConnectionIdleInNanos); in maxConnectionIdle_activeThenRst_pingAck()
806 maxConnectionIdleInNanos = TimeUnit.MILLISECONDS.toNanos(10L); in maxConnectionIdle_activeThenRst_pingTimeoutk()
[all …]
DMaxConnectionIdleManagerTest.java105 TestMaxConnectionIdleManager(long maxConnectionIdleInNanos, Ticker ticker) { in TestMaxConnectionIdleManager() argument
106 super(maxConnectionIdleInNanos, ticker); in TestMaxConnectionIdleManager()