Class BufferedUpdatesStream.FinishedSegments

  • Enclosing class:
    BufferedUpdatesStream

    private static class BufferedUpdatesStream.FinishedSegments
    extends java.lang.Object
    Tracks the contiguous range of packets that have finished resolving. We need this because the packets are concurrently resolved, and we can only write to disk the contiguous completed packets.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private long completedDelGen
      Largest del gen, inclusive, for which all prior packets have finished applying.
      private LongHashSet finishedDelGens
      This lets us track the "holes" in the current frontier of applying del gens; once the holes are filled in we can advance completedDelGen.
      private InfoStream infoStream  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      (package private) void clear()  
      (package private) void finishedSegment​(long delGen)  
      (package private) long getCompletedDelGen()  
      (package private) boolean stillRunning​(long delGen)  
      • Methods inherited from class java.lang.Object

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

      • completedDelGen

        private long completedDelGen
        Largest del gen, inclusive, for which all prior packets have finished applying.
      • finishedDelGens

        private final LongHashSet finishedDelGens
        This lets us track the "holes" in the current frontier of applying del gens; once the holes are filled in we can advance completedDelGen.
    • Constructor Detail

      • FinishedSegments

        FinishedSegments​(InfoStream infoStream)
    • Method Detail

      • clear

        void clear()
      • stillRunning

        boolean stillRunning​(long delGen)
      • getCompletedDelGen

        long getCompletedDelGen()
      • finishedSegment

        void finishedSegment​(long delGen)