Class LongPollReadEntryProcessorV3

    • Constructor Detail

      • LongPollReadEntryProcessorV3

        LongPollReadEntryProcessorV3​(org.apache.bookkeeper.proto.BookkeeperProtocol.Request request,
                                     io.netty.channel.Channel channel,
                                     BookieRequestProcessor requestProcessor,
                                     java.util.concurrent.ExecutorService fenceThreadPool,
                                     java.util.concurrent.ExecutorService longPollThreadPool,
                                     io.netty.util.HashedWheelTimer requestTimer)
    • Method Detail

      • readEntry

        protected org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse readEntry​(org.apache.bookkeeper.proto.BookkeeperProtocol.ReadResponse.Builder readResponseBuilder,
                                                                                        long entryId,
                                                                                        com.google.common.base.Stopwatch startTimeSw)
                                                                                 throws java.io.IOException,
                                                                                        BookieException
        Description copied from class: ReadEntryProcessorV3
        Read a specific entry.
        Overrides:
        readEntry in class ReadEntryProcessorV3
        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
      • update

        public void update​(LastAddConfirmedUpdateNotification newLACNotification)
        Description copied from interface: Watcher
        This method is called whenever the watched object is changed. An application calls an Watchable object's notifyWatchers method to have all the object's watchers notified of the change.
        Specified by:
        update in interface Watcher<LastAddConfirmedUpdateNotification>
        Parameters:
        newLACNotification - the updated value of a watchable