From 5032213e89a2f6f89ee27fd288007ffed14ea2a1 Mon Sep 17 00:00:00 2001 From: wubin01 Date: Tue, 8 Jan 2019 16:08:40 +0800 Subject: [PATCH] remove trx trace info --- .../java/org/tron/core/net/node/NodeImpl.java | 32 +++++++++++-------- 1 file changed, 18 insertions(+), 14 deletions(-) diff --git a/src/main/java/org/tron/core/net/node/NodeImpl.java b/src/main/java/org/tron/core/net/node/NodeImpl.java index b395d7b5591..a8fb40872bf 100644 --- a/src/main/java/org/tron/core/net/node/NodeImpl.java +++ b/src/main/java/org/tron/core/net/node/NodeImpl.java @@ -328,20 +328,24 @@ public void setPool(SyncPool pool) { } public void broadcast(Message msg) { - InventoryType type; - if (msg instanceof BlockMessage) { - logger.info("Ready to broadcast block {}", ((BlockMessage) msg).getBlockId()); - freshBlockId.offer(((BlockMessage) msg).getBlockId()); - BlockCache.put(msg.getMessageId(), (BlockMessage) msg); - type = InventoryType.BLOCK; - } else if (msg instanceof TransactionMessage) { - TrxCache.put(msg.getMessageId(), (TransactionMessage) msg); - type = InventoryType.TRX; - } else { - return; - } - synchronized (advObjToSpread) { - advObjToSpread.put(msg.getMessageId(), type); + try { + InventoryType type; + if (msg instanceof BlockMessage) { + logger.info("Ready to broadcast block {}", ((BlockMessage) msg).getBlockId()); + freshBlockId.offer(((BlockMessage) msg).getBlockId()); + BlockCache.put(msg.getMessageId(), (BlockMessage) msg); + type = InventoryType.BLOCK; + } else if (msg instanceof TransactionMessage) { + TrxCache.put(msg.getMessageId(), new TransactionMessage(msg.getData())); + type = InventoryType.TRX; + } else { + return; + } + synchronized (advObjToSpread) { + advObjToSpread.put(msg.getMessageId(), type); + } + }catch (Exception e) { + logger.error("Broadcast message failed, type: {}, reason: {}", msg.getType(), e.getMessage()); } }