Toggle navigation
Home
java.util.concurrent.ScheduledFuture<?> to net.kuujo.copycat.util.concurrent.Scheduled
No. of Instances - 6
No. of Commits - 1
No. of Projects - {'atomix'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Other
0
to
Duration.ZERO
Add or Remove Method invocation
context.getContext().scheduleAtFixedRate(this::heartbeatMembers,Duration.ZERO,context.getHeartbeatInterval().toMillis(),TimeUnit.MILLISECONDS)
to
context.getContext().schedule(this::heartbeatMembers,Duration.ZERO,context.getHeartbeatInterval())
context.getContext().schedule(() -> { LOGGER.debug("{} - Election timed out",context.getMember().id()); if (quorum != null) { quorum.cancel(); quorum=null; } sendVoteRequests(); LOGGER.debug("{} - Restarted election",context.getMember().id()); } ,delay,TimeUnit.MILLISECONDS)
to
context.getContext().schedule(() -> { LOGGER.debug("{} - Election timed out",context.getMember().id()); if (quorum != null) { quorum.cancel(); quorum=null; } sendVoteRequests(); LOGGER.debug("{} - Restarted election",context.getMember().id()); } ,delay)
context.getContext().schedule(() -> { if (isOpen()) { context.getCluster().setActive(true); transition(RaftServer.State.FOLLOWER); } } ,context.getElectionTimeout().toMillis(),TimeUnit.MILLISECONDS)
to
context.getContext().schedule(() -> { if (isOpen()) { context.getCluster().setActive(true); transition(RaftServer.State.FOLLOWER); } } ,context.getElectionTimeout())
context.getContext().schedule(() -> { if (isOpen()) { LOGGER.warn("{} - Failed to leave the cluster in {} milliseconds",context.getMember().id(),context.getElectionTimeout()); transition(RaftServer.State.INACTIVE); } } ,context.getElectionTimeout().toMillis(),TimeUnit.MILLISECONDS)
to
context.getContext().schedule(() -> { if (isOpen()) { LOGGER.warn("{} - Failed to leave the cluster in {} milliseconds",context.getMember().id(),context.getElectionTimeout()); transition(RaftServer.State.INACTIVE); } } ,context.getElectionTimeout())
context.schedule(() -> { if (isOpen()) { keepAlive(new CompletableFuture<>()).thenRun(this::keepAlive); } } ,keepAliveInterval.toMillis(),TimeUnit.MILLISECONDS)
to
context.schedule(() -> { if (isOpen()) { keepAlive(new CompletableFuture<>()).thenRun(this::keepAlive); } } ,keepAliveInterval)
keepAliveFuture.cancel(false)
to
keepAliveFuture.cancel()
context
to
context.executor()
context.getContext().schedule(() -> { heartbeatTimer=null; if (isOpen()) { if (context.getLastVotedFor() == 0) { LOGGER.debug("{} - Heartbeat timed out in {} milliseconds",context.getMember().id(),delay); sendPollRequests(); } else { resetHeartbeatTimeout(); } } } ,delay,TimeUnit.MILLISECONDS)
to
context.getContext().schedule(() -> { heartbeatTimer=null; if (isOpen()) { if (context.getLastVotedFor() == 0) { LOGGER.debug("{} - Heartbeat timed out in {} milliseconds",context.getMember().id(),delay); sendPollRequests(); } else { resetHeartbeatTimeout(); } } } ,delay)
context.getContext().schedule(() -> { LOGGER.debug("{} - Failed to poll a majority of the cluster in {} milliseconds",context.getMember().id(),context.getElectionTimeout()); resetHeartbeatTimeout(); } ,context.getElectionTimeout().toMillis(),TimeUnit.MILLISECONDS)
to
context.getContext().schedule(() -> { LOGGER.debug("{} - Failed to poll a majority of the cluster in {} milliseconds",context.getMember().id(),context.getElectionTimeout()); resetHeartbeatTimeout(); } ,context.getElectionTimeout())
Update argument list (Method invocation)
cancel
to
cancel
cancel
to
cancel
cancel
to
cancel
cancel
to
cancel
cancel
to
cancel
cancel
to
cancel
cancel
to
cancel