Class ReadController

    • Field Detail

      • IDLE_SLEEP_TIME

        static int IDLE_SLEEP_TIME
      • AGGRESIVE_READ

        static boolean AGGRESIVE_READ
      • normal_priority_entities

        volatile java.util.ArrayList<RateControlledEntity> normal_priority_entities
      • entities_mon

        private final AEMonitor entities_mon
      • next_normal_position

        private int next_normal_position
      • next_high_position

        private int next_high_position
      • loop_count

        private long loop_count
      • wait_count

        private long wait_count
      • non_progress_count

        private long non_progress_count
      • progress_count

        private long progress_count
      • entity_check_count

        private long entity_check_count
      • last_entity_check_count

        private long last_entity_check_count
      • entity_count

        private int entity_count
    • Constructor Detail

      • ReadController

        public ReadController()
    • Method Detail

      • updateStats

        public void updateStats​(java.util.Set types,
                                java.util.Map values)
        Specified by:
        updateStats in interface CoreStatsProvider
      • readProcessorLoop

        void readProcessorLoop()
      • hasConnections

        private boolean hasConnections()
      • doNormalPriorityRead

        private boolean doNormalPriorityRead()
      • doHighPriorityRead

        private boolean doHighPriorityRead()
      • getNextReadyNormalPriorityEntity

        private RateControlledEntity getNextReadyNormalPriorityEntity()
      • addReadEntity

        public void addReadEntity​(RateControlledEntity entity)
        Add the given entity to the controller for read processing.
        Parameters:
        entity - to process reads for
      • removeReadEntity

        public boolean removeReadEntity​(RateControlledEntity entity)
        Remove the given entity from the controller.
        Parameters:
        entity - to remove from read processing
      • getEntityCount

        public int getEntityCount()