(fix) Heartbeating failure counter error

killme2008 · Oct 9, 2016 · 73f622f · 73f622f
1 parent a68e431
commit 73f622f
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/main/java/net/rubyeye/xmemcached/impl/MemcachedHandler.java b/src/main/java/net/rubyeye/xmemcached/impl/MemcachedHandler.java
@@ -237,12 +237,13 @@ public void run() {
 					if (!this.versionCommand.getLatch().await(2000,
 							TimeUnit.MILLISECONDS)) {
 						heartBeatFailCount.incrementAndGet();
-					}
-					if (this.versionCommand.getResult() == null) {
-						heartBeatFailCount.incrementAndGet();
 					} else {
-						// reset
-						heartBeatFailCount.set(0);
+						if (this.versionCommand.getResult() == null) {
+							heartBeatFailCount.incrementAndGet();
+						} else {
+							// reset the failure counter
+							heartBeatFailCount.set(0);
+						}
 					}
 					if (heartBeatFailCount.get() > MAX_HEART_BEAT_FAIL_COUNT) {
 						log.warn("Session("