Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Automatic update #287

Closed
wants to merge 1 commit into from
+573 −377
Closed

Automatic update #287

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Puppetfile
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ mod 'openstacklib',
:git => 'https://github.com/stackforge/puppet-openstacklib.git'

mod 'pacemaker',
:commit => '52acfd9c31e0801cedf970929851d4bece5cf79b',
:commit => '47c85172fedcf452acd004cc880a565e4a326c73',
:git => 'https://github.com/redhat-openstack/puppet-pacemaker.git'

mod 'puppet',
Expand Down
280 changes: 133 additions & 147 deletions pacemaker/lib/puppet/provider/pcmk_resource/default.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,156 +1,142 @@
Puppet::Type.type(:pcmk_resource).provide(:default) do
desc 'A base resource definition for a pacemaker resource'

### overloaded methods
def create
cmd = 'resource create ' + @resource[:name] + ' ' + @resource[:resource_type] + ' ' + @resource[:resource_params] + ' op monitor interval=' + @resource[:interval]
if @resource[:monitor_params] and not @resource[:monitor_params].empty?
cmd += hash_to_params(@resource[:monitor_params])
end
# group defaults to empty
if not @resource[:group].empty?
cmd += ' --group ' + @resource[:group]
end
# clone defaults to false
if @resource[:clone]
cmd += ' --clone'
end
# do pcs create
pcs('create', cmd)
end

def destroy
cmd = 'resource delete ' + @resource[:name]
pcs('delete', cmd)
end

def exists?
cmd = 'resource show ' + @resource[:name] + ' > /dev/null 2>&1'
pcs('show', cmd)
end


### property methods
def resource_params
cmd = 'resource show ' + @resource[:name]
get_attrs = pcs('get interval', cmd)

# find the Attributes
for line in get_attrs.lines.each do
return (line.scan /Attributes: (.+?)$/m)[0][0].strip if line.include? 'Attributes:'
end
# return empty string if Attributes not found
''
end

def resource_params=(value)
cmd = 'resource update ' + @resource[:name] + ' ' + value
pcs('update attributes', cmd)
end

def group
# get the list of groups and their resources
cmd = 'resource --groups'
resource_groups = pcs('group list', cmd)

# find the group that has the resource in it
for group in resource_groups.lines.each do
return group[0, /:/ =~ group] if group.include? @resource[:name]
end
# return empty string if a group wasn't found
# that includes the resource in it.
''
end

def group=(value)
if value.empty?
cmd = 'resource ungroup ' + group + ' ' + @resource[:name]
pcs('ungroup', cmd)
else
cmd = 'resource group add ' + value + ' ' + @resource[:name]
pcs('group add', cmd)
end
end

def clone
cmd = 'resource show ' + @resource[:name] + '-clone > /dev/null 2>&1'
pcs('show clone', cmd) == false ? false : true
end

def clone=(value)
if not value
cmd = 'resource unclone ' + @resource[:name]
pcs('unclone', cmd)
else
cmd = 'resource clone ' + @resource[:name]
pcs('clone', cmd)
end
end

def interval
cmd = 'resource show ' + @resource[:name]
get_interval = pcs('get interval', cmd)

# find the interval value
for line in get_interval.lines.each do
return (line.scan /interval=(.+?) /m)[0][0] if line.include? 'interval='
end
# return empty string if an interval value wasn't found
''
end
desc 'A base resource definition for a pacemaker resource'

def interval=(value)
cmd = 'resource update ' + @resource[:name] + ' op monitor interval=' + value
pcs('update interval', cmd)
end
### overloaded methods
def create
resource_params = @resource[:resource_params]
meta_params = @resource[:meta_params]
op_params = @resource[:op_params]
clone_params = @resource[:clone_params]
group_params = @resource[:group_params]
master_params = @resource[:master_params]

def monitor_params
cmd = 'resource show ' + @resource[:name]
pcs_output = pcs('get monitor params', cmd)

