Skip to content

Commit 7a08ec0

Browse files
committed
feat(net):optimize sync service
1 parent 5cb0028 commit 7a08ec0

2 files changed

Lines changed: 3 additions & 4 deletions

File tree

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -659,7 +659,7 @@ public static void setParam(final String[] args, final String confFileName) {
659659
PARAMETER.dnsPublishConfig = loadDnsPublishConfig(config);
660660

661661
PARAMETER.syncFetchBatchNum = config.hasPath(Constant.NODE_SYNC_FETCH_BATCH_NUM) ? config
662-
.getInt(Constant.NODE_SYNC_FETCH_BATCH_NUM) : 1000;
662+
.getInt(Constant.NODE_SYNC_FETCH_BATCH_NUM) : 2000;
663663
if (PARAMETER.syncFetchBatchNum > 2000) {
664664
PARAMETER.syncFetchBatchNum = 2000;
665665
}

framework/src/main/java/org/tron/core/net/service/sync/SyncService.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -251,12 +251,11 @@ private synchronized void handleSyncBlock() {
251251
}
252252

253253
final boolean[] isProcessed = {true};
254-
final long[] solidNum = {0};
254+
long solidNum = tronNetDelegate.getSolidBlockId().getNum();;
255255

256256
while (isProcessed[0]) {
257257

258258
isProcessed[0] = false;
259-
solidNum[0] = tronNetDelegate.getSolidBlockId().getNum();
260259

261260
blockWaitToProcess.forEach((msg, peerConnection) -> {
262261
synchronized (tronNetDelegate.getBlockLock()) {
@@ -265,7 +264,7 @@ private synchronized void handleSyncBlock() {
265264
invalid(msg.getBlockId(), peerConnection);
266265
return;
267266
}
268-
if (msg.getBlockId().getNum() <= solidNum[0]) {
267+
if (msg.getBlockId().getNum() <= solidNum) {
269268
blockWaitToProcess.remove(msg);
270269
return;
271270
}

0 commit comments

Comments
 (0)