35bc3a4ceb
When referring to TYPE directly, the value is taken from the class in which the method is defined, but we want it to be taken from the class for the object being acted on, so we instead use self.class::TYPE to ensure that methods still work in inherited subclasses. For example this means that Pacemaker::Resource::MasterSlave will be able to inherit from Pacemaker::Resource::Clone.
88 lines
2.0 KiB
Ruby
88 lines
2.0 KiB
Ruby
require 'shellwords'
|
|
require File.expand_path('../resource', File.dirname(__FILE__))
|
|
require File.expand_path('../mixins/resource_meta', File.dirname(__FILE__))
|
|
|
|
class Pacemaker::Resource::Primitive < Pacemaker::Resource
|
|
TYPE = 'primitive'
|
|
register_type TYPE
|
|
|
|
include Pacemaker::Mixins::Resource::Meta
|
|
|
|
attr_accessor :agent, :params, :op
|
|
|
|
def initialize(*args)
|
|
super(*args)
|
|
|
|
@agent = nil
|
|
end
|
|
|
|
def self.attrs_to_copy_from_chef
|
|
%w(agent params meta op)
|
|
end
|
|
|
|
def parse_definition
|
|
unless definition =~ /\A#{self.class::TYPE} (\S+) (\S+)/
|
|
raise Pacemaker::CIBObject::DefinitionParseError, \
|
|
"Couldn't parse definition '#{definition}'"
|
|
end
|
|
self.name = $1
|
|
self.agent = $2
|
|
|
|
%w(params meta).each do |data_type|
|
|
hash = self.class.extract_hash(definition, data_type)
|
|
writer = (data_type + '=').to_sym
|
|
send(writer, hash)
|
|
end
|
|
|
|
self.op = {}
|
|
%w(start stop monitor).each do |op|
|
|
h = self.class.extract_hash(definition, "op #{op}")
|
|
self.op[op] = h unless h.empty?
|
|
end
|
|
end
|
|
|
|
def params_string
|
|
self.class.params_string(params)
|
|
end
|
|
|
|
def op_string
|
|
self.class.op_string(op)
|
|
end
|
|
|
|
def definition_string
|
|
str = "#{self.class::TYPE} #{name} #{agent}"
|
|
%w(params meta op).each do |data_type|
|
|
unless send(data_type).empty?
|
|
data_string = send("#{data_type}_string")
|
|
str << continuation_line(data_string)
|
|
end
|
|
end
|
|
str
|
|
end
|
|
|
|
def crm_configure_command
|
|
args = %w(crm configure primitive)
|
|
args << [name, agent, params_string, meta_string, op_string]
|
|
args.join " "
|
|
end
|
|
|
|
def self.params_string(params)
|
|
return "" if ! params or params.empty?
|
|
"params " +
|
|
params.sort.map do |key, value|
|
|
%'#{key}="#{value}"'
|
|
end.join(' ')
|
|
end
|
|
|
|
def self.op_string(ops)
|
|
return "" if ! ops or ops.empty?
|
|
ops.sort.map do |op, attrs|
|
|
attrs.empty? ? nil : "op #{op} " + \
|
|
attrs.sort.map do |key, value|
|
|
%'#{key}="#{value}"'
|
|
end.join(' ')
|
|
end.compact.join(' ')
|
|
end
|
|
|
|
end
|