Skip to content

Commit 0cc23db

Browse files
committed
refactor(net): reduce shutdown drop-message log level to info; remove early close() in testProcessMessage test
1 parent 2e3164c commit 0cc23db

2 files changed

Lines changed: 2 additions & 3 deletions

File tree

framework/src/main/java/org/tron/core/net/messagehandler/TransactionsMsgHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ public boolean isBusy() {
7777
@Override
7878
public void processMessage(PeerConnection peer, TronMessage msg) throws P2pException {
7979
if (isClosed) {
80-
logger.warn("TransactionsMsgHandler is closed, drop message");
80+
logger.info("TransactionsMsgHandler is closed, drop message");
8181
return;
8282
}
8383
TransactionsMessage transactionsMessage = (TransactionsMessage) msg;
@@ -91,7 +91,7 @@ public void processMessage(PeerConnection peer, TronMessage msg) throws P2pExcep
9191
int dropSmartContractCount = 0;
9292
for (Transaction trx : transactionsMessage.getTransactions().getTransactionsList()) {
9393
if (isClosed) {
94-
logger.warn("TransactionsMsgHandler is closed during processing, stop submit");
94+
logger.info("TransactionsMsgHandler is closed during processing, stop submit");
9595
break;
9696
}
9797
int type = trx.getRawData().getContract(0).getType().getNumber();

framework/src/test/java/org/tron/core/net/messagehandler/TransactionsMsgHandlerTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,6 @@ public void testProcessMessage() {
8686
transactionsMsgHandler.processMessage(peer, new TransactionsMessage(transactionList));
8787
Assert.assertNull(advInvRequest.get(item));
8888
//Thread.sleep(10);
89-
transactionsMsgHandler.close();
9089
BlockingQueue<TrxEvent> smartContractQueue =
9190
new LinkedBlockingQueue(2);
9291
smartContractQueue.offer(new TrxEvent(null, null));

0 commit comments

Comments
 (0)