Home
last modified time | relevance | path

Searched refs:keepAliveTimeInNanos (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DKeepAliveManager.java90 private long keepAliveTimeInNanos; field in KeepAliveManager
126 long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, in KeepAliveManager() argument
128 this(keepAlivePinger, scheduler, SYSTEM_TICKER, keepAliveTimeInNanos, keepAliveTimeoutInNanos, in KeepAliveManager()
134 Ticker ticker, long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, in KeepAliveManager() argument
139 this.keepAliveTimeInNanos = keepAliveTimeInNanos; in KeepAliveManager()
142 nextKeepaliveTime = ticker.read() + keepAliveTimeInNanos; in KeepAliveManager()
156 nextKeepaliveTime = ticker.read() + keepAliveTimeInNanos; in onDataReceived()
176 pingFuture = scheduler.schedule(sendPing, keepAliveTimeInNanos, TimeUnit.NANOSECONDS); in onDataReceived()
233 public static long clampKeepAliveTimeInNanos(long keepAliveTimeInNanos) { in clampKeepAliveTimeInNanos() argument
234 return Math.max(keepAliveTimeInNanos, MIN_KEEPALIVE_TIME_NANOS); in clampKeepAliveTimeInNanos()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerBuilder.java84 private long keepAliveTimeInNanos = DEFAULT_SERVER_KEEPALIVE_TIME_NANOS; field in NettyServerBuilder
300 keepAliveTimeInNanos = timeUnit.toNanos(keepAliveTime); in keepAliveTime()
301 keepAliveTimeInNanos = KeepAliveManager.clampKeepAliveTimeInNanos(keepAliveTimeInNanos); in keepAliveTime()
302 if (keepAliveTimeInNanos >= AS_LARGE_AS_INFINITE) { in keepAliveTime()
304 keepAliveTimeInNanos = SERVER_KEEPALIVE_TIME_NANOS_DISABLED; in keepAliveTime()
306 if (keepAliveTimeInNanos < MIN_KEEPALIVE_TIME_NANO) { in keepAliveTime()
308 keepAliveTimeInNanos = MIN_KEEPALIVE_TIME_NANO; in keepAliveTime()
436 maxMessageSize, maxHeaderListSize, keepAliveTimeInNanos, keepAliveTimeoutInNanos, in buildTransportServer()
DNettyServerTransport.java70 private final long keepAliveTimeInNanos; field in NettyServerTransport
90 long keepAliveTimeInNanos, in NettyServerTransport() argument
107 this.keepAliveTimeInNanos = keepAliveTimeInNanos; in NettyServerTransport()
263 keepAliveTimeInNanos, in createHandler()
DNettyServer.java85 private final long keepAliveTimeInNanos; field in NettyServer
108 long keepAliveTimeInNanos, long keepAliveTimeoutInNanos, in NettyServer() argument
128 this.keepAliveTimeInNanos = keepAliveTimeInNanos; in NettyServer()
202 keepAliveTimeInNanos, in start()
DNettyServerHandler.java107 private final long keepAliveTimeInNanos; field in NettyServerHandler
141 long keepAliveTimeInNanos, in newHandler() argument
166 keepAliveTimeInNanos, in newHandler()
187 long keepAliveTimeInNanos, in newHandler() argument
229 keepAliveTimeInNanos, keepAliveTimeoutInNanos, in newHandler()
245 long keepAliveTimeInNanos, in NettyServerHandler() argument
293 this.keepAliveTimeInNanos = keepAliveTimeInNanos; in NettyServerHandler()
339 if (keepAliveTimeInNanos != SERVER_KEEPALIVE_TIME_NANOS_DISABLED) { in handlerAdded()
341 keepAliveTimeInNanos, keepAliveTimeoutInNanos, true /* keepAliveDuringTransportIdle */); in handlerAdded()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerHandlerTest.java140 private long keepAliveTimeInNanos = DEFAULT_SERVER_KEEPALIVE_TIME_NANOS; field in NettyServerHandlerTest
572 keepAliveTimeInNanos = TimeUnit.MILLISECONDS.toNanos(10L); in keepAliveManager_pingSent()
577 fakeClock().forwardNanos(keepAliveTimeInNanos); in keepAliveManager_pingSent()
592 keepAliveTimeInNanos = 123L /* nanoseconds */; in keepAliveManager_pingTimeout()
596 fakeClock().forwardNanos(keepAliveTimeInNanos); in keepAliveManager_pingTimeout()
1072 keepAliveTimeInNanos, in newHandler()