crowetic/qortal
1
0
Fork 0
forked from Qortal/qortal
Code Pull Requests Activity

Set fileListCache to null when invalidating.

Browse Source
This commit is contained in:
CalDescent 2022-03-11 11:01:29 +00:00
parent 6aad6a1618
commit 7c47e22000
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/org/qortal/repository/BlockArchiveReader.java
View File

@ -23,7 +23,7 @@ import java.util.*;
public class BlockArchiveReader { public class BlockArchiveReader {
private static BlockArchiveReader instance; private static BlockArchiveReader instance;
private Map<String, Triple<Integer, Integer, Integer>> fileListCache = Collections.synchronizedMap(new HashMap<>()); private Map<String, Triple<Integer, Integer, Integer>> fileListCache;
private static final Logger LOGGER = LogManager.getLogger(BlockArchiveReader.class); private static final Logger LOGGER = LogManager.getLogger(BlockArchiveReader.class);
@ -67,7 +67,7 @@ public class BlockArchiveReader {
} }
public Triple<BlockData, List<TransactionData>, List<ATStateData>> fetchBlockAtHeight(int height) { public Triple<BlockData, List<TransactionData>, List<ATStateData>> fetchBlockAtHeight(int height) {
if (this.fileListCache.isEmpty()) { if (this.fileListCache == null || this.fileListCache.isEmpty()) {
this.fetchFileList(); this.fetchFileList();
} }
@ -94,7 +94,7 @@ public class BlockArchiveReader {
public Triple<BlockData, List<TransactionData>, List<ATStateData>> fetchBlockWithSignature( public Triple<BlockData, List<TransactionData>, List<ATStateData>> fetchBlockWithSignature(
byte[] signature, Repository repository) { byte[] signature, Repository repository) {
if (this.fileListCache.isEmpty()) { if (this.fileListCache == null || this.fileListCache.isEmpty()) {
this.fetchFileList(); this.fetchFileList();
} }
@ -167,7 +167,7 @@ public class BlockArchiveReader {
public byte[] fetchSerializedBlockBytesForSignature(byte[] signature, boolean includeHeightPrefix, Repository repository) { public byte[] fetchSerializedBlockBytesForSignature(byte[] signature, boolean includeHeightPrefix, Repository repository) {
if (this.fileListCache.isEmpty()) { if (this.fileListCache == null || this.fileListCache.isEmpty()) {
this.fetchFileList(); this.fetchFileList();
} }
@ -278,7 +278,7 @@ public class BlockArchiveReader {
} }
public void invalidateFileListCache() { public void invalidateFileListCache() {
this.fileListCache.clear(); this.fileListCache = null;
} }
} }