mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2024-11-19 09:52:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add logs

Browse Source
This commit is contained in:
chimp1984 2020-08-25 23:30:52 -05:00
parent c6c56b35f9
commit d59a3adbc3
No known key found for this signature in database
GPG Key ID: 9801B4EC591F90E3
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
p2p/src/main/java/bisq/network/p2p/peers/Broadcaster.java
View File

@ -81,6 +81,8 @@ public class Broadcaster implements BroadcastHandler.ResultHandler {
@Nullable NodeAddress sender, @Nullable NodeAddress sender,
@Nullable BroadcastHandler.Listener listener) { @Nullable BroadcastHandler.Listener listener) {
broadcastRequests.add(new BroadcastRequest(message, sender, listener)); broadcastRequests.add(new BroadcastRequest(message, sender, listener));
log.info("Broadcast requested for {}. We queue it up for next bundled broadcast.",
message.getClass().getSimpleName());
if (timer == null) { if (timer == null) {
timer = UserThread.runAfter(this::maybeBroadcastBundle, BROADCAST_INTERVAL_MS, TimeUnit.MILLISECONDS); timer = UserThread.runAfter(this::maybeBroadcastBundle, BROADCAST_INTERVAL_MS, TimeUnit.MILLISECONDS);
@ -89,9 +91,10 @@ public class Broadcaster implements BroadcastHandler.ResultHandler {
private void maybeBroadcastBundle() { private void maybeBroadcastBundle() {
if (!broadcastRequests.isEmpty()) { if (!broadcastRequests.isEmpty()) {
log.info("Broadcast bundled requests of {} messages", broadcastRequests.size());
BroadcastHandler broadcastHandler = new BroadcastHandler(networkNode, peerManager, this); BroadcastHandler broadcastHandler = new BroadcastHandler(networkNode, peerManager, this);
broadcastHandler.broadcast(new ArrayList<>(broadcastRequests));
broadcastHandlers.add(broadcastHandler); broadcastHandlers.add(broadcastHandler);
broadcastHandler.broadcast(new ArrayList<>(broadcastRequests));
broadcastRequests.clear(); broadcastRequests.clear();
timer = null; timer = null;