fix CR
diff --git a/ceresdb-grpc/src/main/java/io/ceresdb/rpc/GrpcClient.java b/ceresdb-grpc/src/main/java/io/ceresdb/rpc/GrpcClient.java index f598b5b..80946c9 100644 --- a/ceresdb-grpc/src/main/java/io/ceresdb/rpc/GrpcClient.java +++ b/ceresdb-grpc/src/main/java/io/ceresdb/rpc/GrpcClient.java
@@ -603,7 +603,7 @@ ch = this.managedChannelPool.get(endpoint); } - long maxAge = this.opts.getConnectionMaxAge(); + long maxAge = this.opts.getConnectionMaxAgeMs(); if (maxAge != 0 && ch != null) { long createTime = ch.getCreateTime(); long now = System.currentTimeMillis();
diff --git a/ceresdb-rpc/src/main/java/io/ceresdb/rpc/RpcOptions.java b/ceresdb-rpc/src/main/java/io/ceresdb/rpc/RpcOptions.java index 5d5cbb3..20cf072 100644 --- a/ceresdb-rpc/src/main/java/io/ceresdb/rpc/RpcOptions.java +++ b/ceresdb-rpc/src/main/java/io/ceresdb/rpc/RpcOptions.java
@@ -94,7 +94,7 @@ /** * Max time in milliseconds a connection can live, 0 means forever. */ - private long connectionMaxAge = 0; + private long connectionMaxAgeMs = 0; public int getDefaultRpcTimeout() { return defaultRpcTimeout; @@ -104,12 +104,12 @@ this.defaultRpcTimeout = defaultRpcTimeout; } - public long getConnectionMaxAge() { - return connectionMaxAge; + public long getConnectionMaxAgeMs() { + return connectionMaxAgeMs; } - public void setConnectionMaxAge(long connectionMaxAge) { - this.connectionMaxAge = connectionMaxAge; + public void setConnectionMaxAgeMs(long connectionMaxAgeMs) { + this.connectionMaxAgeMs = connectionMaxAgeMs; } public int getRpcThreadPoolSize() { @@ -251,7 +251,7 @@ opts.smoothing = this.smoothing; opts.blockOnLimit = this.blockOnLimit; opts.logOnLimitChange = this.logOnLimitChange; - opts.connectionMaxAge = this.connectionMaxAge; + opts.connectionMaxAgeMs = this.connectionMaxAgeMs; return opts; } @@ -264,7 +264,7 @@ + keepAliveTimeoutSeconds + ", keepAliveWithoutCalls=" + keepAliveWithoutCalls + ", limitKind=" + limitKind + ", initialLimit=" + initialLimit + ", maxLimit=" + maxLimit + ", longRttWindow=" + longRttWindow + ", smoothing=" + smoothing + ", blockOnLimit=" + blockOnLimit + ", logOnLimitChange=" - + logOnLimitChange + ", connectionMaxAge=" + connectionMaxAge + '}'; + + logOnLimitChange + ", connectionMaxAge=" + connectionMaxAgeMs + '}'; } public static RpcOptions newDefault() {