mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-02-23 06:55:08 +01:00
Code Issues Projects Releases Packages Wiki Activity

Change log levels

Browse source
This commit is contained in:
Manfred Karrer 2019-04-15 21:55:43 -05:00
parent 7871aae3d8
commit 2fedc51a87
No known key found for this signature in database
GPG key ID: 401250966A6B2C46
1 changed files with 4 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
core/src/main/java/bisq/core/dao/node/lite/network/LiteNodeNetworkService.java
View file

@ -39,8 +39,6 @@ import bisq.common.util.Tuple2;
import javax.inject.Inject;
import com.google.common.base.Joiner;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
@ -228,19 +226,18 @@ public class LiteNodeNetworkService implements MessageListener, ConnectionListen
@Override
public void onMessage(NetworkEnvelope networkEnvelope, Connection connection) {
if (networkEnvelope instanceof NewBlockBroadcastMessage) {
log.info("We received blocks from peer {}", connection.getPeersNodeAddressOptional());
NewBlockBroadcastMessage newBlockBroadcastMessage = (NewBlockBroadcastMessage) networkEnvelope;
// We combine blockHash and txId list in case we receive blocks with different transactions.
List<String> txIds = newBlockBroadcastMessage.getBlock().getRawTxs().stream().map(BaseTx::getId).collect(Collectors.toList());
String extBlockId = newBlockBroadcastMessage.getBlock().getHash() + "_" + Joiner.on(", ").join(txIds);
String extBlockId = newBlockBroadcastMessage.getBlock().getHash() + ":" + txIds;
if (!receivedBlocks.contains(extBlockId)) {
log.error("We received a new message and broadcast it to our peers. extBlockId={}", extBlockId);
log.info("We received a new message from peer {} and broadcast it to our peers. extBlockId={}",
connection.getPeersNodeAddressOptional(), extBlockId);
receivedBlocks.add(extBlockId);
broadcaster.broadcast(newBlockBroadcastMessage, networkNode.getNodeAddress(), null, false);
listeners.forEach(listener -> listener.onNewBlockReceived(newBlockBroadcastMessage));
} else {
log.error("We had that message already and do not further broadcast it. extBlockId={}", extBlockId);
log.debug("We had that message already and do not further broadcast it. extBlockId={}", extBlockId);
}
}
}