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
|
"""Upstart support for Bcfg2."""
import glob
import re
import Bcfg2.Client.Tools
import Bcfg2.Client.XML
class Upstart(Bcfg2.Client.Tools.SvcTool):
"""Upstart service support for Bcfg2."""
name = 'Upstart'
__execs__ = ['/lib/init/upstart-job',
'/sbin/initctl',
'/usr/sbin/service']
__handles__ = [('Service', 'upstart')]
__req__ = {'Service': ['name', 'status']}
svcre = re.compile("/etc/init/(?P<name>.*).conf")
def get_svc_command(self, service, action):
return "/usr/sbin/service %s %s" % (service.get('name'), action)
def VerifyService(self, entry, _):
"""Verify Service status for entry
Verifying whether or not the service is enabled can be done
at the file level with upstart using the contents of
/etc/init/servicename.conf. All we need to do is make sure
the service is running when it should be.
"""
if entry.get('status') == 'ignore':
return True
if entry.get('parameters'):
params = entry.get('parameters')
else:
params = ''
try:
output = self.cmd.run('/usr/sbin/service %s status %s' %
(entry.get('name'),
params)).stdout.splitlines()[0]
except IndexError:
self.logger.error("Service %s not an Upstart service" %
entry.get('name'))
return False
match = re.compile(r'%s( \(.*\))? (start|stop)/(running|waiting)' %
entry.get('name')).match(output)
if match is None:
# service does not exist
entry.set('current_status', 'off')
status = False
elif match.group(3) == 'running':
# service is running
entry.set('current_status', 'on')
if entry.get('status') == 'off':
status = False
else:
status = True
else:
# service is not running
entry.set('current_status', 'off')
if entry.get('status') == 'on':
status = False
else:
status = True
return status
def InstallService(self, entry):
"""Install Service for entry."""
if entry.get('status') == 'on':
cmd = "start"
elif entry.get('status') == 'off':
cmd = "stop"
return self.cmd.run(self.get_svc_command(entry, cmd)).success
def FindExtra(self):
"""Locate extra Upstart services."""
specified = [entry.get('name') for entry in self.getSupportedEntries()]
extra = []
for fname in glob.glob("/etc/init/*.conf"):
if self.svcre.match(fname).group('name') not in specified:
extra.append(self.svcre.match(fname).group('name'))
return [Bcfg2.Client.XML.Element('Service', type='upstart', name=name)
for name in extra]
|
