apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-10-26 08:42:29 +01:00
Code Issues Packages Projects Releases Wiki Activity

bug CS-16172

Browse Source 
Reviewed-by: chiradeep
This commit is contained in:
Edison Su 2012-08-24 16:01:59 -07:00
parent 0d9b81aac6
commit cefc5cbff3
1 changed files with 45 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
scripts/vm/network/security_group.py
View File

@ -489,36 +489,54 @@ def cleanup_rules_for_dead_vms():
def cleanup_rules(): def cleanup_rules():
try: try:
chainscmd = "iptables-save | grep '^:' | grep -v '.*-def' | grep -v '.*-eg' | awk '{print $1}' | cut -d':' -f2"
chainscmd = "iptables-save | grep '^:' | grep -v '.*-def' | grep -v '.*-eg' | awk '{print $1}' | cut -d':' -f2" chains = execute(chainscmd).split('\n')
chains = execute(chainscmd).split('\n') cleanup = []
cleaned = 0 for chain in chains:
cleanup = [] if 1 in [ chain.startswith(c) for c in ['r-', 'i-', 's-', 'v-'] ]:
for chain in chains: vm_name = chain
if 1 in [ chain.startswith(c) for c in ['r-', 'i-', 's-', 'v-'] ]:
vm_name = chain
cmd = "virsh list |grep " + vm_name cmd = "virsh list |grep " + vm_name
try: try:
result = execute(cmd) result = execute(cmd)
except: except:
result = None result = None
if result == None or len(result) == 0: if result == None or len(result) == 0:
logging.debug("chain " + chain + " does not correspond to a vm, cleaning up") logging.debug("chain " + chain + " does not correspond to a vm, cleaning up")
cleanup.append(vm_name) cleanup.append(vm_name)
continue continue
if result.find("running") == -1: if result.find("running") == -1:
logging.debug("vm " + vm_name + " is not running, cleaning up") logging.debug("vm " + vm_name + " is not running, cleaning up")
cleanup.append(vm_name) cleanup.append(vm_name)
for vmname in cleanup: chainscmd = "ebtables-save |grep :i |awk '{print $1}' |sed -e 's/\-in//g' |sed -e 's/\-out//g' |sed -e 's/^://g'"
destroy_network_rules_for_vm(vmname) chains = execute(chainscmd).split('\n')
for chain in chains:
if 1 in [ chain.startswith(c) for c in ['r-', 'i-', 's-', 'v-'] ]:
vm_name = chain
cmd = "virsh list |grep " + vm_name
try:
result = execute(cmd)
except:
result = None
if result == None or len(result) == 0:
logging.debug("chain " + chain + " does not correspond to a vm, cleaning up")
cleanup.append(vm_name)
continue
if result.find("running") == -1:
logging.debug("vm " + vm_name + " is not running, cleaning up")
cleanup.append(vm_name)
for vmname in cleanup:
destroy_network_rules_for_vm(vmname)
logging.debug("Cleaned up rules for " + str(len(cleanup)) + " chains") logging.debug("Cleaned up rules for " + str(len(cleanup)) + " chains")
except: except:
logging.debug("Failed to cleanup rules !") logging.debug("Failed to cleanup rules !")
def check_rule_log_for_vm(vmName, vmId, vmIP, domID, signature, seqno): def check_rule_log_for_vm(vmName, vmId, vmIP, domID, signature, seqno):
vm_name = vmName; vm_name = vmName;