Skip to content

Commit 651e019

Browse files
committed
fix(config): address PR review feedback
- DynamicArgs: parse NodeConfig once in reload(), pass to both methods - Storage: remove 12 unused getXxxFromConfig static methods - reference.conf: fix influxdb database default to "metrics"
1 parent 4d8d9b9 commit 651e019

3 files changed

Lines changed: 6 additions & 80 deletions

File tree

common/src/main/java/org/tron/core/config/args/Storage.java

Lines changed: 0 additions & 73 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@
2525
import lombok.Getter;
2626
import lombok.Setter;
2727
import lombok.extern.slf4j.Slf4j;
28-
import org.apache.commons.lang3.StringUtils;
2928
import org.iq80.leveldb.CompressionType;
3029
import org.iq80.leveldb.Options;
3130
import org.tron.common.cache.CacheStrategies;
@@ -124,78 +123,6 @@ public class Storage {
124123
// db root
125124
private final Map<String, Sha256Hash> dbRoots = Maps.newConcurrentMap();
126125

127-
/**
128-
* All getXxxFromConfig methods now read from StorageConfig bean instead of
129-
* manual string constants. Signatures preserved for backward compatibility.
130-
*/
131-
132-
public static String getDbEngineFromConfig(final Config config) {
133-
return StorageConfig.fromConfig(config).getDb().getEngine();
134-
}
135-
136-
public static Boolean getDbVersionSyncFromConfig(final Config config) {
137-
return StorageConfig.fromConfig(config).getDb().isSync();
138-
}
139-
140-
public static int getSnapshotMaxFlushCountFromConfig(final Config config) {
141-
int maxFlushCountConfig = StorageConfig.fromConfig(config)
142-
.getSnapshot().getMaxFlushCount();
143-
if (maxFlushCountConfig <= 0) {
144-
throw new IllegalArgumentException("MaxFlushCount value can not be negative or zero!");
145-
}
146-
if (maxFlushCountConfig > 500) {
147-
throw new IllegalArgumentException("MaxFlushCount value must not exceed 500!");
148-
}
149-
return maxFlushCountConfig;
150-
}
151-
152-
public static Boolean getContractParseSwitchFromConfig(final Config config) {
153-
// contractParse is under event.subscribe, not storage — read from EventConfig
154-
EventConfig ec = EventConfig.fromConfig(config);
155-
return ec.isContractParse();
156-
}
157-
158-
public static String getDbDirectoryFromConfig(final Config config) {
159-
return StorageConfig.fromConfig(config).getDb().getDirectory();
160-
}
161-
162-
public static String getIndexDirectoryFromConfig(final Config config) {
163-
return StorageConfig.fromConfig(config).getIndex().getDirectory();
164-
}
165-
166-
public static String getIndexSwitchFromConfig(final Config config) {
167-
String val = StorageConfig.fromConfig(config).getIndex().getSwitch();
168-
return StringUtils.isNotEmpty(val) ? val : DEFAULT_INDEX_SWITCH;
169-
}
170-
171-
public static String getTransactionHistorySwitchFromConfig(final Config config) {
172-
return StorageConfig.fromConfig(config).getTransHistory().getSwitch();
173-
}
174-
175-
public static int getCheckpointVersionFromConfig(final Config config) {
176-
return StorageConfig.fromConfig(config).getCheckpoint().getVersion();
177-
}
178-
179-
public static boolean getCheckpointSyncFromConfig(final Config config) {
180-
return StorageConfig.fromConfig(config).getCheckpoint().isSync();
181-
}
182-
183-
public static int getEstimatedTransactionsFromConfig(final Config config) {
184-
int estimatedTransactions = StorageConfig.fromConfig(config)
185-
.getTxCache().getEstimatedTransactions();
186-
if (estimatedTransactions > 10000) {
187-
estimatedTransactions = 10000;
188-
} else if (estimatedTransactions < 100) {
189-
estimatedTransactions = 100;
190-
}
191-
return estimatedTransactions;
192-
}
193-
194-
public static boolean getTxCacheInitOptimizationFromConfig(final Config config) {
195-
return StorageConfig.fromConfig(config).getTxCache().isInitOptimization();
196-
}
197-
198-
199126
/**
200127
* Accepts raw storage Config sub-tree because cache.strategies has dynamic keys
201128
* (CacheType enum names) that ConfigBeanFactory cannot bind to fixed bean fields.

common/src/main/resources/reference.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -182,7 +182,7 @@ node.metrics = {
182182
influxdb {
183183
ip = ""
184184
port = 8086
185-
database = ""
185+
database = "metrics"
186186
metricsReportInterval = 10
187187
}
188188
}

framework/src/main/java/org/tron/core/config/args/DynamicArgs.java

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -61,14 +61,14 @@ public void run() {
6161
public void reload() {
6262
logger.debug("Reloading ... ");
6363
Config config = Configuration.getByFileName(Args.getConfigFilePath());
64+
NodeConfig nodeConfig = NodeConfig.fromConfig(config);
6465

65-
updateActiveNodes(config);
66+
updateActiveNodes(nodeConfig);
6667

67-
updateTrustNodes(config);
68+
updateTrustNodes(nodeConfig);
6869
}
6970

70-
private void updateActiveNodes(Config config) {
71-
NodeConfig nodeConfig = NodeConfig.fromConfig(config);
71+
private void updateActiveNodes(NodeConfig nodeConfig) {
7272
List<InetSocketAddress> newActiveNodes =
7373
Args.filterInetSocketAddress(nodeConfig.getActive(), true);
7474
parameter.setActiveNodes(newActiveNodes);
@@ -79,8 +79,7 @@ private void updateActiveNodes(Config config) {
7979
TronNetService.getP2pConfig().getActiveNodes().toString());
8080
}
8181

82-
private void updateTrustNodes(Config config) {
83-
NodeConfig nodeConfig = NodeConfig.fromConfig(config);
82+
private void updateTrustNodes(NodeConfig nodeConfig) {
8483
List<InetAddress> newPassiveNodes = new java.util.ArrayList<>();
8584
for (InetSocketAddress sa : Args.filterInetSocketAddress(nodeConfig.getPassive(), false)) {
8685
newPassiveNodes.add(sa.getAddress());

0 commit comments

Comments
 (0)