summaryrefslogtreecommitdiff
path: root/lib/oxidized/jobs.rb
blob: 6476744d2d12089b951c7bf809f87fd559a55cb2 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
module Oxidized
  class Jobs < Array
    attr_accessor :interval, :duration, :max, :want
    def initialize max, interval, nodes
      @max       = max
      #@interval  = interval * 60
      @interval  = interval
      @nodes     = nodes
      @duration  = 4
      new_count
      super()
    end
    def duration last
      @duration = (@duration + last) / 2
      new_count
    end
    def new_count
      @want = ((@nodes.size * @duration) / @interval).to_i
      @want = 1 if @want < 1
      @want = @nodes.size if @want > @nodes.size
      @want = @max if @want > @max
    end
  end
end