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();