Kinetic-test: (602ef1ce) · Commits · kinetic-archive / kinetic-java

bin/chassisTest.sh

+2 −2

Original line number	Diff line number	Diff line
		@@ -82,14 +82,14 @@ do
		do
		node_ip=${node_ip_from_as_array[0]}.${node_ip_from_as_array[1]}.${node_ip_from_as_array[2]}.$curr
		echo "start test ${node_ip}..."
		exec "$JAVA" -classpath "$CLASSPATH" -DRUN_NIO_TEST=true -DRUN_SSL_TEST=true -DRUN_AGAINST_EXTERNAL=true -DKINETIC_HOST=${node_ip} com.seagate.kinetic.allTests.DriveSmokeTestsRunner 1>${LOG_DIR}/${node_ip}.log 2>&1 &
		exec "$JAVA" -classpath "$CLASSPATH" -Dkinetic.io.in=true -Dkinetic.io.out=true -DRUN_NIO_TEST=true -DRUN_SSL_TEST=true -DRUN_AGAINST_EXTERNAL=true -DKINETIC_HOST=${node_ip} com.seagate.kinetic.allTests.DriveSmokeTestsRunner 1>${LOG_DIR}/${node_ip}.log 2>&1 &
		total_nodes=$(( total_nodes + 1 ))
		curr=$(( curr + 1 ))
		done
		else
		node_ip=${node}
		echo "start test ${node_ip}..."
		exec "$JAVA" -classpath "$CLASSPATH" -DRUN_NIO_TEST=true -DRUN_SSL_TEST=true -DRUN_AGAINST_EXTERNAL=true -DKINETIC_HOST=${node_ip} com.seagate.kinetic.allTests.DriveSmokeTestsRunner 1>${LOG_DIR}/${node_ip}.log 2>&1 &
		exec "$JAVA" -classpath "$CLASSPATH" -Dkinetic.io.in=true -Dkinetic.io.out=true -DRUN_NIO_TEST=true -DRUN_SSL_TEST=true -DRUN_AGAINST_EXTERNAL=true -DKINETIC_HOST=${node_ip} com.seagate.kinetic.allTests.DriveSmokeTestsRunner 1>${LOG_DIR}/${node_ip}.log 2>&1 &
		total_nodes=$(( total_nodes + 1 ))
		fi
		done

bin/multiDrivesTest.sh

+1 −2

Original line number	Diff line number	Diff line
		@@ -96,8 +96,7 @@ do
		fi
		done


		for((i=0;i<${total_nodes};i++));
		for((i=0;i<2*${total_nodes};i++));
		do
		j=$(echo "$i+1" \| bc -l)
		wait %$j

kinetic-test/src/test/java/com/seagate/kinetic/AbstractIntegrationTestTarget.java

+1 −0

Original line number	Diff line number	Diff line
		@@ -83,6 +83,7 @@ public abstract class AbstractIntegrationTestTarget {
		clientConfiguration.setHost(host);
		clientConfiguration.setPort(tlsPort);
		clientConfiguration.setNioServiceThreads(1);
		clientConfiguration.setRequestTimeoutMillis(180000);
		return clientConfiguration;
		}

kinetic-test/src/test/java/com/seagate/kinetic/simulator/client/sanity/AdminAPISanityExample.java

+20 −11

Original line number	Diff line number	Diff line
		@@ -83,8 +83,8 @@ public class AdminAPISanityExample {
		"8123"));
		private int sslPort = Integer.parseInt(System.getProperty(
		"KINEITC_SSL_PORT", "8443"));
		private boolean useSsl = Boolean.parseBoolean(System.getProperty("RUN_SSL_TEST",
		"true"));
		private boolean useSsl = Boolean.parseBoolean(System.getProperty(
		"RUN_SSL_TEST", "true"));

		public AdminAPISanityExample() throws KineticException {
		acconfig = new AdminClientConfiguration();
		@@ -486,14 +486,23 @@ public class AdminAPISanityExample {
		kac.close();
		}

		public static void main(String[] args) throws KineticException {
		AdminAPISanityExample example = new AdminAPISanityExample();
		public static void main(String[] args) {
		AdminAPISanityExample example = null;
		try {
		example = new AdminAPISanityExample();
		example.test_setClusterVersion();
		example.test_getLog();
		example.test_getLog_withLogType();
		example.test_getVendorSpecificDeviceLog_ForDrive();
		example.test_setAcl();

		} catch (KineticException e) {
		logger.severe(e.getMessage());
		} finally {
		try {
		example.close();
		} catch (KineticException e) {
		logger.severe(e.getMessage());
		}
		}
		}
		}

kinetic-test/src/test/java/com/seagate/kinetic/simulator/client/sanity/BasicAPISanityExample.java

+27 −13

Original line number	Diff line number	Diff line
		@@ -12,6 +12,7 @@ import java.nio.ByteBuffer;
		import java.util.ArrayList;
		import java.util.Arrays;
		import java.util.List;
		import java.util.logging.Logger;

		import kinetic.client.ClientConfiguration;
		import kinetic.client.Entry;
		@@ -21,8 +22,12 @@ import kinetic.client.KineticClientFactory;
		import kinetic.client.KineticException;

		import com.google.common.collect.Lists;
		import com.seagate.kinetic.IntegrationTestLoggerFactory;

		public class BasicAPISanityExample {
		private static final Logger logger = IntegrationTestLoggerFactory
		.getLogger(BasicAPISanityExample.class.getName());

		private ClientConfiguration cconfig;
		private KineticClient client;
		private String host = System.getProperty("KINETIC_HOST", "127.0.0.1");
		@@ -30,8 +35,8 @@ public class BasicAPISanityExample {
		"8123"));
		private int sslPort = Integer.parseInt(System.getProperty(
		"KINEITC_SSL_PORT", "8443"));
		private boolean useSsl = Boolean.parseBoolean(System.getProperty("RUN_SSL_TEST",
		"false"));
		private boolean useSsl = Boolean.parseBoolean(System.getProperty(
		"RUN_SSL_TEST", "false"));
		private final String KEY_PREFIX = "key";
		private final int MAX_KEYS = 1;

		@@ -288,8 +293,10 @@ public class BasicAPISanityExample {
		client.close();
		}

		public static void main(String[] args) throws KineticException {
		BasicAPISanityExample example = new BasicAPISanityExample();
		public static void main(String[] args) {
		BasicAPISanityExample example = null;
		try {
		example = new BasicAPISanityExample();
		example.testDelete();
		example.testGet();
		example.testGetKeyRange();
		@@ -297,7 +304,14 @@ public class BasicAPISanityExample {
		example.testGetNext();
		example.testGetPrevious();
		example.testPut();

		} catch (KineticException e) {
		logger.severe(e.getMessage());
		} finally {
		try {
		example.close();
		} catch (KineticException e) {
		logger.severe(e.getMessage());
		}
		}
		}
		}