style fixes and removal of comment and log

Signed-off-by: Alfredo Gutierrez <[email protected]>
hashgraph · Aug 14, 2024 · bd13246 · bd13246
1 parent 9fd4a32
commit bd13246
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git a/server/src/main/java/com/hedera/block/server/mediator/LiveStreamMediatorImpl.java b/server/src/main/java/com/hedera/block/server/mediator/LiveStreamMediatorImpl.java
@@ -88,7 +88,7 @@ class LiveStreamMediatorImpl
         // Initialize and start the disruptor
         @NonNull
         final Disruptor<ObjectEvent<SubscribeStreamResponse>> disruptor =
-                // TODO: replace ring buffer size with a configurable value
+                // TODO: replace ring buffer size with a configurable value, create a MediatorConfig
                 new Disruptor<>(ObjectEvent::new, 1024, DaemonThreadFactory.INSTANCE);
         this.ringBuffer = disruptor.start();
         this.executor = Executors.newCachedThreadPool(DaemonThreadFactory.INSTANCE);

diff --git a/server/src/main/java/com/hedera/block/server/persistence/storage/write/BlockAsDirWriter.java b/server/src/main/java/com/hedera/block/server/persistence/storage/write/BlockAsDirWriter.java
@@ -73,8 +73,6 @@ class BlockAsDirWriter implements BlockWriter<BlockItem> {
                 blockNodeContext.configuration().getConfigData(PersistenceStorageConfig.class);
         final Path blockNodeRootPath = Path.of(config.rootPath());
 
-        // TODO: Remove comment but, Ask matt why we are logging the config?
-        // LOGGER.log(System.Logger.Level.INFO, config.toString());
         LOGGER.log(System.Logger.Level.INFO, "Block Node Root Path: " + blockNodeRootPath);
 
         this.blockNodeRootPath = blockNodeRootPath;

diff --git a/...c/test/java/com/hedera/block/server/persistence/storage/PersistenceStorageConfigTest.java b/...c/test/java/com/hedera/block/server/persistence/storage/PersistenceStorageConfigTest.java
@@ -47,7 +47,7 @@ void testPersistenceStorageConfig_emptyRootPath() throws IOException {
     }
 
     public static void deleteDirectory(Path path) throws IOException {
-        if(!Files.exists(path)) {
+        if (!Files.exists(path)) {
             return;
         }
         try (Stream<Path> walk = Files.walk(path)) {