haveno-network/haveno-core
haveno-network/haveno-core
1
0
Fork 1
Code Issues 4 Pull requests Projects 5 Releases 1 Packages Wiki Activity Actions

process connection messages on main run thread

Browse source
This commit is contained in:
woodser 2025-06-01 17:36:57 -04:00 committed by woodser
parent 3648c1eb0e
commit fa375b3cbd
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
p2p/src/main/java/haveno/network/p2p/network/Connection.java
View file

@ -872,7 +872,7 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
log.info("We got a {} from a peer with yet unknown address on connection with uid={}", networkEnvelope.getClass().getSimpleName(), uid);
}
ThreadUtils.execute(() -> onMessage(networkEnvelope, this), THREAD_ID);
onMessage(networkEnvelope, this);
ThreadUtils.execute(() -> connectionStatistics.addReceivedMsgMetrics(System.currentTimeMillis() - ts, size), THREAD_ID);
}
} catch (InvalidClassException e) {