todos

Signed-off-by: Atanas Atanasov <[email protected]>
hashgraph · Jan 29, 2025 · c4600c7 · c4600c7
1 parent c263ccc
commit c4600c7
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/server/src/main/java/com/hedera/block/server/persistence/PersistenceInjectionModule.java b/server/src/main/java/com/hedera/block/server/persistence/PersistenceInjectionModule.java
@@ -26,8 +26,8 @@
 import com.hedera.block.server.persistence.storage.write.BlockAsLocalFileWriter;
 import com.hedera.block.server.persistence.storage.write.BlockWriter;
 import com.hedera.block.server.persistence.storage.write.NoOpBlockWriter;
-import com.hedera.block.server.persistence.storage.write.factory.AsyncBlockWriterFactory;
 import com.hedera.block.server.persistence.storage.write.factory.AsyncBlockAsLocalFileWriterFactory;
+import com.hedera.block.server.persistence.storage.write.factory.AsyncBlockWriterFactory;
 import com.hedera.hapi.block.BlockItemUnparsed;
 import com.hedera.hapi.block.BlockUnparsed;
 import com.hedera.hapi.block.SubscribeStreamResponseUnparsed;

diff --git a/server/src/main/java/com/hedera/block/server/persistence/StreamPersistenceHandlerImpl.java b/server/src/main/java/com/hedera/block/server/persistence/StreamPersistenceHandlerImpl.java
@@ -213,6 +213,7 @@ private void handleBlockItems(final List<BlockItemUnparsed> blockItems)
                 final BlockPersistenceResult blockPersistenceResult = completionResult.get();
                 if (blockPersistenceResult.status().equals(BlockPersistenceStatus.SUCCESS)) {
                     final long blockNumber = blockPersistenceResult.blockNumber();
+                    // @todo(545) migrate the ackHandler to work with persistence results
                     ackHandler.blockPersisted(blockNumber);
                     metricsService.get(BlocksPersisted).increment();
                     LOGGER.log(INFO, "Block [%s] persisted successfully.".formatted(blockNumber));

diff --git a/...ra/block/server/persistence/storage/write/factory/AsyncBlockAsLocalFileWriterFactory.java b/...ra/block/server/persistence/storage/write/factory/AsyncBlockAsLocalFileWriterFactory.java
@@ -3,8 +3,8 @@
 
 import com.hedera.block.server.persistence.storage.compression.Compression;
 import com.hedera.block.server.persistence.storage.path.BlockPathResolver;
-import com.hedera.block.server.persistence.storage.write.AsyncBlockWriter;
 import com.hedera.block.server.persistence.storage.write.AsyncBlockAsLocalFileWriter;
+import com.hedera.block.server.persistence.storage.write.AsyncBlockWriter;
 import edu.umd.cs.findbugs.annotations.NonNull;
 import jakarta.inject.Inject;
 import java.util.Objects;