Skip to content

Commit

Permalink
feat(state-root): add log for write state root
Browse files Browse the repository at this point in the history
  • Loading branch information
halibobo1205 committed Jul 25, 2024
1 parent 750f480 commit 2755f54
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;
import org.tron.common.storage.WriteOptionsWrapper;
import org.tron.common.utils.ByteArray;
import org.tron.common.utils.Pair;
import org.tron.common.utils.Sha256Hash;
import org.tron.core.db.TronDatabase;
Expand Down Expand Up @@ -90,8 +89,7 @@ public void close() {
public void updateByBatch(Map<byte[], byte[]> rows, WriteOptionsWrapper writeOptions) {
Pair<Optional<Long>, Sha256Hash> ret = RootHashService.getRootHash(rows);
super.updateByBatch(rows, writeOptions);
ret.getKey().ifPresent(height -> stateRootStore.put(ByteArray.fromLong(height),
ret.getValue().getBytes()));
ret.getKey().ifPresent(height -> stateRootStore.put(height, ret.getValue()));
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import org.tron.common.storage.WriteOptionsWrapper;
import org.tron.common.utils.ByteArray;
import org.tron.common.utils.Pair;
import org.tron.common.utils.Sha256Hash;
import org.tron.core.db.TronDatabase;
Expand Down Expand Up @@ -61,7 +60,6 @@ public Spliterator spliterator() {
public void updateByBatch(Map<byte[], byte[]> rows, WriteOptionsWrapper writeOptions) {
Pair<Optional<Long>, Sha256Hash> ret = RootHashService.getRootHash(rows);
super.updateByBatch(rows, writeOptions);
ret.getKey().ifPresent(height -> stateRootStore.put(ByteArray.fromLong(height),
ret.getValue().getBytes()));
ret.getKey().ifPresent(height -> stateRootStore.put(height, ret.getValue()));
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.tron.common.utils.ByteArray;
import org.tron.common.utils.Sha256Hash;
import org.tron.core.db.TronDatabase;
import org.tron.core.db.common.iterator.DBIterator;

Expand All @@ -31,6 +32,11 @@ public void put(byte[] key, byte[] item) {
dbSource.putData(key, item);
}

public void put(long key, Sha256Hash root) {
logger.info("block: {},root: {}", key, root);
this.put(ByteArray.fromLong(key), root.getBytes());
}

@Override
public void delete(byte[] key) {
throw new UnsupportedOperationException();
Expand Down

0 comments on commit 2755f54

Please sign in to comment.