- @Override public void setPeerAddress(String peerId, String peerAddress) {
- LOG.info("Peer address for peer {} set to {}", peerId, peerAddress);
- checkState(peerAddresses.containsKey(peerId), peerId + " is unknown");
+ @Override
+ public void setPeerAddress(String peerId, String peerAddress) {
+ PeerInfo peerInfo = peerInfoMap.get(peerId);
+ if(peerInfo != null) {
+ LOG.info("Peer address for peer {} set to {}", peerId, peerAddress);
+ peerInfo.setAddress(peerAddress);
+ }
+ }
+
+ @Override
+ public SnapshotManager getSnapshotManager() {
+ if(snapshotManager == null){
+ snapshotManager = new SnapshotManager(this, LOG);
+ }
+ return snapshotManager;
+ }
+
+ @Override
+ public long getTotalMemory() {
+ return totalMemoryRetriever != null ? totalMemoryRetriever.get() : Runtime.getRuntime().totalMemory();
+ }
+
+ @Override
+ public void setTotalMemoryRetriever(Supplier<Long> retriever) {
+ totalMemoryRetriever = retriever;
+ }
+
+ @Override
+ public boolean hasFollowers() {
+ return getPeerIds().size() > 0;
+ }
+
+ @Override
+ public DataPersistenceProvider getPersistenceProvider() {
+ return persistenceProvider;
+ }