Git-Mirrors/haveno
1
0
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2025-04-18 14:55:53 -04:00
Code Issues Packages Projects Releases Wiki Activity

Use custom timeout for bootstrap node

Browse Source
This commit is contained in:
Manfred Karrer 2014-11-28 19:38:08 +01:00
parent 5ff335f15f
commit 1726e1fc87
1 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/io/bitsquare/app/cli/BootstrapNode.java
View File

@ -19,6 +19,8 @@ package io.bitsquare.app.cli;
import io.bitsquare.network.Node;
import net.tomp2p.connection.ChannelClientConfiguration;
import net.tomp2p.connection.ChannelServerConfiguration;
import net.tomp2p.dht.PeerBuilderDHT;
import net.tomp2p.nat.PeerBuilderNAT;
import net.tomp2p.p2p.Peer;
@ -31,6 +33,7 @@ import net.tomp2p.peers.PeerStatistic;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import io.netty.util.concurrent.DefaultEventExecutorGroup;
import org.springframework.core.env.Environment;
public class BootstrapNode {
@ -51,7 +54,21 @@ public class BootstrapNode {
try {
Number160 peerId = Number160.createHash(name);
peer = new PeerBuilder(peerId).ports(port).start();
DefaultEventExecutorGroup eventExecutorGroup = new DefaultEventExecutorGroup(250);
ChannelClientConfiguration clientConf = PeerBuilder.createDefaultChannelClientConfiguration();
clientConf.pipelineFilter(new PeerBuilder.EventExecutorGroupFilter(eventExecutorGroup));
ChannelServerConfiguration serverConf = PeerBuilder.createDefaultChannelServerConfiguration();
serverConf.pipelineFilter(new PeerBuilder.EventExecutorGroupFilter(eventExecutorGroup));
serverConf.connectionTimeoutTCPMillis(5000);
peer = new PeerBuilder(peerId)
.ports(port)
.channelClientConfiguration(clientConf)
.channelServerConfiguration(serverConf)
.start();
/*peer.objectDataReply((sender, request) -> {
log.trace("received request: " + request.toString());
return "pong";
@ -84,9 +101,8 @@ public class BootstrapNode {
for (PeerAddress peerAddress : peer.peerBean().peerMap().all()) {
log.info(peerAddress.toString());
}
log.info("-----------------------------------------------------");
try {
Thread.sleep(10000);
Thread.sleep(60000);
} catch (InterruptedException e) {
return;
}