grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix

This commit is contained in:
yifeizhuang 2022-08-25 10:47:38 -07:00
parent 221ee494d9
commit 96b9fc1be4
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/main/java/io/grpc/internal/MaxConnectionIdleManager.java
View File

@ -20,13 +20,12 @@ import com.google.common.annotations.VisibleForTesting;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture; import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import javax.annotation.CheckForNull; import javax.annotation.CheckForNull;
/** /**
* Monitors connection idle time; shutdowns the connection if the max connection idle is reached. * Monitors connection idle time; shutdowns the connection if the max connection idle is reached.
*/ */
public class MaxConnectionIdleManager { public final class MaxConnectionIdleManager {
private static final Ticker systemTicker = new Ticker() { private static final Ticker systemTicker = new Ticker() {
@Override @Override
public long nanoTime() { public long nanoTime() {
@ -61,7 +60,6 @@ public class MaxConnectionIdleManager {
* @param closeJob Closes the connection by sending GO_AWAY with status code NO_ERROR and ASCII * @param 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. * debug data max_idle and then doing the graceful connection termination.
*/ */
@VisibleForTesting
public void start(final Runnable closeJob, final ScheduledExecutorService scheduler) { public void start(final Runnable closeJob, final ScheduledExecutorService scheduler) {
this.scheduler = scheduler; this.scheduler = scheduler;
nextIdleMonitorTime = ticker.nanoTime() + maxConnectionIdleInNanos; nextIdleMonitorTime = ticker.nanoTime() + maxConnectionIdleInNanos;