RpcClientProxy's lastUsedNanos is modified with volatile to avoid inc…

…onsistent visibility among multiple threads (#78)
trpc-group · Jan 15, 2025 · e7eccb0 · e7eccb0
1 parent d5ad43f
commit e7eccb0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/trpc-core/src/main/java/com/tencent/trpc/core/cluster/RpcClusterClientManager.java b/trpc-core/src/main/java/com/tencent/trpc/core/cluster/RpcClusterClientManager.java
@@ -127,7 +127,7 @@ public static void scanUnusedClient() {
             } finally {
                 logger.warn("RpcClient in clusterName={}, naming={}, remove rpc client{}, due to unused time > {} ms",
                         bConfig.getName(), bConfig.getNamingOptions().getServiceNaming(),
-                        e.getProtocolConfig().toSimpleString(), e.getProtocolConfig().getIdleTimeout());
+                        e.getProtocolConfig().toSimpleString(), bConfig.getIdleTimeout());
             }
         }));
     }
@@ -252,7 +252,7 @@ private static class RpcClientProxy implements RpcClient {
 
         private RpcClient delegate;
 
-        private long lastUsedNanos = System.nanoTime();
+        private volatile long lastUsedNanos = System.nanoTime();
 
         RpcClientProxy(RpcClient delegate) {
             this.delegate = delegate;