Package org.eclipse.rdf4j.testsuite.sail
Class SailConcurrencyTest
java.lang.Object
org.eclipse.rdf4j.testsuite.sail.SailConcurrencyTest
Tests concurrent read and write access to a Sail implementation.
- Author:
- Arjohn Kampman
-
Nested Class Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected abstract Sail
protected void
protected boolean
protected void
insertTestStatement
(SailConnection connection, int i) protected void
removeTestStatement
(SailConnection connection, int i) void
setUp()
void
tearDown()
void
Verifies that two large concurrent transactions in separate contexts do not cause inconsistencies or errors.void
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.void
void
void
void
void
void
-
Constructor Details
-
SailConcurrencyTest
public SailConcurrencyTest()
-
-
Method Details
-
setUp
@BeforeEach public void setUp() -
createSail
- Throws:
SailException
-
tearDown
@AfterEach public void tearDown() -
testConcurrentAddLargeTxn
Verifies that two large concurrent transactions in separate contexts do not cause inconsistencies or errors. This test may fail intermittently rather than consistently, given its dependency on multi-threading.- Throws:
Exception
- See Also:
-
testConcurrentAddLargeTxnRollback
-
testGetContextIDs
-
testConcurrentConnectionsShutdown
@Test @Timeout(value=30L, unit=MINUTES) public void testConcurrentConnectionsShutdown() throws InterruptedException- Throws:
InterruptedException
-
testSerialThreads
- Throws:
InterruptedException
-
testConcurrentConnectionsShutdownReadCommitted
@Test @Timeout(value=30L, unit=MINUTES) public void testConcurrentConnectionsShutdownReadCommitted() throws InterruptedException- Throws:
InterruptedException
-
testConcurrentConnectionsShutdownAndClose
@Test @Timeout(value=30L, unit=MINUTES) public void testConcurrentConnectionsShutdownAndClose() throws InterruptedException- Throws:
InterruptedException
-
testConcurrentConnectionsShutdownAndCloseRollback
@Test @Timeout(value=30L, unit=MINUTES) public void testConcurrentConnectionsShutdownAndCloseRollback() throws InterruptedException- Throws:
InterruptedException
-
fail
-
hasFailed
protected boolean hasFailed() -
insertTestStatement
- Throws:
SailException
-
removeTestStatement
- Throws:
SailException
-