Class SailConcurrencyTest

java.lang.Object

org.eclipse.rdf4j.testsuite.sail.SailConcurrencyTest

public abstract class SailConcurrencyTest
extends Object

Tests concurrent read and write access to a Sail implementation.

Author:

Arjohn Kampman

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	SailConcurrencyTest.UploadTransaction

Constructor Summary

Constructors

Constructor	Description
SailConcurrencyTest()

Method Summary

Modifier and Type	Method	Description
protected abstract Sail	createSail()
protected void	fail(String message, Throwable t)
protected boolean	hasFailed()
protected void	insertTestStatement(SailConnection connection, int i)
protected void	removeTestStatement(SailConnection connection, int i)
void	setUp()
void	tearDown()
void	testConcurrentAddLargeTxn()	Verifies that two large concurrent transactions in separate contexts do not cause inconsistencies or errors.
void	testConcurrentAddLargeTxnRollback()	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	testConcurrentConnectionsShutdown()
void	testConcurrentConnectionsShutdownAndClose()
void	testConcurrentConnectionsShutdownAndCloseRollback()
void	testConcurrentConnectionsShutdownReadCommitted()
void	testGetContextIDs()
void	testSerialThreads()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SailConcurrencyTest

public SailConcurrencyTest()

Method Details

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

createSail

protected abstract Sail createSail()
                            throws SailException

Throws:

SailException

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

testConcurrentAddLargeTxn

@Test
public void testConcurrentAddLargeTxn()
                               throws Exception

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:

• https://github.com/eclipse/rdf4j/issues/693

testConcurrentAddLargeTxnRollback

@Test
public void testConcurrentAddLargeTxnRollback()
                                       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.

Throws:

Exception

testGetContextIDs

@Test
@Disabled("This test takes a long time and accomplishes little extra")
public void testGetContextIDs()
                       throws Exception

Throws:

Exception

testConcurrentConnectionsShutdown

@Test
public void testConcurrentConnectionsShutdown()
                                       throws InterruptedException

Throws:

InterruptedException

testSerialThreads

@Test
public void testSerialThreads()
                       throws InterruptedException

Throws:

InterruptedException

testConcurrentConnectionsShutdownReadCommitted

@Test
public void testConcurrentConnectionsShutdownReadCommitted()
                                                    throws InterruptedException

Throws:

InterruptedException

testConcurrentConnectionsShutdownAndClose

@Test
public void testConcurrentConnectionsShutdownAndClose()
                                               throws InterruptedException

Throws:

InterruptedException

testConcurrentConnectionsShutdownAndCloseRollback

@Test
public void testConcurrentConnectionsShutdownAndCloseRollback()
                                                       throws InterruptedException

Throws:

InterruptedException

fail

protected void fail(String message,
 Throwable t)

hasFailed

protected boolean hasFailed()

insertTestStatement

protected void insertTestStatement(SailConnection connection,
 int i)
                            throws SailException

Throws:

SailException

removeTestStatement

protected void removeTestStatement(SailConnection connection,
 int i)
                            throws SailException

Throws:

SailException