wip

Author: hmottestad

core/sail/nativerdf/src/main/java/org/eclipse/rdf4j/sail/nativerdf/wal/ValueStoreWAL.java

@@ -192,6 +192,9 @@ public void awaitDurable(long lsn) throws InterruptedException, IOException {
 			return;
 		}
 		requestForce(lsn);
+		if (config.syncPolicy() == ValueStoreWalConfig.SyncPolicy.INTERVAL) {
+			return;
+		}
 		synchronized (ackMonitor) {
 			while (lastForcedLsn.get() < lsn && writerFailure == null && !closed) {
 				ackMonitor.wait(TimeUnit.MILLISECONDS.toMillis(10));

core/sail/nativerdf/src/test/java/org/eclipse/rdf4j/sail/nativerdf/NativeStoreRepositoryCorruptionReproducerTestIT.java

@@ -129,7 +129,7 @@ public void concurrentAddAndReadMayCorrupt() throws Exception {
 					while (System.nanoTime() < until) {
 						try (RepositoryResult<Statement> statements = conn.getStatements(null, null, null, false)) {
 							// no-op; force materialization
-							//noinspection ResultOfMethodCallIgnored
+							// noinspection ResultOfMethodCallIgnored
 							statements.forEachRemaining(Object::toString);
 						}
 						Thread.onSpinWait();
@@ -170,7 +170,7 @@ public void concurrentAddAndReadMayCorrupt() throws Exception {
 			// If corruption occurred, iterating statements should throw RepositoryException
 
 			try (RepositoryResult<Statement> statements = conn.getStatements(null, null, null, false)) {
-				//noinspection ResultOfMethodCallIgnored
+				// noinspection ResultOfMethodCallIgnored
 				statements.forEachRemaining(Object::toString);
 			}
 		}