wip

Author: hmottestad

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

@@ -140,8 +140,8 @@ public static final class Builder {
 		private int queueCapacity = 262_144;
 		private int batchBufferBytes = 1 << 20; // 1 MB
 		private SyncPolicy syncPolicy = SyncPolicy.INTERVAL;
-		private Duration syncInterval = Duration.ofMillis(2);
-		private Duration idlePollInterval = Duration.ofMillis(10);
+		private Duration syncInterval = Duration.ofSeconds(10);
+		private Duration idlePollInterval = Duration.ofMillis(100);
 		private boolean syncBootstrapOnOpen = false;
 		private boolean recoverValueStoreOnOpen = false;
 

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

@@ -128,10 +128,9 @@ public void concurrentAddAndReadMayCorrupt() throws Exception {
 					long until = System.nanoTime() + TimeUnit.SECONDS.toNanos(30);
 					while (System.nanoTime() < until) {
 						try (RepositoryResult<Statement> statements = conn.getStatements(null, null, null, false)) {
-							statements.forEachRemaining(st -> {
-								st.toString();
-								// no-op; force materialization
-							});
+							// no-op; force materialization
+							//noinspection ResultOfMethodCallIgnored
+							statements.forEachRemaining(Object::toString);
 						}
 						Thread.onSpinWait();
 					}
@@ -171,9 +170,8 @@ public void concurrentAddAndReadMayCorrupt() throws Exception {
 			// If corruption occurred, iterating statements should throw RepositoryException
 
 			try (RepositoryResult<Statement> statements = conn.getStatements(null, null, null, false)) {
-				statements.forEachRemaining(st -> {
-					st.toString();
-				});
+				//noinspection ResultOfMethodCallIgnored
+				statements.forEachRemaining(Object::toString);
 			}
 		}