e900db6b6a
If corosync_roles is overridden by a plugin, the merged hiera array will include both the defaults and the override, which leads to a failed deployment. Instead, we should select only the highest priority array, without merge. Change-Id: I4fe7b156e7a21d25f34864fcf4ac53fefad0ce73 Closes-Bug: #1482136
85 lines
2.1 KiB
Ruby
Executable File
85 lines
2.1 KiB
Ruby
Executable File
#!/usr/bin/env ruby
|
|
require 'rubygems'
|
|
require 'hiera'
|
|
require 'timeout'
|
|
|
|
HIERA_CONFIG = '/etc/puppet/hiera.yaml'
|
|
DEFAULT_COROSYNC_ROLES = %w(controller primary-controller)
|
|
|
|
RETRY_COUNT = 5
|
|
RETRY_WAIT = 1
|
|
RETRY_TIMEOUT = 10
|
|
|
|
def hiera
|
|
return $hiera if $hiera
|
|
$hiera = Hiera.new(:config => HIERA_CONFIG)
|
|
Hiera.logger = "noop"
|
|
$hiera
|
|
end
|
|
|
|
def nodes
|
|
nodes_array = hiera.lookup 'nodes', [], {}, nil, :array
|
|
raise 'Invalid nodes data!' unless nodes_array.is_a? Array
|
|
nodes_array
|
|
end
|
|
|
|
def corosync_roles
|
|
return $corosync_roles if $corosync_roles
|
|
$corosync_roles = hiera.lookup 'corosync_roles', DEFAULT_COROSYNC_ROLES, {}, nil, :priority
|
|
raise 'Invalid corosync_roles!' unless $corosync_roles.is_a? Array
|
|
$corosync_roles
|
|
end
|
|
|
|
def corosync_nodes_count
|
|
return $corosync_nodes_count if $corosync_nodes_count
|
|
$corosync_nodes_count = nodes.select do |node|
|
|
corosync_roles.include? node['role']
|
|
end.size
|
|
end
|
|
|
|
def set_quorum_policy(value)
|
|
puts "Setting no-quorum-policy to: '#{value}'"
|
|
RETRY_COUNT.times do |n|
|
|
begin
|
|
Timeout::timeout(RETRY_TIMEOUT) do
|
|
system "crm_attribute --verbose --type crm_config --name no-quorum-policy --update #{value}"
|
|
return if $?.exitstatus == 0
|
|
end
|
|
rescue Timeout::Error
|
|
nil
|
|
end
|
|
puts "Error! Retry: #{n + 1}"
|
|
sleep RETRY_WAIT
|
|
end
|
|
fail "Could not set no-quorum-policy to: '#{value}'!"
|
|
end
|
|
|
|
def get_quorum_policy
|
|
RETRY_COUNT.times do |n|
|
|
begin
|
|
Timeout::timeout(RETRY_TIMEOUT) do
|
|
policy = `crm_attribute --type crm_config --name no-quorum-policy --query --quiet`.chomp
|
|
return policy if $?.exitstatus == 0
|
|
end
|
|
rescue Timeout::Error
|
|
nil
|
|
end
|
|
puts "Error! Retry: #{n + 1}"
|
|
sleep RETRY_WAIT
|
|
end
|
|
fail "Could not get no-quorum-policy!"
|
|
end
|
|
|
|
##############
|
|
|
|
puts "Corosync nodes found: '#{corosync_nodes_count}'"
|
|
|
|
if corosync_nodes_count > 2
|
|
set_quorum_policy 'stop' unless get_quorum_policy == 'stop'
|
|
else
|
|
set_quorum_policy 'ignore' unless get_quorum_policy == 'ignore'
|
|
end
|
|
|
|
puts "Current no-quorum-policy is: '#{get_quorum_policy}'"
|
|
exit 0
|
|
|