Contents

module Log
  class ProgressBar
    BAR_MUTEX = Mutex.new
    BARS = []
    REMOVE = []
    SILENCED = []

    def self.add_offset
      @@offset = offset + 1
      @@offset = 0 if @@offset < 0
      @@offset
    end

    def self.remove_offset
      @@offset = offset - 1
      @@offset = 0 if @@offset < 0
      @@offset
    end


    def self.offset
      @@offset ||= 0
      @@offset = 0 if @@offset < 0
      @@offset
    end

    def self.new_bar(max, options = {})
      cleanup_bars
      BAR_MUTEX.synchronize do
        #Log::LAST.replace "new_bar" if Log::LAST == "progress"
        options = Misc.add_defaults options, :depth => BARS.length + Log::ProgressBar.offset
        BARS << (bar = ProgressBar.new(max, options))
        bar
      end
    end

    def self.cleanup_bars
      BAR_MUTEX.synchronize do
        REMOVE.each do |bar|
          index = BARS.index bar
          if index
            BARS.delete_at index
            BARS.each_with_index do |bar,i|
              bar.depth = i
            end
          end
          index = SILENCED.index bar
          if index
            SILENCED.delete_at index
            SILENCED.each_with_index do |bar,i|
              bar.depth = i
            end
          end
        end
        REMOVE.clear
        BARS.length
      end
    end

    def self.remove_bar(bar, error = false)
      BAR_MUTEX.synchronize do
        return if REMOVE.include? bar
      end
      if error
        bar.error if bar.respond_to? :error
      else
        bar.done if bar.respond_to? :done
      end
      BAR_MUTEX.synchronize do
        REMOVE << bar
      end
    end

    def self.with_bar(max, options = {})
      bar = new_bar(max, options)
      begin
        yield bar
        keep = false
      rescue KeepBar
        keep = true
      ensure
        remove_bar(bar) if bar
      end
    end
  end
end

Version data entries

21 entries across 21 versions & 1 rubygems

Version	Path
rbbt-util-5.23.17	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.16	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.15	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.14	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.13	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.12	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.11	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.10	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.9	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.8	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.7	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.6	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.5	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.4	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.3	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.2	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.1	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.23.0	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.22.5	lib/rbbt/util/log/progress/util.rb
rbbt-util-5.22.4	lib/rbbt/util/log/progress/util.rb