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
|
# Copyright (C) 2012 Canonical Ltd.
# Copyright (C) 2012 Hewlett-Packard Development Company, L.P.
# Copyright (C) 2012 Yahoo! Inc.
#
# Author: Scott Moser <scott.moser@canonical.com>
# Author: Juerg Haefliger <juerg.haefliger@hp.com>
# Author: Joshua Harlow <harlowja@yahoo-inc.com>
#
# This file is part of cloud-init. See LICENSE file for license information.
import os
import re
from cloudinit import handlers
from cloudinit import log as logging
from cloudinit import subp
from cloudinit import util
from cloudinit.settings import (PER_INSTANCE)
LOG = logging.getLogger(__name__)
class UpstartJobPartHandler(handlers.Handler):
prefixes = ['#upstart-job']
def __init__(self, paths, **_kwargs):
handlers.Handler.__init__(self, PER_INSTANCE)
self.upstart_dir = paths.upstart_conf_d
def handle_part(self, data, ctype, filename, payload, frequency):
if ctype in handlers.CONTENT_SIGNALS:
return
# See: https://bugs.launchpad.net/bugs/819507
if frequency != PER_INSTANCE:
return
if not self.upstart_dir:
return
filename = util.clean_filename(filename)
(_name, ext) = os.path.splitext(filename)
if not ext:
ext = ''
ext = ext.lower()
if ext != ".conf":
filename = filename + ".conf"
payload = util.dos2unix(payload)
path = os.path.join(self.upstart_dir, filename)
util.write_file(path, payload, 0o644)
if SUITABLE_UPSTART:
subp.subp(["initctl", "reload-configuration"], capture=False)
def _has_suitable_upstart():
# (LP: #1124384)
# a bug in upstart means that invoking reload-configuration
# at this stage in boot causes havoc. So, try to determine if upstart
# is installed, and reloading configuration is OK.
if not os.path.exists("/sbin/initctl"):
return False
try:
(version_out, _err) = subp.subp(["initctl", "version"])
except Exception:
util.logexc(LOG, "initctl version failed")
return False
# expecting 'initctl version' to output something like: init (upstart X.Y)
if re.match("upstart 1.[0-7][)]", version_out):
return False
if "upstart 0." in version_out:
return False
elif "upstart 1.8" in version_out:
if not os.path.exists("/usr/bin/dpkg-query"):
return False
try:
(dpkg_ver, _err) = subp.subp(["dpkg-query",
"--showformat=${Version}",
"--show", "upstart"], rcs=[0, 1])
except Exception:
util.logexc(LOG, "dpkg-query failed")
return False
try:
good = "1.8-0ubuntu1.2"
subp.subp(["dpkg", "--compare-versions", dpkg_ver, "ge", good])
return True
except subp.ProcessExecutionError as e:
if e.exit_code == 1:
pass
else:
util.logexc(LOG, "dpkg --compare-versions failed [%s]",
e.exit_code)
except Exception:
util.logexc(LOG, "dpkg --compare-versions failed")
return False
else:
return True
SUITABLE_UPSTART = _has_suitable_upstart()
# vi: ts=4 expandtab
|
