improved detection and monitoring

Author: hmottestad

core/http/client/src/main/java/org/eclipse/rdf4j/http/client/QueryCircuitBreaker.java

@@ -254,7 +254,9 @@ private QueryPressureState refreshState(String reason, Configuration configurati
 			LOGGER.info(
 					"Query circuit breaker transition previous={} current={} freeMb={} rollingGcMs={} reason={}",
 					previous, next, snapshot.getFreeMemoryMb(), snapshot.getRollingGcMs(), reason);
-			if (currentState == QueryPressureState.HIGH || (currentState == QueryPressureState.WARN && determineFreeMemoryState(configuration, snapshot.getFreeMemoryMb()) == QueryPressureState.WARN)) {
+			if (currentState == QueryPressureState.HIGH
+					|| (currentState == QueryPressureState.WARN && determineFreeMemoryState(configuration,
+							snapshot.getFreeMemoryMb()) == QueryPressureState.WARN)) {
 				System.gc();
 			}
 		}
@@ -678,7 +680,7 @@ static Configuration fromSystemProperties() {
 					getIntProperty(HIGH_FREE_MB_PROPERTY, 128),
 					getIntProperty(CRITICAL_FREE_MB_PROPERTY, 96),
 					getIntProperty(WARN_ADMISSION_DELAY_MS_PROPERTY, 50),
-					getIntProperty(CHECKPOINT_DELAY_MS_PROPERTY, 10),
+					getIntProperty(CHECKPOINT_DELAY_MS_PROPERTY, 1),
 					getIntProperty(CANCEL_COOLDOWN_MS_PROPERTY, 1000),
 					getIntProperty(RETRY_AFTER_SECONDS_PROPERTY, 3));
 		}

core/http/client/src/main/java/org/eclipse/rdf4j/http/client/QueryExecutionContext.java

@@ -27,8 +27,6 @@ public final class QueryExecutionContext {
 	private static boolean heavyOperatorExecutionEnabled = true;
 	private static int checkpointCalls;
 
-
-
 	private QueryExecutionContext() {
 	}
 
@@ -65,7 +63,8 @@ public static void markHeavy(String operator) {
 	}
 
 	public static void checkpoint(String operator) throws QueryInterruptedException {
-		if(!shouldCheckpoint()) return;
+		if (!shouldCheckpoint())
+			return;
 		State state = CURRENT.get();
 		if (state != null) {
 			QueryCircuitBreaker.getInstance().checkpoint(state.handle, operator);
@@ -96,7 +95,8 @@ public interface Activation extends AutoCloseable {
 	}
 
 	private static boolean shouldCheckpoint() {
-		if(ignoreCheckpointStride) return true;
+		if (ignoreCheckpointStride)
+			return true;
 		return ((++checkpointCalls) & CHECKPOINT_MASK) == 0;
 	}
 
@@ -109,6 +109,5 @@ private State(QueryCircuitBreakerHandle handle, State previous) {
 			this.previous = previous;
 		}
 
-
 	}
 }