Class TryReadLastConfirmedOp

  • All Implemented Interfaces:
    org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryCallback

    class TryReadLastConfirmedOp
    extends java.lang.Object
    implements org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryCallback
    This op is try to read last confirmed without involving quorum coverage checking. Use ReadLastConfirmedOp if you need quorum coverage checking.
    • Field Detail

      • LOG

        static final org.slf4j.Logger LOG
      • bookieClient

        final org.apache.bookkeeper.proto.BookieClient bookieClient
      • numResponsesPending

        int numResponsesPending
      • hasValidResponse

        volatile boolean hasValidResponse
      • completed

        volatile boolean completed
      • maxRecoveredData

        org.apache.bookkeeper.proto.checksum.DigestManager.RecoveryData maxRecoveredData
      • currentEnsemble

        final java.util.List<org.apache.bookkeeper.net.BookieId> currentEnsemble
    • Method Detail

      • initiate

        public void initiate()
      • readEntryComplete

        public void readEntryComplete​(int rc,
                                      long ledgerId,
                                      long entryId,
                                      io.netty.buffer.ByteBuf buffer,
                                      java.lang.Object ctx)
        Specified by:
        readEntryComplete in interface org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryCallback