Class PerChannelBookieClient.CompletionValue

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected java.lang.Object ctx  
      protected long entryId  
      protected long ledgerId  
      protected long startTime  
    • Constructor Summary

      Constructors 
      Constructor Description
      CompletionValue​(java.lang.String operationName, java.lang.Object ctx, long ledgerId, long entryId, OpStatsLogger opLogger, OpStatsLogger timeoutOpLogger)  
    • Field Detail

      • ctx

        protected java.lang.Object ctx
      • ledgerId

        protected long ledgerId
      • entryId

        protected long entryId
      • startTime

        protected long startTime
    • Constructor Detail

      • CompletionValue

        public CompletionValue​(java.lang.String operationName,
                               java.lang.Object ctx,
                               long ledgerId,
                               long entryId,
                               OpStatsLogger opLogger,
                               OpStatsLogger timeoutOpLogger)
    • Method Detail

      • logOpResult

        void logOpResult​(int rc)
      • maybeTimeout

        boolean maybeTimeout()
      • timeout

        void timeout()
      • logResponse

        protected void logResponse​(org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode status,
                                   java.lang.Object... extraInfo)
      • convertStatus

        protected int convertStatus​(org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode status,
                                    int defaultStatus)
      • restoreMdcContext

        public void restoreMdcContext()
      • errorOut

        public abstract void errorOut()
      • errorOut

        public abstract void errorOut​(int rc)
      • setOutstanding

        public void setOutstanding()
      • errorOutAndRunCallback

        protected void errorOutAndRunCallback​(java.lang.Runnable callback)
      • handleV2Response

        public void handleV2Response​(long ledgerId,
                                     long entryId,
                                     org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode status,
                                     BookieProtocol.Response response)
      • handleV3Response

        public abstract void handleV3Response​(org.apache.bookkeeper.proto.BookkeeperProtocol.Response response)