Merge pull request #3 from EMCECS/release-2.1.1

Release 2.1.1

Author: twincitiesguy

build.gradle

@@ -29,16 +29,16 @@ description = 'Smart REST Client - JAX-RS (Jersey) REST client that provides cli
 ext.githubProjectName = 'smart-client-java'
 
 buildscript {
-    ext.commonBuildVersion = '1.5'
+    ext.commonBuildVersion = '1.6'
     ext.commonBuildDir = "https://raw.githubusercontent.com/emcvipr/ecs-common-build/v$commonBuildVersion"
     apply from: "$commonBuildDir/ecs-publish.buildscript.gradle", to: buildscript
 }
 
 apply from: "$commonBuildDir/ecs-publish.gradle"
 
 dependencies {
-    compile 'com.sun.jersey:jersey-client:1.19',
-            'com.sun.jersey.contribs:jersey-apache-client4:1.19',
+    compile 'com.sun.jersey:jersey-client:1.19.3',
+            'com.sun.jersey.contribs:jersey-apache-client4:1.19.3',
             'org.apache.httpcomponents:httpclient:4.2.6',
             'org.slf4j:slf4j-api:1.7.5'
     runtime 'org.slf4j:slf4j-log4j12:1.7.5'

gradle/wrapper/gradle-wrapper.jar

@@ -1,6 +1,6 @@
-#Tue Feb 10 16:00:30 CST 2015
+#Thu Mar 02 11:15:41 CST 2017
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-2.2.1-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-2.14-bin.zip

gradle/wrapper/gradle-wrapper.properties

@@ -26,11 +26,11 @@
  */
 package com.emc.rest.smart;
 
-import java.util.Date;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.Date;
+
 /**
  * Some basic statements about response index calculation:
  * <p>
@@ -105,7 +105,9 @@ public boolean isHealthy() {
         if (!healthy) return false;
         else if (consecutiveErrors == 0) return true;
         else {
-            long coolDownExp = consecutiveErrors > MAX_COOL_DOWN_EXP ? MAX_COOL_DOWN_EXP : consecutiveErrors - 1;
+            // errorWaitTime * 2 ^ (min(errors-1, 4))
+            // i.e. back-off is doubled for each consecutive error up to 4
+            long coolDownExp = Math.min(consecutiveErrors - 1, MAX_COOL_DOWN_EXP);
             long msSinceLastUse = System.currentTimeMillis() - lastConnectionTime;
             long errorCoolDown = (long) Math.pow(2, coolDownExp) * errorWaitTime;
             return msSinceLastUse > errorCoolDown;

gradlew

@@ -138,9 +138,9 @@ static ApacheHttpClient4Handler createApacheClientHandler(SmartConfig smartConfi
 
         // set up multi-threaded connection pool
         org.apache.http.impl.conn.PoolingClientConnectionManager connectionManager = new org.apache.http.impl.conn.PoolingClientConnectionManager();
-        // 200 maximum active connections (should be more than enough for any JVM instance)
-        connectionManager.setDefaultMaxPerRoute(200);
-        connectionManager.setMaxTotal(200);
+        // 999 maximum active connections (max allowed)
+        connectionManager.setDefaultMaxPerRoute(999);
+        connectionManager.setMaxTotal(999);
         clientConfig.getProperties().put(ApacheHttpClient4Config.PROPERTY_CONNECTION_MANAGER, connectionManager);
 
         // set proxy config

gradlew.bat

@@ -71,7 +71,7 @@ public void testHost() throws Exception {
         Thread.sleep(errorWaitTime - 500); // wait until just before the error is cooled down
         Assert.assertFalse(host.isHealthy()); // host should still be in cool down period
 
-        Thread.sleep(500); // wait until cool down period is over
+        Thread.sleep(600); // wait until cool down period is over
         Assert.assertTrue(host.isHealthy());
 
         // test another error
@@ -89,7 +89,7 @@ public void testHost() throws Exception {
         Thread.sleep(2 * errorWaitTime - 500); // wait until just before cool down is over
         Assert.assertFalse(host.isHealthy());
 
-        Thread.sleep(500); // wait until cool down period is over
+        Thread.sleep(600); // wait until cool down period is over
         Assert.assertTrue(host.isHealthy());
 
         // test one more error
@@ -107,7 +107,7 @@ public void testHost() throws Exception {
         Thread.sleep(2 * 2 * errorWaitTime - 500); // wait until just before cool down is over
         Assert.assertFalse(host.isHealthy());
 
-        Thread.sleep(500); // wait until cool down period is over
+        Thread.sleep(600); // wait until cool down period is over
         Assert.assertTrue(host.isHealthy());
 
         // test no more errors

src/main/java/com/emc/rest/smart/Host.java

@@ -55,7 +55,7 @@ public class SmartClientTest {
 
     public static final String PROP_ATMOS_ENDPOINTS = "atmos.endpoints";
     public static final String PROP_ATMOS_UID = "atmos.uid";
-    public static final String PROP_ATMOS_SECRET = "atmos.secret_key";
+    public static final String PROP_ATMOS_SECRET = "atmos.secret";
 
     private static final String HEADER_FORMAT = "EEE, d MMM yyyy HH:mm:ss z";
     private static final ThreadLocal<DateFormat> headerFormat = new ThreadLocal<DateFormat>();
@@ -115,15 +115,15 @@ public void testConnTimeout() throws Exception {
         HttpParams httpParams = new BasicHttpParams();
         HttpConnectionParams.setConnectionTimeout(httpParams, CONNECTION_TIMEOUT_MILLIS);
 
-        SmartConfig smartConfig = new SmartConfig("10.4.4.180");
+        SmartConfig smartConfig = new SmartConfig("8.8.4.4:9020");
         smartConfig.setProperty(ApacheHttpClient4Config.PROPERTY_HTTP_PARAMS, httpParams);
 
         final Client client = SmartClientFactory.createStandardClient(smartConfig);
 
         Future future = Executors.newSingleThreadExecutor().submit(new Runnable() {
             @Override
             public void run() {
-                client.resource("http://10.4.4.180:9020/?ping").get(String.class);
+                client.resource("http://8.8.4.4:9020/?ping").get(String.class);
                 Assert.fail("response was not expected; choose an IP that is not in use");
             }
         });