Class: AMQ::IntAllocator

Inherits:

Object

• Object
• AMQ::IntAllocator

show all

Defined in:

lib/amq/int_allocator.rb

Overview

Instance Attribute Summary (collapse)

• - (Integer) hi readonly

  Upper boundary of the integer range available for allocation.

• - (Integer) lo readonly

  Lower boundary of the integer range available for allocation.

• - (Integer) number_of_bits readonly

  Number of integers in the allocation range.

Instance Method Summary (collapse)

• - (Integer) allocate

  Attempts to allocate next available integer.

• - (Boolean) allocated?(reservation)

  True if provided argument was previously allocated, false otherwise.

• - (NilClass) free(reservation) (also: #release)

  Releases previously allocated integer.

• - (IntAllocator) initialize(lo, hi) constructor

  A new instance of IntAllocator.

• - (Object) reset

  Releases the whole allocation range.

27
28
29
30
31
32
33
34
35
36

# File 'lib/amq/int_allocator.rb', line 27

def initialize(lo, hi)
  raise ArgumentError.new "upper boundary must be greater than the lower one (given: hi = #{hi}, lo = #{lo})" unless hi > lo

  @hi = hi
  @lo = lo

  @number_of_bits = hi - lo
  @range          = Range.new(1, @number_of_bits)
  @free_set       = BitSet.new(@number_of_bits)
end

20
21
22

# File 'lib/amq/int_allocator.rb', line 20

def hi
  @hi
end

22
23
24

# File 'lib/amq/int_allocator.rb', line 22

def lo
  @lo
end

18
19
20

# File 'lib/amq/int_allocator.rb', line 18

def number_of_bits
  @number_of_bits
end

45
46
47
48
49
50
51
52
53

# File 'lib/amq/int_allocator.rb', line 45

def allocate
  if n = find_unallocated_position
    @free_set.set(n)

    n
  else
    -1
  end
end

65
66
67

# File 'lib/amq/int_allocator.rb', line 65

def allocated?(reservation)
  @free_set.get(reservation)
end

59
60
61

# File 'lib/amq/int_allocator.rb', line 59

def free(reservation)
  @free_set.unset(reservation)
end

70
71
72

# File 'lib/amq/int_allocator.rb', line 70

def reset
  @free_set.clear
end