wip

Author: hmottestad

testsuites/sail/src/main/java/org/eclipse/rdf4j/testsuite/sail/SailConcurrencyTest.java

@@ -38,6 +38,7 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.RepeatedTest;
+import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -157,9 +158,9 @@ public int getSize() {
 	 *
 	 * @see <a href="https://github.com/eclipse/rdf4j/issues/693">https://github.com/eclipse/rdf4j/issues/693</a>
 	 */
-	@Test
+//	@Test
 	@Timeout(value = 30, unit = TimeUnit.MINUTES)
-//	@RepeatedTest(100)
+	@RepeatedTest(100)
 	public void testConcurrentAddLargeTxn() throws Exception {
 		logger.info("executing two large concurrent transactions");
 		final CountDownLatch runnersDone = new CountDownLatch(2);
@@ -200,9 +201,9 @@ public void testConcurrentAddLargeTxn() throws Exception {
 	 * Verifies that two large concurrent transactions in separate contexts do not cause inconsistencies or errors when
 	 * one of the transactions rolls back at the end.
 	 */
-	@Test
+//	@Test
 	@Timeout(value = 30, unit = TimeUnit.MINUTES)
-//	@RepeatedTest(100)
+	@RepeatedTest(100)
 	public void testConcurrentAddLargeTxnRollback() throws Exception {
 		logger.info("executing two large concurrent transactions");
 		final CountDownLatch runnersDone = new CountDownLatch(2);
@@ -321,8 +322,8 @@ public void testGetContextIDs() throws Exception {
 		}
 	}
 
-//	@RepeatedTest(100)
-	@Test
+	@RepeatedTest(100)
+//	@Test
 	@Timeout(value = 30, unit = TimeUnit.MINUTES)
 	public void testConcurrentConnectionsShutdown() throws InterruptedException {
 		if (store instanceof AbstractSail) {
@@ -367,8 +368,8 @@ public void testConcurrentConnectionsShutdown() throws InterruptedException {
 	}
 
 	// @Disabled
-//	@RepeatedTest(100)
-	@Test
+	@RepeatedTest(100)
+//	@Test
 	@Timeout(value = 30, unit = TimeUnit.MINUTES)
 	public void testSerialThreads() throws InterruptedException {
 		if (store instanceof AbstractSail) {
@@ -449,8 +450,8 @@ public void testSerialThreads() throws InterruptedException {
 
 	}
 
-//	@RepeatedTest(100)
-	@Test
+	@RepeatedTest(100)
+//	@Test
 	@Timeout(value = 30, unit = TimeUnit.MINUTES)
 	public void testConcurrentConnectionsShutdownReadCommitted() throws InterruptedException {
 		if (store instanceof AbstractSail) {
@@ -506,8 +507,8 @@ public void testConcurrentConnectionsShutdownReadCommitted() throws InterruptedE
 
 	}
 
-//	@RepeatedTest(100)
-	@Test
+	@RepeatedTest(100)
+//	@Test
 	@Timeout(value = 30, unit = TimeUnit.MINUTES)
 	public void testConcurrentConnectionsShutdownAndClose() throws InterruptedException {
 		if (store instanceof AbstractSail) {
@@ -594,8 +595,8 @@ public void testConcurrentConnectionsShutdownAndClose() throws InterruptedExcept
 		store.shutDown();
 	}
 
-//	@RepeatedTest(100)
-	@Test
+	@RepeatedTest(1000)
+//	@Test
 	@Timeout(value = 30, unit = TimeUnit.MINUTES)
 	public void testConcurrentConnectionsShutdownAndCloseRollback() throws InterruptedException {
 		if (store instanceof AbstractSail) {