Class PendingWriteLacOp

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

    class PendingWriteLacOp
    extends java.lang.Object
    implements org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.WriteLacCallback
    This represents a pending WriteLac operation. When it has got success from Ack Quorum bookies, sends success back to the application, otherwise failure is sent back to the caller.

    This is an optional protocol operations to facilitate tailing readers to be up to date with the writer. This is best effort to get latest LAC from bookies, and doesn't affect the correctness of the protocol.

    • Method Detail

      • setLac

        void setLac​(long lac)
      • sendWriteLacRequest

        void sendWriteLacRequest​(int bookieIndex)
      • initiate

        void initiate​(org.apache.bookkeeper.util.ByteBufList toSend)
      • writeLacComplete

        public void writeLacComplete​(int rc,
                                     long ledgerId,
                                     org.apache.bookkeeper.net.BookieId addr,
                                     java.lang.Object ctx)
        Specified by:
        writeLacComplete in interface org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.WriteLacCallback