summaryrefslogtreecommitdiff
path: root/cloudinit
diff options
context:
space:
mode:
authorDaniel Watkins <daniel.watkins@canonical.com>2015-05-08 12:58:20 +0100
committerDaniel Watkins <daniel.watkins@canonical.com>2015-05-08 12:58:20 +0100
commit28e9e693942d758fb5bdc952c32542c77e16f23a (patch)
treef6415adf18813f9de0305df197c920b2181127d7 /cloudinit
parent2edfd791b29df3271bdc3aff40d60336ddd636ed (diff)
downloadvyos-cloud-init-28e9e693942d758fb5bdc952c32542c77e16f23a.tar.gz
vyos-cloud-init-28e9e693942d758fb5bdc952c32542c77e16f23a.zip
Add logging.
Diffstat (limited to 'cloudinit')
-rw-r--r--cloudinit/sources/DataSourceAzure.py13
1 files changed, 12 insertions, 1 deletions
diff --git a/cloudinit/sources/DataSourceAzure.py b/cloudinit/sources/DataSourceAzure.py
index b93357d5..deffd9b2 100644
--- a/cloudinit/sources/DataSourceAzure.py
+++ b/cloudinit/sources/DataSourceAzure.py
@@ -127,6 +127,7 @@ class AzureEndpointHttpClient(object):
def find_endpoint():
+ LOG.debug('Finding Azure endpoint...')
content = util.load_file('/var/lib/dhcp/dhclient.eth0.leases')
value = None
for line in content.splitlines():
@@ -143,7 +144,9 @@ def find_endpoint():
value = struct.pack('>L', int(hex_string.replace(':', ''), 16))
else:
value = value.encode('utf-8')
- return socket.inet_ntoa(value)
+ endpoint_ip_address = socket.inet_ntoa(value)
+ LOG.debug('Azure endpoint found at %s', endpoint_ip_address)
+ return endpoint_ip_address
class GoalState(object):
@@ -199,7 +202,9 @@ class OpenSSLManager(object):
self.generate_certificate()
def generate_certificate(self):
+ LOG.debug('Generating certificate for communication with fabric...')
if self.certificate is not None:
+ LOG.debug('Certificate already generated.')
return
with cd(self.tmpdir.name):
util.subp([
@@ -213,6 +218,7 @@ class OpenSSLManager(object):
if "CERTIFICATE" not in line:
certificate += line.rstrip()
self.certificate = certificate
+ LOG.debug('New certificate generated.')
def parse_certificates(self, certificates_xml):
tag = ElementTree.fromstring(certificates_xml).find(
@@ -259,6 +265,7 @@ class OpenSSLManager(object):
class WALinuxAgentShim(object):
def __init__(self):
+ LOG.debug('WALinuxAgentShim instantiated...')
self.endpoint = find_endpoint()
self.openssl_manager = OpenSSLManager()
self.http_client = AzureEndpointHttpClient(
@@ -275,9 +282,11 @@ class WALinuxAgentShim(object):
time.sleep(i + 1)
else:
break
+ LOG.debug('Successfully fetched GoalState XML.')
goal_state = GoalState(response.contents, self.http_client)
public_keys = []
if goal_state.certificates_xml is not None:
+ LOG.debug('Certificate XML found; parsing out public keys.')
public_keys = self.openssl_manager.parse_certificates(
goal_state.certificates_xml)
data = {
@@ -289,6 +298,7 @@ class WALinuxAgentShim(object):
return data
def _report_ready(self, goal_state):
+ LOG.debug('Reporting ready to Azure fabric.')
document = REPORT_READY_XML_TEMPLATE.format(
incarnation=goal_state.incarnation,
container_id=goal_state.container_id,
@@ -299,6 +309,7 @@ class WALinuxAgentShim(object):
data=document,
extra_headers={'Content-Type': 'text/xml; charset=utf-8'},
)
+ LOG.info('Reported ready to Azure fabric.')
def get_hostname(hostname_command='hostname'):