Class ReadEntryProcessorV3

    • Field Detail

      • lastPhaseStartTime

        protected com.google.common.base.Stopwatch lastPhaseStartTime
      • ledgerId

        protected final long ledgerId
      • entryId

        protected final long entryId
    • Method Detail

      • getPreviousLAC

        protected java.lang.Long getPreviousLAC()
      • handleReadResultForFenceRead

        protected void handleReadResultForFenceRead​(io.netty.buffer.ByteBuf entryBody,
                                                    BookkeeperProtocol.ReadResponse.Builder readResponseBuilder,
                                                    long entryId,
                                                    com.google.common.base.Stopwatch startTimeSw)
        Handle read result for fence read.
        Parameters:
        entryBody - read result
        readResponseBuilder - read response builder
        entryId - entry id
        startTimeSw - timer for the read request
      • readEntry

        protected BookkeeperProtocol.ReadResponse readEntry​(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder,
                                                            long entryId,
                                                            com.google.common.base.Stopwatch startTimeSw)
                                                     throws java.io.IOException,
                                                            BookieException
        Read a specific entry.
        Parameters:
        readResponseBuilder - read response builder.
        entryId - entry to read
        startTimeSw - stop watch to measure the read operation.
        Returns:
        read response or null if it is a fence read operation.
        Throws:
        java.io.IOException
        BookieException
      • readEntry

        protected BookkeeperProtocol.ReadResponse readEntry​(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder,
                                                            long entryId,
                                                            boolean readLACPiggyBack,
                                                            com.google.common.base.Stopwatch startTimeSw)
                                                     throws java.io.IOException,
                                                            BookieException
        Read a specific entry.
        Parameters:
        readResponseBuilder - read response builder.
        entryId - entry to read
        startTimeSw - stop watch to measure the read operation.
        Returns:
        read response or null if it is a fence read operation.
        Throws:
        java.io.IOException
        BookieException
      • run

        public void run()
      • executeOp

        protected void executeOp()
      • registerSuccessfulEvent

        protected void registerSuccessfulEvent​(OpStatsLogger statsLogger,
                                               com.google.common.base.Stopwatch startTime)
      • registerFailedEvent

        protected void registerFailedEvent​(OpStatsLogger statsLogger,
                                           com.google.common.base.Stopwatch startTime)
      • registerEvent

        protected void registerEvent​(boolean failed,
                                     OpStatsLogger statsLogger,
                                     com.google.common.base.Stopwatch startTime)
      • toString

        public java.lang.String toString()
        this toString method filters out masterKey from the output. masterKey contains the password of the ledger.
        Overrides:
        toString in class PacketProcessorBaseV3