AlphaX/qortal
1
0
Fork 0
forked from Qortal/qortal
Code Issues Pull Requests Projects Releases Wiki Activity

Fix missing network-related repository.saveChanges()

Browse Source
This commit is contained in:
catbref 2019-06-03 16:25:41 +01:00
parent 7993c3e594
commit 9ac52f6a86
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/qora/network/Network.java
View File

@ -269,6 +269,8 @@ public class Network extends Thread {
LOGGER.debug(String.format("Deleting old peer %s from repository", peerData.getAddress().toString())); LOGGER.debug(String.format("Deleting old peer %s from repository", peerData.getAddress().toString()));
repository.getNetworkRepository().delete(peerData); repository.getNetworkRepository().delete(peerData);
} }
repository.saveChanges();
} }
} }
@ -351,6 +353,7 @@ public class Network extends Thread {
if (!peer.isOutbound()) if (!peer.isOutbound())
try (final Repository repository = RepositoryManager.getRepository()) { try (final Repository repository = RepositoryManager.getRepository()) {
repository.getNetworkRepository().delete(peer.getPeerData()); repository.getNetworkRepository().delete(peer.getPeerData());
repository.saveChanges();
} catch (DataException e) { } catch (DataException e) {
LOGGER.warn(String.format("Repository issue while trying to delete inbound peer %s", peer)); LOGGER.warn(String.format("Repository issue while trying to delete inbound peer %s", peer));
} }