diff options
| author | Soren Hansen <soren@linux2go.dk> | 2011-03-22 14:39:35 +0100 |
|---|---|---|
| committer | Soren Hansen <soren@linux2go.dk> | 2011-03-22 14:39:35 +0100 |
| commit | 01e7e598d0eb4aab9c3e7f69926a2875cdf22136 (patch) | |
| tree | 7ceaff6c574a9a3174529c689b05d229429baf15 /nova/virt | |
| parent | 116e5a0b13f3da174137bbff0a5b9b0202caa4a4 (diff) | |
Get rid of IptablesManager's explicit semaphore.
Diffstat (limited to 'nova/virt')
| -rw-r--r-- | nova/virt/libvirt_conn.py | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/nova/virt/libvirt_conn.py b/nova/virt/libvirt_conn.py index ca8d81f5f..902866167 100644 --- a/nova/virt/libvirt_conn.py +++ b/nova/virt/libvirt_conn.py @@ -1766,14 +1766,11 @@ class IptablesFirewallDriver(FirewallDriver): def refresh_security_group_members(self, security_group): pass + @utils.synchronized('iptables', external=True) def refresh_security_group_rules(self, security_group): - # We use the semaphore to make sure noone applies the rule set - # after we've yanked the existing rules but before we've put in - # the new ones. - with self.iptables.semaphore: - for instance in self.instances.values(): - self.remove_filters_for_instance(instance) - self.add_filters_for_instance(instance) + for instance in self.instances.values(): + self.remove_filters_for_instance(instance) + self.add_filters_for_instance(instance) self.iptables.apply() def _security_group_chain_name(self, security_group_id): |
