From 70ada1dda72832258b67e871c0ccf230b13c0b1f Mon Sep 17 00:00:00 2001 From: shaozhuguang Date: Mon, 29 Jun 2020 10:21:52 +0800 Subject: [PATCH] add logs --- .../service/PeerConnectionManager.java | 24 +++++++++++-------- 1 file changed, 14 insertions(+), 10 deletions(-) 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 528fab9f..034fdcc8 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 @@ -133,16 +133,20 @@ public class PeerConnectionManager implements PeerService, PeerConnector { if (haveNewLedger) { LOGGER.info("New ledger have been found, I will reconnect {} now !!!", peerAddress); // 有新账本的情况下重连,并更新本地账本 - PeerBlockchainServiceFactory peerServiceFactory = PeerBlockchainServiceFactory.connect( - gateWayKeyPair, peerAddress, peerProviders); - if (peerServiceFactory != null) { - peerBlockchainServiceFactories.put(peerAddress, peerServiceFactory); - localLedgerCache.addAll(Arrays.asList(peerLedgerHashs)); - mostLedgerPeerServiceFactory = new PeerServiceFactory(peerAddress, peerServiceFactory); - LOGGER.info("Most ledgers remote update to {}", mostLedgerPeerServiceFactory.peerAddress); - } else { - LOGGER.error("Peer connect fail {}", peerAddress); - } + try { + PeerBlockchainServiceFactory peerServiceFactory = PeerBlockchainServiceFactory.connect( + gateWayKeyPair, peerAddress, peerProviders); + if (peerServiceFactory != null) { + peerBlockchainServiceFactories.put(peerAddress, peerServiceFactory); + localLedgerCache.addAll(Arrays.asList(peerLedgerHashs)); + mostLedgerPeerServiceFactory = new PeerServiceFactory(peerAddress, peerServiceFactory); + LOGGER.info("Most ledgers remote update to {}", mostLedgerPeerServiceFactory.peerAddress); + } else { + LOGGER.error("Peer connect fail {}", peerAddress); + } + } catch (Exception e) { + LOGGER.error("Peer connect fail {}", peerAddress); + } } } LOGGER.info("------ Load ledgers complete ------");