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

Use PersistenceManager

Browse Source
This commit is contained in:
chimp1984 2020-10-01 20:03:41 -05:00
parent 482bc56036
commit fe4c21b35c
No known key found for this signature in database
GPG Key ID: 9801B4EC591F90E3
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
monitor/src/main/java/bisq/monitor/metric/P2PNetworkLoad.java
View File

@ -35,15 +35,14 @@ import bisq.network.p2p.network.TorNetworkNode;
import bisq.network.p2p.peers.PeerManager; import bisq.network.p2p.peers.PeerManager;
import bisq.network.p2p.peers.keepalive.KeepAliveManager; import bisq.network.p2p.peers.keepalive.KeepAliveManager;
import bisq.network.p2p.peers.peerexchange.PeerExchangeManager; import bisq.network.p2p.peers.peerexchange.PeerExchangeManager;
import bisq.network.p2p.peers.peerexchange.PeerList;
import bisq.network.p2p.storage.messages.BroadcastMessage; import bisq.network.p2p.storage.messages.BroadcastMessage;
import bisq.common.ClockWatcher; import bisq.common.ClockWatcher;
import bisq.common.config.Config; import bisq.common.config.Config;
import bisq.common.file.CorruptedStorageFileHandler; import bisq.common.file.CorruptedStorageFileHandler;
import bisq.common.persistence.PersistenceManager;
import bisq.common.proto.network.NetworkEnvelope; import bisq.common.proto.network.NetworkEnvelope;
import bisq.common.proto.network.NetworkProtoResolver; import bisq.common.proto.network.NetworkProtoResolver;
import bisq.common.storage.Storage;
import java.time.Clock; import java.time.Clock;
@ -134,7 +133,7 @@ public class P2PNetworkLoad extends Metric implements MessageListener, SetupList
networkProtoResolver, storageDir, corruptedStorageFileHandler); networkProtoResolver, storageDir, corruptedStorageFileHandler);
DefaultSeedNodeRepository seedNodeRepository = new DefaultSeedNodeRepository(config); DefaultSeedNodeRepository seedNodeRepository = new DefaultSeedNodeRepository(config);
PeerManager peerManager = new PeerManager(networkNode, seedNodeRepository, new ClockWatcher(), PeerManager peerManager = new PeerManager(networkNode, seedNodeRepository, new ClockWatcher(),
maxConnections, new Storage<PeerList>(storageDir, persistenceProtoResolver, corruptedStorageFileHandler)); maxConnections, new PersistenceManager<>(storageDir, persistenceProtoResolver, corruptedStorageFileHandler));
// init file storage // init file storage
peerManager.readPersisted(); peerManager.readPersisted();