mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-02-25 07:27:18 +01:00
Code Issues Projects Releases Packages Wiki Activity

Add logs at peer insert and remove

Browse source
This commit is contained in:
Manfred Karrer 2014-11-14 02:08:12 +01:00
parent 9a010a1a4d
commit 61012bf6f9
1 changed files with 30 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
src/main/java/io/bitsquare/app/cli/BootstrapNode.java
View file

@ -26,8 +26,9 @@ import net.tomp2p.p2p.Peer;
import net.tomp2p.p2p.PeerBuilder; import net.tomp2p.p2p.PeerBuilder;
import net.tomp2p.peers.Number160; import net.tomp2p.peers.Number160;
import net.tomp2p.peers.PeerAddress; import net.tomp2p.peers.PeerAddress;
import net.tomp2p.peers.PeerMapChangeListener;
import net.tomp2p.peers.PeerStatistic;
import net.tomp2p.replication.IndirectReplication; import net.tomp2p.replication.IndirectReplication;
import net.tomp2p.rpc.ObjectDataReply;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -53,31 +54,41 @@ public class BootstrapNode {
try { try {
Number160 peerId = Number160.createHash(name); Number160 peerId = Number160.createHash(name);
peer = new PeerBuilder(peerId).ports(port).start(); peer = new PeerBuilder(peerId).ports(port).start();
peer.objectDataReply(new ObjectDataReply() { peer.objectDataReply((sender, request) -> {
@Override log.trace("received request: " + request.toString());
public Object reply(PeerAddress sender, Object request) throws Exception { return "pong";
log.trace("received request: ", request.toString());
return "pong";
}
}); });
PeerDHT peerDHT = new PeerBuilderDHT(peer).start(); PeerDHT peerDHT = new PeerBuilderDHT(peer).start();
new PeerBuilderNAT(peer).start(); new PeerBuilderNAT(peer).start();
new IndirectReplication(peerDHT).start(); new IndirectReplication(peerDHT).start();
log.debug("Bootstrap node started with name " + name + " and port " + port); peer.peerBean().peerMap().addPeerMapChangeListener(new PeerMapChangeListener() {
new Thread(new Runnable() {
@Override @Override
public void run() { public void peerInserted(PeerAddress peerAddress, boolean verified) {
while (running) { log.debug("peerInserted: " + peerAddress);
for (PeerAddress pa : peer.peerBean().peerMap().all()) { }
log.debug("peer online:" + pa);
} @Override
try { public void peerRemoved(PeerAddress peerAddress, PeerStatistic storedPeerAddress) {
Thread.sleep(2000); log.debug("peerRemoved: " + peerAddress);
} catch (InterruptedException e) { }
return;
} @Override
public void peerUpdated(PeerAddress peerAddress, PeerStatistic storedPeerAddress) {
}
});
log.debug("Bootstrap node started with name " + name + " and port " + port);
new Thread(() -> {
while (running) {
for (PeerAddress peerAddress : peer.peerBean().peerMap().all()) {
log.debug("Peer online: " + peerAddress);
}
try {
Thread.sleep(60000);
} catch (InterruptedException e) {
return;
} }
} }
}).start(); }).start();