Class ReadLastConfirmedAndEntryOp

    • Field Detail

      • LOG

        static final org.slf4j.Logger LOG
      • heardFromHostsBitSet

        final java.util.BitSet heardFromHostsBitSet
      • emptyResponsesFromHostsBitSet

        final java.util.BitSet emptyResponsesFromHostsBitSet
      • maxMissedReadsAllowed

        final int maxMissedReadsAllowed
      • parallelRead

        boolean parallelRead
      • requestComplete

        final java.util.concurrent.atomic.AtomicBoolean requestComplete
      • requestTimeNano

        final long requestTimeNano
    • Method Detail

      • cancelSpeculativeTask

        protected void cancelSpeculativeTask​(boolean mayInterruptIfRunning)
      • issueSpeculativeRequest

        public com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean> issueSpeculativeRequest()
        Speculative Read Logic.
        Specified by:
        issueSpeculativeRequest in interface SpeculativeRequestExecutor
        Returns:
        whether more speculative requests should be issued
      • initiate

        public void initiate()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object