Class ForceLedgerOp

  • All Implemented Interfaces:
    java.lang.Runnable, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ForceLedgerCallback

    class ForceLedgerOp
    extends java.lang.Object
    implements java.lang.Runnable, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ForceLedgerCallback
    This represents a request to sync the ledger on every bookie.
    • Constructor Summary

      Constructors 
      Constructor Description
      ForceLedgerOp​(LedgerHandle lh, org.apache.bookkeeper.proto.BookieClient bookieClient, java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, java.util.concurrent.CompletableFuture<java.lang.Void> cb)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void forceLedgerComplete​(int rc, long ledgerId, org.apache.bookkeeper.net.BookieId addr, java.lang.Object ctx)  
      (package private) void initiate()  
      void run()  
      (package private) void sendForceLedgerRequest​(int bookieIndex)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • cb

        final java.util.concurrent.CompletableFuture<java.lang.Void> cb
      • completed

        boolean completed
      • errored

        boolean errored
      • lastSeenError

        int lastSeenError
      • currentEnsemble

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

        long currentNonDurableLastAddConfirmed
      • bookieClient

        final org.apache.bookkeeper.proto.BookieClient bookieClient
    • Constructor Detail

      • ForceLedgerOp

        ForceLedgerOp​(LedgerHandle lh,
                      org.apache.bookkeeper.proto.BookieClient bookieClient,
                      java.util.List<org.apache.bookkeeper.net.BookieId> ensemble,
                      java.util.concurrent.CompletableFuture<java.lang.Void> cb)
    • Method Detail

      • sendForceLedgerRequest

        void sendForceLedgerRequest​(int bookieIndex)
      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable
      • initiate

        void initiate()
      • forceLedgerComplete

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