Toggle navigation
Home
java.lang.String to net.kuujo.copycat.raft.RaftMember
No. of Instances - 7
No. of Commits - 1
No. of Projects - {'atomix'}
Hierarchy/Composition: Composition
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Add or Remove Method invocation
VoteRequest.builder().withUri(member).withTerm(context.getTerm()).withCandidate(context.getLocalMember()).withLogIndex(lastIndex).withLogTerm(lastTerm)
to
VoteRequest.builder().withUri(member.uri()).withTerm(context.getTerm()).withCandidate(context.getLocalMember().uri()).withLogIndex(lastIndex).withLogTerm(lastTerm)
LOGGER.warn(context.getLocalMember(),error)
to
LOGGER.warn(context.getLocalMember().uri(),error)
LOGGER.debug("{} - Received greater term from {}",context.getLocalMember(),member)
to
LOGGER.debug("{} - Received greater term from {}",context.getLocalMember().uri(),member)
LOGGER.info("{} - Received rejected vote from {}",context.getLocalMember(),member)
to
LOGGER.info("{} - Received rejected vote from {}",context.getLocalMember().uri(),member)
LOGGER.info("{} - Received successful vote for a different term from {}",context.getLocalMember(),member)
to
LOGGER.info("{} - Received successful vote for a different term from {}",context.getLocalMember().uri(),member)
LOGGER.info("{} - Received successful vote from {}",context.getLocalMember(),member)
to
LOGGER.info("{} - Received successful vote from {}",context.getLocalMember().uri(),member)
member.equals(context.getLocalMember())
to
replicas.contains(member.uri())
PollRequest.builder().withUri(member).withTerm(context.getTerm()).withCandidate(context.getLocalMember()).withLogIndex(lastIndex).withLogTerm(lastTerm)
to
PollRequest.builder().withUri(member.uri()).withTerm(context.getTerm()).withCandidate(context.getLocalMember().uri()).withLogIndex(lastIndex).withLogTerm(lastTerm)
LOGGER.warn(context.getLocalMember(),error)
to
LOGGER.warn(context.getLocalMember().uri(),error)
LOGGER.info("{} - Received rejected poll from {}",context.getLocalMember(),member)
to
LOGGER.info("{} - Received rejected poll from {}",context.getLocalMember().uri(),member)
LOGGER.info("{} - Received accepted poll for a different term from {}",context.getLocalMember(),member)
to
LOGGER.info("{} - Received accepted poll for a different term from {}",context.getLocalMember().uri(),member)
LOGGER.info("{} - Received accepted poll from {}",context.getLocalMember(),member)
to
LOGGER.info("{} - Received accepted poll from {}",context.getLocalMember().uri(),member)
activeMembers
to
localMember.type()
AppendRequest.builder().withUri(member).withTerm(context.getTerm()).withLeader(context.getLocalMember()).withLogIndex(prevIndex).withLogTerm(prevEntry != null ? prevEntry.getLong() : null).withEntries(entries).withFirstIndex(prevIndex == null || context.log().firstIndex() == prevIndex + 1).withCommitIndex(context.getCommitIndex())
to
AppendRequest.builder().withUri(member.uri()).withTerm(context.getTerm()).withLeader(context.getLocalMember().uri()).withLogIndex(prevIndex).withLogTerm(prevEntry != null ? prevEntry.getLong() : null).withEntries(entries).withFirstIndex(prevIndex == null || context.log().firstIndex() == prevIndex + 1).withCommitIndex(context.getCommitIndex())
LOGGER.debug("{} - Received {} from {}",context.getLocalMember(),response,member)
to
LOGGER.debug("{} - Received {} from {}",context.getLocalMember().uri(),response,member)
LOGGER.debug("{} - Received higher term from {}",context.getLocalMember(),member)
to
LOGGER.debug("{} - Received higher term from {}",context.getLocalMember().uri(),member)
LOGGER.warn("{} - {}",context.getLocalMember(),response.error() != null ? response.error().getMessage() : "")
to
LOGGER.warn("{} - {}",context.getLocalMember().uri(),response.error() != null ? response.error().getMessage() : "")
LOGGER.warn("{} - {}",context.getLocalMember(),error.getMessage())
to
LOGGER.warn("{} - {}",context.getLocalMember().uri(),error.getMessage())