Parent

Included Modules

Chef::Expander::VNodeTable

Attributes

vnodes_by_node[R]

Public Class Methods

new(vnode_supervisor) click to toggle source
# File lib/chef/expander/vnode_table.rb, line 35
def initialize(vnode_supervisor)
  @node_update_mutex = Mutex.new
  @vnode_supervisor = vnode_supervisor
  @vnodes_by_node = {}
end

Public Instance Methods

leader_node() click to toggle source
# File lib/chef/expander/vnode_table.rb, line 69
def leader_node
  if @vnodes_by_node.empty?
    nil
  else
    Array(@vnodes_by_node).reject { |node| node[1].empty? }.sort { |a,b| a[1].min <=> b[1].min }.first[0]
  end
end
local_node_is_leader?() click to toggle source
# File lib/chef/expander/vnode_table.rb, line 77
def local_node_is_leader?
  (Node.local_node == leader_node) || (@vnodes_by_node[Node.local_node].include?(0))
end
nodes() click to toggle source
# File lib/chef/expander/vnode_table.rb, line 41
def nodes
  @vnodes_by_node.keys
end
remove_node(node_info) click to toggle source
# File lib/chef/expander/vnode_table.rb, line 63
def remove_node(node_info)
  @node_update_mutex.synchronize do
    @vnodes_by_node.delete(Node.from_hash(node_info))
  end
end
update_node(node_info) click to toggle source
# File lib/chef/expander/vnode_table.rb, line 57
def update_node(node_info)
 @node_update_mutex.synchronize do
    @vnodes_by_node[Node.from_hash(node_info)] = node_info[:vnodes]
  end
end
update_table(table_update) click to toggle source
# File lib/chef/expander/vnode_table.rb, line 45
def update_table(table_update)
  case table_update[:update]
  when "add", "update"
    update_node(table_update)
  when "remove"
    remove_node(table_update)
  else
    raise InvalidVNodeTableUpdate, "no action or action not acceptable: #{table_update.inspect}"
  end
  log.debug { "current vnode table: #{@vnodes_by_node.inspect}" }
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.