1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
"""This is rc-update support."""
import os
import Bcfg2.Client.Tools
import Bcfg2.Client.XML
class RcUpdate(Bcfg2.Client.Tools.SvcTool):
"""RcUpdate support for Bcfg2."""
name = 'RcUpdate'
__execs__ = ['/sbin/rc-update', '/bin/rc-status']
__handles__ = [('Service', 'rc-update')]
__req__ = {'Service': ['name', 'status']}
def get_enabled_svcs(self):
"""
Return a list of all enabled services.
"""
return [line.split()[0]
for line in self.cmd.run(['/bin/rc-status',
'-s']).stdout.splitlines()
if 'started' in line]
def get_default_svcs(self):
"""Return a list of services in the 'default' runlevel."""
return [line.split()[0]
for line in self.cmd.run(['/sbin/rc-update',
'show']).stdout.splitlines()
if 'default' in line]
def verify_bootstatus(self, entry, bootstatus):
"""Verify bootstatus for entry."""
# get a list of all started services
allsrv = self.get_default_svcs()
# set current_bootstatus attribute
if entry.get('name') in allsrv:
entry.set('current_bootstatus', 'on')
else:
entry.set('current_bootstatus', 'off')
if bootstatus == 'on':
return entry.get('name') in allsrv
else:
return entry.get('name') not in allsrv
def VerifyService(self, entry, _):
"""
Verify Service status for entry.
Assumes we run in the "default" runlevel.
"""
entry.set('target_status', entry.get('status')) # for reporting
bootstatus = self.get_bootstatus(entry)
if bootstatus is None:
return True
current_bootstatus = self.verify_bootstatus(entry, bootstatus)
# check if init script exists
try:
os.stat('/etc/init.d/%s' % entry.get('name'))
except OSError:
self.logger.debug('Init script for service %s does not exist' %
entry.get('name'))
return False
if entry.get('status') == 'ignore':
# 'ignore' should verify
current_svcstatus = True
svcstatus = True
else:
svcstatus = self.check_service(entry)
if entry.get('status') == 'on':
if svcstatus:
current_svcstatus = True
else:
current_svcstatus = False
elif entry.get('status') == 'off':
if svcstatus:
current_svcstatus = False
else:
current_svcstatus = True
if svcstatus:
entry.set('current_status', 'on')
else:
entry.set('current_status', 'off')
return current_bootstatus and current_svcstatus
def InstallService(self, entry):
"""Install Service entry."""
self.logger.info('Installing Service %s' % entry.get('name'))
bootstatus = entry.get('bootstatus')
if bootstatus is not None:
if bootstatus == 'on':
# make sure service is enabled on boot
bootcmd = '/sbin/rc-update add %s default'
elif bootstatus == 'off':
# make sure service is disabled on boot
bootcmd = '/sbin/rc-update del %s default'
bootcmdrv = self.cmd.run(bootcmd % entry.get('name')).success
if self.setup['servicemode'] == 'disabled':
# 'disabled' means we don't attempt to modify running svcs
return bootcmdrv
buildmode = self.setup['servicemode'] == 'build'
if (entry.get('status') == 'on' and not buildmode) and \
entry.get('current_status') == 'off':
svccmdrv = self.start_service(entry)
elif (entry.get('status') == 'off' or buildmode) and \
entry.get('current_status') == 'on':
svccmdrv = self.stop_service(entry)
else:
svccmdrv = True # ignore status attribute
return bootcmdrv and svccmdrv
else:
# when bootstatus is 'None', status == 'ignore'
return True
def FindExtra(self):
"""Locate extra rc-update services."""
allsrv = self.get_enabled_svcs()
self.logger.debug('Found active services:')
self.logger.debug(allsrv)
specified = [srv.get('name') for srv in self.getSupportedEntries()]
return [Bcfg2.Client.XML.Element('Service', type='rc-update',
name=name)
for name in allsrv if name not in specified]
|
