Adding timeouts to tests

Author: ssambasu

test-complete/src/test/java/com/marklogic/client/datamovement/functionaltests/QBFailover.java

@@ -273,7 +273,7 @@ public void tearDown() throws Exception {
 		clearDB(port);
 	}
 
-	@Test
+	@Test(timeout = 300000)
 	public void testStopOneNode() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		AtomicInteger success = new AtomicInteger(0);
@@ -308,7 +308,7 @@ public void testStopOneNode() throws Exception {
 		assertEquals("document count", 0, failure.intValue());
 	}
 
-	@Test
+	@Test(timeout = 300000)
 	public void testRestart() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		AtomicInteger success = new AtomicInteger(0);
@@ -345,7 +345,7 @@ public void testRestart() throws Exception {
 		assertEquals("document count", 0, failure.intValue());
 	}
 
-	@Test
+	@Test(timeout = 300000)
 	public void testRepeatedStopOneNode() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		AtomicInteger success = new AtomicInteger(0);
@@ -389,7 +389,7 @@ public void testRepeatedStopOneNode() throws Exception {
 		assertEquals("document count", 0, failure.intValue());
 	}
 
-	@Test
+	@Test(timeout = 300000)
 	public void testMinNodes() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		AtomicInteger success = new AtomicInteger(0);
@@ -433,7 +433,7 @@ public void testMinNodes() throws Exception {
 		Assert.assertTrue(success.intValue() < 20000);
 	}
 
-	@Test
+	@Test(timeout = 300000)
 	public void testStopTwoNodes() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		try {
@@ -476,7 +476,7 @@ public void testStopTwoNodes() throws Exception {
 		}
 	}
 
-	@Test
+	@Test(timeout = 300000)
 	public void xQueryMasstransformReplace() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		ServerTransform transform = new ServerTransform("add-attr-xquery-transform");
@@ -546,7 +546,7 @@ public void xQueryMasstransformReplace() throws Exception {
 
 	}
 
-	@Test
+	@Test(timeout = 300000)
 	public void xQueryMasstransformReplaceTwoNodes() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		ServerTransform transform = new ServerTransform("add-attr-xquery-transform");
@@ -618,7 +618,7 @@ public void xQueryMasstransformReplaceTwoNodes() throws Exception {
 		assertEquals("document count", 0, skipped.intValue());
 	}
 
-	@Test
+	@Test(timeout = 300000)
 	public void xQueryMasstransformReplaceRepeated() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		ServerTransform transform = new ServerTransform("add-attr-xquery-transform");
@@ -696,7 +696,7 @@ public void xQueryMasstransformReplaceRepeated() throws Exception {
 		assertEquals("document count", 0, failure.intValue());
 	}
 
-	@Test
+	@Test(timeout = 300000)
 	public void massDeleteConsistentSnapShot() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		AtomicBoolean isRunning = new AtomicBoolean(true);

test-complete/src/test/java/com/marklogic/client/datamovement/functionaltests/WBFailover.java

@@ -231,7 +231,7 @@ public void tearDown() throws Exception {
 		clearDB(port);
 	}
 
-	@Test
+	@Test(timeout = 200000)
 	public void testBlackListHost() throws Exception {
 		try {
 			System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
@@ -276,7 +276,7 @@ public void testBlackListHost() throws Exception {
 		}
 	}
 
-	@Test
+	@Test(timeout = 200000)
 	public void testStopOneNode() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		Assert.assertTrue(evalClient.newServerEval().xquery(query1).eval().next().getNumber().intValue() == 0);
@@ -321,7 +321,7 @@ public void testStopOneNode() throws Exception {
 		Assert.assertTrue(evalClient.newServerEval().xquery(query1).eval().next().getNumber().intValue() == 50000);
 	}
 
-	@Test
+	@Test(timeout = 200000)
 	public void testRestart() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		Assert.assertTrue(evalClient.newServerEval().xquery(query1).eval().next().getNumber().intValue() == 0);
@@ -369,7 +369,7 @@ public void testRestart() throws Exception {
 		Assert.assertTrue(evalClient.newServerEval().xquery(query1).eval().next().getNumber().intValue() == 20000);
 	}
 
-	@Test
+	@Test(timeout = 200000)
 	public void testRepeatedStopOneNode() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		try {
@@ -426,7 +426,7 @@ public void testRepeatedStopOneNode() throws Exception {
 		}
 	}
 
-	@Test
+	@Test(timeout = 200000)
 	public void testStopTwoNodes() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		try {
@@ -485,7 +485,7 @@ public void testStopTwoNodes() throws Exception {
 
 	}
 
-	@Test
+	@Test(timeout = 200000)
 	public void testMinHosts() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		final AtomicInteger successCount = new AtomicInteger(0);
@@ -528,7 +528,7 @@ public void testMinHosts() throws Exception {
 		System.out.println("Ending min test");
 	}
 
-	@Test
+	@Test(timeout = 200000)
 	public void testWhiteBlackListNPE() throws Exception {
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		try {