summaryrefslogtreecommitdiffstats
path: root/nfvbench/cleanup.py
diff options
context:
space:
mode:
authorahothan <ahothan@cisco.com>2018-10-07 15:55:25 -0700
committerahothan <ahothan@cisco.com>2018-10-08 10:44:31 -0700
commit391dcf76fefb747888a3411ae3b8df7b1ad26685 (patch)
treeb823ae8a5f0e837bb285f53acb1502e0aad1bdf0 /nfvbench/cleanup.py
parent99260f95219301bb5c0b58921e793bcad6ec4990 (diff)
2.0 beta NFVBENCH-91 Allow multi-chaining with separate edge networks
Includes complete refactoring of code Beta for NFVbench 2.0 Change-Id: I2997f0fb7722d5ac626cd11a68692ae458c7676e Signed-off-by: ahothan <ahothan@cisco.com>
Diffstat (limited to 'nfvbench/cleanup.py')
-rw-r--r--nfvbench/cleanup.py25
1 files changed, 12 insertions, 13 deletions
diff --git a/nfvbench/cleanup.py b/nfvbench/cleanup.py
index 246be3f..819514a 100644
--- a/nfvbench/cleanup.py
+++ b/nfvbench/cleanup.py
@@ -54,7 +54,7 @@ class ComputeCleaner(object):
except Exception:
LOG.exception("Instance %s deletion failed", server.name)
LOG.info(' Waiting for %d instances to be fully deleted...', len(self.servers))
- retry_count = 5 + len(self.servers) * 2
+ retry_count = 15 + len(self.servers) * 5
while True:
retry_count -= 1
self.servers = [server for server in self.servers if self.instance_exists(server)]
@@ -66,7 +66,7 @@ class ComputeCleaner(object):
len(self.servers), retry_count)
time.sleep(2)
else:
- LOG.warning(' instance deletion verification timed out: %d not removed',
+ LOG.warning(' instance deletion verification time-out: %d still not deleted',
len(self.servers))
break
@@ -74,20 +74,19 @@ class ComputeCleaner(object):
class NetworkCleaner(object):
"""A cleaner for network resources."""
- def __init__(self, neutron_client, network_names):
+ def __init__(self, neutron_client, network_name_prefixes):
self.neutron_client = neutron_client
LOG.info('Discovering networks...')
all_networks = self.neutron_client.list_networks()['networks']
self.networks = []
+ net_ids = []
for net in all_networks:
- try:
- network_names.remove(net['name'])
- self.networks.append(net)
- except ValueError:
- pass
- if not network_names:
- break
- net_ids = [net['id'] for net in self.networks]
+ netname = net['name']
+ for prefix in network_name_prefixes:
+ if netname.startswith(prefix):
+ self.networks.append(net)
+ net_ids.append(net['id'])
+ break
if net_ids:
LOG.info('Discovering ports...')
all_ports = self.neutron_client.list_ports()['ports']
@@ -161,8 +160,8 @@ class Cleaner(object):
table.extend(res_list)
count = len(table) - 1
if count:
- LOG.info('Discovered %d NFVbench resources:', count)
- print tabulate(table, headers="firstrow", tablefmt="psql")
+ LOG.info('Discovered %d NFVbench resources:\n%s', count,
+ tabulate(table, headers="firstrow", tablefmt="psql"))
else:
LOG.info('No matching NFVbench resources found')
return count