ENHANCE: Moved cache list change logic from IO thread to CacheManger …

…thread.
naver · Mar 20, 2024 · e2b1a9e · e2b1a9e
1 parent 1fcd2d7
commit e2b1a9e
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 3 deletions.
diff --git a/src/main/java/net/spy/memcached/CacheManager.java b/src/main/java/net/spy/memcached/CacheManager.java
@@ -398,6 +398,17 @@ public void run() {
             waitBeforeRetryMonitorCheck(1000L - elapsed);
           }
         }
+
+        // Handling cacheList changes to a MemcachedConnection resulting
+        // from the processing of a CacheMonitor's Watch event.
+        for (ArcusClient ac : getAC()) {
+          try {
+            ac.getMemcachedConnection().handleCacheNodesChange();
+          } catch (IOException e) {
+            getLogger().error("Cache List update error in ArcusClient {}, exception = {}",
+                    ac.getName(), e.getCause());
+          }
+        }
       }
     }
     getLogger().info("Close cache manager.");

diff --git a/src/main/java/net/spy/memcached/MemcachedConnection.java b/src/main/java/net/spy/memcached/MemcachedConnection.java
@@ -304,9 +304,6 @@ public void handleIO() throws IOException {
     }
     /* ENABLE_REPLICATION end */
 
-    // Deal with the memcached server group that's been added by CacheManager.
-    handleCacheNodesChange();
-
     if (!reconnectQueue.isEmpty()) {
       attemptReconnects();
     }