From 358e7d6a8b3fe9b6e256919733f19a3e1cde6335 Mon Sep 17 00:00:00 2001 From: shaozhuguang Date: Sun, 28 Jun 2020 18:40:17 +0800 Subject: [PATCH] modify most peer connection --- .../jd/blockchain/gateway/service/PeerConnectionManager.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/source/gateway/src/main/java/com/jd/blockchain/gateway/service/PeerConnectionManager.java b/source/gateway/src/main/java/com/jd/blockchain/gateway/service/PeerConnectionManager.java index e0df616c..3bbcc616 100644 --- a/source/gateway/src/main/java/com/jd/blockchain/gateway/service/PeerConnectionManager.java +++ b/source/gateway/src/main/java/com/jd/blockchain/gateway/service/PeerConnectionManager.java @@ -111,6 +111,7 @@ public class PeerConnectionManager implements PeerService, PeerConnector { ledgerHashLock.lock(); try { if (isConnected()) { + LOGGER.info("------ Start to load ledgers ------"); // 已连接成功,判断账本信息 PeerServiceFactory serviceFactory = mostLedgerPeerServiceFactory; if (serviceFactory == null) { @@ -136,8 +137,11 @@ public class PeerConnectionManager implements PeerService, PeerConnector { gateWayKeyPair, peerAddress, peerProviders); peerBlockchainServiceFactories.put(peerAddress, peerServiceFactory); localLedgerCache.addAll(Arrays.asList(peerLedgerHashs)); + mostLedgerPeerServiceFactory = new PeerServiceFactory(peerAddress, peerServiceFactory); + LOGGER.info("Most ledgers remote update to {}", mostLedgerPeerServiceFactory.peerAddress); } } + LOGGER.info("------ Load ledgers complete ------"); } } finally { ledgerHashLock.unlock();