pcs_output.each_line do |line|
line.strip.match(/(Operations: )?monitor ([^(]+)/) do |match|
Puppet.debug(match.inspect)
return params_to_hash(match[2])
end
end
# return empty string if monitor params not found
''
suffixes = 0
if clone_params then suffixes +=1 end
if master_params then suffixes +=1 end
if group_params then suffixes +=1 end
if suffixes > 1
raise(Puppet::Error, "May only define one of clone_params, "+
"master_params and group_params")
end

def monitor_params=(value)
cmd = 'resource update ' + @resource[:name] + ' op monitor ' + hash_to_params(value)
pcs('update interval', cmd)
end
# Build the 'pcs resource create' command. Check out the pcs man page :-)
cmd = 'resource create ' + @resource[:name]+' ' +@resource[:resource_type]
if not_empty_string(resource_params)
cmd += ' ' + resource_params
end
if not_empty_string(meta_params)
cmd += ' meta ' + meta_params
end
if not_empty_string(op_params)
cmd += ' op ' + op_params
end
if clone_params
cmd += ' --clone'
if not_empty_string(clone_params)
cmd += ' ' + clone_params
end
end
if not_empty_string(group_params)
cmd += ' --group ' + group_params
end
if master_params
cmd += ' --master'
if not_empty_string(master_params)
cmd += ' ' + master_params
end
end

# do pcs create
pcs('create', cmd)
end

def destroy
cmd = 'resource delete ' + @resource[:name]
pcs('delete', cmd)
end

def exists?
cmd = 'resource show ' + @resource[:name] + ' > /dev/null 2>&1'
pcs('show', cmd)
end


### property methods

# It isn't an easy road if you want to make these true
# puppet-like resource properties. Here is a start if you are feeling brave:
# https://github.com/cwolferh/puppet-pacemaker/blob/pcmk_resource_improvements_try0/lib/puppet/provider/pcmk_resource/default.rb#L64
def resource_params
@resource[:resource_params]
end

def resource_params=(value)
end

def op_params
@resource[:op_params]
end

def op_params=(value)
end

def meta_params
@resource[:meta_params]
end

def meta_params=(value)
end

def group_params
@resource[:group_params]
end

def group_params=(value)
end

def master_params
@resource[:master_params]
end

def master_params=(value)
end

def clone_params
@resource[:clone_params]
end

def clone_params=(value)
end

def not_empty_string(p)
p && p.kind_of?(String) && ! p.empty?
end

private

def pcs(name, cmd)
Puppet.debug("/usr/sbin/pcs #{cmd}")
pcs_out = `/usr/sbin/pcs #{cmd}`
#puts name
#puts $?.exitstatus
if $?.exitstatus != 0 and pcs_out.lines.first and not name.include? 'show'
Puppet.debug("Error: #{pcs_out}")
raise Puppet::Error, "pcs #{name} failed: #{pcs_out.lines.first.chomp!}" if $?.exitstatus
end
def pcs(name, cmd)
try_sleep = @resource[:try_sleep]
max_tries = name.include?('show') ? 1 : @resource[:tries]
max_tries.times do |try|
try_text = max_tries > 1 ? "try #{try+1}/#{max_tries}: " : ''
Puppet.debug("#{try_text}/usr/sbin/pcs #{cmd}")
pcs_out = `/usr/sbin/pcs #{cmd} 2>&1`
if name.include?('show')
# return output for good exit or false for failure.
$?.exitstatus == 0 ? pcs_out : false
end
return $?.exitstatus == 0 ? pcs_out : false
end
if $?.exitstatus == 0
sleep @resource[:post_success_sleep]
return pcs_out
end
Puppet.debug("Error: #{pcs_out}")
if try == max_tries-1
pcs_out_line = pcs_out.lines.first ? pcs_out.lines.first.chomp! : ''
raise Puppet::Error, "pcs #{name} failed: #{pcs_out_line}"
end
if try_sleep > 0
Puppet.debug("Sleeping for #{try_sleep} seconds between tries")
sleep try_sleep
end
end
end

def params_to_hash(str)
str.split.reduce({}) do |hash, param|
k,v = param.split '='
hash[k] = v
hash
end
end

def hash_to_params(hash)
params = ''
hash.each_pair do |k,v|
params += " #{k}=#{v}"
end
params
end
end
Loading