diff options
Diffstat (limited to 'cloudinit')
| -rw-r--r-- | cloudinit/sources/DataSourceAzure.py | 13 |
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'): |