meta-phosphor/classes/obmc-phosphor-systemd.bbclass - mdmillerii/openbmc - Gitiles

 # Common code for systemd based services.
 #
 # Prior to inheriting this class, recipes can define services like this:
 #
 # SYSTEMD_SERVICE_${PN} = "foo.service bar.socket baz@.service"
 #
 # and these files will be added to the main package if they exist.
 #
 # Alternatively this class can just be inherited and
 # ${PN}.service will be added to the main package.
 #
 # Other variables:
 # INHIBIT_SYSTEMD_RESTART_POLICY_${unit}
 #    Inhibit the warning that is displayed if a service unit without a
 #    restart policy is detected.
 #
 # SYSTEMD_SUBSTITUTIONS = "var:val:file"
 #    A specification for making python style {format} string
 #    substitutions where:
 #      var: the format string to search for
 #      val: the value to replace with
 #      file: the file in which to make the substitution
 #
 # SYSTEMD_USER_${PN}.service = "foo"
 # SYSTEMD_USER_${unit}.service = "foo"
 #    The user for the unit/package.
 #
 # SYSTEMD_ENVIRONMENT_FILE_${PN} = "foo"
 #    One or more environment files to be installed.
 #
 # SYSTEMD_LINK_${PN} = "tgt:name"
 #    A specification for installing arbitrary links in
 #    the ${systemd_system_unitdir} namespace, where:
 #      tgt: the link target
 #      name: the link name, relative to ${systemd_system_unitdir}
 #
 # SYSTEMD_OVERRIDE_${PN} = "src:dest"
 #    A specification for installing unit overrides where:
 #      src: the override file template
 #      dest: the override install location, relative to ${systemd_system_unitdir}
 #
 #    Typically SYSTEMD_SUBSTITUTIONS is used to deploy a range
 #    of overrides from a single template file.  To simply install
 #    a single override use "foo.conf:my-service.d/foo.conf"


 inherit obmc-phosphor-utils
 inherit systemd
 inherit useradd

 _INSTALL_SD_UNITS=""
 SYSTEMD_DEFAULT_TARGET ?= "multi-user.target"
 envfiledir ?= "${sysconfdir}/default"

 # Big ugly hack to prevent useradd.bbclass post-parse sanity checker failure.
 # If there are users to be added, we'll add them in our post-parse.
 # If not...there don't seem to be any ill effects...
 USERADD_PACKAGES ?= " "
 USERADD_PARAM_${PN} ?= ";"


 def SystemdUnit(unit):
     class Unit(object):
         def __init__(self, unit):
             self.unit = unit

         def __getattr__(self, item):
             if item is 'name':
                 return self.unit
             if item is 'is_activated':
                 return self.unit.startswith('dbus-')
             if item is 'is_template':
                 return '@.' in self.unit
             if item is 'is_instance':
                 return '@' in self.unit and not self.is_template
             if item in ['is_service', 'is_target']:
                 return self.unit.split('.')[-1] == item
             if item is 'base':
                 cls = self.unit.split('.')[-1]
                 base = self.unit.replace('dbus-', '')
                 base = base.replace('.%s' % cls, '')
                 if self.is_instance:
                     base = base.replace('@%s' % self.instance, '')
                 if self.is_template:
                     base = base.rstrip('@')
                 return base
             if item is 'instance' and self.is_instance:
                 inst = self.unit.rsplit('@')[-1]
                 return inst.rsplit('.')[0]
             if item is 'template' and self.is_instance:
                 cls = self.unit.split('.')[-1]
                 return '%s@.%s' % (self.base, cls)
             if item is 'template' and self.is_template:
                 return '.'.join(self.base.split('@')[:-1])

             raise AttributeError(item)
     return Unit(unit)


 def systemd_parse_unit(d, path):
     import configparser
     parser = configparser.SafeConfigParser(strict=False)
     parser.optionxform = str
     parser.read('%s' % path)
     return parser


 python() {
     def check_sd_unit(d, unit):
         searchpaths = d.getVar('FILESPATH', True)
         path = bb.utils.which(searchpaths, '%s' % unit.name)
         if not os.path.isfile(path):
             # Unit does not exist in tree. Allow it to install from repo.
             # Return False here to indicate it does not exist.
             return False

         parser = systemd_parse_unit(d, path)
         inhibit = listvar_to_list(d, 'INHIBIT_SYSTEMD_RESTART_POLICY_WARNING')
         if unit.is_service and \
                 not unit.is_template and \
                 unit.name not in inhibit and \
                 not parser.has_option('Service', 'Restart'):
             bb.warn('Systemd unit \'%s\' does not '
                 'have a restart policy defined.' % unit.name)
         return True


     def add_default_subs(d, file):
         for x in [
                 'base_bindir',
                 'bindir',
                 'sbindir',
                 'envfiledir',
                 'sysconfdir',
                 'SYSTEMD_DEFAULT_TARGET' ]:
             set_append(d, 'SYSTEMD_SUBSTITUTIONS',
                 '%s:%s:%s' % (x, d.getVar(x, True), file))


     def add_sd_unit(d, unit, pkg, unit_exist):
         # Do not add unit if it does not exist in tree.
         # It will be installed from repo.
         if not unit_exist:
             return

         name = unit.name
         unit_dir = d.getVar('systemd_system_unitdir', True)
         set_append(d, 'SRC_URI', 'file://%s' % name)
         set_append(d, 'FILES_%s' % pkg, '%s/%s' % (unit_dir, name))
         set_append(d, '_INSTALL_SD_UNITS', name)
         add_default_subs(d, name)


     def add_sd_user(d, file, pkg):
         opts = [
             '--system',
             '--home',
             '/',
             '--no-create-home',
             '--shell /sbin/nologin',
             '--user-group']

         var = 'SYSTEMD_USER_%s' % file
         user = listvar_to_list(d, var)
         if len(user) is 0:
             var = 'SYSTEMD_USER_%s' % pkg
             user = listvar_to_list(d, var)
         if len(user) is not 0:
             if len(user) is not 1:
                 bb.fatal('Too many users assigned to %s: \'%s\'' % (var, ' '.join(user)))

             user = user[0]
             set_append(d, 'SYSTEMD_SUBSTITUTIONS',
                 'USER:%s:%s' % (user, file))
             if user not in d.getVar('USERADD_PARAM_%s' % pkg, True):
                 set_append(
                     d,
                     'USERADD_PARAM_%s' % pkg,
                     '%s' % (' '.join(opts + [user])),
                     ';')
             if pkg not in d.getVar('USERADD_PACKAGES', True):
                 set_append(d, 'USERADD_PACKAGES', pkg)


     def add_env_file(d, name, pkg):
         set_append(d, 'SRC_URI', 'file://%s' % name)
         set_append(d, 'FILES_%s' % pkg, '%s/%s' \
             % (d.getVar('envfiledir', True), name))
         set_append(d, '_INSTALL_ENV_FILES', name)


     def install_link(d, spec, pkg):
         tgt, dest = spec.split(':')

         set_append(d, 'FILES_%s' % pkg, '%s/%s' \
             % (d.getVar('systemd_system_unitdir', True), dest))
         set_append(d, '_INSTALL_LINKS', spec)


     def add_override(d, spec, pkg):
         tmpl, dest = spec.split(':')
         set_append(d, '_INSTALL_OVERRIDES', '%s' % spec)
         unit_dir = d.getVar('systemd_system_unitdir', True)
         set_append(d, 'FILES_%s' % pkg, '%s/%s' % (unit_dir, dest))
         add_default_subs(d, '%s' % dest)
         add_sd_user(d, '%s' % dest, pkg)


     if d.getVar('CLASSOVERRIDE', True) != 'class-target':
         return

     d.appendVarFlag('do_install', 'postfuncs', ' systemd_do_postinst')

     pn = d.getVar('PN', True)
     if d.getVar('SYSTEMD_SERVICE_%s' % pn, True) is None:
         d.setVar('SYSTEMD_SERVICE_%s' % pn, '%s.service' % pn)

     for pkg in listvar_to_list(d, 'SYSTEMD_PACKAGES'):
         svc = listvar_to_list(d, 'SYSTEMD_SERVICE_%s' % pkg)
         svc = [SystemdUnit(x) for x in svc]
         tmpl = [x.template for x in svc if x.is_instance]
         tmpl = list(set(tmpl))
         tmpl = [SystemdUnit(x) for x in tmpl]
         svc = [x for x in svc if not x.is_instance]

         for unit in tmpl + svc:
             unit_exist = check_sd_unit(d, unit)
             add_sd_unit(d, unit, pkg, unit_exist)
             add_sd_user(d, unit.name, pkg)
         for name in listvar_to_list(d, 'SYSTEMD_ENVIRONMENT_FILE_%s' % pkg):
             add_env_file(d, name, pkg)
         for spec in listvar_to_list(d, 'SYSTEMD_LINK_%s' % pkg):
             install_link(d, spec, pkg)
         for spec in listvar_to_list(d, 'SYSTEMD_OVERRIDE_%s' % pkg):
             add_override(d, spec, pkg)
 }


 python systemd_do_postinst() {
     def make_subs(d):
         all_subs = {}
         for spec in listvar_to_list(d, 'SYSTEMD_SUBSTITUTIONS'):
             spec, file = spec.rsplit(':', 1)
             all_subs.setdefault(file, []).append(spec)

         for f, v in all_subs.items():
             subs = dict([ x.split(':') for x in v])
             if not subs:
                 continue

             path = d.getVar('D', True)
             path += d.getVar('systemd_system_unitdir', True)
             path += '/%s' % f
             with open(path, 'r') as fd:
                 content = fd.read()
             with open(path, 'w+') as fd:
                 try:
                     fd.write(content.format(**subs))
                 except KeyError as e:
                     bb.fatal('No substitution found for %s in '
                         'file \'%s\'' % (e, f))


     def install_envs(d):
         install_dir = d.getVar('D', True)
         install_dir += d.getVar('envfiledir', True)
         searchpaths = d.getVar('FILESPATH', True)

         for f in listvar_to_list(d, '_INSTALL_ENV_FILES'):
             src = bb.utils.which(searchpaths, f)
             if not os.path.isfile(src):
                 bb.fatal('Did not find SYSTEMD_ENVIRONMENT_FILE:'
                     '\'%s\'' % src)

             dest = os.path.join(install_dir, f)
             parent = os.path.dirname(dest)
             if not os.path.exists(parent):
                 os.makedirs(parent)

             with open(src, 'r') as fd:
                 content = fd.read()
             with open(dest, 'w+') as fd:
                 fd.write(content)


     def install_links(d):
         install_dir = d.getVar('D', True)
         install_dir += d.getVar('systemd_system_unitdir', True)

         for spec in listvar_to_list(d, '_INSTALL_LINKS'):
             tgt, dest = spec.split(':')
             dest = os.path.join(install_dir, dest)
             parent = os.path.dirname(dest)
             if not os.path.exists(parent):
                 os.makedirs(parent)
             os.symlink(tgt, dest)


     def install_overrides(d):
         install_dir = d.getVar('D', True)
         install_dir += d.getVar('systemd_system_unitdir', True)
         searchpaths = d.getVar('FILESPATH', True)

         for spec in listvar_to_list(d, '_INSTALL_OVERRIDES'):
             tmpl, dest = spec.split(':')
             source = bb.utils.which(searchpaths, tmpl)
             if not os.path.isfile(source):
                 bb.fatal('Did not find SYSTEMD_OVERRIDE '
                     'template: \'%s\'' % source)

             dest = os.path.join(install_dir, dest)
             parent = os.path.dirname(dest)
             if not os.path.exists(parent):
                 os.makedirs(parent)

             with open(source, 'r') as fd:
                 content = fd.read()
             with open('%s' % dest, 'w+') as fd:
                 fd.write(content)


     install_links(d)
     install_envs(d)
     install_overrides(d)
     make_subs(d)
 }


 do_install_append() {
         # install systemd service/socket/template files
         [ -z "${_INSTALL_SD_UNITS}" ] || \
                 install -d ${D}${systemd_system_unitdir}
         for s in ${_INSTALL_SD_UNITS}; do
                 install -m 0644 ${WORKDIR}/$s \
                         ${D}${systemd_system_unitdir}/$s
                 sed -i -e 's,@BASE_BINDIR@,${base_bindir},g' \
                         -e 's,@BINDIR@,${bindir},g' \
                         -e 's,@SBINDIR@,${sbindir},g' \
                         ${D}${systemd_system_unitdir}/$s
         done
 }
	# Common code for systemd based services.
	#
	# Prior to inheriting this class, recipes can define services like this:
	#
	# SYSTEMD_SERVICE_${PN} = "foo.service bar.socket baz@.service"
	#
	# and these files will be added to the main package if they exist.
	#
	# Alternatively this class can just be inherited and
	# ${PN}.service will be added to the main package.
	#
	# Other variables:
	# INHIBIT_SYSTEMD_RESTART_POLICY_${unit}
	# Inhibit the warning that is displayed if a service unit without a
	# restart policy is detected.
	#
	# SYSTEMD_SUBSTITUTIONS = "var:val:file"
	# A specification for making python style {format} string
	# substitutions where:
	# var: the format string to search for
	# val: the value to replace with
	# file: the file in which to make the substitution
	#
	# SYSTEMD_USER_${PN}.service = "foo"
	# SYSTEMD_USER_${unit}.service = "foo"
	# The user for the unit/package.
	#
	# SYSTEMD_ENVIRONMENT_FILE_${PN} = "foo"
	# One or more environment files to be installed.
	#
	# SYSTEMD_LINK_${PN} = "tgt:name"
	# A specification for installing arbitrary links in
	# the ${systemd_system_unitdir} namespace, where:
	# tgt: the link target
	# name: the link name, relative to ${systemd_system_unitdir}
	#
	# SYSTEMD_OVERRIDE_${PN} = "src:dest"
	# A specification for installing unit overrides where:
	# src: the override file template
	# dest: the override install location, relative to ${systemd_system_unitdir}
	#
	# Typically SYSTEMD_SUBSTITUTIONS is used to deploy a range
	# of overrides from a single template file. To simply install
	# a single override use "foo.conf:my-service.d/foo.conf"


	inherit obmc-phosphor-utils
	inherit systemd
	inherit useradd

	_INSTALL_SD_UNITS=""
	SYSTEMD_DEFAULT_TARGET ?= "multi-user.target"
	envfiledir ?= "${sysconfdir}/default"

	# Big ugly hack to prevent useradd.bbclass post-parse sanity checker failure.
	# If there are users to be added, we'll add them in our post-parse.
	# If not...there don't seem to be any ill effects...
	USERADD_PACKAGES ?= " "
	USERADD_PARAM_${PN} ?= ";"


	def SystemdUnit(unit):
	class Unit(object):
	def __init__(self, unit):
	self.unit = unit

	def __getattr__(self, item):
	if item is 'name':
	return self.unit
	if item is 'is_activated':
	return self.unit.startswith('dbus-')
	if item is 'is_template':
	return '@.' in self.unit
	if item is 'is_instance':
	return '@' in self.unit and not self.is_template
	if item in ['is_service', 'is_target']:
	return self.unit.split('.')[-1] == item
	if item is 'base':
	cls = self.unit.split('.')[-1]
	base = self.unit.replace('dbus-', '')
	base = base.replace('.%s' % cls, '')
	if self.is_instance:
	base = base.replace('@%s' % self.instance, '')
	if self.is_template:
	base = base.rstrip('@')
	return base
	if item is 'instance' and self.is_instance:
	inst = self.unit.rsplit('@')[-1]
	return inst.rsplit('.')[0]
	if item is 'template' and self.is_instance:
	cls = self.unit.split('.')[-1]
	return '%s@.%s' % (self.base, cls)
	if item is 'template' and self.is_template:
	return '.'.join(self.base.split('@')[:-1])

	raise AttributeError(item)
	return Unit(unit)


	def systemd_parse_unit(d, path):
	import configparser
	parser = configparser.SafeConfigParser(strict=False)
	parser.optionxform = str
	parser.read('%s' % path)
	return parser


	python() {
	def check_sd_unit(d, unit):
	searchpaths = d.getVar('FILESPATH', True)
	path = bb.utils.which(searchpaths, '%s' % unit.name)
	if not os.path.isfile(path):
	# Unit does not exist in tree. Allow it to install from repo.
	# Return False here to indicate it does not exist.
	return False

	parser = systemd_parse_unit(d, path)
	inhibit = listvar_to_list(d, 'INHIBIT_SYSTEMD_RESTART_POLICY_WARNING')
	if unit.is_service and \
	not unit.is_template and \
	unit.name not in inhibit and \
	not parser.has_option('Service', 'Restart'):
	bb.warn('Systemd unit \'%s\' does not '
	'have a restart policy defined.' % unit.name)
	return True


	def add_default_subs(d, file):
	for x in [
	'base_bindir',
	'bindir',
	'sbindir',
	'envfiledir',
	'sysconfdir',
	'SYSTEMD_DEFAULT_TARGET' ]:
	set_append(d, 'SYSTEMD_SUBSTITUTIONS',
	'%s:%s:%s' % (x, d.getVar(x, True), file))


	def add_sd_unit(d, unit, pkg, unit_exist):
	# Do not add unit if it does not exist in tree.
	# It will be installed from repo.
	if not unit_exist:
	return

	name = unit.name
	unit_dir = d.getVar('systemd_system_unitdir', True)
	set_append(d, 'SRC_URI', 'file://%s' % name)
	set_append(d, 'FILES_%s' % pkg, '%s/%s' % (unit_dir, name))
	set_append(d, '_INSTALL_SD_UNITS', name)
	add_default_subs(d, name)


	def add_sd_user(d, file, pkg):
	opts = [
	'--system',
	'--home',
	'/',
	'--no-create-home',
	'--shell /sbin/nologin',
	'--user-group']

	var = 'SYSTEMD_USER_%s' % file
	user = listvar_to_list(d, var)
	if len(user) is 0:
	var = 'SYSTEMD_USER_%s' % pkg
	user = listvar_to_list(d, var)
	if len(user) is not 0:
	if len(user) is not 1:
	bb.fatal('Too many users assigned to %s: \'%s\'' % (var, ' '.join(user)))

	user = user[0]
	set_append(d, 'SYSTEMD_SUBSTITUTIONS',
	'USER:%s:%s' % (user, file))
	if user not in d.getVar('USERADD_PARAM_%s' % pkg, True):
	set_append(
	d,
	'USERADD_PARAM_%s' % pkg,
	'%s' % (' '.join(opts + [user])),
	';')
	if pkg not in d.getVar('USERADD_PACKAGES', True):
	set_append(d, 'USERADD_PACKAGES', pkg)


	def add_env_file(d, name, pkg):
	set_append(d, 'SRC_URI', 'file://%s' % name)
	set_append(d, 'FILES_%s' % pkg, '%s/%s' \
	% (d.getVar('envfiledir', True), name))
	set_append(d, '_INSTALL_ENV_FILES', name)


	def install_link(d, spec, pkg):
	tgt, dest = spec.split(':')

	set_append(d, 'FILES_%s' % pkg, '%s/%s' \
	% (d.getVar('systemd_system_unitdir', True), dest))
	set_append(d, '_INSTALL_LINKS', spec)


	def add_override(d, spec, pkg):
	tmpl, dest = spec.split(':')
	set_append(d, '_INSTALL_OVERRIDES', '%s' % spec)
	unit_dir = d.getVar('systemd_system_unitdir', True)
	set_append(d, 'FILES_%s' % pkg, '%s/%s' % (unit_dir, dest))
	add_default_subs(d, '%s' % dest)
	add_sd_user(d, '%s' % dest, pkg)


	if d.getVar('CLASSOVERRIDE', True) != 'class-target':
	return

	d.appendVarFlag('do_install', 'postfuncs', ' systemd_do_postinst')

	pn = d.getVar('PN', True)
	if d.getVar('SYSTEMD_SERVICE_%s' % pn, True) is None:
	d.setVar('SYSTEMD_SERVICE_%s' % pn, '%s.service' % pn)

	for pkg in listvar_to_list(d, 'SYSTEMD_PACKAGES'):
	svc = listvar_to_list(d, 'SYSTEMD_SERVICE_%s' % pkg)
	svc = [SystemdUnit(x) for x in svc]
	tmpl = [x.template for x in svc if x.is_instance]
	tmpl = list(set(tmpl))
	tmpl = [SystemdUnit(x) for x in tmpl]
	svc = [x for x in svc if not x.is_instance]

	for unit in tmpl + svc:
	unit_exist = check_sd_unit(d, unit)
	add_sd_unit(d, unit, pkg, unit_exist)
	add_sd_user(d, unit.name, pkg)
	for name in listvar_to_list(d, 'SYSTEMD_ENVIRONMENT_FILE_%s' % pkg):
	add_env_file(d, name, pkg)
	for spec in listvar_to_list(d, 'SYSTEMD_LINK_%s' % pkg):
	install_link(d, spec, pkg)
	for spec in listvar_to_list(d, 'SYSTEMD_OVERRIDE_%s' % pkg):
	add_override(d, spec, pkg)
	}


	python systemd_do_postinst() {
	def make_subs(d):
	all_subs = {}
	for spec in listvar_to_list(d, 'SYSTEMD_SUBSTITUTIONS'):
	spec, file = spec.rsplit(':', 1)
	all_subs.setdefault(file, []).append(spec)

	for f, v in all_subs.items():
	subs = dict([ x.split(':') for x in v])
	if not subs:
	continue

	path = d.getVar('D', True)
	path += d.getVar('systemd_system_unitdir', True)
	path += '/%s' % f
	with open(path, 'r') as fd:
	content = fd.read()
	with open(path, 'w+') as fd:
	try:
	fd.write(content.format(**subs))
	except KeyError as e:
	bb.fatal('No substitution found for %s in '
	'file \'%s\'' % (e, f))


	def install_envs(d):
	install_dir = d.getVar('D', True)
	install_dir += d.getVar('envfiledir', True)
	searchpaths = d.getVar('FILESPATH', True)

	for f in listvar_to_list(d, '_INSTALL_ENV_FILES'):
	src = bb.utils.which(searchpaths, f)
	if not os.path.isfile(src):
	bb.fatal('Did not find SYSTEMD_ENVIRONMENT_FILE:'
	'\'%s\'' % src)

	dest = os.path.join(install_dir, f)
	parent = os.path.dirname(dest)
	if not os.path.exists(parent):
	os.makedirs(parent)

	with open(src, 'r') as fd:
	content = fd.read()
	with open(dest, 'w+') as fd:
	fd.write(content)


	def install_links(d):
	install_dir = d.getVar('D', True)
	install_dir += d.getVar('systemd_system_unitdir', True)

	for spec in listvar_to_list(d, '_INSTALL_LINKS'):
	tgt, dest = spec.split(':')
	dest = os.path.join(install_dir, dest)
	parent = os.path.dirname(dest)
	if not os.path.exists(parent):
	os.makedirs(parent)
	os.symlink(tgt, dest)


	def install_overrides(d):
	install_dir = d.getVar('D', True)
	install_dir += d.getVar('systemd_system_unitdir', True)
	searchpaths = d.getVar('FILESPATH', True)

	for spec in listvar_to_list(d, '_INSTALL_OVERRIDES'):
	tmpl, dest = spec.split(':')
	source = bb.utils.which(searchpaths, tmpl)
	if not os.path.isfile(source):
	bb.fatal('Did not find SYSTEMD_OVERRIDE '
	'template: \'%s\'' % source)

	dest = os.path.join(install_dir, dest)
	parent = os.path.dirname(dest)
	if not os.path.exists(parent):
	os.makedirs(parent)

	with open(source, 'r') as fd:
	content = fd.read()
	with open('%s' % dest, 'w+') as fd:
	fd.write(content)


	install_links(d)
	install_envs(d)
	install_overrides(d)
	make_subs(d)
	}


	do_install_append() {
	# install systemd service/socket/template files
	[ -z "${_INSTALL_SD_UNITS}" ] \|\| \
	install -d ${D}${systemd_system_unitdir}
	for s in ${_INSTALL_SD_UNITS}; do
	install -m 0644 ${WORKDIR}/$s \
	${D}${systemd_system_unitdir}/$s
	sed -i -e 's,@BASE_BINDIR@,${base_bindir},g' \
	-e 's,@BINDIR@,${bindir},g' \
	-e 's,@SBINDIR@,${sbindir},g' \
	${D}${systemd_system_unitdir}/$s
	done
	}