Class ReadLastConfirmedOp

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

    class ReadLastConfirmedOp
    extends java.lang.Object
    implements org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryCallback
    This class encapsulated the read last confirmed operation.
    • Field Detail

      • LOG

        static final org.slf4j.Logger LOG
    • Constructor Detail

      • ReadLastConfirmedOp

        public ReadLastConfirmedOp​(org.apache.bookkeeper.proto.BookieClient bookieClient,
                                   DistributionSchedule schedule,
                                   org.apache.bookkeeper.proto.checksum.DigestManager digestManager,
                                   long ledgerId,
                                   java.util.List<org.apache.bookkeeper.net.BookieId> ensemble,
                                   byte[] ledgerKey,
                                   ReadLastConfirmedOp.LastConfirmedDataCallback cb)
    • Method Detail

      • initiate

        public void initiate()
      • initiateWithFencing

        public void initiateWithFencing()
      • 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
      • getNumResponsesPending

        int getNumResponsesPending()