blob: 05404c3a0ca78b0857f7534ac366a04485ff3ba3 (
plain)
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
|
#
# Common code for the EC2 initialisation scripts in Ubuntu
# Copyright (C) 2008-2009 Canonical Ltd
#
# Author: Soren Hansen <soren@canonical.com>
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License version 3, as
# published by the Free Software Foundation.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
#
import os
from configobj import ConfigObj
import boto.utils
datadir = '/var/lib/cloud/data'
cachedir = datadir + '/cache'
user_data = datadir + '/user-data.txt'
user_data_raw = datadir + '/user-data.raw'
user_config = datadir + '/user-config.txt'
import DataSourceEc2
class EC2Init:
datasource_list = [ DataSourceEc2.DataSourceEc2 ]
def restore_from_cache(self):
try:
f=open(cachedir + "/obj.pkl", "rb")
data = pickle.load(f)
self.datasource = data
return True
except:
return False
def write_to_cache(self):
try:
f=open(cachedir + "/obj.pkl", "wb")
data = pickle.dump(self.datasource,f)
return True
except:
return False
def get_data_source(self):
if self.restore_from_cache():
return True
for source in self.datasource_list:
try:
s = source()
if s.get_data():
self.datasource = s
return
except:
pass
raise Exception("Could not find data source")
def get_user_data(self):
return(self.datasource.get_user_data())
def get_cfg_option_bool(self, key, default=None):
val = self.config.get(key, default)
if val.lower() in ['1', 'on', 'yes']:
return True
return False
def initctl_emit(self):
import subprocess
subprocess.Popen(['initctl', 'CFG_FILE=%s' % user_config]).communicate()
|
