Commit 0bdd49a0 authored by lichenchong's avatar lichenchong
Browse files

Kinetic-test:

Modify cluster version failure check for setClusterVersion API negative
test.
parent 380b6717
Loading
Loading
Loading
Loading
+2850 −2847
Original line number Diff line number Diff line
@@ -47,6 +47,7 @@ import kinetic.admin.Role;
import kinetic.admin.Statistics;
import kinetic.admin.Temperature;
import kinetic.admin.Utilization;
import kinetic.client.ClusterVersionFailureException;
import kinetic.client.Entry;
import kinetic.client.EntryMetadata;
import kinetic.client.EntryNotFoundException;
@@ -238,9 +239,9 @@ public class KineticAdminTest extends IntegrationTestCase {

        try {
            resetClusterVersionToDefault(newClusterVersion);
		} catch (KineticException e) {
        } catch (ClusterVersionFailureException e) {
            assertTrue(e.getResponseMessage().getCommand().getStatus()
					.getStatusMessage().contains("CLUSTER_VERSION_FAILURE"));
                    .getCode().equals(StatusCode.VERSION_FAILURE));

            long requestClusterVersion = e.getRequestMessage().getCommand()
                    .getHeader().getClusterVersion();
@@ -252,6 +253,8 @@ public class KineticAdminTest extends IntegrationTestCase {
                    + requestClusterVersion
                    + ", respose cluster version="
                    + responseClusterVersion);
        } catch (Exception e1) {
            Assert.fail("Throw wrong exception. " + e1.getMessage());
        }

        logger.info(this.testEndInfo());