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

  • 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 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:

    • 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

    • 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