import org.opendaylight.controller.cluster.raft.policy.RaftPolicy;
import org.slf4j.Logger;
+/**
+ * Implementation of the RaftActorContext interface.
+ *
+ * @author Moiz Raja
+ * @author Thomas Pantelis
+ */
public class RaftActorContextImpl implements RaftActorContext {
private static final LongSupplier JVM_MEMORY_RETRIEVER = () -> Runtime.getRuntime().maxMemory();
private final Map<String, PeerInfo> peerInfoMap = new HashMap<>();
- private final Logger LOG;
+ private final Logger log;
private ConfigParams configParams;
this.lastApplied = lastApplied;
this.configParams = configParams;
this.persistenceProvider = persistenceProvider;
- this.LOG = logger;
+ this.log = logger;
for(Map.Entry<String, String> e: peerAddresses.entrySet()) {
peerInfoMap.put(e.getKey(), new PeerInfo(e.getKey(), e.getValue(), VotingState.VOTING));
cluster = Optional.of(Cluster.get(getActorSystem()));
} catch(Exception e) {
// An exception means there's no cluster configured. This will only happen in unit tests.
- LOG.debug("{}: Could not obtain Cluster: {}", getId(), e);
+ log.debug("{}: Could not obtain Cluster: {}", getId(), e);
cluster = Optional.empty();
}
}
}
@Override public Logger getLogger() {
- return this.LOG;
+ return this.log;
}
@Override
@Override
public String getPeerAddress(String peerId) {
- String peerAddress = null;
+ String peerAddress;
PeerInfo peerInfo = peerInfoMap.get(peerId);
if(peerInfo != null) {
peerAddress = peerInfo.getAddress();
votingMember = false;
}
- LOG.debug("{}: Updated server config: isVoting: {}, peers: {}", id, votingMember, peerInfoMap.values());
+ log.debug("{}: Updated server config: isVoting: {}, peers: {}", id, votingMember, peerInfoMap.values());
setDynamicServerConfigurationInUse();
}
}
@Override
- public void addToPeers(String id, String address, VotingState votingState) {
- peerInfoMap.put(id, new PeerInfo(id, address, votingState));
+ public void addToPeers(String peerId, String address, VotingState votingState) {
+ peerInfoMap.put(peerId, new PeerInfo(peerId, address, votingState));
numVotingPeers = -1;
}
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);
+ 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);
+ snapshotManager = new SnapshotManager(this, log);
}
return snapshotManager;
}
@Override
public boolean hasFollowers() {
- return getPeerIds().size() > 0;
+ return !getPeerIds().isEmpty();
}
@Override
newConfig.add(new ServerInfo(getId(), votingMember));
}
- return (new ServerConfigurationPayload(newConfig));
+ return new ServerConfigurationPayload(newConfig);
}
@Override
try {
currentBehavior.close();
} catch (Exception e) {
- LOG.debug("{}: Error closing behavior {}", getId(), currentBehavior.state());
+ log.debug("{}: Error closing behavior {}", getId(), currentBehavior.state(), e);
}
}
}