fix: avoid benching already benched proxy.

drallieiv · May 23, 2017 · a047418 · a047418
1 parent de18df1
commit a047418
Showing 1 changed file with 9 additions and 8 deletions.
diff --git a/KinanCity-core/src/main/java/com/kinancity/core/proxy/ProxyManager.java b/KinanCity-core/src/main/java/com/kinancity/core/proxy/ProxyManager.java
@@ -71,15 +71,16 @@ public synchronized Optional<ProxySlot> getEligibleProxy() {
 	}
 
 	public void benchProxy(ProxyInfo proxy) {
-		proxies.remove(proxy);
-		proxyBench.add(proxy);
-		logger.warn("Proxy [{}] moved out of rotation, {} proxy left",proxy, proxies.size());
-
-		if(recycler != null && getNbProxyInRotation() == 0){
-			recycler.setFastMode(true);
-			recycler.checkAndRecycleAllBenched();
+		if(proxies.contains(proxy) && !proxyBench.contains(proxy)){
+			proxies.remove(proxy);
+			proxyBench.add(proxy);
+			logger.warn("Proxy [{}] moved out of rotation, {} proxy left",proxy, proxies.size());
+
+			if(recycler != null && getNbProxyInRotation() == 0){
+				recycler.setFastMode(true);
+				recycler.checkAndRecycleAllBenched();
+			}
 		}
-
 	}
 
 	public int getNbProxyInRotation(){