Skip to content

Commit a70bea8

Browse files
committed
Add logging to MerkleTree operations for better traceability and debugging
1 parent f6468c2 commit a70bea8

File tree

2 files changed

+18
-0
lines changed

2 files changed

+18
-0
lines changed

pom.xml

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,17 @@
1515
</properties>
1616

1717
<dependencies>
18+
<dependency>
19+
<groupId>org.slf4j</groupId>
20+
<artifactId>slf4j-api</artifactId>
21+
<version>2.0.9</version>
22+
</dependency>
23+
<dependency>
24+
<groupId>ch.qos.logback</groupId>
25+
<artifactId>logback-classic</artifactId>
26+
<version>1.4.11</version>
27+
</dependency>
28+
1829
<!-- https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-core -->
1930
<dependency>
2031
<groupId>org.json</groupId>

src/main/java/io/pwrlabs/database/rocksdb/MerkleTree.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package io.pwrlabs.database.rocksdb;
22

3+
import com.sun.tools.javac.Main;
34
import io.pwrlabs.hashing.PWRHash;
45
import io.pwrlabs.util.encoders.BiResult;
56
import io.pwrlabs.util.encoders.ByteArrayWrapper;
@@ -8,6 +9,7 @@
89
import lombok.Getter;
910
import lombok.SneakyThrows;
1011
import org.json.JSONObject;
12+
import org.junit.platform.commons.logging.LoggerFactory;
1113
import org.rocksdb.*;
1214

1315
import java.io.File;
@@ -27,6 +29,8 @@
2729
public class MerkleTree {
2830

2931
//region ===================== Statics =====================
32+
private static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(Main.class);
33+
3034
static {
3135
RocksDB.loadLibrary();
3236
}
@@ -495,6 +499,7 @@ public void close() throws RocksDBException {
495499
}
496500

497501
public MerkleTree clone(String newTreeName) throws RocksDBException, IOException {
502+
logger.info("Cloning MerkleTree: " + treeName + " to new tree: " + newTreeName);
498503
long startTime = System.currentTimeMillis();
499504
errorIfClosed();
500505

@@ -567,8 +572,10 @@ public void update(MerkleTree sourceTree) throws RocksDBException, IOException {
567572
&& Arrays.equals(getRootHashSavedOnDisk(), sourceTree.getRootHashSavedOnDisk())
568573
) {
569574
//This means that this tree is already a copy of the source tree and we only need to replace the cache
575+
logger.info("Updating MerkleTree: " + treeName + " with source tree: " + sourceTree.treeName + " by updating the cache");
570576
copyCache(sourceTree);
571577
} else {
578+
logger.info("Updating MerkleTree: " + treeName + " with source tree: " + sourceTree.treeName + " by cloning the tree");
572579
if (metaDataHandle != null) {
573580
metaDataHandle.close();
574581
metaDataHandle = null;

0 commit comments

Comments
 (0)