Package org.eclipse.rdf4j.testsuite.sail

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()

createSail

protected abstract Sail createSail()
                            throws SailException

Throws:

SailException

tearDown

@AfterEach
public void tearDown()

testConcurrentAddLargeTxn

@Test
@Timeout(value=30L,
         unit=MINUTES)
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
@Timeout(value=30L,
         unit=MINUTES)
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
@Timeout(value=30L,
         unit=MINUTES)
@Disabled("This test takes a long time and accomplishes little extra")
public void testGetContextIDs()
                       throws Exception

Throws:

Exception

testConcurrentConnectionsShutdown

@Test
@Timeout(value=30L,
         unit=MINUTES)
public void testConcurrentConnectionsShutdown()
                                       throws InterruptedException

Throws:

InterruptedException

testSerialThreads

@Test
@Timeout(value=30L,
         unit=MINUTES)
public void testSerialThreads()
                       throws InterruptedException

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

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