summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMichael Still <mikal@stillhq.com>2012-02-10 11:59:36 +1100
committerMichael Still <mikal@stillhq.com>2012-02-10 18:27:23 +1100
commitb70bd00cf84fb1c78037efcea030df313ff1f923 (patch)
tree6cd51a0ab30c8a8e32af8a9f4554854dcb4fcde8
parent5ad971810aaedcf5c9efd1b56add0e23921899ae (diff)
downloadnova-b70bd00cf84fb1c78037efcea030df313ff1f923.tar.gz
nova-b70bd00cf84fb1c78037efcea030df313ff1f923.tar.xz
nova-b70bd00cf84fb1c78037efcea030df313ff1f923.zip
Log instance id consistently inside the firewall code.
This brings this code inline with the way connection.py does instance logging now. Change-Id: I3a9b256cb87bc273352f4b9338ae32dbc1faa6f6
-rw-r--r--nova/tests/test_virt_drivers.py3
-rw-r--r--nova/virt/libvirt/firewall.py20
2 files changed, 14 insertions, 9 deletions
diff --git a/nova/tests/test_virt_drivers.py b/nova/tests/test_virt_drivers.py
index 58d295a6f..3ec2155cf 100644
--- a/nova/tests/test_virt_drivers.py
+++ b/nova/tests/test_virt_drivers.py
@@ -211,7 +211,8 @@ class _VirtDriverTestCase(test.TestCase):
@catch_notimplementederror
def test_destroy_instance_nonexistant(self):
- fake_instance = {'id': 42, 'name': 'I just made this up!'}
+ fake_instance = {'id': 42, 'name': 'I just made this up!',
+ 'uuid': 'bda5fb9e-b347-40e8-8256-42397848cb00'}
network_info = test_utils.get_test_network_info()
self.connection.destroy(fake_instance, network_info)
diff --git a/nova/virt/libvirt/firewall.py b/nova/virt/libvirt/firewall.py
index 0c0772dba..81cb7858f 100644
--- a/nova/virt/libvirt/firewall.py
+++ b/nova/virt/libvirt/firewall.py
@@ -137,14 +137,15 @@ class NWFilterFirewall(base_firewall.FirewallDriver):
def setup_basic_filtering(self, instance, network_info):
"""Set up basic filtering (MAC, IP, and ARP spoofing protection)"""
- LOG.info(_('called setup_basic_filtering in nwfilter'))
+ LOG.info(_('Called setup_basic_filtering in nwfilter'),
+ instance=instance)
if self.handle_security_groups:
# No point in setting up a filter set that we'll be overriding
# anyway.
return
- LOG.info(_('ensuring static filters'))
+ LOG.info(_('Ensuring static filters'), instance=instance)
self._ensure_static_filters()
if instance['image_ref'] == str(FLAGS.vpn_image_id):
@@ -259,7 +260,8 @@ class NWFilterFirewall(base_firewall.FirewallDriver):
_nw.undefine()
except libvirt.libvirtError:
LOG.debug(_('The nwfilter(%(instance_filter_name)s) '
- 'for %(instance_name)s is not found.') % locals())
+ 'is not found.') % locals(),
+ instance=instance)
instance_secgroup_filter_name = ('%s-secgroup' %
self._instance_filter_name(instance))
@@ -270,7 +272,7 @@ class NWFilterFirewall(base_firewall.FirewallDriver):
_nw.undefine()
except libvirt.libvirtError:
LOG.debug(_('The nwfilter(%(instance_secgroup_filter_name)s) '
- 'for %(instance_name)s is not found.') % locals())
+ 'is not found.') % locals(), instance=instance)
def prepare_instance_filter(self, instance, network_info):
"""Creates an NWFilter for the given instance.
@@ -453,7 +455,8 @@ class NWFilterFirewall(base_firewall.FirewallDriver):
except libvirt.libvirtError:
name = instance.name
LOG.debug(_('The nwfilter(%(instance_filter_name)s) for'
- '%(name)s is not found.') % locals())
+ '%(name)s is not found.') % locals(),
+ instance=instance)
return False
return True
@@ -467,7 +470,8 @@ class IptablesFirewallDriver(base_firewall.IptablesFirewallDriver):
"""Set up provider rules and basic NWFilter."""
self.nwfilter.setup_basic_filtering(instance, network_info)
if not self.basicly_filtered:
- LOG.debug(_('iptables firewall: Setup Basic Filtering'))
+ LOG.debug(_('iptables firewall: Setup Basic Filtering'),
+ instance=instance)
self.refresh_provider_fw_rules()
self.basicly_filtered = True
@@ -485,8 +489,8 @@ class IptablesFirewallDriver(base_firewall.IptablesFirewallDriver):
self.iptables.apply()
self.nwfilter.unfilter_instance(instance, network_info)
else:
- LOG.info(_('Attempted to unfilter instance %s which is not '
- 'filtered'), instance['id'])
+ LOG.info(_('Attempted to unfilter instance which is not '
+ 'filtered'), instance=instance)
def instance_filter_exists(self, instance, network_info):
"""Check nova-instance-instance-xxx exists"""