Toggle navigation
Home
net.kuujo.copycat.resource.internal.CopycatStateContext to int
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'atomix'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Rename Variable
context
to
id
context
to
id
Add or Remove Method invocation
Math.max(matchIndex,prevIndex != null ? Long.valueOf(prevIndex + entries.size()) : Long.valueOf(context.log().firstIndex() + entries.size() - 1))
to
id
triggerCommitFutures(prevIndex != null ? Long.valueOf(prevIndex + 1) : context.log().firstIndex(),prevIndex != null ? Long.valueOf(prevIndex + entries.size()) : Long.valueOf(context.log().firstIndex() + entries.size() - 1),error)
to
commit()
context.log().firstIndex()
to
LOGGER.debug("{} - Received higher term from {}",context.getLocalMember(),member)
Long.valueOf(prevIndex + entries.size())
to
response.error().getMessage()
entries.size()
to
response.error().getMessage()
doCommit()
to
commitEntries()
triggerCommitFutures(prevIndex != null ? Long.valueOf(prevIndex + 1) : context.log().firstIndex(),matchIndex)
to
commit()
triggerCommitFutures(prevIndex != null ? Long.valueOf(prevIndex + 1) : context.log().firstIndex(),prevIndex != null ? Long.valueOf(prevIndex + entries.size()) : Long.valueOf(context.log().firstIndex() + entries.size() - 1),new CopycatException("Not the leader"))
to
LOGGER.debug("{} - Received higher term from {}",context.getLocalMember(),member)
Long.valueOf(response.logIndex() + 1)
to
response.error().getMessage()
triggerCommitFutures(prevIndex != null ? Long.valueOf(prevIndex + 1) : context.log().firstIndex(),prevIndex != null ? Long.valueOf(prevIndex + entries.size()) : Long.valueOf(context.log().firstIndex() + entries.size() - 1),response.error())
to
LOGGER.warn("{} - {}",context.getLocalMember(),response.error() != null ? response.error().getMessage() : "")
whenCompleteAsync
to
whenCompleteAsync