Class CoordinatorSession


  • public class CoordinatorSession
    extends ConsistentSession
    Coordinator side logic and state of a consistent repair session. Like ActiveRepairService.ParentRepairSession, there is only one CoordinatorSession per user repair command, regardless of the number of tables and token ranges involved.
    • Method Detail

      • prepare

        public com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean> prepare()
      • handlePrepareResponse

        public void handlePrepareResponse​(InetAddressAndPort participant,
                                          boolean success)
      • setRepairing

        public void setRepairing()
      • finalizePropose

        public com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean> finalizePropose()
      • handleFinalizePromise

        public void handleFinalizePromise​(InetAddressAndPort participant,
                                          boolean success)
      • finalizeCommit

        public void finalizeCommit()
      • fail

        public void fail()
      • execute

        public com.google.common.util.concurrent.ListenableFuture execute​(java.util.function.Supplier<com.google.common.util.concurrent.ListenableFuture<java.util.List<RepairSessionResult>>> sessionSubmitter,
                                                                          java.util.concurrent.atomic.AtomicBoolean hasFailure)
        Runs the asynchronous consistent repair session. Actual repair sessions are scheduled via a submitter to make unit testing easier