reproduce test failure

Author: hmottestad

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

@@ -20,6 +20,7 @@
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicReference;
 
+import org.eclipse.rdf4j.common.concurrent.locks.Properties;
 import org.eclipse.rdf4j.common.iteration.CloseableIteration;
 import org.eclipse.rdf4j.common.transaction.IsolationLevels;
 import org.eclipse.rdf4j.model.IRI;
@@ -36,7 +37,7 @@
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.RepeatedTest;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -76,6 +77,7 @@ public abstract class SailConcurrencyTest {
 
 	@BeforeEach
 	public void setUp() {
+		Properties.setLockTrackingEnabled(true);
 		store = createSail();
 		store.init();
 		vf = store.getValueFactory();
@@ -154,7 +156,8 @@ public int getSize() {
 	 *
 	 * @see <a href="https://github.com/eclipse/rdf4j/issues/693">https://github.com/eclipse/rdf4j/issues/693</a>
 	 */
-	@Test
+//	@Test
+	@RepeatedTest(100)
 	public void testConcurrentAddLargeTxn() throws Exception {
 		logger.info("executing two large concurrent transactions");
 		final CountDownLatch runnersDone = new CountDownLatch(2);
@@ -195,7 +198,7 @@ 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
+	@RepeatedTest(100)
 	public void testConcurrentAddLargeTxnRollback() throws Exception {
 		logger.info("executing two large concurrent transactions");
 		final CountDownLatch runnersDone = new CountDownLatch(2);
@@ -236,7 +239,7 @@ public void testConcurrentAddLargeTxnRollback() throws Exception {
 
 	}
 
-	@Test
+	@RepeatedTest(100)
 	@Disabled("This test takes a long time and accomplishes little extra")
 	public void testGetContextIDs() throws Exception {
 		// Create one thread which writes statements to the repository, on a
@@ -313,7 +316,7 @@ public void testGetContextIDs() throws Exception {
 		}
 	}
 
-	@Test
+	@RepeatedTest(100)
 	public void testConcurrentConnectionsShutdown() throws InterruptedException {
 		if (store instanceof AbstractSail) {
 			((AbstractSail) store).setConnectionTimeOut(200);
@@ -356,8 +359,8 @@ public void testConcurrentConnectionsShutdown() throws InterruptedException {
 
 	}
 
-//	@Disabled
-	@Test
+	// @Disabled
+	@RepeatedTest(100)
 	public void testSerialThreads() throws InterruptedException {
 		if (store instanceof AbstractSail) {
 			((AbstractSail) store).setConnectionTimeOut(200);
@@ -437,7 +440,7 @@ public void testSerialThreads() throws InterruptedException {
 
 	}
 
-	@Test
+	@RepeatedTest(100)
 	public void testConcurrentConnectionsShutdownReadCommitted() throws InterruptedException {
 		if (store instanceof AbstractSail) {
 			((AbstractSail) store).setConnectionTimeOut(200);
@@ -492,7 +495,7 @@ public void testConcurrentConnectionsShutdownReadCommitted() throws InterruptedE
 
 	}
 
-	@Test
+	@RepeatedTest(100)
 	public void testConcurrentConnectionsShutdownAndClose() throws InterruptedException {
 		if (store instanceof AbstractSail) {
 			((AbstractSail) store).setConnectionTimeOut(200);
@@ -537,13 +540,24 @@ public void testConcurrentConnectionsShutdownAndClose() throws InterruptedExcept
 
 		try {
 			if (thread2.isAlive()) {
+//                try {
 				connection2.get().close();
+
+//                }finally {
 				connection1.get().close();
+
+//                }
 			} else {
+//                try {
 				connection1.get().close();
+
+//                }finally {
 				connection2.get().close();
+
+//                }
 			}
-		} catch (SailException ignored) {
+		} catch (Throwable logged) {
+			logger.error("Error closing connection", logged);
 		}
 
 		try (SailConnection connection = store.getConnection()) {
@@ -567,7 +581,7 @@ public void testConcurrentConnectionsShutdownAndClose() throws InterruptedExcept
 		store.shutDown();
 	}
 
-	@Test
+	@RepeatedTest(100)
 	public void testConcurrentConnectionsShutdownAndCloseRollback() throws InterruptedException {
 		if (store instanceof AbstractSail) {
 			((AbstractSail) store).setConnectionTimeOut(200);