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

Remove storage

Browse source
This commit is contained in:
Manfred Karrer 2014-11-10 16:02:33 +01:00
parent efe6c1bec9
commit 882b7c2842
2 changed files with 1 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/main/java/io/bitsquare/msg/tomp2p/BootstrappedPeerFactory.java
View file

@ -43,7 +43,6 @@ import net.tomp2p.connection.Bindings;
import net.tomp2p.connection.ChannelClientConfiguration;
import net.tomp2p.dht.PeerBuilderDHT;
import net.tomp2p.dht.PeerDHT;
import net.tomp2p.dht.StorageLayer;
import net.tomp2p.futures.BaseFuture;
import net.tomp2p.futures.BaseFutureListener;
import net.tomp2p.futures.FutureBootstrap;
@ -60,7 +59,6 @@ import net.tomp2p.peers.PeerMap;
import net.tomp2p.peers.PeerMapChangeListener;
import net.tomp2p.peers.PeerMapConfiguration;
import net.tomp2p.peers.PeerStatistic;
import net.tomp2p.storage.Storage;
import net.tomp2p.utils.Utils;
import org.jetbrains.annotations.NotNull;
@ -80,7 +78,6 @@ class BootstrappedPeerFactory {
static final String NETWORK_INTERFACE_UNSPECIFIED = "<unspecified>";
private KeyPair keyPair;
private Storage storage;
private final Node bootstrapNode;
private String networkInterface;
private final Persistence persistence;
@ -113,10 +110,6 @@ class BootstrappedPeerFactory {
this.keyPair = keyPair;
}
public void setStorage(@NotNull Storage storage) {
this.storage = storage;
}
///////////////////////////////////////////////////////////////////////////////////////////
// Public methods
@ -138,7 +131,7 @@ class BootstrappedPeerFactory {
peer = new PeerBuilder(keyPair).ports(port).peerMap(pm).bindings(bindings)
.channelClientConfiguration(cc).start();
peerDHT = new PeerBuilderDHT(peer).storageLayer(new StorageLayer(storage)).start();
peerDHT = new PeerBuilderDHT(peer).start();
peer.peerBean().peerMap().addPeerMapChangeListener(new PeerMapChangeListener() {
@Override

6
src/main/java/io/bitsquare/msg/tomp2p/TomP2PNode.java
View file

@ -54,7 +54,6 @@ import net.tomp2p.futures.FuturePeerConnection;
import net.tomp2p.peers.Number160;
import net.tomp2p.peers.PeerAddress;
import net.tomp2p.storage.Data;
import net.tomp2p.storage.Storage;
import net.tomp2p.utils.Utils;
import org.jetbrains.annotations.NotNull;
@ -79,7 +78,6 @@ public class TomP2PNode {
private PeerAddress storedPeerAddress;
private PeerDHT peerDHT;
private Storage storage;
private BootstrappedPeerFactory bootstrappedPeerFactory;
@ -118,7 +116,6 @@ public class TomP2PNode {
}
public void start(BootstrapListener bootstrapListener) {
bootstrappedPeerFactory.setStorage(storage);
setupTimerForIPCheck();
ListenableFuture<PeerDHT> bootstrapComplete = bootstrap(port);
@ -144,9 +141,6 @@ public class TomP2PNode {
public void shutDown() {
if (peerDHT != null && peerDHT.peer() != null)
peerDHT.peer().shutdown();
if (storage != null)
storage.close();
}