feat: Make worker loop sleep duration configurable (#20007)

Signed-off-by: Petar Tonev <[email protected]>

Author: petreze

hedera-node/hedera-app/src/main/java/com/hedera/node/app/blocks/impl/streaming/BlockNodeConnectionManager.java

@@ -72,10 +72,8 @@ public class BlockNodeConnectionManager {
      */
     public static final Duration INITIAL_RETRY_DELAY = Duration.ofSeconds(1);
     /**
-     * The amount of time the worker thread will sleep when there is no work available to process.
+     * The multiplier used for exponential backoff when retrying connections.
      */
-    private static final int PROCESSOR_LOOP_DELAY_MS = 10;
-
     private static final long RETRY_BACKOFF_MULTIPLIER = 2;
     /**
      * The maximum delay used for reties.
@@ -220,6 +218,18 @@ private int blockItemBatchSize() {
                 .blockItemBatchSize();
     }
 
+    /**
+     * The amount of time the worker thread will sleep when there is no work available to process.
+     *
+     * @return the sleep duration of the worker loop
+     */
+    private Duration workerLoopSleepDuration() {
+        return configProvider
+                .getConfiguration()
+                .getConfigData(BlockStreamConfig.class)
+                .workerLoopSleepDuration();
+    }
+
     /**
      * Extracts block node configurations from the specified configuration file.
      *
@@ -549,8 +559,7 @@ private void blockStreamWorkerLoop() {
 
                 // Sleep for a short duration to avoid busy waiting
                 if (shouldSleep) {
-                    // TODO: make sleep duration configurable
-                    Thread.sleep(PROCESSOR_LOOP_DELAY_MS);
+                    Thread.sleep(workerLoopSleepDuration());
                 }
             } catch (final InterruptedException e) {
                 logger.error("Block stream worker interrupted", e);

hedera-node/hedera-config/src/main/java/com/hedera/node/config/data/BlockStreamConfig.java

@@ -33,7 +33,8 @@ public record BlockStreamConfig(
         @ConfigProperty(defaultValue = "2s") @Min(0) @NetworkProperty Duration blockPeriod,
         @ConfigProperty(defaultValue = "256") @Min(0) @NetworkProperty int blockItemBatchSize,
         @ConfigProperty(defaultValue = "5m") @Min(0) @NetworkProperty Duration blockBufferTtl,
-        @ConfigProperty(defaultValue = "1s") @Min(0) @NetworkProperty Duration blockBufferPruneInterval) {
+        @ConfigProperty(defaultValue = "1s") @Min(0) @NetworkProperty Duration blockBufferPruneInterval,
+        @ConfigProperty(defaultValue = "10ms") @Min(1) @NodeProperty Duration workerLoopSleepDuration) {
 
     /**
      * Whether to stream to block nodes.